装订课题二6发明专利

1、(19)(12)发明专利申请(10)申请公布号 CN 104683445(43)申请公布日 2015.06.03A(21)申请号201510038575.7(22)申请日2015.01.26(71)申请人邮电大学地址 100876市海淀区西土城路 10 号(72)发明人(74)专利机构聿宏知识产权公司 11372有限人红(51).Cl.H04L 29/08(2006.01)权利要求书2页说明书10页附图11页(54) 发明名称分布式实时数据融合系统(57) 摘要本发明公开了一种分布式实时数据融合系统，其包括决策信息分发模块以及依次运行在Storm 引擎的五个工作节点上的模块、预处理模块、对准模

2、块、状态估计模块和威胁估计模块。本发明采用 Storm 实时流式计算引擎作为系统的基础设施，使模块、预处理模块、对准模块、状态估计模块和威胁估计模块分别运行在 Storm 集群环境中的五个工作节点上，能够充分利用 Storm 分布式集群的高性能并行处理能力，大大提高了分布式实时数据融合系统的数据实时处理能力、容错性和稳定性，增强了分布式实时数据融合系统的并发性和扩展性，克服了传统的集中式数据融合系统存在的在并发性和扩展性上将受到限制的技术缺陷。CN 104683445 A权利要求书CN 104683445 A1/2 页1.一种分布式实时数据融合系统，其特征在于，包括 ：模块，设置为获取并多个数

3、据源发送的感知数据预 对准间片上 ；状态估计 方程，并根据更新威胁估计模块及决策信息分发模块 依次运行在 Storm 引态估计模块和威胁估计模块均 2.根据权利要求 1 所述的包括 ：；以块、状模块据 ；格式化单元，设置为对各个数据源 去冗余单元，设置为删除各个数据源各个数据源对应的3.根据权利要求 2 所述的分布式实时数据还包括与所述去冗余单元电连接的日志生成单元源对应的余数据，得到模块成单元设置为利用各个数据的运行日志提交给日志单元。根据权利要求 1 所述的分布式实时数据融合系括： 第一接收单元，设置为接收所述数据 ；第一缓存单元，设置为依次对每个数据源，将所述数据源对入相应的预处理缓存队

4、列中 ；第一判断单元，设置为判断所述预处理缓存队列中的于或者等于预设的第一数据个数 ；滤波单元，设置为在所述预处理缓存队列里的第一数据个数时，从所述预处理缓存队列里取出从当前时刻起的第一数据个感知数据，并将取出的所述数据源对应的滤波后的感知数据。根据权利要求 4 所述的分布式实时数据融合系统，其特征在于包括与所述滤波单元电连接的优化单元 ；所述优化单元，设置为依次对每个数据源，利用所替换所述数据源对应的预处理缓存队列里的知存否大者等于后的到块还据6.根据权利要求 1 所述的分布式实时数据融合系统，其特征在于，所述对准模块包括 ：第二接收单元，设置为接收所述预处理模块发送的各个数据源对应的滤波后

5、的感知数22权利要求书CN 104683445 A2/2 页据； 第二缓存单元，设置为依次对每个数据源，将所述数据源对应的滤波后的感知数据存入相应的对准缓存队列中 ；第二判断单元，设置为判断各个数据源对应的对准缓存队列中的滤波后的感知数据的个数是否均大于或者等于预设的第二数据个数 ；对准单元，设置为在各个数据源对应的对准缓存队列中的滤波后的感知数据的个数均大于或者等于第二数据个数时，依次从各个数据源对应的对准缓存队列里取出从当前时刻起的第二数据个数的滤波后的感知数据，并将取出的滤波后的感知数据装载进对准算法执行器中进行分析和计算，得到各个数据源对应的对准后的感知数据。根据权利要求 1 所述的分

6、布式实时数据融合系统，其特征在于，所述状态估计模块包括 ：第三接收单元，设置为接收所述对准模块发送的各个数据源对应的对准后的感知数据； 第三缓存单元，设置为依次对每个数据源，将所述数据源对应的对准后的感知数据存入相应的状态估计缓存队列中 ；第三判断单元，设置为判断所述状态估计缓存队列里的对准后的感知数据的个数是否大于或者等于预设的第三数据个数 ；状态估计单元，设置为在所述状态估计缓存队列里的对准后的感知数据的个数大于或者等于第三数据个数时，从所述状态估计缓存队列里取出从当前时刻起的第三数据个数的对准后的感知数据，并将取出的对准后的感知数据装载进状态估计算法执行器中进行分析和计算，得到所述目标特

7、征数据。根据权利要求 1 所述的分布式实时数据融合系统，其特征在于，所述威胁估计模块包括 ：第四接收单元，设置为接收所述状态估计模块发送的目标特征数据 ；策略执行单元，设置为根据所述目标特征数据从评估策略集中选择威胁评估策略 ； 决策信息生成单元，设置为根据所述目标特征数据和所述威胁评估策略，生成决策信息。根据权利要求 1 所述的分布式实时数据融合系统，其特征在于，所述决策信息分发模块包括 ：第一连接构建单元，设置为构建集成在威胁估计模块中的发布者客户端与决策信息分发单元之间的第一连接 ；第二连接构建单元，设置为构建集成在决策信息分发模块中的订阅者客户端与服务器之间的第二连接 ；创建单元，设置

8、为在决策信息分布模块中创建；决策信息分布单元，设置为通过所述第一连接接收所述威胁估计模块发送的决策信息且使所述决策信息与一个阅的相关联，并通过所述第二连接将与订阅用户对应的服务器订10.根据权利要求 1 至 9 中任数据源为传感器合系统，其特征在于，所述33说明书CN 104683445 A1/10 页分布式实时数据融合系统技术领域0001本发明涉及计算机技术领域，尤其涉及一种分布式实时数据融合系统。背景技术0002 随着传感器技术及其相关技术的不断发展，传感器技术的应用场景不断丰富，工业、农业、军事等领域都在大量地使用传感器来感知环境中的各种参数。多传感器数据融合技术是一门集多种学科于一体的

9、前沿技术，已经广泛应用于战场监视、自动目标识别、工业过程控制、机器人、遥感、医疗等领域。多传感器数据融合技术经过多年的已经取得了丰硕的进步也为多传感器数据融与发展0003在民用领域，传感器技及时地反馈生产过程状态或发出感器的应用更为重要，通过部署大量传感器弥方面的短板，对现代国防工业的发展具有重要的意义。一种类传感器提供的感知或观测数据已经远远可以生产设备的各项指标并持久性等的实际应用中，只采用单日益增长的需求用多种类型传感器的感知或观测数据综合计算与分析，得到目标或场中，实时处理技术在多传感器数据融合系统中的作用和地位越来越重要，应泛。随着系统结构越来越复杂，数据规模越来越大，随着系统结构越

10、来越 来越大，需要一种实时数据处理策略来维持系统的稳定运行，确保的计算。其越来越广规模越发明内容0004本发明所要解决的技术问题是 ：随着传感器类型的增加、传感器部署区域的扩大，多传感器数据融合技术的应用场景也越来越多，加上现代数据融合的算法更加复杂，新型传感器感知数据的结构更加多样，多传感器数据融合系统在并发性和扩展性上将逐渐受到限制，传统的集中式数据融合系统着严峻的性能考验。0005为了解决上述技术问题，本发明提供了一种基于 Storm 引擎的分布式实时数据融合系统，充分利用了 Storm 引擎分布式集群的高性能并行处理能力。0006本发明的技术方案为 ：0007一种分布式实时数据融合系统，包括 ：模块，设置为获取并多个数据源发送的感知