(19)中华 人民共和国 国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202111491449.9 (22)申请日 2021.12.08 (71)申请人 广州市中南民航空管通信网络科技 有限公司 地址 510080 广东省广州市白云区北太路 1633号广州民营科技园科盛路8号配 套服务大楼605-8房 (72)发明人 沈仲针　蔡建坤　尹阳　吴新球　 贺礼超　 (74)专利代理 机构 广州市越秀区哲力专利商标 事务所(普通 合伙) 44288 代理人 陶洁雯 (51)Int.Cl. H04L 9/40(2022.01) H04L 12/66(2006.01)H04L 51/18(2022.01) H04L 67/12(2022.01) (54)发明名称 一种异步空管数据交互方法、 系统、 介质及 产品 (57)摘要 本发明提供一种异 步空管数据交互方法， 包 括接收目标用户发送的用于获取目标异步空管 数据的消息消费请求， 所述消息消费请求包括消 息队列名称和消费用户ID； 根据所述消息队列名 称在若干预设消息输出队列中筛选对应的目标 消息输出队列， 根据所述消费用户ID在所述目标 消息输出队列中定位出含有目标异步空管数据 的目标消息； 将所述目标消息通过所述目标消息 输出队列发送至目标用户。 本方明的一种异步空 管数据交互方法， 使数据消费端和数据生产端之 间接触耦合 关系， 数据消费端的行为不会影响数 据生产端的性能， 还可以降低两个终端之间数据 交换的网格复杂程度， 便于运维和改造， 增加了 异步空管 数据交互的稳定性。 权利要求书2页 说明书6页 附图2页 CN 114422171 A 2022.04.29 CN 114422171 A 1.一种异步空管 数据交互方法， 其特 征在于： 包括以下步骤： 接收消息消费请求， 接收目标用户发送的用于获取目标异步空管数据的消息消费请 求， 所述消息消费请求包括消息队列名称和 消费用户ID； 响应请求， 根据 所述消息队列名称在若干预设消息输出队列中筛选对应的目标消息输 出队列， 根据所述消费用户ID在所述目标消息输出队列中定位出含有目标异 步空管数据的 目标消息； 反馈目标消息， 将所述目标消息通过 所述目标消息 输出队列发送至目标用户。 2.如权利要求1所述的一种异步空管数据交互方法， 其特征在于： 所述根据所述消费用 户ID在所述目标消息输出队列中定位出含有目标异 步空管数据的目标消息具体为： 根据所 述消费用户ID确定已经发送至目标用户的消息的数量， 记为已发送消息数量， 根据所述已 发送消息数量生成与所述目标消息对应的目标消息偏移 量， 根据目标消息偏移 量在所述目 标消息输出队列中定位出含有目标异步空管 数据的目标消息 。 3.如权利要求1所述的一种异步空管数据交互方法， 其特征在于： 还包括消息回溯， 接 收目标用户发送的含有消费用户ID的消息回溯 请求， 根据所述消费用户ID确认需要回溯的 目标消息的回溯消息偏移量， 在预设消息输入队列中从所述消息偏移量对应的消息作为起 始点拉取对应的消息作为回溯消息， 并将所述回溯消息通过对应的目标消息输出队列输出 至目标用户。 4.如权利要求1所述的一种异步空管数据交互方法， 其特征在于： 还包括存储消息， 监 听消息生产者发送的初始消息， 将所述初始消息插入至预设消息输入队列中， 并生成与每 条初始信息对应的消息偏移量， 将消息偏移量与对应的初始消息进行关联， 对每条所述初 始消息进 行解析并提取对应的关键信息， 根据所述关键信息以及预设输出队列配置表为所 述初始消息筛选出对应的预设消息输出队列， 将含有相同关键信息的每条初始消息均发送 至对应的预设消息 输出队列中。 5.如权利要求1所述的一种异步空管数据交互方法， 其特征在于： 在所述响应请求之前 还包括权限判定步骤， 根据所述消息消费请求中的所述消费用户ID判断目标用户是否具有 请求权限， 若是， 执 行所述响应请求 步骤， 若否， 则不作响应。 6.一种异步空管数据交互系统， 其特征在于： 包括接入层、 服务层， 所述接入层包括接 入端口和网关， 所述接入端口与所述网关连接， 所述服务层包括数据总线， 所述数据总线包 括若干个分布式排布的消息输出队列、 单个消息输入队列以及分发模块， 所述消息输出队 列和所述消息输入队列均与所述网关连接， 所述分发模块与所消息输出队列和所述消息输 入队列连接； 所述分发模块通过所述网关接收目标用户发送的用于获取目标异步空管数据的消息 消费请求， 所述消息消费请求包括消息队列名称和消费用户ID； 所述分发模块根据所述消 息队列名称在若干预设消息输出队列中筛选对应的目标消息输出队列， 所述分发模块根据 所述消费用户ID在所述目标消息输出队列中定位出含有目标异 步空管数据的目标消息； 所 述分发模块将所述目标消息通所述目标消息输出队列发送至所述网关， 再由所述网关发送 至目标用户。 7.如权利要求6所述的一种异步空管数据交互系统， 其特征在于： 所述分发模块包括流 处理组件以及配置中心， 所述配置中心存储有消息输出队列配置表， 所述流处理组件根据权　利　要　求　书 1/2 页 2 CN 114422171 A 2所述消息队列名称以及所述消息输出队列配置表在若干预设消息输出队列中筛选对应的 目标消息 输出队列。 8.如权利要求6所述的一种异步空管数据交互系统， 其特征在于： 所述数据总 线还包括 监听模块， 所述监听模块实时监听消息生产者发送的初始消息， 所述监听模块将所述初始 消息插入至预设消息输入队列中， 并生成与每条初始信息对应的消息偏移量， 所述监听模 块将消息偏移量与对应的初始消息进 行关联， 所述监听模块对每条所述初始消息进行解析 并提取对应的关键信息， 所述监听模块根据所述关键信息以及预设输出队列配置表为所述 初始消息筛选出对应的预设消息输出队列， 所述监听模块将含有相同关键信息的每条初始 消息均发送至对应的预设消息 输出队列中。 9.一种计算机可读存储介质， 其上存储有计算机程序， 其特征在于： 所述计算机程序被 处理器执行权利要求1 ‑5中任意一项所述的一种异步空管 数据交互方法。 10.一种计算机程序产品， 包括计算机程序， 其特征在于， 该计算机程序被处理器执行 时实现权利要求1 ‑5中任意一项所述的一种异步空管 数据交互方法。权　利　要　求　书 2/2 页 3 CN 114422171 A 3