minbox-message-pipe基于 Redis 的顺序消息管道
基于 Redis
实现的分布式消息顺序消费管道。
什么是Message Pipe?
MessagePipe
是基于 Redis
实现的顺序消息管道,由于内部引入了 Redisson
分布式锁,所以它是线程安全的,多线程情况下也会按照写入管道的顺序执行消费。
MessagePipe
采用 Client
、 Server
概念进行设计,内部通过 grpc-netty
来建立消息通道相互通信的长连接,消息的分发由 Server
负责,而每一个管道内的消息在分发时会通过 LoadBalance(负载均衡)
的方式来获取在线的 Client
信息并向 Client
顺序发送消息。
特性
- 自动注册
- 心跳检查
- 消息分发
- 顺序消费
- 读写分离
- 线程安全
- 负载均衡
- 自动剔除
评论