Primus + primus-rooms + sockjs：如何检索连接到房间的所有客户端

我有一个运行在sockjs变压器上的primus服务器。我正在使用primus房间插件来支持房间。加入和离开房间是成功的，我可以向连接到特定房间的客户发送消息。Primus + primus-rooms + sockjs：如何检索连接到房间的所有客户端

在某些时候，我需要检索特定房间中的所有连接的客户端。我想用这样的：https://github.com/cayasso/primus-rooms#primusroomroomclientsfn

primus.room('room').clients(fn);

但Fn功能总是返回null，即使有连接到我针对房间的客户。这是我的实现：

var remoteRoom = 'the_room_I_need_to_target'; 
primus.room(remoteRoom).clients(function(clients){ 
    console.dir('primus clients in room ' + remoteRoom + ': ' + clients); 
});

我是否需要配置额外的东西才能使其运行？我想我需要为房间配置一个适配器，但我不确定它的功能和应该如何完成。

是有点完整的，这是我的博智初始设置：

var app = require('express')(); 
var server = require('http').Server(app); 
var Primus = require('primus'); 
var Rooms = require('primus-rooms'); 
var primus = new Primus(server, {transformer: 'sockjs', pathname: '/primus/my-room'}); 
primus.plugin('rooms', Rooms);

我可以加入和离开成功客房。加入&离开是由客户端的一些操作触发：

primus.on('connection', function (spark) { 
    spark.on('data', function(data) { 

    data = data || {}; 

    var action = data.action; 
    var roomToJoin = data.roomToJoin; 

    if ('join' === action) { //join room 
     spark.join(roomToJoin, function() { 
      logger.debug('primus id ' + spark.id + ' joined room ' + roomToJoin);  
     }); 
    }else if ('leave' === action) { //leave room 
     spark.leave(roomToJoin, function() { 
      logger.debug('primus id ' + spark.id + ' left room ' + roomToJoin); 

     }); 
    } 
}

来源

2017-08-03 Dries Cleymans

该处理函数FN（错误，客户端），而不是FN（客户端）。将代码更改为以下会导致预期的行为：

var remoteRoom = 'the_room_I_need_to_target'; 
primus.room(remoteRoom).clients(function(error, clients){ 
    console.dir('primus clients in room ' + remoteRoom + ': ' + clients); 
});

来源

2017-08-30 07:29:28

Primus + primus-rooms + sockjs：如何检索连接到房间的所有客户端

回答

相关问题