事件广播到特定用户(套接字).Io, redis, node)

我想创建一个基于用户触发事件的通知系统，并将其传递给另一个用户('X写在你的墙上')。我理解广播事件的逻辑，但是如果我广播，消息将被发送给频道上的每个人。

我正在使用Laravel 5，我使用Jeffrey Way的Nodejs, Redis, Socket。io教程。很有帮助。

对于广播和捕获消息，

• Server.js

  var server = require('http').Server();
  var io = require('socket.io')(server);
  var Redis = require('ioredis');
  var redis = new Redis();
  redis.subscribe('globalNotificationChannel');
  redis.on('message', function(channel, message) {
      message = JSON.parse(message);
      io.emit(channel + ':' + message.event, message.data);
  });
  server.listen(3000);
  

  客户

  • <script>
       var socket = io('http://localhost:3000');
       socket.on('globalNotificationChannel:WroteOnWall', function(data) {
            //     (Notification Received)
           //      console.log(data.message)
         }.bind(this));
       }
    <script>
    

  • 触发行动

    $data = [
      'event' => 'WroteOnWall',
      'data' => [
          'message' => $username + ' wrote on your wall.'
      ]
    ];
    Redis::publish('globalNotificationChannel', json_encode($data));
    

---

直到这里一切都很清楚，但在这一点上我迷路了。我有几个问题。

• 首先，如果每个人都订阅了同一频道，我如何将触发的事件传递到特定用户的频道。

• 或者有一种方法可以制作独特的通道?如果是这样，我如何存储unique_channel_ids以防止任何错误?

• 其次，我看到人们正在使用集群。这对我的案子有用吗?它会给我带来什么好处吗?

• 请注意，在客户端，我将其插入母版页，因为我需要在每个页面中运行，但是现在，我需要在每个页面中调用"连接"answers"侦听"。当重新运行连接脚本时，我不会得到不同的套接字吗?

编辑:我找到了这个答案，我相信它解决了我的问题，但我不能适应它在redis实例

var jwt = require('jsonwebtoken');
var returnedToken = jwt.sign(user, app.get('superSecret'), {
            expiresInMinutes: 1440 // expires in 24 hours
        });

var socket = io('http://localhost:3000', { query: 'token='+token });

//This adds the jwt session token to handshake when connecting to the socket
var socketioJwt = require('socketio-jwt');
io.use(socketioJwt.authorize({
    secret:'superSecret',
    handshake:true
}));
//When a user connects throw them in their own unique room
io.on('connection', function (socket) {
    //This will get the encoded user object in the JWT token
    var user = socket.decoded_token;
    //This puts them into their unique room
    socket.join('user_room_'+user._id);
});

io.to('user_room_'+referenceToSameUserId).emit('Your message');