ApsaraMQ for RabbitMQ:Koneksi dan channel

Gunakan koneksi persisten

Buka koneksi saat startup aplikasi dan pertahankan selama seluruh siklus hidup aplikasi. Jangan membuka dan menutup koneksi untuk setiap operasi publikasi atau konsumsi.

Jika beban kerja Anda memerlukan pembuatan channel yang sering, gunakan kembali satu set koneksi yang stabil dan buat beberapa channel di dalamnya. Untuk batasan laju pembukaan koneksi dan channel, lihat Limits.

Pisahkan koneksi produsen dan konsumen

Gunakan minimal satu koneksi untuk memproduksi pesan dan koneksi terpisah untuk mengonsumsi. ApsaraMQ for RabbitMQ menerapkan flow control (back pressure) pada koneksi yang mempublikasikan lebih cepat daripada kemampuan instans memprosesnya. Jika produsen dan konsumen berbagi koneksi yang sama, flow control pada sisi publikasi dapat menunda acknowledgment dari konsumen, sehingga menurunkan throughput konsumsi.

Gunakan satu channel per thread

Beberapa thread dapat berbagi satu koneksi. Namun, channel tidak aman untuk thread (thread-safe) di sebagian besar library client. Berikan setiap thread channel-nya sendiri; jangan berbagi channel lintas thread.

// Anti-pattern: berbagi channel lintas thread
Channel shared = connection.createChannel(); // Tidak thread-safe

// Direkomendasikan: satu channel per thread
ExecutorService executor = Executors.newFixedThreadPool(4);
for (int i = 0; i < 4; i++) {
    executor.submit(() -> {
        Channel ch = connection.createChannel();
        // Gunakan ch untuk operasi publikasi/konsumsi thread ini
    });
}

Saat beberapa proses berbagi satu koneksi, hindari membuka dan menutupnya secara terlalu sering. Jika tidak, error ChannelNotFind dapat terjadi.

Cegah consumption skew

Saat hanya beberapa koneksi yang menangani volume pesan besar, distribusi konsumsi bisa menjadi tidak merata di antara konsumen. Untuk mencegah hal ini:

• Tingkatkan jumlah koneksi per konsumen atau tambahkan lebih banyak konsumen.

• Pastikan setiap konsumen membuat jumlah koneksi yang sama.

• Pertahankan minimal total 30 koneksi konsumen sebagai panduan.