Message Pipe

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

GitHub地址：https://github.com/minbox-projects/message-pipe

Gitee地址：https://gitee.com/minbox-projects/message-pipe

I. 什么是Message Pipe？

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

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

II. 更新日志

✨ New Features

• [ #1 ] Server分发消息到Client
• [ #2 ] Server分发消息时支持LoadBalance随机权重策略
• [ #15 ] 支持Client定时向Server发送心跳
• [ #18 ] 每个管道实现独立分发消息
• [ #24 ] 设置 “分发消息时从通道获取消息的Lock时间"
• [ #26 ] 使用 "minbox-sequence" 来生成RequestID
• [ #31 ] Server重启后Client实现自动重连

🐛 Fix Bugs

• [ #20 ] 解决InetAddress偶尔获取的HostAddress不一致的问题
• [ #29 ] 消息分发时检查Redisson Client连接是否已经关闭
• [ #33 ] Server启动后，如果没有注册的Client会一直抛出异常信息
• [ #35 ] Server发送消息到Client时，如果发生Client状态不可用“UNAVAILABLE”则自动剔除本地缓存Client的Channel
• [#37 ] Server分发消息时选择指定管道上绑定的Client列表，排除OFF_LINE状态的Client

III. 特性

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

IIII. 快速上手

为了快速上手，提供了message-pipe使用的示例项目，项目源码：https://github.com/minbox-projects/message-pipe-example。

4.1 安装Redis

由于message-pipe基于Redis实现，所以我们首先需要在本机安装Redis，下面是使用Docker方式安装步骤：

# 拉取Redis镜像
docker pull redis
# 创建一个名为"redis"的后台运行容器，端口号映射宿主机6379
docker run --name redis -d -p 6379:6379 redis

4.2 查看Redis数据

# 运行容器内命令
docker exec -it redis /bin/sh
# 运行Redis客户端
redis-cli
# 选择索引为1的数据库
select 1
# 查看全部的数据
keys *

4.3 启动示例项目

# 下载源码
git clone https://github.com/minbox-projects/message-pipe-example.git
# 进入项目目录
cd message-pipe-example
# 运行项目
mvn spring-boot:run

V. License

message-pipe采用Apache2开源许可进行编写。