最近在開發一個游戲的客服系統，同一時間咨詢問題的玩家多，為了保證服務器高可用，需要利用分布式，另外服務器宕機還需要玩家無感知重連，最關鍵的一點是如何實現服務器的高擴展性，即性能不足時，如何以最少的代價增加一臺新的服務器。

1.單臺websocket

單臺消息互傳實現十分簡單，通過websocket中轉就可以了，不再多加贅述。

2.多臺websocket

當客戶端不在同一臺服務器上時，如何實現消息互通？

一開始的時候，我是想著把server A 與 server B 通過websocket連接起來，互發消息，這種方案在服務器數量小的時候，維護起來也不算麻煩。

例如增加server C 就要把 A、B、C連起來，但是每增加一臺服務器，工作量指數級增長，還要考慮到服務器宕機、服務器心跳的各種問題，想想都頭疼。

3.多臺websocket消息推送

這下舒服了。

1.使用全局redis存儲客戶端與服務端的關系；

2.webscoket服務器各自訂閱不同的消息隊列。

發消息流程：

情況一：

clientA 給 clientB 發消息時，先從緩存中讀取clientB在哪個服務器上，發現clientA 與clientB 在同一服務器時，消息直接發送至clientB

情況二：

clientB 給 clientC 發消息時，從緩存中讀到clientC和clientB并不在同一服務器上，例如clientC在wsB，那么clientB將消息發送到rabbitmq隊列B，然后rabbitmq推送到wsB，wsB給clientC發送消息。

4.總結

新增服務器只需要多訂閱一條消息隊列。

服務器宕機時，客服端重連websocket，重新綁定redis的server關系。

rabbitmq的ack機制保證消息的可靠性。

5.改進

壓縮消息，節省帶寬。推薦使用google的protobuf，就是穩。

總結

以上是生活随笔為你收集整理的【转】分布式websocket服务器的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。