Message Pipe分散式訊息順序消費管道v1.0.6
1.0.6
Message Pipe是基於Redis實現的順序訊息管道,由於內部引入了Redisson分散式鎖所以它是線程安全的,多執行緒情況下也會按照寫入管道的順序執行消費。
Message Pipe採用Client、Server概念進行設計,內部透過grpc-netty來建立訊息通道相互通訊的長連接,訊息的分發由Server負責,而每個管道內的訊息在分發時會透過LoadBalance(負載平衡)的方式來取得線上的Client資訊並向Client順序發送訊息。
特性
自動註冊
心跳檢查
訊息分發
順序消費
讀寫分離
線程安全
負載平衡
自動剔除