[發(fā)明專利]一種實(shí)時(shí)通信服務(wù)動(dòng)態(tài)分布式部署的方法

有效

• 申請(qǐng)?zhí)枺?/td>: 201710651454.9
• 申請(qǐng)日: 2017-08-02
• 公開（公告）號(hào): CN107493325B
• 公開（公告）日: 2020-12-15
• 發(fā)明（設(shè)計(jì)）人: 曾志超;劉陽(yáng);葉一志
• 申請(qǐng)（專利權(quán)）人: 深圳市易材科技有限公司
• 主分類號(hào): H04L29/08
• 分類號(hào): H04L29/08;H04L29/06
• 代理公司: 北京隆源天恒知識(shí)產(chǎn)權(quán)代理事務(wù)所(普通合伙) 11473
• 代理人: 閆冬

一種實(shí)時(shí)通信服務(wù)動(dòng)態(tài)分布式部署的方法，該方法在服務(wù)端接入層實(shí)現(xiàn)請(qǐng)求轉(zhuǎn)發(fā)服務(wù)，實(shí)現(xiàn)動(dòng)態(tài)部署socket服務(wù)功能，在每個(gè)socket服務(wù)所在的服務(wù)器上部署一個(gè)監(jiān)聽腳本和一個(gè)消息發(fā)送腳本，從而實(shí)現(xiàn)服務(wù)端支持更多的來(lái)自客戶端的socket并發(fā)連接。

技術(shù)領(lǐng)域

本發(fā)明涉及一種實(shí)時(shí)通信服務(wù)動(dòng)態(tài)分布式部署的方法。

背景技術(shù)

現(xiàn)有的解決方案是部署一個(gè)消息中間件服務(wù)，所有的分布式部署的socket進(jìn)程通過(guò)消息中間件服務(wù)實(shí)現(xiàn)與其他服務(wù)器上的socket進(jìn)程進(jìn)行消息通信。這種解決方案有三點(diǎn)不足：1、消息中間件服務(wù)本身是個(gè)單實(shí)例進(jìn)程，無(wú)法多機(jī)部署，會(huì)形成單點(diǎn)；2、服務(wù)器上的socket進(jìn)程在消息監(jiān)聽和發(fā)送時(shí)會(huì)與消息中間件服務(wù)通信，如果消息中間件服務(wù)故障，則服務(wù)器上的socket進(jìn)程也會(huì)被影響，有發(fā)生雪崩效應(yīng)的風(fēng)險(xiǎn)；3、單實(shí)例部署的消息中間件服務(wù)能承受的并發(fā)請(qǐng)求是有限的，單一的增加socket服務(wù)器的數(shù)量并不能線性提升并發(fā)能力，會(huì)有短板效應(yīng)。

現(xiàn)有技術(shù)存在以下缺點(diǎn)：1、本方法需要部署消息訂閱與發(fā)布服務(wù)，該服務(wù)需要的服務(wù)器數(shù)量會(huì)隨著并發(fā)要求的增加而線性增加，會(huì)增加服務(wù)器成本；2、本方法需要實(shí)現(xiàn)轉(zhuǎn)發(fā)服務(wù)(反向代理服務(wù))，該服務(wù)需要的服務(wù)器成本會(huì)隨著并發(fā)要求的增加而線性增加，也會(huì)造成服務(wù)器成本的增加。

本方法可解決的問(wèn)題：1、socket動(dòng)態(tài)部署服務(wù)可以學(xué)習(xí)歷史并發(fā)量數(shù)據(jù)從而實(shí)現(xiàn)根據(jù)當(dāng)前并發(fā)量動(dòng)態(tài)部署socket服務(wù)；2、每個(gè)socket服務(wù)都部署一個(gè)socket進(jìn)程、一個(gè)消息監(jiān)聽腳本、一個(gè)數(shù)據(jù)發(fā)送腳本，socket進(jìn)程運(yùn)行過(guò)程中不與其他socket服務(wù)器上的socket進(jìn)程通信，增加了socket服務(wù)的整體魯棒性；3、每個(gè)環(huán)節(jié)上的服務(wù)都不是單點(diǎn)，所以理論上只要有足夠多服務(wù)器，整個(gè)socket服務(wù)所支持的并發(fā)數(shù)是沒(méi)有上限的。

發(fā)明內(nèi)容

本發(fā)明專利的目的在于提供一種實(shí)時(shí)通信服務(wù)動(dòng)態(tài)分布式部署的方法，本發(fā)明采用如下技術(shù)方案：

一種實(shí)時(shí)通信服務(wù)動(dòng)態(tài)分布式部署的方法，其特征在于該方法包括以下步驟：

步驟一，首先客戶端的用戶1向socket服務(wù)器發(fā)送一條消息A與socket服務(wù)器建立連接請(qǐng)求，所述用戶1和socket服務(wù)器之間具有反向代理負(fù)載均衡器，通過(guò)智能部署服務(wù)器與該反向代理負(fù)載均衡器的連接，從而獲得所有socket服務(wù)器負(fù)載情況的數(shù)據(jù)，并將客戶端的用戶1的連接請(qǐng)求發(fā)送給負(fù)載最低的socket服務(wù)器并建立連接；

步驟二，當(dāng)客戶端的用戶1與負(fù)載最低的socket服務(wù)器建立連接后，該socket服務(wù)器將socket服務(wù)處理的消息A反饋給用戶1，并向所有用戶廣播一條消息B，

步驟三，步驟二中該socket服務(wù)器將socket服務(wù)處理的消息A反饋給用戶1的同時(shí)該socket服務(wù)將用戶1發(fā)送的消息A發(fā)給socket服務(wù)器的數(shù)據(jù)發(fā)送腳本，該數(shù)據(jù)發(fā)送腳本將消息A發(fā)布至訂閱與發(fā)布集群，該訂閱與發(fā)布集群將收到的消息A經(jīng)過(guò)處理得到經(jīng)過(guò)訂閱的消息A，并將該訂閱的消息A發(fā)送至送至所有的socket服務(wù)器，并與所有socket服務(wù)器的消息監(jiān)聽腳本建立連接并獲得訂閱的消息A；

步驟三，步驟二中的socket服務(wù)器的消息監(jiān)聽腳本獲得訂閱的消息A后，將該訂閱的消息A發(fā)送至socket服務(wù)器的socket服務(wù)；

如果該socket服務(wù)器已將socket服務(wù)處理的消息A反饋給用戶1，該服務(wù)器將會(huì)自動(dòng)忽略該訂閱的消息A；其他的socket服務(wù)器將該訂閱的消息A通過(guò)反向代理負(fù)載均衡器反饋給除用戶1之外的所有用戶同時(shí)廣播一條消息B。

所述智能部署服務(wù)器具有動(dòng)態(tài)socket部署腳本；所述反向代理負(fù)載均衡器包括健康檢查腳本，歷史并發(fā)量健康度數(shù)據(jù)庫(kù)，歷史并發(fā)量學(xué)習(xí)腳本，并發(fā)策略腳本。

所述所有的socket服務(wù)器的socket進(jìn)程運(yùn)行過(guò)程中，不與其他socket服務(wù)器上的socket進(jìn)行通信。