基于Redis实现的分布式消息顺序消费管道。什么是MessagePipe？MessagePipe是基于Redis实现的顺序消息管道，由于内部引入了Redisson分布式锁，所以它是线程安全的，多线程情况下也会按照写入管道的顺序执行消费。MessagePipe采用Client、Server概念进行设计，内部通过grpc-netty来建立消息通道相互通信的长连接，消息的分发由Server负责，而每一个管道内的消息在分发时会通过LoadBalance（负载均衡）的方式来获取在线的Client信息并向Client顺序发送消息。特性自动注册心跳检查消息分发顺序消费读写分离线程安全负载均衡自动剔除声明：本文仅代表作者观点，不代表本站立场。如果侵犯到您的合法权益，请联系我们删除侵权资源！如果遇到资源链接失效，请您通过评论或工单的方式通知管理员。未经允许，不得转载，本站所有资源文章禁止商业使用运营!
下载安装【程序员客栈】APP
实时对接需求、及时收发消息、丰富的开放项目需求、随时随地查看项目状态
2020年08月24日
评论