这两天开发中要用到swoole的websocket,但是有些没太搞明白
$serv = new swoole_websocket_server("127.0.0.1", 9502);
$serv->on('Open', function($server, $req) {
echo "connection open: ".$req->fd;
});
$serv->on('Message', function($server, $frame) {
echo "message: ".$frame->data;
$server->push($frame->fd, json_encode(["hello", "world"]));
});
$serv->on('Close', function($server, $fd) {
echo "connection close: ".$fd;
});
$serv->start();
这是swoole官网的demo,通过监听消息事件客户端发送消息给服务端的时候,服务端会发送消息给客户端,那如果我想实现这种场景:如果队列里面有消息了,那就给用户发送一条消息(这里的队列假设为redis的队列),这样的话消息事件就监听不到了,请问一下这个如何实现
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
.