Message Pipe distributed message sequential consumption pipeline v1.0.6

Message Pipe is a sequential message pipeline implemented based on Redis. Since the Redisson distributed lock is introduced internally, it is thread-safe. In multi-threaded situations, consumption will also be performed in the order written into the pipeline.

Message Pipe is designed using the concepts of Client and Server. Internally, grpc-netty is used to establish long connections for message channels to communicate with each other. The Server is responsible for the distribution of messages, and the messages in each pipeline are distributed through LoadBalance (load balancing). Method to obtain online Client information and send messages to the Client sequentially.

characteristic

Automatic registration

heartbeat check

message distribution

Sequential consumption

Read and write separation

Thread safety

load balancing

Automatic culling