Pipa Pesan mendistribusikan pipa konsumsi sekuensial pesan v1.0.6

Pipa Pesan adalah alur pesan berurutan yang diimplementasikan berdasarkan Redis. Karena kunci terdistribusi Redisson diperkenalkan secara internal, maka aman untuk thread dalam situasi multi-utas, konsumsi juga akan dilakukan sesuai urutan yang ditulis ke dalam alur.

Pipa Pesan dirancang menggunakan konsep Klien dan Server. Secara internal, grpc-netty digunakan untuk membuat koneksi panjang bagi saluran pesan untuk berkomunikasi satu sama lain. Server bertanggung jawab atas distribusi pesan, dan pesan di setiap pipa didistribusikan melalui LoadBalance (loadbalancing). Metode untuk memperoleh informasi Klien secara online dan mengirimkan pesan ke Klien secara berurutan.

ciri

Pendaftaran otomatis

pemeriksaan detak jantung

distribusi pesan

Konsumsi berurutan

Membaca dan menulis pemisahan

Keamanan benang

penyeimbangan beban

Pemusnahan otomatis