[發(fā)明專利]通信方法、裝置和系統(tǒng)、網(wǎng)絡(luò)服務(wù)器和存儲(chǔ)介質(zhì)

有效

• 申請(qǐng)?zhí)枺?/td>: 201810161035.1
• 申請(qǐng)日: 2018-02-26
• 公開(kāi)（公告）號(hào): CN110198325B
• 公開(kāi)（公告）日: 2022-04-12
• 發(fā)明（設(shè)計(jì)）人: 王瑞波
• 申請(qǐng)（專利權(quán)）人: 北京京東尚科信息技術(shù)有限公司;北京京東世紀(jì)貿(mào)易有限公司
• 主分類號(hào): H04L67/14
• 分類號(hào): H04L67/14;H04L67/101;H04L67/1012;H04L67/1042;H04L41/0663;H04L43/10
• 代理公司: 中國(guó)貿(mào)促會(huì)專利商標(biāo)事務(wù)所有限公司 11038
• 代理人: 許蓓

1.一種通信方法，包括：

從分布式部署的網(wǎng)絡(luò)服務(wù)器集群中選舉的主網(wǎng)絡(luò)服務(wù)器為客戶控制端與機(jī)場(chǎng)服務(wù)器提供網(wǎng)絡(luò)連接服務(wù)，以便所述客戶控制端向所述機(jī)場(chǎng)服務(wù)器發(fā)送控制命令；

所述主網(wǎng)絡(luò)服務(wù)器提供的網(wǎng)絡(luò)連接服務(wù)包括：

與所述客戶控制端建立第一連接；

與所述機(jī)場(chǎng)服務(wù)器建立第二連接；

在所述第二連接上向所述機(jī)場(chǎng)服務(wù)器持續(xù)發(fā)送心跳包，使得所述機(jī)場(chǎng)服務(wù)器在超過(guò)預(yù)設(shè)時(shí)間未收到心跳包時(shí)關(guān)閉所述第二連接；

在檢測(cè)到所述第二連接關(guān)閉、且滿足預(yù)設(shè)的業(yè)務(wù)規(guī)則時(shí)，觸發(fā)主網(wǎng)絡(luò)服務(wù)器的重新選舉過(guò)程，以便新選舉的主網(wǎng)絡(luò)服務(wù)器繼續(xù)提供所述網(wǎng)絡(luò)連接服務(wù)。

2.如權(quán)利要求1所述的通信方法，其中，通過(guò)以下方法選舉所述主網(wǎng)絡(luò)服務(wù)器：

網(wǎng)絡(luò)服務(wù)器集群中的各個(gè)網(wǎng)絡(luò)服務(wù)器連接到分布式應(yīng)用程序協(xié)調(diào)服務(wù)，搶先注冊(cè)所述分布式應(yīng)用程序協(xié)調(diào)服務(wù)中設(shè)定的臨時(shí)節(jié)點(diǎn)的網(wǎng)絡(luò)服務(wù)器選舉為主網(wǎng)絡(luò)服務(wù)器，若注冊(cè)所述臨時(shí)節(jié)點(diǎn)的網(wǎng)絡(luò)服務(wù)器失去連接，所述分布式應(yīng)用程序協(xié)調(diào)服務(wù)從所述臨時(shí)節(jié)點(diǎn)中刪除失去連接的網(wǎng)絡(luò)服務(wù)器。

3.如權(quán)利要求2所述的通信方法，其中，未搶先注冊(cè)所述臨時(shí)節(jié)點(diǎn)的網(wǎng)絡(luò)服務(wù)器訂閱所述臨時(shí)節(jié)點(diǎn)的刪除事件，在接收到所述刪除事件的通知時(shí)，重新注冊(cè)所述臨時(shí)節(jié)點(diǎn)。

4.如權(quán)利要求2所述的通信方法，其中，所述分布式應(yīng)用程序協(xié)調(diào)服務(wù)為zookeeper集群，通過(guò)主網(wǎng)絡(luò)服務(wù)器與zookeeper集群斷開(kāi)連接的方式，觸發(fā)主網(wǎng)絡(luò)服務(wù)器的重新選舉過(guò)程。

5.如權(quán)利要求1所述的通信方法，其中，重新選舉之前的主網(wǎng)絡(luò)服務(wù)器在預(yù)設(shè)的一段時(shí)間內(nèi)不參與所述重新選舉過(guò)程。

6.如權(quán)利要求1所述的通信方法，其中，預(yù)設(shè)的所述業(yè)務(wù)規(guī)則為：重新與所述機(jī)場(chǎng)服務(wù)器建立連接的嘗試次數(shù)達(dá)到預(yù)設(shè)值，觸發(fā)主網(wǎng)絡(luò)服務(wù)器的重新選舉過(guò)程。

7.如權(quán)利要求1所述的通信方法，其中，所述第一連接為HTTP連接，所述第二連接為TCP連接。

8.一種網(wǎng)絡(luò)服務(wù)器，包括：

應(yīng)用模塊，用于參與網(wǎng)絡(luò)服務(wù)器集群中主網(wǎng)絡(luò)服務(wù)器的選舉工作；

網(wǎng)絡(luò)連接服務(wù)模塊，用于在主網(wǎng)絡(luò)服務(wù)器工作模式下，為客戶控制端與機(jī)場(chǎng)服務(wù)器提供網(wǎng)絡(luò)連接服務(wù)，以便所述客戶控制端向所述機(jī)場(chǎng)服務(wù)器發(fā)送控制命令；

所述網(wǎng)絡(luò)連接服務(wù)模塊包括：

通訊單元，用于與所述客戶控制端建立第一連接；與所述機(jī)場(chǎng)服務(wù)器建立第二連接；在檢測(cè)到所述第二連接關(guān)閉、且滿足預(yù)設(shè)的業(yè)務(wù)規(guī)則時(shí)，觸發(fā)主網(wǎng)絡(luò)服務(wù)器的重新選舉過(guò)程，以便新選舉的主網(wǎng)絡(luò)服務(wù)器繼續(xù)提供所述網(wǎng)絡(luò)連接服務(wù)；

鏈路檢查單元，用于在所述第二連接上向所述機(jī)場(chǎng)服務(wù)器持續(xù)發(fā)送心跳包，使得所述機(jī)場(chǎng)服務(wù)器在超過(guò)預(yù)設(shè)時(shí)間未收到心跳包時(shí)關(guān)閉所述第二連接。

9.如權(quán)利要求8所述的網(wǎng)絡(luò)服務(wù)器，其中，所述應(yīng)用模塊，用于：

連接到分布式應(yīng)用程序協(xié)調(diào)服務(wù)，注冊(cè)所述分布式應(yīng)用程序協(xié)調(diào)服務(wù)中設(shè)定的臨時(shí)節(jié)點(diǎn)，其中，搶先注冊(cè)所述分布式應(yīng)用程序協(xié)調(diào)服務(wù)中設(shè)定的臨時(shí)節(jié)點(diǎn)的網(wǎng)絡(luò)服務(wù)器選舉為主網(wǎng)絡(luò)服務(wù)器，若注冊(cè)所述臨時(shí)節(jié)點(diǎn)的網(wǎng)絡(luò)服務(wù)器失去連接，所述分布式應(yīng)用程序協(xié)調(diào)服務(wù)從所述臨時(shí)節(jié)點(diǎn)中刪除失去連接的網(wǎng)絡(luò)服務(wù)器。

10.如權(quán)利要求9所述的網(wǎng)絡(luò)服務(wù)器，其中，所述應(yīng)用模塊，還用于：在未搶先注冊(cè)所述臨時(shí)節(jié)點(diǎn)時(shí)，訂閱所述臨時(shí)節(jié)點(diǎn)的刪除事件，在接收到所述刪除事件的通知時(shí)，重新注冊(cè)所述臨時(shí)節(jié)點(diǎn)。

11.如權(quán)利要求9所述的網(wǎng)絡(luò)服務(wù)器，其中，所述分布式應(yīng)用程序協(xié)調(diào)服務(wù)為zookeeper集群，通過(guò)主網(wǎng)絡(luò)服務(wù)器與zookeeper集群斷開(kāi)連接的方式，觸發(fā)主網(wǎng)絡(luò)服務(wù)器的重新選舉過(guò)程。

12.如權(quán)利要求8所述的網(wǎng)絡(luò)服務(wù)器，其中，應(yīng)用模塊，還用于作為重新選舉之前的主網(wǎng)絡(luò)服務(wù)器時(shí)，在預(yù)設(shè)的一段時(shí)間內(nèi)不參與所述重新選舉過(guò)程。