Message Transmission Method Based on Star Topology Architecture

Abstract

The invention discloses a star topology framework-based message transmission method. The method comprises the following steps of: 1) setting a source and a destination of message transfer; 2) constructing and configuring a middleware module between a center node and non-center nodes according to the quantity of the non-center nodes, wherein the middleware module is sued for pulling synchronous data from a source node and transmitting the synchronous data to an objective node according to appointed transmission direction; 3) starting each middleware sub-module, and determining the non-center nodes with data synchronization requirement according to configured content in the step 2); 4) obtaining messages in a consumer message queue, namely, a second message queue, by a message pull sub-module of the middleware module; 5) comparing a message offset of the second message queue and a message offset of a first message queue; 6) submitting the message offset of the consumer message queue to a producer by the middleware module through the center node; and 7) combing a message offset of an own queue and the message offset of the consumer message queue by the producer, and transmitting newly added data to the center node.

Description

technical field [0001] The invention belongs to the field of data transmission in software technology, and in particular relates to a message transmission method based on star topology architecture. Background technique [0002] Nowadays, more and more enterprises choose to build distributed systems due to the prominent advantages of distributed environment, but they undoubtedly also face data management problems caused by data integration and system integration, especially distributed data call has attracted much attention; subsequently, Distributed object invocation technologies, such as RPC middleware technologies such as ORBA, DCOM, and RMI, emerged as the times require. RPC refers to middleware based on Remote Procedure Call (RPC), which allows procedures in one application to call procedures in a remote application as if they were local calls. This middleware implements a chaining mechanism that looks up remote procedures and enables callers to use these procedures in...

AI Technical Summary

Problems solved by technology

Communication between any two nodes in the star network must be controlled by the central node, which is highly dependent on the central node

Images