-
公开(公告)号:CN116260893B
公开(公告)日:2023-09-12
申请号:CN202310068318.2
申请日:2023-02-06
申请人: 中国西安卫星测控中心
摘要: 本发明公开了一种数据处理系统消息订阅发布装置,数据处理系统包括多个节点,每个节点上运行至少一个数据处理服务,包括至少一个节点上设置消息代理模块,每个所述数据处理服务均设置消息订阅模块和消息发布模块,消息订阅模块,通过IPC方式或TCP方式订阅消息;消息发布模块通过IPC或TCP方式发布;消息代理模块,通过TCP方式订阅其它节点发布的消息并将其通过IPC方式发布;通过IPC方式订阅本节点发布的消息并将其通过TCP和IPC方式发布。本发明设计合理,采用TCP和IPC方式进行订阅发布,减小了系统内部通过TCP网络传输的数据量,提高了通信效率。
-
公开(公告)号:CN115878696A
公开(公告)日:2023-03-31
申请号:CN202310201739.8
申请日:2023-03-06
申请人: 中国西安卫星测控中心
IPC分类号: G06F16/2458 , G06F16/23 , G06F16/2455
摘要: 本发明公开了一种分布式数据处理集群高可用方法和装置,包括:多个数据处理子单元共用的分布式锁控制器在发起抢锁的时,不断查询分布式缓存中是否存在多个数据处理子单元的第一锁信息,若存在,则读取分布式缓存中的第一锁信息并判断第一锁信息的节点标识是否一致,若一致且处理标志为处理,则创建第二锁信息并将服务状态控制器的数据处理状态设置为活跃,第二锁信息为利用最新的更新时间戳和通用唯一标识码更新后的第一锁信息,将第二锁信息存储,并将数据处理状态为活跃的一个数据处理子单元,或者一个数据处理服务单元,或者一个节点作为主状态对数据进行处理。该方法可以解决集群时间不连续情况下分布式锁的可用性问题。
-
公开(公告)号:CN115617917A
公开(公告)日:2023-01-17
申请号:CN202211618872.5
申请日:2022-12-16
申请人: 中国西安卫星测控中心
IPC分类号: G06F16/27 , H04L67/10 , H04L67/568
摘要: 本发明公开了一种数据库集群多活控制方法,包括以下步骤:一、获取集群中所有节点的数据库状态;二、判断所有节点的状态;三、异常节点的处理;四、对正常服务节点进行数据库集群分裂性判断与处理;五、根据集群状态和节点状态对经过分裂性判断与处理后的正常服务节点进行控制。本发明方法步骤简单,根据集群状态和节点状态控制节点数据库过程中,以启动集群的方式和加入集群的方式解决了数据库在节点上的自动启动、重启、恢复问题。
-
公开(公告)号:CN116861161A
公开(公告)日:2023-10-10
申请号:CN202311137955.7
申请日:2023-09-05
申请人: 中国西安卫星测控中心
IPC分类号: G06F17/18 , G06F18/213 , G06F18/243
摘要: 本发明公开了一种基于多叉树结构的航天测量数据实时统计方法,包括:一、采用航天测量网获取航天测量数据;二、航天测量数据进行规范性检测得到待统计航天测量数据;三、待统计航天测量数据中特征信息的设定;四、对待统计航天测量数据进行统计。本发明方法步骤简单、设计合理,通过多个从进程对待统计航天测量数据中的每一帧数据进行一次遍历统计,然后通过主进程在一次统计的基础上进行二次统计,从而适应航天测量数据特征点种类多,数据量大的情况,且能针对不同的感兴趣维度,提取感兴趣的有效信息,极大的提高了数据中有效信息的利用率。
-
公开(公告)号:CN116260893A
公开(公告)日:2023-06-13
申请号:CN202310068318.2
申请日:2023-02-06
申请人: 中国西安卫星测控中心
摘要: 本发明公开了一种数据处理系统消息订阅发布装置,数据处理系统包括多个节点,每个节点上运行至少一个数据处理服务,包括至少一个节点上设置消息代理模块,每个所述数据处理服务均设置消息订阅模块和消息发布模块,消息订阅模块,通过IPC方式或TCP方式订阅消息;消息发布模块通过IPC或TCP方式发布;消息代理模块,通过TCP方式订阅其它节点发布的消息并将其通过IPC方式发布;通过IPC方式订阅本节点发布的消息并将其通过TCP和IPC方式发布。本发明设计合理,采用TCP和IPC方式进行订阅发布,减小了系统内部通过TCP网络传输的数据量,提高了通信效率。
-
公开(公告)号:CN115878696B
公开(公告)日:2023-04-28
申请号:CN202310201739.8
申请日:2023-03-06
申请人: 中国西安卫星测控中心
IPC分类号: G06F16/2458 , G06F16/23 , G06F16/2455
摘要: 本发明公开了一种分布式数据处理集群高可用方法和装置,包括:多个数据处理子单元共用的分布式锁控制器在发起抢锁的时,不断查询分布式缓存中是否存在多个数据处理子单元的第一锁信息,若存在,则读取分布式缓存中的第一锁信息并判断第一锁信息的节点标识是否一致,若一致且处理标志为处理,则创建第二锁信息并将服务状态控制器的数据处理状态设置为活跃,第二锁信息为利用最新的更新时间戳和通用唯一标识码更新后的第一锁信息,将第二锁信息存储,并将数据处理状态为活跃的一个数据处理子单元,或者一个数据处理服务单元,或者一个节点作为主状态对数据进行处理。该方法可以解决集群时间不连续情况下分布式锁的可用性问题。
-
公开(公告)号:CN115952204A
公开(公告)日:2023-04-11
申请号:CN202310241086.6
申请日:2023-03-14
申请人: 中国西安卫星测控中心
IPC分类号: G06F16/2455 , G06F16/13 , G06F16/22 , G06F16/28
摘要: 本发明提出了一种缓存式SQLite读取方法,包括写缓存方法和读缓存方法,写缓存方法为:读取SQLite所有数据表表名,将其插入到内存数据库Redis列表Ⅰ中,定义列表Ⅰ的key为SQLite文件的数据库名;将每一张数据表的每一行的主键序列化字符串后插入到内存数据库Redis的列表Ⅱ中,定义列表Ⅱ的key为数据库名和表名的拼接;将每一张表的每一行内容均序列化后写入到内存数据库Redis中;读缓存方法为:读取所有主键序列化字符串;读取所有行内容。本发明将SQLite数据表内容写入到内存数据库Redis中,读取数据通过读取内存数据库Redis中缓存内容实现,读写分离,实现了在分布式环境下读取SQLite。
-
公开(公告)号:CN113961349B
公开(公告)日:2022-09-06
申请号:CN202111260776.3
申请日:2021-10-28
申请人: 中国西安卫星测控中心
摘要: 本发明公开的一种QPID集群控制方法,包括获取本节点QPID服务状态;获取Master节点状态;根据本节点角色和Master状态进行角色处理。本发明还公开了执行上述QPID集群控制方法的系统。本发明公开的一种QPID集群控制方法及系统,解决了现有QPID集群方案适用性不强的问题。
-
公开(公告)号:CN109683873B
公开(公告)日:2021-10-08
申请号:CN201811366628.8
申请日:2018-11-16
申请人: 中国西安卫星测控中心
摘要: 本发明公开了一种利用ASN1规则的航天信息接口编码方法,使用接口定义语言IDL定义逻辑一致的接口,使用traits技术生成应用层接口Interface与ASN库结构Struct之间的转换模块代码集TRAITS;当程序应用层的信息接口需要进行编解码处理时,将应用层传递的接口实例转化为配套的应用结构实例;ASN BER转换模块按照BER规则将struct转换为相应二进制流stream,并将之传递给传输层,本发明通过进行“接口‑结构‑二进制流”3级映射的航天测控信息接口编解码解决方案,解决了现有技术中存在的航天测控领域无法适应对面向对象编程范式中接口Interface元素的有效解读的问题。
-
公开(公告)号:CN117194731B
公开(公告)日:2024-01-26
申请号:CN202311461963.7
申请日:2023-11-06
申请人: 中国西安卫星测控中心
IPC分类号: G06F16/901 , G06Q10/0631
摘要: 本发明公开了一种基于有向带环图的测控流程自动化调度方法,包括以下步骤:一、采用计算机基于n个测控事件的执行顺序和约束关系形成测控流程有向带环图;二、采用计算机在测控流程有向带环图中增加初始节点和结束节点;三、采用计算机基于触发函数对测控流程有向带环图中的n个测控事件进行自动化调度。本发明方法步骤简单、设计合理,实现了对具有多个测控事件、各个测控事件之间具有明确的执行顺序和约束关系的测控流程的自动化调度,解决了计划工作模式难以支持复杂的测控流程调度的问题。
-
-
-
-
-
-
-
-
-