基于星型拓扑架构的消息传输方法

基于星型拓扑架构的消息传输方法，1)设置消息传递的源头和目的；2)按照非中心节点的数目，构建并配置中心节点和非中心节点之间的中间件模块，用于实现从源节点拉取同步数据，并按照指定传输方向发送同步数据至目标节点；3)启动各个中间件子模块，按照2)中的配置内容，明确有数据同步需求的非中心节点；4)中间件模块的消息拉取子模块实时获取消费者消息队列即第二消息队列中的消息；5)通过比对第二消息队列的消息偏移量和第一消息队列的消息偏移量，6)中间件模块将消费者消息队列的消息偏移量经由中心节点，提交至生产者；7)生产者结合自身队列的消息偏移量和消费者消息队列的消息偏移量，并将新增数据传送至中心节点。