node websocket多进程问题

在做一个聊天程序,单进程情况下每连接一个ws连接我就会存在内存中,但多进程中,若两个用户的socket连接到了不同的进程,便无法通信了。

本来想用redis来储存ws连接对象,但奇怪的是发现无法储存,由于对象中有函数,似乎也不能序列化后再存。求问有什么解决方案

阅读 5.2k
2 个回答

借助 redis 的消息订阅功能实现,ws创建后,就向redis订阅自己key(可以使用uuid或者socketId)消息监。例如 ws-A 如果想向 ws-B 发消息,找到 ws-b 在Redis中的key,把消息存入其中, 就回触发,ws-b那边的订阅回调

可以参考一下 socket.io-redis 这个库的实现.
他是 socket.io 的一个插件库.如果你用的是这个库的话,也可以直接拿来使用.

大概就是用到了 redis发布/订阅 (publish/subscribe) 模式, 每个服务器和客户端的 websocket 连接, 都有一个唯一的 ID, 一个进程的服务接收到了 websocket 的消息, 会通过 redis发布/订阅 (publish/subscribe) 模式, 广播到每个进程, 然后各自处理.

服务端向客户端推送消息也是一样, 如果当前进程找不到客户端(的 ID), 就通过 redis 广播到所有进程.

另外, 也可以通过进程间通信, 通过主进程来进行通信等等方法. 就有点儿复杂了.

撰写回答
你尚未登录,登录后可以
  • 和开发者交流问题的细节
  • 关注并接收问题和回答的更新提醒
  • 参与内容的编辑和改进,让解决方法与时俱进
推荐问题