[發(fā)明專利]一種并發(fā)通信傳輸數(shù)據(jù)的方法

有效

• 申請(qǐng)?zhí)枺?/td>: 201810240810.2
• 申請(qǐng)日: 2018-03-22
• 公開(kāi)（公告）號(hào): CN108429665B
• 公開(kāi)（公告）日: 2020-12-15
• 發(fā)明（設(shè)計(jì)）人: 馬哲
• 申請(qǐng)（專利權(quán)）人: 四川長(zhǎng)虹電器股份有限公司
• 主分類號(hào): H04L12/46
• 分類號(hào): H04L12/46;H04W4/70
• 代理公司: 四川省成都市天策商標(biāo)專利事務(wù)所 51213
• 代理人: 秦華云;劉渝

本發(fā)明公開(kāi)了一種并發(fā)通信傳輸數(shù)據(jù)的方法，包含以下步驟：S1.定義全局變量：定義相關(guān)連接請(qǐng)求信息變量和相關(guān)操作信息變量；S2.構(gòu)造器：根據(jù)請(qǐng)求信息對(duì)請(qǐng)求信息變量進(jìn)行初始化，并通過(guò)相關(guān)操作對(duì)其合法性做出判斷并給出對(duì)應(yīng)的回應(yīng)，對(duì)合法的連接請(qǐng)求在連接成功后對(duì)相關(guān)變量進(jìn)行初始化及實(shí)例化；S3.啟用相關(guān)線程連接。本發(fā)明的并發(fā)通信傳輸數(shù)據(jù)的方法，采用發(fā)布訂閱的方式將xmpp服務(wù)器與mqtt服務(wù)器橋接到一起，實(shí)現(xiàn)并發(fā)通信傳輸數(shù)據(jù)。

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

本發(fā)明涉及計(jì)算機(jī)不同協(xié)議系統(tǒng)服務(wù)與mqtt系統(tǒng)服務(wù)通信數(shù)據(jù)傳輸應(yīng)用技術(shù)領(lǐng)域，特別涉及一種并發(fā)通信傳輸數(shù)據(jù)的方法，可實(shí)現(xiàn)不同協(xié)議系統(tǒng)服務(wù)與 MQTT系統(tǒng)服務(wù)的并發(fā)通信傳輸數(shù)據(jù)。

背景技術(shù)

當(dāng)下是物聯(lián)網(wǎng)的時(shí)代，而mqtt協(xié)議是實(shí)現(xiàn)物聯(lián)網(wǎng)非常好的協(xié)議，對(duì)于過(guò)去未使用該協(xié)議作為系統(tǒng)服務(wù)的公司及重大項(xiàng)目，而考慮將來(lái)轉(zhuǎn)向使用mqtt協(xié)議作為系統(tǒng)服務(wù)的，在保證不影響之前系統(tǒng)服務(wù)的前提下，就需要實(shí)現(xiàn)之前的系統(tǒng)服務(wù)與mqtt系統(tǒng)服務(wù)之間的數(shù)據(jù)傳輸通信，這就在不影響之前系統(tǒng)服務(wù)的使用的情況下完成向mqtt系統(tǒng)服務(wù)的轉(zhuǎn)接。

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

本發(fā)明的目的是克服上述背景技術(shù)中不足，提供一種并發(fā)通信傳輸數(shù)據(jù)的方法，采用發(fā)布訂閱的方式將xmpp服務(wù)器與mqtt服務(wù)器橋接到一起，實(shí)現(xiàn)并發(fā)通信傳輸數(shù)據(jù)。

為了達(dá)到上述的技術(shù)效果，本發(fā)明采取以下技術(shù)方案：

一種并發(fā)通信傳輸數(shù)據(jù)的方法，可實(shí)現(xiàn)不同協(xié)議系統(tǒng)服務(wù)與MQTT系統(tǒng)服務(wù)的并發(fā)通信傳輸數(shù)據(jù)，具體包含以下步驟：

S1.定義全局變量：定義相關(guān)連接請(qǐng)求信息變量和相關(guān)操作信息變量；

S2.構(gòu)造器：根據(jù)請(qǐng)求信息對(duì)請(qǐng)求信息變量進(jìn)行初始化，并通過(guò)相關(guān)操作對(duì)其合法性做出判斷并給出對(duì)應(yīng)的回應(yīng)，對(duì)合法的連接請(qǐng)求在連接成功后對(duì)相關(guān)變量進(jìn)行初始化及實(shí)例化；

S3.啟用相關(guān)線程連接。

進(jìn)一步地，還包含步驟S4.定義回調(diào)函數(shù)：在所述步驟S3啟用連接中時(shí)定義相關(guān)回調(diào)。

進(jìn)一步地，所述步驟S4具體包含：

S40.定義連接回調(diào)，根據(jù)連接結(jié)果成功與否調(diào)用對(duì)應(yīng)的回調(diào)；

S41.實(shí)例化一個(gè)監(jiān)聽(tīng)者對(duì)是否連接成功進(jìn)行監(jiān)聽(tīng)；

S42.實(shí)例化一個(gè)等待對(duì)象，等待監(jiān)聽(tīng)者監(jiān)聽(tīng)到連接成功；

S43.定義不同的連接成功的回調(diào)，根據(jù)對(duì)應(yīng)函數(shù)中不同連接成功的個(gè)數(shù)給出對(duì)應(yīng)的回應(yīng)；

S44.定義一個(gè)獲取隨機(jī)客戶端的函數(shù)，獲取隨機(jī)連接；

S45.定義一個(gè)獲取全部連接對(duì)象的函數(shù)；

S46.定義一個(gè)布爾型函數(shù)，判斷失敗的連接是否包含連接成功的客戶端，根據(jù)不同結(jié)果返回相應(yīng)信息；

S47.定義一個(gè)函數(shù)用來(lái)打印連接失敗的原因，將連接失敗的原因存入相關(guān)變量中；

S48.分別定義發(fā)布訂閱和取消訂閱的函數(shù)；

S49.基于發(fā)布，訂閱函數(shù)，通過(guò)訂閱共享主題，連接池的客戶端根據(jù)主題連接訂閱者，由于是共享訂閱，每個(gè)客戶端對(duì)于相同的主題只有一個(gè)客戶端會(huì)接收。

進(jìn)一步地，所述步驟S49中共享訂閱的訂閱共享主題具有多個(gè)分組，每個(gè)分組均代表不同特征的對(duì)象。

本發(fā)明與現(xiàn)有技術(shù)相比，具有以下的有益效果：