ApsaraMQ for RocketMQ:Migrasikan kluster Apache RocketMQ yang dikelola sendiri ke ApsaraMQ for RocketMQ

Persyaratan kluster sumber

Kluster Apache RocketMQ sumber harus memenuhi persyaratan berikut. Jika tidak, kirim tiket.

Batasan instans tujuan

Untuk daftar lengkap, lihat Kuota dan batasan.

Kompatibilitas SDK

Remoting SDK menggunakan dependensi Maven dan format titik akhir berikut:

<dependency>
    <groupId>org.apache.rocketmq</groupId>
    <artifactId>rocketmq-client</artifactId>
    <version>{version}</version>
</dependency>

producer.setNamesrvAddr("xxx:9876");
consumer.setNamesrvAddr("xxx:9876");

Pesan terjadwal dan pesan retry

Periksa apakah kluster sumber Anda berisi pesan terjadwal atau pesan yang menunggu retry. Setelah migrasi, semua koneksi produsen dan konsumen dialihkan ke instans ApsaraMQ for RocketMQ. Pesan terjadwal dan pesan retry yang masih berada di kluster sumber mungkin tidak akan dikonsumsi. Pertahankan beberapa proses konsumen yang berjalan di kluster sumber untuk mengosongkan pesan-pesan tersebut sebelum Anda menonaktifkannya.

Rencanakan batch migrasi Anda

Tool migrasi mendukung migrasi per topik dengan operasi batch, rilis canary, dan rollback, sehingga meminimalkan dampak setiap perubahan.

1. Pilih topik dan rencanakan batch. Identifikasi topik yang akan dimigrasikan dan kelompokkan ke dalam batch. Mulailah dengan topik bisnis non-kritis.

2. Koordinasikan dengan tim hulu dan hilir. Beri tahu semua aplikasi produsen dan konsumen yang menggunakan topik yang dipilih. Setiap aplikasi harus memperbarui titik akhirnya.

Apa yang diakses oleh tool migrasi

Tool migrasi hanya mengakses informasi berikut dari kluster sumber (hak akses minimal):

• Metadata topik

• Metadata kelompok konsumen

• Pendaftaran routing dinamis untuk topik

• Status koneksi konsumen dan akumulasi pesan

Tool ini tidak mengakses data kluster lainnya atau menulis konfigurasi apa pun ke kluster sumber.

Prosedur

1. Login ke Konsol ApsaraMQ for RocketMQ.

2. Di bilah navigasi atas, pilih wilayah tempat kluster sumber dan instans tujuan berada. Di panel navigasi kiri, pilih RocketMQ Copilot > Migration to Cloud.

3. Di halaman Migration to Cloud, klik Create Task.

4. Di panel Create Migration Task, konfigurasikan parameter yang dijelaskan dalam tabel berikut lalu klik OK.

5. Di langkah Network Settings wizard migrasi, masukkan detail jaringan kluster Apache RocketMQ sumber lalu klik Configure Network.

6. Tunggu hingga konfigurasi jaringan selesai, lalu klik Next.

Referensi parameter

Prosedur

1. Di langkah Metadata Migration, klik tab Topic Metadata.

2. Pilih topik dari daftar, pilih Message Type yang benar dari daftar drop-down, lalu klik Confirm and Import. Untuk mengimpor beberapa topik sekaligus, pilih semuanya lalu klik Batch Import.

   Penting

   Apache RocketMQ 4.x tidak mendefinisikan tipe pesan di tingkat topik. ApsaraMQ for RocketMQ memvalidasi bahwa tipe pesan yang Anda tetapkan sesuai dengan pesan aktual di topik tersebut. Pilih tipe berdasarkan logika aplikasi Anda. Jika memilih tipe yang salah, pesan gagal dikirim atau diterima setelah migrasi. Jika Anda tidak yakin tentang tipe pesan, kirim tiket.

3. Klik tab Group Metadata. Pilih kelompok konsumen, pilih Consumption Order yang benar dari daftar drop-down, lalu klik Confirm and Import. Untuk mengimpor beberapa kelompok sekaligus, pilih semuanya lalu klik Batch Import.

   Penting

   Pada SDK Apache RocketMQ 4.x, urutan konsumsi pesan ditentukan di sisi klien. Di ApsaraMQ for RocketMQ 5.x, broker mengontrol urutan konsumsi di tingkat kelompok. Pilih urutan berdasarkan kebutuhan aplikasi Anda. Urutan yang salah menyebabkan exception saat konsumsi. Jika Anda tidak yakin, kirim tiket.

4. Verifikasi bahwa semua topik dan kelompok untuk batch migrasi ini telah diimpor, lalu klik Next.

Sebelum melanjutkan

• Setelah mengubah titik akhir, restart setiap aplikasi agar terhubung ke instans tujuan.

• Pastikan setiap aplikasi produsen dan konsumen memperbarui titik akhirnya:

  • Produsen yang tidak beralih: beberapa pesan gagal dikirim.

  • Konsumen yang tidak beralih: pesan menumpuk dan tidak dapat dikonsumsi.

Contoh perubahan titik akhir

producer.setNamesrvAddr("192.168.XX.XX:9876");
consumer.setNamesrvAddr("192.168.XX.XX:9876");

producer.setNamesrvAddr("rmq-cn-pe334******-vpc.cn-hangzhou.rmq.aliyuncs.com:8080");
// vipChannelEnabled default-nya false. Jika di-set true, komentari baris ini.
// producer.setVipChannelEnabled(false);

consumer.setNamesrvAddr("rmq-cn-pe334******-vpc.cn-hangzhou.rmq.aliyuncs.com:8080");
// vipChannelEnabled default-nya false. Jika di-set true, komentari baris ini.
// consumer.setVipChannelEnabled(false);

producer.setNamesrvAddr("rmq-cn-pe334******-vpc.cn-hangzhou.rmq.aliyuncs.com:8080");
// vipChannelEnabled default-nya true. Set ke false.
producer.setVipChannelEnabled(false);

consumer.setNamesrvAddr("rmq-cn-pe334******-vpc.cn-hangzhou.rmq.aliyuncs.com:8080");
// vipChannelEnabled default-nya true. Set ke false.
consumer.setVipChannelEnabled(false);

ClientConfiguration clientConfiguration = ClientConfiguration.newBuilder()
            .setEndpoints("192.168.XX.XX:9876")
            .setCredentialProvider(sessionCredentialsProvider)
            .build();

ClientConfiguration clientConfiguration = ClientConfiguration.newBuilder()
            .setEndpoints("rmq-cn-pe334******-vpc.cn-hangzhou.rmq.aliyuncs.com:8080")
            .setCredentialProvider(sessionCredentialsProvider)
            .build();

Prosedur

Setelah semua aplikasi memperbarui titik akhir dan melakukan restart, klik Next di langkah Change Endpoint.

Sebelum melanjutkan

• Pada setiap tahap, verifikasi bahwa pesan dikirim dan diterima dengan benar sebelum melanjutkan. Jika terjadi masalah, rollback ke tahap sebelumnya dan lakukan troubleshooting.

• Alihkan traffic untuk semua topik yang dimigrasikan dan pastikan operasi normal sebelum menyelesaikan tugas migrasi. Pengaturan alih traffic tidak dapat diubah setelah tugas ditandai selesai.

Tahapan alih traffic

Setiap topik melewati empat tahap berikut:

Topologi traffic untuk setiap tahap:

Tahap	Topologi
Baca dan tulis di kluster sumber
Tulis di kluster sumber, baca di kedua kluster
Tulis di kluster tujuan, baca di kedua kluster
Baca dan tulis di kluster tujuan

Pemeriksaan verifikasi di setiap tahap

Prosedur

1. Di langkah Message Migration, pilih topik yang akan dimigrasikan dan periksa status verifikasinya.

   • Check Passed: Lanjutkan ke langkah berikutnya.

   • Tidak lolos: Lakukan troubleshooting berdasarkan hasil pemeriksaan, lalu klik Re-verify hingga pemeriksaan lolos.

   • Tidak lolos, tetapi dipastikan tidak menghambat: Klik Ignore Check dan lanjutkan.

2. Di kolom Actions, klik Switch Traffic.

3. Di dialog konfirmasi, klik OK.

4. Ulangi langkah 1 hingga 3 untuk setiap tahap hingga Traffic Switching Stage menampilkan Read and Write in Destination Cluster.

5. Setelah semua topik sepenuhnya dialihkan, klik Migrated di bagian bawah halaman.

Operasi tambahan

Operasi berikut tersedia di halaman Message Migration:

• Roll Back

  • Roll back to the previous stage: Mengembalikan topik ke tahap terakhir di mana migrasi berjalan dengan benar. Lakukan troubleshooting sebelum melanjutkan lagi.

  • Roll back to the initial stage: Mengembalikan ke status routing awal. Gunakan ini hanya untuk troubleshooting darurat.

    Catatan

    Rollback ke tahap awal dapat menyebabkan pesan yang belum dikonsumsi yang diproduksi selama tahap sebelumnya tertunda atau tidak dapat diproses.

• Create Topic: Jika topik tidak dipilih selama migrasi metadata, buat langsung di instans ApsaraMQ for RocketMQ 5.x tujuan.

• Batch Traffic Switching / Batch Rollback: Alihkan traffic atau rollback untuk beberapa topik sekaligus. Kedua operasi hanya berlaku untuk topik yang berada pada tahap alih traffic yang sama.