如何推送通知到特定用户Node + AngularJS + Laravel

How to push notification to specific user Node + AngularJS + Laravel

本文关键字:Node AngularJS Laravel 用户 何推送 通知 知到      更新时间:2023-09-26

我需要帮助如何向特定用户推送通知。我现在可以推送通知但所有用户都会得到那个通知。我可以在客户端过滤,但我认为这是不安全的…

首先我用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();
            }
        });

WIth this part:

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

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

有什么办法可以改善吗?

要将消息推送给特定的用户,必须将他/她的引用存储在某个地方。

为例

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

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

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

Update: Explanation

This假设每个使用你的web应用程序的用户都有某种身份验证

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

客户端

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

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

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

在nodejs中首先声明一个数组,该数组包含所有加入网站的用户的套接字

var clients = [];

现在在nodejs应用程序中编写以下附加代码

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

到目前为止,登录到您的网站的用户将从客户端调用add-user事件,这将反过来在nodejs上调用add-user, socket将被添加到客户端数组

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

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