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

基于 Redis實(shí)現(xiàn)的分布式消息順序消費(fèi)管道。

什么是Message Pipe？

MessagePipe是基于 Redis實(shí)現(xiàn)的順序消息管道，由于內(nèi)部引入了 Redisson分布式鎖，所以它是線(xiàn)程安全的，多線(xiàn)程情況下也會(huì)按照寫(xiě)入管道的順序執(zhí)行消費(fèi)。

MessagePipe采用 Client、 Server概念進(jìn)行設(shè)計(jì)，內(nèi)部通過(guò) grpc-netty來(lái)建立消息通道相互通信的長(zhǎng)連接，消息的分發(fā)由 Server負(fù)責(zé)，而每一個(gè)管道內(nèi)的消息在分發(fā)時(shí)會(huì)通過(guò) LoadBalance（負(fù)載均衡）的方式來(lái)獲取在線(xiàn)的 Client信息并向 Client順序發(fā)送消息。

特性

• 自動(dòng)注冊(cè)
• 心跳檢查
• 消息分發(fā)
• 順序消費(fèi)
• 讀寫(xiě)分離
• 線(xiàn)程安全
• 負(fù)載均衡
• 自動(dòng)剔除