Socket io Nodejs-当用户打开多个标签时管理

Question

我想在我的应用程序中写一个聊天，我有一个问题，不知道如何管理它！ 这里是senario： 我们有很多的用户是authenricated所以他们都有一个唯一的ID，我想实现像Facebook这样的聊天，因此每两个用户可以相互聊天。 对于我有内容的server.js文件：

var app = require('express')(); 
var server = require('http').Server(app); 
var io = require('socket.io')(server); 
var redis = require('redis'); 
var users = []; 
server.listen(8890); 
io.on('connection', function (socket) { 

    console.log("client connected"); 
    var redisClient = redis. 
    redisClient.subscribe('message'); 

    redisClient.on("message", function(channel, data) { 
     var data = JSON.parse(data); 
     socket.to('user_'+data.user).emit(channel, data); 
    }); 

    // join a room  
    socket.on('newUser',function (user, type){ 
     socket.type = type; 
     socket.join('user_'+user); 

    }); 
}); 

并有client.js：

<form action="{{ route('message.send') }}" method="POST" class="ajax-form"> 
    <input name="_method" value="put" type="hidden"/> 
    <input name="user" value="{{ $user }}" type="hidden"/> 
    <input name="item" value="{{ $item }}" type="hidden"/> 
    <input name="type" value="{{ $type }}" type="hidden"/> 
    <input name="socketId" value="" type="hidden"/> 
    <input name="message" value="message to {{ $user }} from {{ @$requirements->user->id }}" type="text" class="input-xxlarge" placeHolder="Message" /> 
    <br> 
    <input type="submit" value="Send" /> 
</form> 

和：

var socket = io.connect('http://127.0.0.1:8890'); 
if (auth) { 
    socket.on('connect', function(){ 
     socket.emit('newUser', userId, userType); 
    }); 
} 

socket.on('message', function(data) { 

    console.log(data); 
    // var data = JSON.parse(data); 
    var content = $("#messages").html(); 
    var newMsgContent = '<li>' + data.message + '</li>'; 
    var newContent = newMsgContent + content; 

    $("#messages").html(newContent); 
}); 

一种形式，邮件将被发送最后用Redis我会发信息：

$redis = \LRedis::connection(); 
$data = ['user' => $request->user, 'message' => $request->message]; 
if($redis->publish('message', json_encode($data))) 
    return true; 

在上面的代码中，仅当用户打开我的应用程序时，将使用连接，并且newUser会启动，因此我使用他的Id为该用户创建了一个空间，并将其加入此空间（socket.join（'user _'+ user） ）。 然后，当用户想要发送消息给这个用户时，我只发送接收用户的ID（我们之前为他创建了一个房间），并将消息发送到该Id所在的房间（socket.to（'user_ '+ data.user）.emit（channel，data）;）。 问题是，当用户打开多个选项卡时，它们中的每一个都被识别为用户，并将与另一个socket.id连接到同一个房间，但都是具有一个唯一ID的用户！ 然后，当我向有两个选项卡打开的用户发送消息时，他将从一个请求中获得2条消息！像： 你好ID 5 你好ID 5

所以，现在我应该怎么做来发送消息每个选项卡中的所有选项卡，用户打开！ 在此先感谢。

Answer 1

将您的redisCLient.subscribe移到连接侦听器的外部。每次建立连接时，都会再次附加事件，这就是为什么您要重复的原因。

var redisClient = redis.createClient(); 
redisClient.subscribe('message'); 

redisClient.on("message", function(channel, data) { 
    var data = JSON.parse(data); 
    //Changed socket.to with io.to 
    io.to('user_'+ data.user).emit(channel, data); 
}); 

io.on('connection', function (socket) { 

    console.log("client connected"); 

    // join a room  
    socket.on('newUser',function (user, type){ 
     socket.type = type; 
     socket.join('user_'+user); 

    }); 
}); 

作为一个侧面说明，您的客户端代码可以使用append

socket.on('message', function(data) { 
    console.log(data); 
    // var data = JSON.parse(data); 
    $("#messages").append('<li>' + data.message + '</li>');  
});