ApsaraMQ for RocketMQ adalah layanan utama untuk pelepasan asinkron dalam bisnis berbasis arsitektur terdistribusi. Data jejak yang disediakan oleh ApsaraMQ for RocketMQ secara efektif menghubungkan aplikasi hulu dan hilir dari bisnis, membantu Anda mengidentifikasi dan menyelesaikan masalah. Topik ini menjelaskan skenario penggunaan jejak pesan, parameter jejak yang disediakan oleh ApsaraMQ for RocketMQ, serta cara melihat jejak pesan.
Skenario Umum
Data penting untuk perpesanan didefinisikan sebagai parameter jejak dalam ApsaraMQ for RocketMQ. ApsaraMQ for RocketMQ menyediakan fitur visualisasi yang menampilkan hasil kueri dan analisis dalam bentuk grafik, memungkinkan Anda dengan cepat memperoleh status bisnis dan mengidentifikasi masalah melalui jejak pesan.
Berikut adalah skenario tipikal penggunaan jejak pesan:
Skenario 1: Memeriksa apakah pesan telah dikirim atau dikonsumsi.
Skenario 2: Memeriksa apakah pesan terjadwal atau tertunda dikirim sesuai waktu yang dijadwalkan.
Skenario 3: Memeriksa apakah pesan transaksional telah dikomit atau dibatalkan.
Skenario 4: Memeriksa informasi identitas dan mesin produsen serta konsumen untuk pemecahan masalah.
Parameter Jejak
Tabel berikut menjelaskan parameter jejak dalam ApsaraMQ for RocketMQ.
Kategori | Parameter | Deskripsi |
Produser | Informasi Produser | Akun ApsaraMQ for RocketMQ atau ID AccessKey yang digunakan oleh produser untuk mengirim pesan. |
Nama Host | Nama host dari mesin tempat klien produser berada. | |
Dikirim Pada | Waktu ketika produser mulai mengirim pesan. | |
Tiba Pada | Waktu ketika pesan disimpan di broker ApsaraMQ for RocketMQ. | |
Hasil Pengiriman | Hasil pengiriman pesan. Nilai valid:
| |
Informasi dasar pesan | Jenis Pesan | |
ID Pesan | Pengenal unik global dari pesan. Pengenal ini dihasilkan secara otomatis oleh ApsaraMQ for RocketMQ. | |
Topik | Nama topik ke mana pesan tersebut milik. | |
Kunci Pesan | Kunci pesan. Kunci pesan adalah pengenal bisnis yang ditetapkan oleh produser untuk secara unik mengidentifikasi logika bisnis. | |
Tag Pesan | Tag pesan. Tag digunakan untuk menentukan jenis konsumsi pesan dalam topik tertentu. | |
Pesan terurut | Grup Pesan | Grup ke mana pesan tersebut milik. Grup ke mana pesan terurut milik ditentukan oleh produser. Pesan dalam grup yang sama diproses dalam urutan pertama masuk, pertama keluar (FIFO). |
Pesan transaksional | Waktu Panggil Balik Pemeriksaan | Waktu panggil balik ketika status transaksi diperiksa untuk pesan setengah. |
Dikomit Pada | Waktu ketika pesan transaksional dikomit kepada konsumen oleh broker. | |
Dibatalkan Pada | Waktu ketika pesan transaksional dibatalkan. | |
Pesan terjadwal | Waktu Penundaan yang Ditetapkan | Waktu ketika pesan dijadwalkan untuk dikirim. |
Konsumen | Hasil Konsumsi | Hasil konsumsi pesan. Nilai valid:
|
Informasi Konsumen | Akun ApsaraMQ for RocketMQ atau ID AccessKey yang digunakan oleh konsumen untuk berlangganan pesan. | |
Nama Host | Nama host dari mesin tempat klien konsumen berada. | |
Pengiriman Terurut | Menunjukkan apakah pengiriman terurut diaktifkan untuk grup konsumen ke mana konsumen tersebut milik. | |
Waktu Pengiriman | Waktu ketika broker ApsaraMQ for RocketMQ mengirimkan pesan kepada konsumen. | |
Waktu Tanggapan | Waktu ketika broker ApsaraMQ for RocketMQ menerima hasil konsumsi yang dikembalikan oleh konsumen. | |
Durasi Tak Terlihat | Periode waktu selama pesan yang dikirim oleh konsumen sederhana tidak terlihat. Untuk informasi lebih lanjut, lihat Kebijakan ulang untuk pesan yang dikonsumsi dalam Mode Sederhana. | |
Ubah Durasi Tak Terlihat | Waktu ketika konsumen sederhana memanggil operasi ChangeInvisibleDuration. | |
Waktu Masuk Antrian Pesan Gagal | Waktu ketika pesan dikirim ke antrian pesan gagal jika pesan gagal dikonsumsi. |
Batasan
Secara default, fitur jejak pesan dinonaktifkan pada klien yang menggunakan Apache RocketMQ 3.x atau 4.x SDK. Untuk informasi lebih lanjut, lihat Ikhtisar. Jika Anda menggunakan klien semacam itu dan ingin menanyakan jejak pesan di Konsol ApsaraMQ for RocketMQ, Anda harus mengaktifkan fitur jejak pesan dalam kode perpesanan. Berikut adalah konfigurasi detail dalam kode perpesanan:
Produser
producer.setAccessChannel(AccessChannel.CLOUD);Konsumen
consumer.setAccessChannel(AccessChannel.CLOUD);
Aturan Penagihan
Untuk instance ApsaraMQ for RocketMQ berlangganan dan bayar sesuai pemakaian, fitur jejak pesan diaktifkan secara default dan gratis.
Untuk instance ApsaraMQ for RocketMQ tanpa server, Anda dapat mengaktifkan atau menonaktifkan fitur jejak pesan secara manual. Untuk informasi lebih lanjut, lihat Aktifkan atau nonaktifkan fitur jejak pesan untuk instance tanpa server.
Jika Anda mengaktifkan fitur jejak pesan untuk instance ApsaraMQ for RocketMQ tanpa server, Anda akan dikenakan biaya jejak pesan berdasarkan jumlah jejak pesan yang dihasilkan. Untuk informasi lebih lanjut, lihat Biaya jejak pesan.
Durasi Penyimpanan
Untuk instance ApsaraMQ for RocketMQ berlangganan dan bayar sesuai pemakaian, jejak pesan dapat disimpan selama tiga hari.
Untuk instance ApsaraMQ for RocketMQ tanpa server, jejak pesan dapat disimpan selama 14 hari.
Metode Kueri
ApsaraMQ for RocketMQ memungkinkan Anda menanyakan jejak pesan menggunakan salah satu metode berikut:
Kueri berdasarkan ID pesan: Metode ini direkomendasikan karena pencocokan tepat dan kecepatannya yang tinggi.
Kueri berdasarkan kunci pesan: Metode ini merupakan kueri kabur. Jika Anda menggunakan metode ini, Anda dapat menanyakan hingga 1.000 jejak pesan sekaligus. Jika Anda mengetahui kunci pesan tetapi tidak mengetahui ID pesan, Anda dapat menggunakan metode ini.
Kueri berdasarkan topik: Metode ini merupakan kueri rentang. Metode ini cocok untuk skenario di mana tidak ada ID pesan atau kunci pesan yang dicatat dan jumlah pesan sedikit. Kami merekomendasikan agar Anda tidak menggunakan metode kueri ini karena sering kali sejumlah besar pesan dihasilkan dalam topik dalam rentang waktu tertentu, sehingga sulit untuk mengidentifikasi pesan spesifik.
Aktifkan atau nonaktifkan fitur jejak pesan untuk instance tanpa server
Setelah Anda menonaktifkan fitur jejak pesan untuk instance ApsaraMQ for RocketMQ tanpa server, Anda tidak dapat menyimpan atau menanyakan jejak pesan dari instance tersebut, dan Konsol ApsaraMQ for RocketMQ tidak menampilkan titik masuk untuk jejak pesan.
Setelah Anda mengaktifkan fitur jejak pesan untuk instance ApsaraMQ for RocketMQ tanpa server, Anda akan dikenakan biaya untuk jejak pesan. Untuk informasi lebih lanjut, lihat Biaya jejak pesan.
Masuk ke Konsol ApsaraMQ for RocketMQ. Di panel navigasi kiri, klik Instances.
Di bilah navigasi atas, pilih wilayah, seperti China (Hangzhou). Di halaman Instance, klik nama instance yang ingin Anda kelola.
Di halaman Instance Details, klik tab Basic Information. Di kartu Message Trace, klik Enable atau Disable.
Di pesan yang muncul, klik OK.
Kueri jejak pesan
Masuk ke Konsol ApsaraMQ for RocketMQ. Di panel navigasi kiri, klik Instances.
Di bilah navigasi atas, pilih wilayah, seperti China (Hangzhou). Di halaman Instance, klik nama instance yang ingin Anda kelola.
Di panel navigasi kiri, klik Message Traces. Di halaman Message Traces, pilih metode kueri, masukkan kondisi kueri, lalu klik Search.
Di hasil kueri, klik Message Trace di kolom Actions. Di panel yang muncul, lihat informasi tentang jejak pesan.
Jika pesan dikonsumsi, klik ID grup di kartu Consumer untuk melihat rincian konsumsi. Di sisi kiri atas panel, klik Export Image untuk menghasilkan gambar yang menggambarkan rincian jejak pesan.
Operasi API Terkait
Anda juga dapat memanggil operasi API berikut untuk mengelola jejak pesan: