基于go的websocket消息推送的集群實現(xiàn)

目前websocket技術(shù)已經(jīng)很成熟，選型Go語言，當然是為了節(jié)省成本以及它強大的高并發(fā)性能。我使用的是第三方開源的websocket庫即gorilla/websocket。

創(chuàng)新互聯(lián)主營東營網(wǎng)站建設(shè)的網(wǎng)絡(luò)公司,主營網(wǎng)站建設(shè)方案,成都app軟件開發(fā),東營h5小程序開發(fā)搭建,東營網(wǎng)站營銷推廣歡迎東營等地區(qū)企業(yè)咨詢

由于我們線上推送的量不小，推送后端需要部署多節(jié)點保持高可用，所以需要自己做集群，具體架構(gòu)方案如圖：

Auth Service：鑒權(quán)服務(wù)，根據(jù)Token驗證用戶權(quán)限。

Collect Service：消息采集服務(wù)，負責收集業(yè)務(wù)系統(tǒng)消息，存入MongoDB后，發(fā)送給消息分發(fā)服務(wù)。

Dispatch Service：消息分發(fā)服務(wù)，根據(jù)路由規(guī)則分發(fā)至對應(yīng)消息推送服務(wù)節(jié)點上。

Push Service：消息推送服務(wù)，通過websocket將消息推送給用戶。

集群推送的關(guān)鍵點在于，web端與服務(wù)端建立長連接之后，具體跟哪個推送節(jié)點保持長連接的，如果我們能夠找到對應(yīng)的連接節(jié)點，那么我們就可以將消息推送出去。下面講解一下集群的大致流程：

1. web端用戶登錄之后，帶上token與后端推送服務(wù)（Push Service）保持長連接。

2. 推送服務(wù)收到連接請求之后，攜帶token去鑒權(quán)服務(wù)（Auth Service）驗證此token權(quán)限，并返回用戶ID。

3. 把返回的用戶ID與長連接存入本地緩存，保持用戶ID與長連接綁定關(guān)系。

4. 再將用戶ID與本推送節(jié)點IP存入redis，建立用戶（即長連接）與節(jié)點綁定關(guān)系，并設(shè)置失效時間。

5. 采集服務(wù)（Collect Service）收集業(yè)務(wù)消息，首先存入mongodb，然后將消息透傳給分發(fā)服務(wù)（Dispatch Service）。

6. 分發(fā)服務(wù)收到消息之后，根據(jù)消息體中的用戶ID，從redis中獲取對應(yīng)的推送服務(wù)節(jié)點IP，然后轉(zhuǎn)發(fā)給對應(yīng)的推送節(jié)點。

7. 推送服務(wù)節(jié)點收到消息之后，根據(jù)用戶ID，從本地緩存中取出對應(yīng)的長連接，將消息推送給客戶端。

其他注意事項：

Go語言list（列表）

2021-11-10

列表是一種非連續(xù)的存儲容器，有多個節(jié)點組成，節(jié)點通過一些變量記錄彼此之間的關(guān)系

單鏈表和雙鏈表就是列表的兩種方法。

原理：A、B、C三個人，B懂A的電話，C懂B的電話只是單方知道號碼，這樣就形成了一個單鏈表結(jié)構(gòu)。

如果C把自己的號碼給B，B把自己的號碼給A，因為是雙方都知道對方的號碼，這樣就形成了一個雙鏈表結(jié)構(gòu)

如果B換號碼了，他需要通知AC，把自己的號碼刪了，這個過程就是列表的刪除操作。

在Go語言中，列表使用 container/list 包來實現(xiàn)，內(nèi)部的實現(xiàn)原理是雙鏈表，列表能夠高效地進行任意位置的元素插入和刪除操作。

列表初始化的兩種辦法

列表沒有給出具體的元素類型的限制，所以列表的元素可以是任意類型的，

例如給列表中放入了一個 interface{} 類型的值，取出值后，如果要將 interface{} 轉(zhuǎn)換為其他類型將會發(fā)生宕機。

雙鏈表支持從隊列前方或后方插入元素，分別對應(yīng)的方法是 PushFront 和 PushBack。

列表插入函數(shù)的返回值會提供一個 *list.Element 結(jié)構(gòu)，這個結(jié)構(gòu)記錄著列表元素的值以及與其他節(jié)點之間的關(guān)系等信息，從列表中刪除元素時，需要用到這個結(jié)構(gòu)進行快速刪除。

遍歷完也能看到最后的結(jié)果

學(xué)習(xí)地址：

go語言tcp協(xié)議push指令怎么用

PUSH指令主要用于編寫子程序和中斷服務(wù)程序，可以臨時保存程序狀態(tài)字PSW和累加器ACC的內(nèi)容 或其它寄存器和存儲器單元的內(nèi)容。

在子程序和中斷服務(wù)程序結(jié)束返回主程序前，要用POP彈棧指令，從堆棧中取出被保護的數(shù)據(jù)，恢復(fù)程序狀態(tài)字PSW和累加器ACC的內(nèi)容 或其它寄存器和存儲器單元的內(nèi)容。

呵呵 滿意 就選滿意回答啊

go語言里的list應(yīng)該怎么使用

package main

import (

"container/list"

"fmt"

"strings"

)

func main() {

items := list.New()

for _, x := range strings.Split("ABCDEFGH", "") {

items.PushFront(x)

}

items.PushBack(9)

for element := items.Front(); element != nil; element = element.Next() {

switch value := element.Value.(type) {

case string:

fmt.Printf("%s ", value)

case int:

fmt.Printf("%d ", value)

}

}

fmt.Println()

}

分享題目：go語言怎么push,go語言怎么讀
分享路徑：http://m.newbst.com/article38/phhspp.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供ChatGPT、商城網(wǎng)站、手機網(wǎng)站建設(shè)、App開發(fā)、網(wǎng)站設(shè)計公司、網(wǎng)站制作

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)