1

我的要求是为特定用户发布消息。

控制器

$messageQueueKey=(string)$receiver; (receiver_id)
$redis->publish($messageQueueKey, json_encode($data));

Server.js //节点js

  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);  
      } 
  });

但是，我的代码适用于硬编码密钥“消息”，但接收者收到多条消息，这就是为什么我想根据每个用户的身份验证 ID 发布和订阅不同密钥的每个用户

4

1 回答 1

0

没关系！如果用户收到多条消息，您可以忽略其中一条：P

于 2015-10-06T11:50:13.063 回答