公开(公告)号：CN118113424A

公开(公告)日：2024-05-31

申请号：CN202311844662.2

申请日：2023-12-28

Applicant: 中国兵器工业计算机应用技术研究所

Inventor： 彭龙 ,  孟英谦 ,  李胜昌 ,  杜宏博 ,  鲁东民 ,  徐天敕 ,  米丽媛 ,  刘晓兰 ,  饶雷 ,  薛行 ,  郭亚辉 ,  张敏 ,  随秋林

IPC: G06F9/46 ,  G06F9/48 ,  G06F9/50

Abstract: 本发明涉及一种分布式流计算引擎，包括：控制节点模块，计算节点模块和Zookeeper集群模块；计算节点模块包括多个物理计算节点，用于监测和执行对应的流计算任务；Zookeeper集群模块部署在多个服务器上，用于存储多个物理计算节点的所有状态信息和任务信息，以供计算节点模块和控制节点模块进行实时监控调用；控制节点模块用于基于流处理任务生成有向无环图；并将待执行的任务按照有向无环图中的对应关系下发到对应的物理计算节点进行处理，并基于每个物理计算节点的资源信息进行任务调度，以实现流数据的低延时处理。本发明解决了现有技术中的流数据处理由于硬件资源受限导致数据处理瓶颈，进而引起数据处理延迟的问题。

公开(公告)号：CN115586869A

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

申请号：CN202211193073.8

申请日：2022-09-28

Applicant: 中国兵器工业计算机应用技术研究所

Inventor： 孟英谦 ,  彭龙 ,  鲁东民 ,  李胜昌 ,  杜宏博 ,  曾帅 ,  印泰桦 ,  米丽媛 ,  郭亚辉 ,  饶雷 ,  许童 ,  王强 ,  徐天敕 ,  梁冬 ,  薛行 ,  崔琳

IPC: G06F3/06

Abstract: 本发明涉及一种自组网系统及自组网系统的流数据处理方法，属于数据处理技术领域；解决现有技术中的自组网系统硬件存储成本高，且现有的流数据处理方法处理速度慢的问题；本发明的系统包括至少一种数据采集设备、客户端和服务器；其中，至少一种数据采集设备用于采集得到流数据，并通过无线链路向服务器发送写数据请求；客户端用于向服务器发送读数据请求；服务器包括存储器和处理器；处理器用于在接收到写数据请求时将接收到的流数据按照冷数据和热数据在存储器中分别进行存储，并在接收到读数据请求时，按预设的流程读取存储器中存储的数据到客户端；冷数据和热数据通过预设时间内对存储器中存储的数据的读写频率统计得到。

公开(公告)号：CN117828165A

公开(公告)日：2024-04-05

申请号：CN202311842554.1

申请日：2023-12-28

Applicant: 中国兵器工业计算机应用技术研究所

Inventor： 李旭光 ,  彭龙 ,  邵鹏志 ,  鲁东民 ,  杜宏博 ,  薛行 ,  饶雷 ,  郭亚辉 ,  张敏 ,  王静阳 ,  邬书豪 ,  宋伟梁 ,  李晓政

IPC: G06F16/9532 ,  G06F16/332 ,  G06F16/31 ,  G06F16/182 ,  G06F9/50

Abstract: 本发明涉及一种分布式搜索计算引擎，包括：包括索引存储管理模块和搜索计算模块，其中：索引存储管理模块用于基于文档数据创建索引，将索引分为多个索引分片分散存储在多个物理分片上，物理分片上还存储有该索引分片对应的文档数据；物理分片的数量基于搜索集群各物理节点的性能和索引的数据量计算得到；搜索计算模块用于基于客户端输入的搜索关键词，通过查询操作在各个索引分片中进行关键词匹配及匹配度计算，得到多个匹配文档的文档ID；并通过取值操作，基于文档ID和路由公式，从对应的物理分片中获取得到匹配文档。本发明解决了现有技术中的搜索计算引擎没有考虑集群节点的性能和索引数据量，导致索引性能和集群性能受限的问题。