在项目中遇到:多个服务作为websocket服务端时,怎么跟前端设备进行数据通信的问题。具体解决方案,分享一下。
1.遇到问题
项目中使用websocket与前端设备建立长链接,用于推送过车、车位数、支付等相关信息,由于项目是负载均衡的,存在项目部署在多台机器上。这样就会存在一个问题,当一次请求负载到第一台服务器时,socketsession在第一台服务器线程上,第二次请求,负载到第二台服务器上,需要通过岗亭id查找当前用户的session时,是查找不到的。
2.解决思路
方案一:将websocket session存放在Redis中使其在各服务间共享,但是由于websocket的session并没有实现序列化接口。所以无法将session序列化到redis中,此路行不通。
方案二:将消息发送至kafka,不同服务建立不同消费组去消费同一主题消息,查找当前服务是否存在对应岗亭的session,并完成推送。