javascript - 如何向特定用户推送通知 Node + AngularJS + Laravel

Question

我需要有关如何将通知推送给特定用户的帮助。我现在可以推送通知，但所有用户都会收到该通知。我可以在 clinet 端过滤它，但我认为它不安全......

首先我用 laravel 5 发送数据:

$redis = Redis::connection();
$redis->publish('update.answer', json_encode($events));

这是我发出数据的 node.js:

var app = require('express')();
var http = require('http').Server(app);
var io = require('socket.io')(http);
var Redis = require('ioredis');
var redis = new Redis();
redis.subscribe('update.group', function(err, count) {
});
redis.subscribe('update.question', function(err, count) {
});
redis.subscribe('update.answer', function(err, count) {
});
redis.subscribe('update.comment', function(err, count) {
});
redis.on('message', function(channel, message) {
    message = JSON.parse(message);
    console.log(message);
    io.emit(channel, message);
});
http.listen(3000, function(){
    console.log('Listening on Port 3000');
});

我使用 angularjs 获取数据并推送给客户端。

socket.on('update.answer',function(data){
            if($scope.remove){
                $scope.remove = false;
            }
            $scope.feed = $("#feed").val();
            if(parseInt($scope.feed) === parseInt(data.userID)){
            $scope.answers.push(data);
            $scope.$digest();
            }
        });

这部分:

 $scope.feed = $("#feed").val();
                    if(parseInt($scope.feed) === parseInt(data.user_id) && data.admin_id !== null){

}

我检查客户端是否应该收到通知，但它是不安全的...

有什么办法可以改善吗？

Answer 1

要向特定用户推送消息，您必须在某处存储他/她的引用。

前任

io.on('connection', function(socket) {
     socket.on('add-user', function(data){
        clients[data.username] = socket;
      });
});

现在向特定用户推送消息只需使用他的用户名来检索他的套接字

clients[data.username].emit(channel, message);

更新:解释

这假设每个使用您的网络应用程序的用户都有某种身份验证。

一旦用户登录到您的应用程序，就让他加入 nodejs 后端套接字。

在客户端

socket.emit('add-user',userObj); 
        });

userObj是包含用户详细信息的对象，你也可以单独发送用户名

socket.emit('add-user',username);

在你的 nodejs 中首先 decalre 一个包含所有加入网站的用户的套接字的数组

var clients = [];

现在在您的 nodejs 应用程序中编写此附加代码

   io.on('connection', function(socket) {
         socket.on('add-user', function(data){
            clients[data.username] = socket;
          });
    });

到目前为止，登录您网站的用户将从客户端调用 add-user 事件，该事件将依次调用 nodejs 和套接字上的 add-user将被添加到客户端数组中

现在要向任何特定用户发送消息，您必须知道用户名，所以如果您知道用户的用户名，那么您可以简单地向他们发送消息，使用

clients[data.username].emit(channel, message);