我的要求是为特定的用户发布消息。
控制器$messageQueueKey=(string)$receiver; (receiver_id)
$redis->publish($messageQueueKey, json_encode($data));
Server.js//nodejs
var handshakeData = socket.request;
var messageQueueKey=handshakeData._query['userid'];
clients[socket.id] = socket;
var redisClient = redis.createClient();
redisClient.subscribe(messageQueueKey);
// redisClient.subscribe('message');
redisClient.on('message', function(channel, message)
{
var data = JSON.parse(message);
if(typeof connectedClients[data['receiver']] === 'undefined'){}
else
{
connectedClients[data['receiver']].socket.emit(channel, message);
}
});
然而,我的代码适用于硬编码密钥'消息',但接收器接收多个消息,这就是为什么我想根据他们的auth id发布和订阅每个用户的不同密钥
很好!如果用户收到多条消息,可以忽略其中一条:P