如何實現(xiàn)支持?jǐn)?shù)億用戶的長連消息系統(tǒng)

1、room實例地址，通過room service下發(fā)給長連接 Center Service比較重的工作如全網(wǎng)廣播，需要把所有的任務(wù)分解成一系列的子任務(wù)，分發(fā)給所有center，然后在所有的子任務(wù)里，分別獲取在線和離線的所有用戶，再批量推到Room Service。

創(chuàng)新互聯(lián)是專業(yè)的絳縣網(wǎng)站建設(shè)公司，絳縣接單;提供成都做網(wǎng)站、成都網(wǎng)站建設(shè),網(wǎng)頁設(shè)計,網(wǎng)站設(shè)計,建網(wǎng)站,PHP網(wǎng)站建設(shè)等專業(yè)做網(wǎng)站服務(wù);采用PHP框架,可快速的進(jìn)行絳縣網(wǎng)站開發(fā)網(wǎng)頁制作和功能擴展;專業(yè)做搜索引擎喜愛的網(wǎng)站,專業(yè)的做網(wǎng)站團隊,希望更多企業(yè)前來合作!

2、現(xiàn)在流行的消息推送實現(xiàn)方式，主要為長鏈接方式實現(xiàn)。

3、利用kafka技術(shù)可以在廉價PC Server上搭建起大規(guī)模的消息系統(tǒng)。Kafka具有消息持久化、高吞吐、分布式、實時、低耦合、多客戶端支持、數(shù)據(jù)可靠等諸多特點，適合在線和離線的消息處理。

4、基于TCP長連接則能夠更好地支持大批量用戶，問題是客戶端和服務(wù)器的實現(xiàn)比較復(fù)雜。也有一些改進(jìn)，比如下行使用MQTT進(jìn)行服務(wù)器通知/消息的下發(fā)，上行使用HTTP短連接進(jìn)行指令和消息的上傳。

WebSocket+SLB(負(fù)載均衡)會話保持解決重連問題

只要SLB能夠正常識別WS握手協(xié)議里Request的cookie和正常識別服務(wù)器返回的Response并且往里面插入cookie，就可以利用會話保持解決重連問題。

負(fù)載均衡所解決的問題主要包括兩點：第一點，SLB能夠消除系統(tǒng)的單點故障，這是因為SLB的后面是由多臺云服務(wù)器組成的服務(wù)器池，那么當(dāng)其中某一臺服務(wù)器出現(xiàn)故障的時候并不會影響整個系統(tǒng)的可服務(wù)性。

首先它不能降低內(nèi)部連接數(shù)量以及轉(zhuǎn)發(fā)次數(shù)，所以無法降低資源消耗；而負(fù)載均衡應(yīng)該做到內(nèi)部一個子節(jié)點僅用一個連接，做到批量發(fā)送數(shù)據(jù)減少內(nèi)部數(shù)據(jù)發(fā)送次數(shù)。

go語言中的tcpconn是阻塞還是非阻塞的

阻塞socket和非阻塞socket的區(qū)別： 讀操作 對于阻塞的socket，當(dāng)socket的接收緩沖區(qū)中沒有數(shù)據(jù)時，read調(diào)用會一直阻塞住，直到有數(shù)據(jù)到來才返回。當(dāng)socket緩沖區(qū)中的數(shù)據(jù)量小于期望讀取的數(shù)據(jù)量時，返回實際讀取的字節(jié)數(shù)。

如果 net.Conn Close() 了，不論 Read() 阻塞還是 Write() 阻塞都會立即收到 err 返回。一般來說，Write() 是不可能主動知道連接斷開的，除非是 SetDeadline() 猜測對方斷掉了，指定時間內(nèi)沒有寫成功就認(rèn)為是斷開。

socket當(dāng)前還沒發(fā)現(xiàn)這樣的api，確實有io timeout，但是不是這個場景，如果recv_buf中有數(shù)據(jù)了，哪怕是一個字節(jié)，read調(diào)用就返回。當(dāng)前還沒發(fā)現(xiàn)，不知道其他的有沒有庫提供這功能。

本質(zhì)上，是作為文件處理的，發(fā)送是“write，print”，接受是“read”。連接相當(dāng)于打開文件。