All Products
Search

This Product

    Microservices Engine:Konfigurasi rilis canary pesan

    Document Center

    Microservices Engine:Konfigurasi rilis canary pesan

    Last Updated:Mar 12, 2026

    Aktifkan rilis canary pesan untuk skenario seperti peluncuran kanari ujung ke ujung dan isolasi lingkungan pengembangan. Rilis canary pesan memperluas semantik canary ke RocketMQ dengan memberi tag setiap pesan menggunakan konteks lingkungannya, sehingga konsumen canary dan baseline hanya memproses pesan yang ditujukan untuk mereka.

    Gunakan rilis canary pesan untuk:

    • Memverifikasi perubahan logika konsumsi secara aman. Arahkan sebagian kecil pesan ke konsumen canary untuk memvalidasi logika baru sebelum menangani traffic produksi.

    • Mencegah kebocoran traffic dalam peluncuran kanari ujung ke ujung. Saat konsumen pesan menghasilkan RPC downstream, pesan tanpa tag dapat keluar dari routing canary dan mencapai node produksi. Pemberian tag pada pesan menjaga seluruh rantai panggilan tetap berada dalam lingkungan yang benar.

    MSE hanya mendukung rilis canary pesan untuk RocketMQ, baik edisi open-source maupun edisi komersial Alibaba Cloud.

    Cara kerja

    Saat produsen mengirim pesan, MSE Agent menyambungkan konteks lingkungan saat ini ke atribut pesan. Selama konsumsi, agen menyaring pesan berdasarkan konteks ini sehingga setiap konsumen hanya menerima pesan yang ditujukan untuk lingkungannya.

    Klasifikasi pesan canary

    Suatu pesan diklasifikasikan sebagai pesan canary dalam salah satu kondisi berikut:

    1. Diproduksi oleh node canary. Setiap pesan yang dikirim dari produsen yang berjalan di lingkungan canary.

    2. Diproduksi oleh node baseline yang menangani traffic canary. Saat tidak ada produsen canary, traffic canary dialihkan ke node baseline. Pesan yang diproduksi dalam kondisi fallback ini juga diklasifikasikan sebagai pesan canary.

    Perilaku konsumsi default

    Setelah Anda mengaktifkan rilis canary pesan:

    • Pesan baseline hanya dikonsumsi oleh konsumen baseline.

    • Pesan canary dikonsumsi oleh konsumen baseline maupun konsumen canary yang sesuai. Kedua kelompok tersebut secara independen mengonsumsi pesan canary yang sama.

    Untuk membatasi pesan canary hanya dikonsumsi oleh konsumen canary, lihat Konfigurasi konsumen pesan canary.

    Kompatibilitas

    RocketMQ Server

    EdisiPenyaringan sisi serverClient-Side Filtering
    RocketMQ open-source (4.5.0 atau lebih baru)Didukung (memerlukan enablePropertyFilter=true dalam broker.conf)Didukung
    Alibaba Cloud RocketMQ 4.xHanya Edisi PlatinumSemua edisi
    Alibaba Cloud RocketMQ 5.xDidukungDidukung

    RocketMQ Client

    KlienVersi minimumDukungan penyaringan
    Ons Client (Alibaba Cloud)1.8.0.Final atau lebih baru (seri 1.x)--
    org.apache.rocketmq:rocketmq-client4.2.0 atau lebih baru (seri 4.x)Sisi server dan sisi client
    org.apache.rocketmq:rocketmq-client-javaSeri 5.x (memerlukan MSE Agent 4.2.2+)Hanya sisi server

    Untuk perbedaan antara SDK RocketMQ open-source, lihat dokumentasi resmi RocketMQ.

    Catatan

    MSE Agent tidak mendukung pesan transaksional.

    Batasan

    • Rilis canary pesan hanya berlaku jika diaktifkan untuk produsen dan konsumen dalam governance layanan MSE.

    • Setelah Anda mengaktifkan rilis canary pesan, MSE Agent memodifikasi Consumer Group setiap konsumen canary dengan menambahkan _<tag> ke nama grup aslinya, di mana <tag> adalah tag lingkungan.

      Sebagai contoh, jika Consumer Group asli adalah group1 dan tag lingkungan adalah gray, maka Consumer Group berubah menjadi group1_gray.

      Penting

      Jika Anda menggunakan Alibaba Cloud RocketMQ, buat Consumer Group yang telah dimodifikasi (misalnya, group1_gray) sebelum mengaktifkan rilis canary pesan.

    • MSE menggunakan penyaringan SQL-92 untuk penyaringan sisi server. Jika Anda menggunakan RocketMQ open-source 4.x, atur enablePropertyFilter=true dalam broker.conf untuk mengaktifkan dukungan SQL-92.

    • Jika pengaturan Anda tidak mendukung penyaringan SQL-92, pilih penyaringan sisi client saat mengaktifkan rilis canary pesan. Penyaringan sisi client mengharuskan setiap lingkungan memproses semua pesan, yang meningkatkan beban pada produsen dan konsumen. Hindari penyaringan sisi client di lingkungan produksi.

    Aktifkan rilis canary pesan

    Sebelum memulai, pastikan Anda telah:

    • Memiliki aplikasi yang dikelola MSE dengan produsen dan konsumen pesan yang terhubung ke governance layanan mikro

    • Memiliki pengaturan RocketMQ yang didukung (lihat Kompatibilitas)

    • (Jika menggunakan Alibaba Cloud RocketMQ) Sebuah Consumer Group telah dibuat untuk setiap lingkungan canary.

    Untuk mengaktifkan rilis canary pesan:

    1. Masuk ke Konsol MSE, lalu pilih wilayah di bilah navigasi atas.

    2. Di panel navigasi kiri, pilih Microservices Governance > Application Governance.

    3. Pada halaman Application list, klik kartu resource aplikasi yang diinginkan. Di panel navigasi kiri, klik Traffic management.

    4. Klik tab Message grayscale.

    5. Di samping Open message grayscale, klik Edit. Konfigurasikan metode penyaringan dan aturan konsumsi, lalu klik OK.

      Catatan

      Setelah mengubah pengaturan rilis canary pesan, restart semua node aplikasi agar perubahan berlaku. Hal ini berlaku baik untuk penyaringan sisi server maupun sisi client.

      Catatan

      Rilis canary pesan merupakan sub-fitur dari peluncuran kanari ujung ke ujung. Untuk hasil terbaik, konfigurasikan juga kemampuan peluncuran kanari ujung ke ujung terkait.

    Konfigurasi konsumen pesan canary

    Secara default, konsumen baseline dan canary sama-sama menerima pesan canary. Untuk membatasi pesan canary hanya dikonsumsi oleh konsumen canary, kosongkan centang kotak Baseline Consumer untuk tag yang sesuai.

    Setelah perubahan ini, konsumen baseline hanya memproses pesan baseline dan pesan canary yang secara eksplisit dipilih untuk dikonsumsi oleh konsumen baseline.

    1. Masuk ke Konsol MSE, lalu pilih wilayah di bilah navigasi atas.

    2. Di panel navigasi kiri, pilih Microservices Governance > Application Governance.

    3. Pada halaman Application list, klik kartu resource aplikasi yang diinginkan. Di panel navigasi kiri, klik Traffic management.

    4. Klik tab Message grayscale.

    5. Pada bagian Message Canary Release Configuration, klik Edit. Kosongkan centang kotak Baseline Consumer untuk tag yang sesuai, lalu klik OK.

    Catatan

    Perubahan aturan konsumsi berlaku secara dinamis tanpa perlu restart aplikasi. Namun, jika semua konsumen canary offline sementara kotak centang Baseline Consumer dikosongkan, pesan canary dengan tag tersebut tidak akan dikonsumsi.

    Alur kerja rilis canary

    Konsumen canary permanen

    Gunakan alur kerja ini ketika konsumen canary berjalan terus-menerus bersama konsumen baseline. Satu konfigurasi menjaga agar pesan canary diarahkan ke konsumen canary dan pesan baseline diarahkan ke konsumen baseline.

    Catatan

    Jika pesan Anda tidak idempoten, pastikan konsumen canary dan baseline hanya memproses pesan masing-masing. Ikuti langkah-langkah di bawah ini.

    Sebelum memulai, pastikan Anda telah:

    • Aplikasi produsen dan konsumen pesan terhubung ke governance layanan mikro

    • Rilis canary pesan diaktifkan, dan semua node aplikasi telah direstart

    Langkah-langkah:

    1. Konfigurasikan aturan konsumsi untuk aplikasi konsumen. Untuk tag canary, kosongkan centang kotak Baseline Consumer.

    2. Tunggu 1 hingga 3 menit agar hubungan langganan di sisi RocketMQ diperbarui.

    3. Nyalakan node konsumen canary.

    4. Nyalakan node produsen canary untuk mulai mengirim pesan canary.

    Konsumen canary dinamis

    Gunakan alur kerja ini ketika node canary bersifat temporary dan terkait dengan iterasi rilis tertentu. Karena konsumen canary mungkin offline setelah verifikasi, sesuaikan penyaringan konsumen baseline untuk mencegah akumulasi atau loss pesan.

    Prosedur rilis:

    1. Konfigurasikan aturan konsumsi untuk aplikasi konsumen. Untuk tag canary, kosongkan centang kotak Baseline Consumer agar pesan canary hanya dikonsumsi oleh konsumen canary. Tunggu 1 hingga 3 menit agar hubungan langganan di sisi RocketMQ diperbarui.

    2. Nyalakan node konsumen canary.

    3. Kirim pesan canary dari node produsen canary.

    4. Verifikasi pesan canary.

    5. Matikan node produsen canary.

    6. Bandingkan offset kelompok konsumen. Pastikan offset consumer_group baseline kurang dari atau sama dengan offset consumer_group canary. Gunakan log dan pemantauan untuk memastikan semua pesan canary telah dikonsumsi.

      Penting

      Jika offset consumer_group baseline kurang dari atau sama dengan offset consumer_group canary, konsumen baseline dapat dengan aman mengambil pesan canary yang tersisa. Beberapa pesan mungkin dikonsumsi dua kali — pastikan logika bisnis Anda menangani idempotensi.

      Jika offset baseline lebih besar daripada offset canary, melanjutkan ke langkah berikutnya menyebabkan kehilangan pesan canary. Tunggu hingga offset tersebut sejajar.

    7. Aktifkan kembali konsumsi baseline. Untuk tag canary, centang kotak Baseline Consumer agar konsumen baseline dapat memproses pesan canary yang tersisa. Tunggu 1 hingga 3 menit agar hubungan langganan diperbarui.

    8. Matikan node konsumen canary dan hapus consumer_group canary.

      Penting

      Jika Anda tidak menghapus consumer_group canary, pesan akan terakumulasi di grup tersebut. Saat konsumen canary berikutnya online, mereka melanjutkan konsumsi dari offset terakhir yang terekam, bukan dari posisi terbaru.