基于Redis实现的分布式消息顺序消费管道。
什么是MessagePipe？MessagePipe是基于Redis实现的顺序消息管道，由于内部引入了Redisso分布式锁，所以它是线程安全的，多线程情况下也会按照写入管道的顺序执行消费。MessagePipe采用Cliet、Server概念进行设计，内部通过grpc-etty来建立消息通道相互通信的长连接，消息的分发由Server负责，而每一个管道内的消息在分发时会通过LoadBalace（负载均衡）的方式来获取在线的Cliet信息并向Cliet顺序发送消息。特性自动注册心跳检查消息分发顺序消费读写分离线程安全负载均衡自动剔除
点击空白处退出提示
评论