一种数据处理系统消息订阅发布装置

    公开(公告)号:CN116260893B

    公开(公告)日:2023-09-12

    申请号:CN202310068318.2

    申请日:2023-02-06

    IPC分类号: H04L69/16 H04L67/01 H04L67/56

    摘要: 本发明公开了一种数据处理系统消息订阅发布装置,数据处理系统包括多个节点,每个节点上运行至少一个数据处理服务,包括至少一个节点上设置消息代理模块,每个所述数据处理服务均设置消息订阅模块和消息发布模块,消息订阅模块,通过IPC方式或TCP方式订阅消息;消息发布模块通过IPC或TCP方式发布;消息代理模块,通过TCP方式订阅其它节点发布的消息并将其通过IPC方式发布;通过IPC方式订阅本节点发布的消息并将其通过TCP和IPC方式发布。本发明设计合理,采用TCP和IPC方式进行订阅发布,减小了系统内部通过TCP网络传输的数据量,提高了通信效率。

    一种集群网络动态配置方法、装置和系统

    公开(公告)号:CN115714722A

    公开(公告)日:2023-02-24

    申请号:CN202211609585.8

    申请日:2022-12-15

    摘要: 本发明公开了一种集群网络动态配置方法,所述集群包括N个数据处理服务的节点,对外提供数据处理服务的节点数为M,且M小于N,只有对外提供数据处理服务的节点配置对外服务网络,在任一个节点上进行网络动态配置,包括以下步骤:初始化服务状态及网络;其中,所述服务为依赖于外部网络的数据处理服务,所述服务的状态内容包括键和值,键和值存储于内存数据库中,键是唯一标识,值包括时间戳、节点标识;更新服务状态;服务异常管理。本发明方法步骤简单,能实现对同一网络配置多个地址,在集群中配置多个网络的多组地址。