ApsaraMQ for RocketMQ:Kueri Pesan

Metode kueri

Secara default, pesan dalam ApsaraMQ for RocketMQ disimpan selama tiga hari. Artinya, Anda hanya dapat mengkueri pesan dari tiga hari terakhir. Misalnya, jika waktu saat ini adalah 15:09:48 pada 10 Juni 2019, pesan paling awal yang dapat dikueri dalam suatu topic dikirim pada pukul 15:09:48 tanggal 7 Juni 2019.

Tabel berikut menjelaskan dan membandingkan ketiga metode kueri tersebut.

Proses kueri yang direkomendasikan

Kami menyarankan Anda mengikuti proses berikut untuk mengkueri pesan.

Prosedur

1. Masuk ke ApsaraMQ for RocketMQ console. Di panel navigasi sebelah kiri, klik Instances.

2. Di bilah navigasi atas, pilih wilayah, misalnya China (Hangzhou).

3. Pada halaman Instances, temukan instans target. Di kolom Actions, klik More, lalu pilih Message Query dari daftar drop-down.

4. Pada halaman Message Query, pilih metode kueri, masukkan informasi yang diperlukan, lalu klik Search.

   • Query by Message ID

     Untuk melakukan kueri exact match terhadap pesan tertentu, masukkan Topic dan Message ID-nya. Mencatat Message ID setelah pengiriman berhasil akan mempermudah troubleshooting.

     Kode berikut menunjukkan cara mendapatkan Message ID menggunakan Java SDK.

        SendResult sendResult = producer.send(msg);
        String msgId = sendResult.getMessageId();

     Untuk bahasa lainnya, lihat Ringkasan referensi SDK.

   • Query by Message Key

     ApsaraMQ for RocketMQ membuat indeks untuk pesan berdasarkan Message Key yang Anda tetapkan. Saat mencari pesan menggunakan kunci tersebut, ApsaraMQ for RocketMQ menggunakan indeks tersebut untuk menemukan dan mengembalikan pesan yang sesuai.

     Penting

     • Anda harus menetapkan Message Key saat mengirim pesan agar dapat menggunakan metode kueri ini.

     • Kueri berdasarkan Message Key hanya mengembalikan 64 pesan terbaru yang sesuai. Gunakan kunci yang unik dan dapat dibedakan secara bisnis.

     Kode berikut menunjukkan cara menetapkan Message Key.

             Message msg = new Message("Topic","*","Hello MQ".getBytes());
             /**
              * Tetapkan kunci bisnis unik untuk pengambilan pesan. Disarankan menggunakan kunci yang unik secara global.
              * Hal ini memungkinkan Anda mengkueri pesan di konsol ApsaraMQ for RocketMQ jika gagal menerimanya.
              * Jika Anda tidak menetapkan kunci, pengiriman dan penerimaan pesan tidak terpengaruh, tetapi kueri berbasis kunci tidak akan berfungsi.
              */
           msg.setKey("TestKey"+System.currentTimeMillis());                                

   • Query by Topic

     Gunakan metode ini jika Anda tidak mengetahui Message ID atau Message Key-nya. Tentukan Topic dan rentang waktu untuk mengambil semua pesan yang dikirim selama periode tersebut.

     Penting

     Saat mengkueri pesan berdasarkan Topic:

     • Pencocokan berbasis rentang ini dapat mengembalikan banyak pesan. Persempit rentang waktu sebanyak mungkin untuk membatasi hasil.

     • Hasil ditampilkan secara terpaginasi karena kueri dapat mengembalikan volume pesan yang besar.

Hasil kueri

Verifikasi konsumsi

ApsaraMQ for RocketMQ menyediakan fitur verifikasi konsumsi. Fitur ini memungkinkan Anda mendorong pesan tertentu ke client online untuk menguji logika konsumsinya dan memverifikasi hasilnya.

Pada kotak dialog verifikasi konsumsi, pilih group ID dan client ID, lalu klik OK. Verifikasi konsumsi dapat menyebabkan redelivery pesan.

Referensi

Dari hasil kueri, Anda dapat melihat jejak pesan untuk memeriksa status dan hasil konsumsinya. Untuk informasi lebih lanjut, lihat query message traces.