在做一个聊天程序,单进程情况下每连接一个ws连接我就会存在内存中,但多进程中,若两个用户的socket连接到了不同的进程,便无法通信了。
本来想用redis来储存ws连接对象,但奇怪的是发现无法储存,由于对象中有函数,似乎也不能序列化后再存。求问有什么解决方案
在做一个聊天程序,单进程情况下每连接一个ws连接我就会存在内存中,但多进程中,若两个用户的socket连接到了不同的进程,便无法通信了。
本来想用redis来储存ws连接对象,但奇怪的是发现无法储存,由于对象中有函数,似乎也不能序列化后再存。求问有什么解决方案
可以参考一下 socket.io-redis 这个库的实现.
他是 socket.io
的一个插件库.如果你用的是这个库的话,也可以直接拿来使用.
大概就是用到了 redis
的 发布/订阅 (publish/subscribe)
模式, 每个服务器和客户端的 websocket
连接, 都有一个唯一的 ID
, 一个进程的服务接收到了 websocket
的消息, 会通过 redis
的 发布/订阅 (publish/subscribe)
模式, 广播到每个进程, 然后各自处理.
服务端向客户端推送消息也是一样, 如果当前进程找不到客户端(的 ID
), 就通过 redis
广播到所有进程.
另外, 也可以通过进程间通信, 通过主进程来进行通信等等方法. 就有点儿复杂了.
5 回答4.8k 阅读✓ 已解决
4 回答2.4k 阅读✓ 已解决
2 回答1.7k 阅读✓ 已解决
5 回答1.9k 阅读
2 回答1.3k 阅读✓ 已解决
3 回答2k 阅读
1 回答3.2k 阅读
借助 redis 的消息订阅功能实现,ws创建后,就向redis订阅自己key(可以使用uuid或者socketId)消息监。例如 ws-A 如果想向 ws-B 发消息,找到 ws-b 在Redis中的key,把消息存入其中, 就回触发,ws-b那边的订阅回调