message-pipe v1.0.1 發布,支持 Nacos 服務發現

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

• [ #39 ] Client通過 "Cglib動態代理" 的方式實現動態綁定管道
• [ #40 ] Client/Server 通過正則表達式進行匹配 "pipeName"
• [ #41 ] 禁用Server接收註冊請求後根據每一個"Pipe Name"創建消息管道
• [ #47 ] 使用Jackson代替fastjson轉換實體與json字符串之間的相互轉換方式
• [ #51 ] MessageProcessor新增正則表達式方式處理消息，並為每個匹配的表達式管道建立一個Porxy代理類
• [ #59 ] Server啟動時自動加載Redis內的消息管道列表，並自動創建MessagePipe實例
• [ #64 ] 重構Client連接Server的實現方式，新增支持Nacos NamingService方式

🐛 Fix Bugs

• [ #45 ] 修復Client啟動時一直重試註冊到Server，導致阻塞主線程
• [ #48 ] 刪除客戶端ReceiveMessageService處理消息時使用線程池
• [ #53 ] 修復Redisson在高並發下出現的解鎖異常
• [ #55 ] 修復獲取MessageProcessors實例時可能出現線程安全性問題
• [ #57 ] 消息分發時，只有存在客戶端列表才進行處理消息發送邏輯
• [ #61 ] Server運行過程中CPU飆升
• [ #65 ] Client註冊時偶爾會出現獲取IP位址為 "127.0.0.1"的情況

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"的後臺運行容器，埠號映射宿主機6379docker 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開源許可進行編寫。