メッセージ パイプ分散メッセージ順次消費パイプライン v1.0.6

メッセージ パイプは、Redis に基づいて実装されたシーケンシャル メッセージ パイプラインです。Redisson 分散ロックが内部的に導入されているため、マルチスレッド状況では、消費もパイプラインに書き込まれた順序で実行されます。

メッセージ パイプは、クライアントとサーバーの概念を使用して設計されています。内部的には、メッセージ チャネルが相互に通信するための長い接続を確立するために grpc-netty が使用され、サーバーはメッセージの配布を担当し、各パイプライン内のメッセージが配布されます。 LoadBalance (負荷分散) を介してオンラインのクライアント情報を取得し、クライアントにメッセージを順次送信する方法。

特性

自動登録

心拍確認

メッセージ配信

逐次消費

読み取りと書き込みの分離

スレッドの安全性

負荷分散

自動カリング