redis - 使用 socket.io-redis 的示例

Question

大家好，感谢您的时间和帮助。

我需要一个使用 socket.io-redis 的简单示例，请发表评论。我阅读了文档，但我不明白。谢谢，

Answer 1

socket.io-redis 文档没有提到您实际上需要运行一个 redis 服务器，所以您可能已经忘记了这一点。socket.io-redis 插件使用 redis 服务器的 pub/sub 客户端连接多个 socket.io 实例。

1. 从https://redis.io下载并安装一个 redis 服务器

2. 将 redis 插件添加到您的 socket.io 实例中：

   var express = require('express');
   var app = express();
   var server = require('http').Server(app);
   var io = require('socket.io')(server);
   var redis = require('socket.io-redis');
   io.adapter(redis({ host: 'localhost', port: 6379 }));
   

   6379 是默认的 redis 端口，如果您在同一台服务器上运行 node 和 redis，则为 localhost。

3. 添加你需要的socket.io和socket.io-redis函数

   var your_namespace_socket = io.of('/your-namespace');
   your_namespace_socket.on('connection', function(socket){
   
     socket.on('join', function(room){
       socket.join(room);
   
       //log other socket.io-id's in the room
       your_namespace_socket.adapter.clients([room], (err, clients) => {
         console.log(clients);
       });
     });
   });
   

4. 使用 socket.io 启动服务器

   server.listen(3000, function(){
      logger.debug('listening on *:3000');
   });