您现在的位置是:首页 > 文章详情

minbox 开源组织下的新成员 message-pipe 初版发布

日期:2020-08-25点击:726

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采用ClientServer概念进行设计,内部通过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开源许可进行编写。

原文链接:https://www.oschina.net/news/118153/minbox-message-pipe-released
关注公众号

低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。

持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。

转载内容版权归作者及来源网站所有,本站原创内容转载请注明来源。

文章评论

共有0条评论来说两句吧...

文章二维码

扫描即可查看该文章

点击排行

推荐阅读

最新文章