Le websocket de Swoole sera utilisé dans le développement au cours des deux derniers jours, mais je n'en comprends pas certaines parties
$serv = new swoole_websocket_server("127.0.0.1", 9502);
$serv->on('Ouvrir', function($server, $req) {
echo "connexion ouverte : ".$req->fd;
});
$serv->on('Message', function($server, $frame) {
echo "message : ".$frame->data;
$server->push($frame->fd, json_encode(["hello", "world"]));
});
$serv->on('Fermer', function($server, $fd) {
echo "connexion fermée : ".$fd;
});
$serv->start();
Ceci est la démo du site officiel de swoole. Lorsque le client envoie un message au serveur en écoutant l'événement de message, le serveur enverra le message au client. Si je veux réaliser ce scénario : s'il y a un. message dans la file d'attente, puis envoyer un message à l'utilisateur (la file d'attente ici est supposée être une file d'attente redis. Dans ce cas, l'événement de message ne peut pas être surveillé ?
Ensuite, vous devez stocker les données des utilisateurs en ligne. . Après la connexion, enregistrez l'ID utilisateur et l'ID client dans le websocket, correspondance individuelle s'il y a des données, vous appelez la méthode push pour transmettre les données à l'utilisateur
.