Untuk mencapai pemesejan RabbitMQ berprestasi tinggi di Java, anda mesti mengoptimumkan konfigurasi pelanggan dan broker. 1. Gunakan sambungan dan penyatuan saluran melalui CachingConnectionFactory dengan kolam saluran cache untuk mengurangkan overhead. 2. Dayakan Penerbit mengesahkan secara asynchronously dan gunakan pengesahan batch atau penjejakan async dengan tag penghantaran untuk penerbitan berkelajuan tinggi yang boleh dipercayai. 3. Kurangkan saiz mesej dengan menggunakan serialisasi yang cekap seperti protobuf dan memampatkan muatan besar dengan GZIP apabila bermanfaat. 4. Tetapkan kiraan prefetch pengguna menggunakan BasicQOS untuk mengimbangi beban dan menghalang pengguna yang perlahan daripada menghalang orang lain. 5. Gunakan pelbagai saluran melalui satu sambungan untuk penerbitan dan tugas memakan yang berasingan untuk mengelakkan penyekatan kepala. 6. Tune RabbitMQ Broker Tetapan dengan menggunakan SSD, memantau panjang giliran, membolehkan beratur malas atau kuorum, dan menggunakan beratur cermin untuk ketersediaan yang tinggi. 7. Melaksanakan pengendalian kegagalan yang mantap dengan logik penyambungan semula, pengguna idempotent, dan pemutus litar untuk mengekalkan daya tahan di bawah beban. Dengan menggabungkan strategi ini, anda boleh mencapai puluhan ribu mesej setiap saat dengan kebolehpercayaan dan kecekapan pada perkakasan sederhana melalui kejuruteraan yang penuh perhatian dan pengoptimuman akhir-ke-akhir.

Apabila membina sistem yang berskala, diedarkan di Java, pemesejan memainkan peranan penting dalam decoupling komponen dan membolehkan komunikasi tak segerak. Rabbitmq, broker mesej sumber terbuka yang diterima pakai, cemerlang dalam ruang ini-terutamanya apabila prestasi dan kebolehpercayaan tidak boleh dirunding. Tetapi mencapai pemesejan berprestasi tinggi dengan RabbitMQ di Java memerlukan lebih daripada sekadar persediaan asas. Ia menuntut konfigurasi pintar, penggunaan protokol AMQP yang cekap, dan kesedaran tentang kesesakan biasa.

Inilah cara untuk mendapatkan yang terbaik daripada Rabbitmq dalam persekitaran Java yang tinggi.

1. Gunakan sambungan dan penyatuan saluran

Sambungan RabbitMQ mahal untuk dicipta - mereka melibatkan rundingan TCP dan rundingan protokol AMQP. Walaupun Connection adalah benang-selamat, objek Channel (digunakan untuk penerbitan dan memakan) tidak. Walau bagaimanapun, mewujudkan saluran baru untuk setiap operasi juga tidak cekap.

? Amalan terbaik:

• Gunakan semula satu Connection di seluruh aplikasi anda.
• Gunakan kolam saluran (misalnya, dengan Apache Commons Pool2) untuk menguruskan contoh Channel yang boleh diguna semula.
• Sebagai alternatif, gunakan rangka kerja seperti AMQP Spring , yang mengendalikan pengumpulan secara automatik melalui CachingConnectionFactory .

 CachingConnectionFactory Factory = New CachingConnectionFactory ("localhost");
kilang.SetchannelCachesize (25);
Factory.SetCachemode (Cachemode.Channel);

Ini mengurangkan overhead dan mengelakkan kebocoran saluran.

2. Dayakan penerbit mengesahkan dan menggunakan penerbitan async

Secara lalai, RabbitMQ tidak mengesahkan penghantaran mesej kepada broker. Dalam senario berprestasi tinggi, anda memerlukan penghantaran yang dijamin tanpa mengorbankan kelajuan.

? Dayakan penerbit mengesahkan:

• Hidupkan publisher-confirms di Rabbitmq.
• Gunakan channel.confirmSelect() dan dengar untuk ConfirmListener Callbacks.

Tetapi menyekat setiap pengesahan membunuh melalui.

? Gunakan pengesahan batch asynchronous:

• Hantar pelbagai mesej, kemudian tunggu untuk mengesahkan dalam kumpulan.
• Atau gunakan pendengar Nack-Aware untuk menerbitkan semula mesej gagal.

 Channel.ConFirmSelect ();
untuk (int i = 0; i <messageCount; i) {
    Channel.BasicPublish (Exchange, RoutingKey, Null, MessageBody);
}
Channel.WaitForConfirmSordie (5_000); // tunggu semua mengesahkan

Untuk prestasi yang lebih baik, tag penghantaran dan pegangan mengesahkan secara asynchronously.

3. Mengoptimumkan saiz mesej dan bersiri

Mesej besar melambatkan pemindahan rangkaian dan meningkatkan tekanan GC di Java.

? Mengurangkan saiz muatan:

• Elakkan menghantar data yang berlebihan.
• Gunakan serialisasi yang cekap (misalnya, Protobuf , Kryo , atau Avro ) dan bukannya format verbose seperti Serialization JSON atau Java.

? Memampatkan mesej besar:

• Memampatkan muatan sebelum menghantar (contohnya, menggunakan GZIP), terutamanya untuk data teks-berat.
• Tetapi keseimbangan kos CPU berbanding penjimatan rangkaian.

Juga, pertimbangkan untuk memisahkan mesej besar - RabbitMQ mempunyai had praktikal (saiz mesej maksimum lalai ~ 128MB, tetapi prestasi merendahkan lebih awal).

4. Gunakan prefetch pengguna untuk mengimbangi beban

Dalam persediaan multi-pengguna, Rabbitmq menggunakan penghantaran bulat-robin secara lalai. Tanpa kawalan aliran, pengeluar cepat dapat mengatasi pengguna yang perlahan.

? Tetapkan kiraan prefetch:

• Hadkan bilangan mesej yang tidak diketahui setiap pengguna menggunakan basicQos(prefetchCount) .

 Channel.Basicqos (50); // Benarkan sehingga 50 mesej Unack'd

Ini membolehkan penghantaran adil dan menghalang pengguna yang perlahan daripada menghalang orang lain.

Bagi pengguna yang tinggi, pasangkan nilai ini berdasarkan kelajuan dan memori pemprosesan.

5. Multiplexing Sambungan Leverage dengan pelbagai saluran

Anda tidak boleh menggunakan saluran tunggal dari pelbagai benang, tetapi anda boleh menggunakan pelbagai saluran melalui satu sambungan.

? Gunakan saluran khusus:

• Satu saluran untuk penerbitan.
• Satu atau lebih untuk memakan.
• Elakkan menyekat operasi pada saluran bersama.

Ini membantu mengelakkan penyekatan kepala dan meningkatkan kesesuaian.

6. Memantau dan menala Rabbitmq dalaman

Malah kod Java terbaik tidak dapat mengatasi broker yang salah.

? Petua Penalaan Rabbitmq Key:

• Jalankan RabbitMQ pada Penyimpanan Cepat (SSD) jika kegigihan digunakan.
• Pantau panjang giliran - beratur panjang meningkatkan penggunaan memori dan pemulihan perlahan.
• Gunakan beratur malas untuk jumlah mesej yang tinggi dengan akses yang jarang berlaku.
• Dayakan beratur cermin (atau gunakan beratur kuorum) untuk HA tanpa mengorbankan terlalu banyak prestasi.

Gunakan rabbitmqctl atau plugin pengurusan untuk memantau kadar mesej, kadar pengguna, dan tekanan belakang.

7. Mengendalikan kegagalan dengan anggun

Prestasi tinggi tidak bermakna jika sistem anda pecah di bawah beban.

? Melaksanakan:

• Logik penyambungan semula dengan backoff eksponen.
• Pengguna idempotent (dalam hal pengubahsuaian).
• Pemutus litar untuk perkhidmatan hiliran.

Gunakan pelanggan yang mantap seperti Pika (Python) atau perpustakaan Java yang diuji dengan baik seperti RabbitMQ Java Client atau Spring AMQP .

Pemikiran terakhir

Pemesejan berprestasi tinggi dengan RabbitMQ di Java bukan mengenai kelajuan mentah sahaja-ia mengenai kecekapan, daya tahan, dan penggunaan sumber pintar . Dengan menggabungkan penyatuan pelanggan yang betul, Async mengesahkan, pengoptimuman mesej, dan penalaan broker, anda boleh mencapai throughput dalam puluhan ribu mesej sesaat, walaupun pada perkakasan sederhana.

Ia bukan sihir - hanya kejuruteraan yang penuh perhatian.

Pada asasnya, jangan merawat Rabbitmq sebagai kotak hitam. Memahami aliran dari aplikasi Java kepada broker kepada pengguna, dan mengoptimumkan setiap hop.

Atas ialah kandungan terperinci Pemesejan Java berprestasi tinggi dengan Rabbitmq. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!