Dalam sistem aplikasi terdistribusi, interaksi antar layanan melibatkan jaringan komunikasi dan transmisi data yang kompleks. Untuk memproses permintaan, layanan internal dalam sistem harus saling berkomunikasi. Jika terjadi pengecualian selama proses ini, tugas di layanan eksternal mungkin gagal dieksekusi atau mengalami timeout, sehingga pemecahan masalah menjadi sulit. Fitur analisis penelusuran mencatat proses transmisi permintaan ketika layanan berinteraksi satu sama lain dalam sistem. Fitur ini juga menyediakan log rinci dan data kinerja. ApsaraMQ for RocketMQ memungkinkan Anda mengintegrasikan data jejak yang sesuai dengan spesifikasi OpenTelemetry ke layanan analisis penelusuran Alibaba Cloud untuk membantu mendiagnosis dan menyelesaikan pengecualian.
Apa itu jejak?
Data jejak ApsaraMQ for RocketMQ memenuhi konvensi semantik untuk rentang pesan yang didefinisikan dalam spesifikasi OpenTelemetry. Untuk informasi lebih lanjut, lihat Konvensi Semantik Jejak.
Apa itu rentang pesan?
Rentang pesan mendefinisikan hubungan topologi antara berbagai jenis rentang, termasuk hubungan induk-anak dan hubungan tautan antara rentang pengiriman, penerimaan, dan pemrosesan. Untuk informasi lebih lanjut, lihat Konvensi Semantik untuk Rentang Pesan.
Tabel berikut menjelaskan jenis rentang yang terlibat dalam ApsaraMQ for RocketMQ.
rentang | Deskripsi |
kirim | Pesan dikirim dari produser ke konsumen. Rentang jenis ini dimulai ketika pesan mulai dikirim dan berakhir ketika pesan terkirim, pesan gagal dikirim, atau pengecualian dilemparkan. Jika pesan dicoba ulang selama pengiriman pesan, beberapa rentang dicatat. |
terima | Proses polling panjang saat pesan diterima oleh konsumen. Siklus hidup rentang jenis ini sesuai dengan siklus hidup polling panjang. Secara default, rentang penerimaan dinonaktifkan. Untuk mengaktifkan rentang penerimaan, Anda harus menambahkan parameter |
proses | Proses saat pesan diproses oleh operasi |
Gambar berikut menjelaskan hubungan antara jenis rentang yang disebutkan di atas.
Jika rentang penerimaan dinonaktifkan, rentang proses merupakan anak dari rentang pengiriman.
Jika rentang penerimaan diaktifkan, rentang proses merupakan anak dari rentang penerimaan dan ditautkan ke rentang pengiriman.
Apa itu atribut pesan?
Atribut umum yang terkandung dalam rentang pesan dijelaskan dalam konvensi semantik untuk rentang pesan. Berikut adalah atribut tersebut:
messaging.message.id: ID pesan. Ini adalah pengenal unik pesan.
messaging.destination: tujuan ke mana pesan dikirim. Dalam banyak kasus, tujuan adalah antrian atau topik.
messaging.operation: jenis operasi yang dilakukan pada pesan, seperti kirim, terima, dan akui.
Untuk informasi tentang atribut lainnya, lihat Atribut Apache RocketMQ.
Produk pesan yang berbeda memiliki perilaku dan atribut yang berbeda. Tabel berikut menjelaskan atribut unik dari ApsaraMQ for RocketMQ.
Atribut | Tipe nilai | Deskripsi |
messaging.rocketmq.client_group | string | Grup penyeimbangan beban konsumen. |
messaging.rocketmq.client_id | string | ID klien. ID ini adalah pengenal unik klien. |
messaging.rocketmq.message.delivery_timestamp | int | Waktu yang dijadwalkan untuk mengirim pesan terjadwal. |
messaging.rocketmq.message.group | string | Grup tempat pesan terurut milik. |
messaging.rocketmq.message.type | string | Tipe pesan. Nilai valid:
|
messaging.rocketmq.message.tag | string | Tag yang digunakan untuk menyaring pesan. Konsumen dapat menyaring pesan berdasarkan tag. Dengan cara ini, konsumen hanya dapat menerima pesan yang berisi tag tertentu. |
messaging.rocketmq.message.keys | string[] | Kunci pesan. Anda dapat mengonfigurasi kunci yang berbeda untuk pesan yang berbeda. Ini membantu Anda menemukan pesan yang ingin Anda kelola dengan cepat. |
Batasan
Hanya klien yang menggunakan SDK untuk Java yang dapat melaporkan data jejak ke layanan analisis penelusuran. Untuk informasi tentang catatan rilis SDK untuk Java, lihat Deskripsi Versi.
ApsaraMQ for RocketMQ hanya melacak data produksi terkait pesan transaksional.
ApsaraMQ for RocketMQ hanya melacak data pesan yang dikonsumsi oleh konsumen push. Untuk informasi lebih lanjut, lihat Tipe Konsumen.
Solusi integrasi data jejak yang disediakan oleh ApsaraMQ for RocketMQ
Untuk menerapkan analisis penelusuran, ApsaraMQ for RocketMQ pertama-tama melaporkan data jejak yang sesuai dengan spesifikasi OpenTelemetry ke server analisis penelusuran. Kemudian, server mengumpulkan dan menampilkan data jejak.
Anda dapat membangun server analisis penelusuran sendiri atau menggunakan layanan analisis penelusuran yang disediakan oleh Alibaba Cloud sebagai server analisis penelusuran. ApsaraMQ for RocketMQ memungkinkan Anda mengintegrasikan data jejak ke Layanan Log Sederhana Alibaba Cloud dan Application Real-Time Monitoring Service (ARMS). Untuk informasi lebih lanjut, lihat Catatan Penggunaan dan Apa Itu Managed Service for OpenTelemetry?
Integrasi data jejak ke Layanan Log Sederhana
Untuk informasi tentang cara mengintegrasikan data jejak ApsaraMQ for RocketMQ ke Layanan Log Sederhana, lihat Impor Data Jejak dari Aplikasi Java ke Layanan Log Sederhana Menggunakan OpenTelemetry SDK untuk Java.
Contoh:
Penelusuran Metrik Dasbor ApsaraMQ for RocketMQ: Dalam contoh ini, metrik seperti penundaan pengiriman pesan, tingkat keberhasilan pengiriman pesan, tingkat keberhasilan konsumsi pesan, dan latensi ujung-ke-ujung ditampilkan. Metrik ini didasarkan pada data jejak ApsaraMQ for RocketMQ.
Analisis Metrik Dasbor ApsaraMQ for RocketMQ: Anda dapat melakukan analisis lebih lanjut pada permintaan abnormal berdasarkan ID pesan atau ID jejak.
Integrasi data jejak ke ARMS
Untuk informasi tentang cara mengintegrasikan data jejak ApsaraMQ for RocketMQ ke ARMS, lihat Panduan Integrasi OpenTelemetry.