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

联合创作 · 2023-10-01 07:21

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

什么是Message Pipe?

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

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

特性

  • 自动注册
  • 心跳检查
  • 消息分发
  • 顺序消费
  • 读写分离
  • 线程安全
  • 负载均衡
  • 自动剔除
浏览 3
点赞
评论
收藏
分享

手机扫一扫分享

编辑 分享
举报
评论
图片
表情
推荐
点赞
评论
收藏
分享

手机扫一扫分享

编辑 分享
举报