基于MQTT協(xié)議的多報文數(shù)據(jù)采集方法、采集系統(tǒng)

基本信息

申請?zhí)?/td> CN202111032599.3 申請日 -
公開（公告）號 CN113746919A 公開（公告）日 2021-12-03
申請公布號 CN113746919A 申請公布日 2021-12-03
分類號 H04L29/08（2006.01）I 分類 電通信技術;
發(fā)明人 朱孟;張曉明 申請（專利權）人 中化信息技術有限公司
代理機構 北京衛(wèi)智易創(chuàng)專利代理事務所（普通合伙） 代理人 朱春野
地址 100032北京市西城區(qū)復興門內大街28號凱晨世貿(mào)中心中座7層703室
法律狀態(tài) -

摘要

摘要 基于MQTT協(xié)議的多報文數(shù)據(jù)采集方法，包括：采集預設的多種工業(yè)數(shù)據(jù)源數(shù)據(jù)，確定多種工業(yè)數(shù)據(jù)源數(shù)據(jù)的需要傳輸?shù)臄?shù)據(jù)報文，將數(shù)據(jù)報文發(fā)送到MQTT服務端；定義數(shù)據(jù)實體，使其覆蓋數(shù)據(jù)報文中的所有字段；解析工業(yè)數(shù)據(jù)源數(shù)據(jù)流映射到定義的數(shù)據(jù)實體上，若訂閱到的報文數(shù)據(jù)為空，則不進行處理；若訂閱到的數(shù)據(jù)報文不為空，則將報文數(shù)據(jù)反序列化到定義的數(shù)據(jù)實體上，將流式數(shù)據(jù)解析為內存對象；定義報文格式，使其包含特征字段并符合數(shù)據(jù)后續(xù)處理要求；根據(jù)報文格式，判斷內存對象中數(shù)據(jù)的報文格式，從內存對象中獲取復合定義的報文格式的數(shù)據(jù)。