公开(公告)号：CN115061814A

公开(公告)日：2022-09-16

申请号：CN202210669827.6

申请日：2022-06-14

Applicant: 北京恒泰实达科技股份有限公司

Inventor： 钱苏晋 ,  熊江舟 ,  吴志勇 ,  饶涛 ,  邓亮戈

IPC: G06F9/50 ,  G06F9/54

Abstract: 本发明公开了一种基于去中心化作业任务的分布式高并发调度系统，包括，分布式消息队列；节点；节点包括调度器和执行器；内存数据库；用于作为缓存使用；节点发送数据至指定的分布式消息队列中，供其他节点消费，进而实现与其他节点的数据交互通信；对于发送的重要数据，自动保存在内存数据库中，以便提高数据持久化效率。优点是：实现调度器的可水平扩展，实现其分布式功能，保证每一个调度器都在执行调度任务，所有节点中有且仅有一个调度器节点在工作；尽最大可能的利用服务器提升性能。

公开(公告)号：CN115665281A

公开(公告)日：2023-01-31

申请号：CN202211339931.5

申请日：2022-10-27

Applicant: 北京恒泰实达科技股份有限公司

Inventor： 钱苏晋 ,  吴琼 ,  熊江舟 ,  吴志勇 ,  邓亮戈

IPC: H04L69/16 ,  H04L69/22 ,  H04L43/10 ,  H04L47/20

Abstract: 本发明公开了一种基于MQTT集群广播数据的系统，包括，网络通讯层：提供IP协议的TCP/UDP、串口通讯的RS232/485支持以及无线的ZIGBEE支持；基础组件层：包括引导程序模块、终端管理模块、权限认证模块、数据桥模块、路由规则模块、路由管理模块；数据处理层：包括数据桥接模块、数据路由模块、协议解析模块、消息处理模块、配置管理模块、运行监测模块、边缘计算模块、终端联动模块；数据持久层：包括消息队列模块、ODS数仓、客户端订阅模块。优点是：对MQTT集群改进，在MQTT集群中间采用了无状态集群模式，大大提高了维护性能和线性扩展；该集群模式提供了满足数千万级的设备接入和每秒近千万级消息的处理能力，各终端之间能够实现数据的相互订阅。