[發(fā)明專利]物聯(lián)網(wǎng)平臺同步調(diào)用的方法、物聯(lián)網(wǎng)系統(tǒng)和網(wǎng)絡設備

有效

• 申請?zhí)枺?/td>: 202010047097.7
• 申請日: 2020-01-16
• 公開（公告）號: CN111212085B
• 公開（公告）日: 2022-11-22
• 發(fā)明（設計）人: 李俊民;陳子為
• 申請（專利權）人: 廈門網(wǎng)宿有限公司
• 主分類號: H04L67/133
• 分類號: H04L67/133;H04L67/12
• 代理公司: 北京華智則銘知識產(chǎn)權代理有限公司 11573
• 代理人: 王昌貴

本發(fā)明實施例提供了一種物聯(lián)網(wǎng)平臺同步調(diào)用的方法、物聯(lián)網(wǎng)系統(tǒng)和網(wǎng)絡設備，屬于物聯(lián)網(wǎng)技術領域。其中，方法可以包括：在接收到調(diào)用方發(fā)送的同步調(diào)用請求時，阻塞與所述同步調(diào)用請求對應的收發(fā)線程，并為所述同步調(diào)用請求生成調(diào)用標識符；建立所述調(diào)用標識符與所述收發(fā)線程的對應關系，并將攜帶所述調(diào)用標識符的請求消息發(fā)送至所述同步調(diào)用請求指定的物聯(lián)網(wǎng)設備；在接收到攜帶所述調(diào)用標識符的響應消息時，根據(jù)所述調(diào)用標識符喚醒對應的所述收發(fā)線程，并通過所述收發(fā)線程將調(diào)用結果發(fā)送至所述調(diào)用方。采用本發(fā)明，無需改動異步通信模式，即可實現(xiàn)調(diào)用方對物聯(lián)網(wǎng)平臺進行同步調(diào)用。

技術領域

本發(fā)明涉及物聯(lián)網(wǎng)技術領域，特別涉及一種物聯(lián)網(wǎng)平臺同步調(diào)用的方法、物聯(lián)網(wǎng)系統(tǒng)和網(wǎng)絡設備。

背景技術

隨著互聯(lián)網(wǎng)技術的不斷發(fā)展，物聯(lián)網(wǎng)技術得到廣泛應用。各個物聯(lián)網(wǎng)設備通過網(wǎng)絡互聯(lián)，有效推動了各個行業(yè)的智能化發(fā)展。

MQTT(Message Queuing Telemetry Transport，消息隊列遙測傳輸)協(xié)議采用Pub/Sub(Public/Subscribe，發(fā)布/訂閱)的異步通信模式，能夠為連接遠程設備提供實時可靠的消息服務。因此，物聯(lián)網(wǎng)設備與物聯(lián)網(wǎng)平臺通常采用MQTT協(xié)議進行異步通信。

本專利申請的發(fā)明人通過研究現(xiàn)有的物聯(lián)網(wǎng)技術，發(fā)現(xiàn)現(xiàn)有技術至少存在以下問題：在面對涉及共享資源、多次調(diào)用操作存在嚴格時序關系等場景時，用戶往往需要對物聯(lián)網(wǎng)平臺進行同步調(diào)用，進而通過物聯(lián)網(wǎng)平臺向物聯(lián)網(wǎng)設備下發(fā)指令。在這種情況下，用戶需要在接收到物聯(lián)網(wǎng)設備回復的調(diào)用結果后才能進行其他操作。然而，現(xiàn)有的采用異步通信模式的物聯(lián)網(wǎng)系統(tǒng)不能滿足用戶同步調(diào)用的場景需求。

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

本申請的目的在于提供一種物聯(lián)網(wǎng)平臺同步調(diào)用的方法、物聯(lián)網(wǎng)系統(tǒng)和網(wǎng)絡設備，無需改動物聯(lián)網(wǎng)平臺與物聯(lián)網(wǎng)設備的異步通信模式，即可實現(xiàn)調(diào)用方對物聯(lián)網(wǎng)平臺進行同步調(diào)用。所述技術方案如下：

第一方面，提供了一種物聯(lián)網(wǎng)平臺同步調(diào)用的方法，所述方法包括：

在接收到調(diào)用方發(fā)送的同步調(diào)用請求時，阻塞與所述同步調(diào)用請求對應的收發(fā)線程，并為所述同步調(diào)用請求生成調(diào)用標識符；

建立所述調(diào)用標識符與所述收發(fā)線程的對應關系，并將攜帶所述調(diào)用標識符的請求消息發(fā)送至所述同步調(diào)用請求指定的物聯(lián)網(wǎng)設備；

在接收到攜帶所述調(diào)用標識符的響應消息時，根據(jù)所述調(diào)用標識符喚醒對應的所述收發(fā)線程，并通過所述收發(fā)線程將調(diào)用結果發(fā)送至所述調(diào)用方。

在實施中，物聯(lián)網(wǎng)平臺在接收到同步調(diào)用請求后，阻塞對應的收發(fā)線程，物聯(lián)網(wǎng)平臺與物聯(lián)網(wǎng)設備之間仍進行異步通信。物聯(lián)網(wǎng)平臺無需改動原有的異步通信模式，根據(jù)調(diào)用標識符將涉及同一調(diào)用請求的收發(fā)線程、請求消息、以及響應消息關聯(lián)起來。對于調(diào)用方而言，同步調(diào)用結果與同步調(diào)用請求對應，即實現(xiàn)了對物聯(lián)網(wǎng)平臺進行同步調(diào)用。

進一步的，建立所述調(diào)用標識符與所述收發(fā)線程的對應關系，并將攜帶所述調(diào)用標識符的請求消息發(fā)送至所述同步調(diào)用請求指定的物聯(lián)網(wǎng)設備，包括：

通過業(yè)務處理服務建立所述調(diào)用標識符與所述收發(fā)線程的對應關系，并對所述同步調(diào)用請求進行業(yè)務處理；

根據(jù)所述同步調(diào)用請求和所述調(diào)用標識符生成所述請求消息，并通過所述業(yè)務處理服務將攜帶所述調(diào)用標識符的請求消息發(fā)送至鏈接管理服務；

通過所述鏈接管理服務建立所述調(diào)用標識符與所述業(yè)務處理服務的對應關系，并將所述請求消息發(fā)送至所述物聯(lián)網(wǎng)設備。

在實施中，若物聯(lián)網(wǎng)平臺內(nèi)的業(yè)務處理服務與鏈接管理服務分離，業(yè)務處理服務與鏈接管理服務進行異步通信過程中可以攜帶調(diào)用標識符。這樣，可以將調(diào)用標識符與業(yè)務處理服務關聯(lián)起來，為物聯(lián)網(wǎng)平臺將響應消息正確發(fā)送至業(yè)務處理服務進行業(yè)務處理提供基礎。并且，請求消息在轉(zhuǎn)發(fā)過程中始終攜帶調(diào)用標識符，為實現(xiàn)調(diào)用方的同步調(diào)用提供了基礎。