minbox-message-pipe基于 Redis 的顺序消息管道

基于 Redis实现的分布式消息顺序消费管道。

什么是Message Pipe？

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

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

特性

• 自动注册
• 心跳检查
• 消息分发
• 顺序消费
• 读写分离
• 线程安全
• 负载均衡
• 自动剔除