ApsaraMQ for RocketMQ：Memigrasi cluster Apache RocketMQ ke instance ApsaraMQ for RocketMQ

Evaluasi teknis

• Batasan pada cluster Apache RocketMQ: Sebelum memigrasikan cluster Apache RocketMQ ke instance ApsaraMQ for RocketMQ, evaluasi apakah cluster memenuhi persyaratan. Jika cluster tidak memenuhi persyaratan, Kirim tiket. Tabel berikut menggambarkan batasan pada cluster Apache RocketMQ.

  Batasan	Deskripsi
  Versi yang digunakan	Broker Apache RocketMQ 4.x dan 5.x didukung.
  Jaringan	Cluster Apache RocketMQ sumber harus diterapkan dalam VPC. Jika cluster Apache RocketMQ sumber diterapkan di pusat data lokal, pastikan bahwa cluster dapat diakses dari VPC.
  Wilayah	Anda dapat memigrasikan cluster Apache RocketMQ yang dikelola sendiri ke instance ApsaraMQ for RocketMQ di wilayah berikut: Cina (Hangzhou), Cina (Shanghai), Cina (Beijing), Cina (Shenzhen), Cina (Zhangjiakou), AS (Silicon Valley), dan Singapura.
  Parameter	Ukuran pesan Periode retensi pesan Nilai minimum: 24. Unit: jam. Nilai maksimum: 720. Unit: jam. Waktu penundaan maksimum pesan terjadwal Instance Edisi Standar berlangganan dan bayar sesuai pemakaian dan instance Edisi Standar serverless dan Edisi Profesional: 7 hari. Instance Edisi Profesional berlangganan dan bayar sesuai pemakaian dan Edisi Platinum Perusahaan: 40 hari. Untuk informasi lebih lanjut, lihat Kuota dan batasan.

• Batasan pada versi SDK: Solusi migrasi mengikuti prinsip perubahan minimal. Dalam kebanyakan kasus, versi SDK klien diperbarui secara otomatis. Jika migrasi melibatkan peningkatan versi utama, fitur baru ditambahkan dan optimasi stabilitas diberikan. Dalam hal ini, kami menyarankan Anda memperbarui versi SDK selama migrasi.

  SDK	Bahasa pemrograman	Versi SDK	Peningkatan diperlukan atau tidak
  Apache RocketMQ Remoting SDK Contoh kode untuk dependensi Maven SDK untuk Java: <dependency> <groupId>org.apache.rocketmq</groupId> <artifactId>rocketmq-client</artifactId> <version>{version}</version> </dependency> Format titik akhir: producer.setNamesrvAddr(“xxx:9876”); consumer.setNamesrvAddr(“xxx:9876”);	Java	SDK 5.x	Jenis SDK ini kompatibel dengan instance ApsaraMQ for RocketMQ. Tidak diperlukan peningkatan.
  	Java dan C++	SDK 4.x	Jika operasi PullConsumer, DefaultLitePullConsumer, dan DefaultPullConsumer dipanggil oleh cluster Apache RocketMQ sumber, Anda harus meningkatkan SDK ke 5.x. Untuk informasi lebih lanjut, lihat Ikhtisar.

Konfirmasi ruang lingkup migrasi

Solusi migrasi yang disediakan oleh ApsaraMQ for RocketMQ memungkinkan Anda memigrasikan cluster Apache RocketMQ ke instance ApsaraMQ for RocketMQ berdasarkan topik. Migrasi batch, rilis canary, dan rollback juga didukung. Ini secara efektif mengurangi risiko yang disebabkan oleh perubahan skala besar.

Catatan penggunaan

• Alat migrasi yang disediakan oleh ApsaraMQ for RocketMQ hanya dapat mengakses informasi berikut tentang cluster Apache RocketMQ sumber berdasarkan kebijakan cakupan minimal:

  • Metadata topik

  • Metadata grup

  • Informasi tentang pendaftaran routing dinamis dalam topik

  • Informasi tentang koneksi konsumen dan akumulasi pesan

  Alat migrasi tidak mengakses informasi lain tentang cluster Apache RocketMQ sumber atau menulis informasi konfigurasi ke cluster. Oleh karena itu, akses alat migrasi ke cluster Apache RocketMQ tidak berdampak pada jalannya cluster.

• Pastikan konfigurasi jaringan valid sebelum melanjutkan ke langkah berikutnya. Setelah masuk ke langkah berikutnya, Anda tidak dapat kembali ke langkah konfigurasi jaringan. Untuk memodifikasi konfigurasi jaringan, Anda harus membuat tugas migrasi baru.

Prosedur

1. Masuk ke Konsol ApsaraMQ for RocketMQ.

2. Di bilah navigasi atas, pilih wilayah tempat cluster Apache RocketMQ sumber dan instance ApsaraMQ for RocketMQ tujuan berada. Di panel navigasi sisi kiri, pilih RocketMQ Copilot > Migration to Cloud.

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

4. Di panel Create Migration Task, konfigurasikan parameter dan klik OK.

   Untuk informasi tentang parameter, lihat Parameter yang dikonfigurasi untuk jaringan cluster Apache RocketMQ sumber.

5. Di langkah Network Settings dari wizard Migration to Cloud, masukkan informasi jaringan tentang cluster Apache RocketMQ sumber dan klik Configure Network.

   Untuk informasi tentang parameter, lihat Parameter yang dikonfigurasi untuk jaringan cluster Apache RocketMQ sumber.

6. Tunggu hingga konfigurasi latar belakang selesai. Lalu, klik Next.

Pengaturan parameter

Catatan penggunaan

• Selama migrasi metadata, alat migrasi ApsaraMQ for RocketMQ secara dinamis membaca informasi tentang semua topik dan grup yang dibuat dalam cluster Apache RocketMQ dan menampilkan informasi tersebut dalam daftar. Anda hanya perlu memigrasikan metadata dari topik dan grup yang ingin dimigrasikan.

• Anda tidak dapat kembali ke langkah ini. Pastikan bahwa topik dan grup yang ingin dimigrasikan semuanya telah dimigrasikan sebelum melanjutkan ke langkah berikutnya. Jika tidak, Anda harus menambahkan topik secara manual dalam operasi selanjutnya.

Prosedur

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

2. Pilih topik yang ingin dimigrasikan dari daftar topik dan tipe pesan yang sesuai dari daftar drop-down Message Type. Lalu, klik Confirm and Import di kolom Actions untuk mengimpor topik.

   Anda juga dapat memilih beberapa topik dan klik Batch Import untuk mengimpor topik sekaligus.

   Penting

   Tipe pesan tidak didefinisikan dalam Apache RocketMQ 4.x. ApsaraMQ for RocketMQ memverifikasi apakah tipe pesan yang Anda tentukan untuk topik yang akan dimigrasikan konsisten dengan jenis pesan yang ditangani oleh topik tersebut. Saat memigrasikan metadata, Anda harus memilih tipe pesan berdasarkan bisnis aktual Anda.

   Jika Anda memilih tipe pesan yang salah, pesan gagal dikirim atau diterima setelah migrasi. Jika Anda tidak yakin tentang tipe pesan topik atau apakah ada tipe pesan yang berbeda dalam topik, Kirim tiket.

3. Klik tab Group Metadata, pilih grup yang ingin dimigrasikan dari daftar grup, pilih urutan konsumsi pesan dari daftar drop-down Consumption Order, lalu klik Confirm and Import di kolom Actions untuk mengimpor grup.

   Anda juga dapat memilih beberapa grup dan klik Batch Import untuk mengimpor grup sekaligus.

   Penting

   Urutan konsumsi pesan dalam SDK Apache RocketMQ 4.x ditentukan di sisi klien. Urutan konsumsi pesan dalam grup pada instance ApsaraMQ for RocketMQ 5.x dikontrol oleh broker. Saat memigrasikan metadata, Anda harus menentukan urutan konsumsi pesan dalam grup berdasarkan skenario bisnis Anda.

   Jika Anda memilih urutan konsumsi pesan yang salah, pengecualian konsumsi terjadi setelah migrasi. Jika Anda tidak yakin tentang urutan konsumsi pesan dalam grup, Kirim tiket.

4. Klik Next setelah mengonfirmasi bahwa semua topik dan grup yang ingin dimigrasikan telah diimpor.

Catatan penggunaan

• Setelah mengubah titik akhir, Anda harus memulai ulang aplikasi produsen dan konsumen untuk menghubungkan aplikasi ke instance ApsaraMQ for RocketMQ tujuan. Selama proses ini, alat migrasi merutekan topik yang digunakan untuk perpesanan ke cluster Apache RocketMQ di backend. Sistem perpesanan tetap tidak berubah pada langkah ini. Tidak ada batasan yang diberlakukan pada urutan aplikasi perpesanan yang mengubah titik akhir.

• Pastikan titik akhir diubah di semua aplikasi produsen dan konsumen yang terlibat dalam migrasi.

  • Jika titik akhir tidak diubah dalam aplikasi produsen tertentu, pesan tertentu gagal dikirim.

  • Jika titik akhir tidak diubah dalam aplikasi konsumen tertentu, akumulasi pesan terjadi dan pesan tertentu tidak dapat dikonsumsi.

Contoh perubahan titik akhir

• Apache RocketMQ Remoting SDK

  • Sebelum Perubahan:

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

  • Setelah Perubahan:

    Versi 4.5.1 dan lebih baru

    producer.setNamesrvAddr(“rmq-cn-pe334******-vpc.cn-hangzhou.rmq.aliyuncs.com:8080”);
    // Nilai default vipChannelEnabled adalah false. Jika vipChannelEnabled disetel ke true, komentar parameter ini.
    // producer.setVipChannelEnabled(false);
      
    consumer.setNamesrvAddr(“rmq-cn-pe334******-vpc.cn-hangzhou.rmq.aliyuncs.com:8080”);
    // Nilai default vipChannelEnabled adalah false. Jika vipChannelEnabled disetel ke true, komentar parameter ini.
    // consumer.setVipChannelEnabled(false);

    Versi lebih lama dari 4.5.1

    producer.setNamesrvAddr(“rmq-cn-pe334******-vpc.cn-hangzhou.rmq.aliyuncs.com:8080”);
    // Nilai default vipChannelEnabled adalah true. Anda harus menyetelnya ke false.
    producer.setVipChannelEnabled(false);
      
    consumer.setNamesrvAddr(“rmq-cn-pe334******-vpc.cn-hangzhou.rmq.aliyuncs.com:8080”);
    // Nilai default vipChannelEnabled adalah true. Anda harus menyetelnya ke false.
    consumer.setVipChannelEnabled(false);

• Apache RocketMQ gRPC SDK

  • Sebelum Perubahan:

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

  • Setelah Perubahan:

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

Prosedur

Catatan penggunaan

• Selama pergantian lalu lintas, Anda harus memeriksa apakah pesan dikirim dan diterima sesuai harapan setiap kali status topik berubah. Jika tidak ada pengecualian, lanjutkan ke langkah berikutnya. Jika pengecualian terjadi, kembalikan ke langkah sebelumnya dan perbaiki masalah.

• Pastikan bahwa lalu lintas di semua topik yang ingin dimigrasikan dialihkan dan pesan dapat dikirim dan diterima sesuai harapan sebelum menyelesaikan tugas migrasi. Anda tidak dapat memodifikasi informasi tentang pergantian lalu lintas setelah menyelesaikan tugas migrasi.

Detail pergantian lalu lintas

Ganti lalu lintas

1. Di langkah Message Migration, pilih topik yang ingin dimigrasikan pesannya dan konfirmasikan status pemeriksaan topik tersebut.

   • Jika statusnya adalah Check Passed, lanjutkan ke langkah berikutnya.

   • Jika statusnya bukan Check Passed, perbaiki pengecualian berdasarkan hasil pemeriksaan. Lalu, klik Re-verify di kolom Actions hingga pemeriksaan berhasil. Setelah pemeriksaan berhasil, lanjutkan ke langkah berikutnya.

     Untuk informasi tentang item yang diperiksa selama setiap tahap pergantian lalu lintas, lihat Item Pemeriksaan.

   • Jika statusnya bukan Check Passed dan Anda mengonfirmasi bahwa hasil pemeriksaan tidak memengaruhi migrasi, klik Ignore Check di kolom Actions topik dan lanjutkan ke langkah berikutnya.

2. Di kolom Actions topik yang ingin dialihkan lalu lintasnya, klik Switch Traffic.

3. Di pesan yang muncul, klik OK.

   Pergantian lalu lintas terdiri dari empat tahap. Anda harus melakukan operasi pergantian lalu lintas sebanyak empat kali. Pergantian lalu lintas selesai ketika Traffic Switching Stage berubah menjadi Read and Write in Destination Cluster.

   Untuk informasi tentang perubahan lalu lintas baca dan tulis dalam topik selama setiap tahap pergantian lalu lintas, lihat Status Pergantian Lalu Lintas.

4. Konfirmasikan bahwa lalu lintas dari semua topik yang ingin dimigrasikan dalam tugas migrasi telah dialihkan dan klik Migrated di bagian bawah halaman.

Operasi lainnya

Item berikut menggambarkan operasi lain yang dapat Anda lakukan di halaman Migrasi Pesan saat mengganti lalu lintas:

• • Kembalikan ke status sebelumnya: Jika migrasi tidak berfungsi sesuai harapan, Anda dapat mengembalikan status topik yang ditentukan ke status sebelumnya di mana migrasi berfungsi sesuai harapan dan melakukan operasi selanjutnya setelah memperbaiki masalah.

  • Kembalikan ke status awal: Anda dapat mengembalikan ke status awal pergantian lalu lintas dengan menggunakan metode ini. Status awal pergantian lalu lintas merujuk pada status rute dan digunakan untuk pemecahan masalah darurat.

    Catatan

    Jika Anda melakukan operasi ini, perubahan besar akan terjadi pada status pergantian lalu lintas. Pesan yang belum dikonsumsi yang dihasilkan selama proses migrasi sebelumnya mungkin tertunda atau tidak dapat diproses.

• Create Topic

  Jika topik yang ingin dimigrasikan tidak dipilih selama migrasi metadata, Anda dapat membuat topik dengan nama yang sama dengan topik yang ingin dimigrasikan pada instance ApsaraMQ for RocketMQ 5.x selama pergantian lalu lintas.

• Batch Traffic Switching/Batch Rollback

  Anda dapat melakukan pergantian lalu lintas batch dan rollback batch.

  Catatan

  Anda hanya dapat melakukan pergantian lalu lintas batch dan rollback batch untuk topik yang berada pada tahap pergantian lalu lintas yang sama.

Item pemeriksaan selama pergantian lalu lintas