Message Pipe分布式消息顺序消费管道

简单介绍

文章导读：Message Pipe是基于Redis实现的顺序消息管道，由于内部引入了Redisson分布式锁所以它是线程安全的，多线程情况下也会按照写入管道的顺序执行消费。Message Pipe采用Client、Server概念进行设计，内部通过g。

Message Pipe是基于Redis实现的顺序消息管道，由于内部引入了Redisson分布式锁所以它是线程安全的，多线程情况下也会按照写入管道的顺序执行消费。

Message Pipe采用Client、Server概念进行设计，内部通过grpc-netty来建立消息通道相互通信的长连接，消息的分发由Server负责，而每一个管道内的消息在分发时会通过LoadBalance（负载均衡）的方式来获取在线的Client信息并向Client顺序发送消息。

特性：

自动注册

心跳检查

消息分发

顺序消费

读写分离

线程安全

负载均衡

自动剔除