如何用Akka+Play框架连接两台Scala服务器共享WebSocket客户端池？

核心问题复盘 #

你当前的困境是：

• 多台HTTP服务器通过负载均衡向WebSocket节点发消息时，消息可能被路由到没有目标客户端连接的节点，导致推送失败
• 客户端触发的事件（如接受报价）仅在当前连接的节点生效，其他节点无法同步状态，需要额外发布事件才能协调，工作量大

推荐解决方案 #

方案1：基于Akka Cluster实现分布式协作（最契合你的技术栈） #

既然你用的是Akka+Play，直接利用Akka Cluster的原生能力就能让两台服务器像单节点一样协同工作：

1. 组建Akka Cluster

   • 给两台Scala服务器配置相同的集群种子节点，让它们加入同一个集群，节点间自动建立通信通道
   • Play Framework原生支持Akka Cluster，只需在application.conf中配置集群参数即可

2. 全局客户端路由管理

   • 用Akka Cluster Sharding或者Akka Distributed Data维护全局的客户端连接映射：
     • 客户端连接WebSocket时，所在节点将客户端ID -> 节点标识写入分布式存储
     • 当某节点收到HTTP服务器发来的目标客户端消息时，先查询分布式映射找到客户端所在节点，通过Akka远程消息直接转发到目标节点，由目标节点推送给客户端
   • 示例：用Akka Distributed Data维护客户端路由表

     import akka.cluster.ddata.Replicator._
     import akka.cluster.ddata.{ORMap, ORMapKey, SelfUniqueAddress}
     
     val replicator = DistributedData(system).replicator
     val clientRouteKey = ORMapKey[String, String]("client-routes")
     
     // 客户端连接时，注册路由
     def registerClient(clientId: String, nodeAddress: String): Unit = {
       replicator ! Update(clientRouteKey, ORMap.empty[String, String], WriteLocal)(
         _.put(SelfUniqueAddress(system), clientId, nodeAddress)
       )
     }
     
     // 查询客户端所在节点
     def findClientNode(clientId: String): Unit = {
       replicator ! Get(clientRouteKey, ReadLocal, Some(clientId))
     }
     

3. 全局状态同步

   • 用Akka Distributed Pub/Sub实现事件的全局广播：
     • 所有节点订阅同一个主题（如quote-management）
     • 当某节点收到客户端的报价接受消息后，直接发布报价取消事件到主题，所有节点收到后同步更新本地状态，无需额外调用SNS
   • 示例：Pub/Sub的使用

     val pubSub = DistributedPubSub(system)
     val mediator = pubSub.mediator
     
     // 订阅报价事件主题
     mediator ! Subscribe("quote-management", self)
     
     // 处理客户端接受报价的逻辑
     def handleQuoteAccepted(quoteId: String): Unit = {
       // 取消本地节点的对应报价
       cancelLocalQuotes(quoteId)
       // 发布事件通知所有节点
       mediator ! Publish("quote-management", QuoteCanceled(quoteId))
     }
     
     // 接收全局事件并同步状态
     override def receive: Receive = {
       case QuoteCanceled(id) => cancelLocalQuotes(id)
     }
     

方案2：基于共享存储的轻量实现（如果不想用Akka Cluster） #

如果不想引入Akka Cluster的复杂度，可以用Redis这类分布式缓存实现：

1. 客户端路由映射

   • 客户端连接时，所在节点将客户端ID -> 节点地址写入Redis，并设置过期时间（与WebSocket超时一致）
   • 节点收到HTTP消息时，先查询Redis获取目标客户端的节点地址，然后通过HTTP接口或Akka远程调用转发消息到对应节点

2. 状态同步

   • 利用Redis的Pub/Sub功能，所有节点订阅同一个频道，事件发生时发布到频道，所有节点同步本地状态

方案优势对比 #

• 无需依赖外部SNS服务，节点间的协作和状态同步都在内部完成，减少额外工作量
• 上游HTTP服务器无需关心客户端连接到哪个WebSocket节点，只需将消息发送到任意节点，路由逻辑由集群或共享存储处理
• 完全满足你"两台服务器像一台一样工作"的需求

内容的提问来源于stack exchange，提问作者Nate