All Products
Search

This Product

    ApsaraMQ for RocketMQ:Dasbor

    Document Center

    ApsaraMQ for RocketMQ:Dasbor

    Last Updated:Aug 15, 2026

    ApsaraMQ for RocketMQ memanfaatkan kemampuan penyimpanan dan visualisasi metrik dari Managed Service for Prometheus dan Managed Service for Grafana dalam Application Real-Time Monitoring Service (ARMS) untuk menyediakan dasbor statistik waktu nyata. Fitur ini memungkinkan Anda mengumpulkan dan memantau metrik guna memahami kondisi operasional bisnis secara cepat. Topik ini menjelaskan kasus penggunaan, penagihan, metrik yang tersedia, serta cara menggunakan dasbor.

    Kasus penggunaan

    • Menerima peringatan segera atas anomali konsumsi pesan untuk menemukan dan menyelesaikan masalah dengan cepat serta memastikan pemrosesan pesan tepat waktu.

    • Memecahkan masalah pada pesanan tertentu, seperti status abnormal, dengan meninjau jejak pesan untuk memverifikasi transmisi pesan yang tepat sepanjang alur kerja.

    • Menganalisis tren trafik pesan, pola distribusi, dan volume keseluruhan untuk memprediksi tren bisnis dan merencanakan sumber daya.

    • Memvisualisasikan dan menganalisis topologi ketergantungan aplikasi guna memahami dependensi hulu dan hilir, sehingga menyederhanakan perencanaan peningkatan arsitektur, optimasi, dan refaktoring.

    Prasyarat

    • Aktifkan Managed Service for Prometheus

    • Buat peran terkait layanan.

      • Nama peran: AliyunServiceRoleForOns

      • Nama kebijakan peran: AliyunServiceRolePolicyForOns

      • Deskripsi izin: Mengizinkan Message Queue for RocketMQ untuk mengasumsikan peran dan mengakses CloudMonitor serta ARMS demi fitur pemantauan, peringatan, dan dasbor.

      • Untuk detail selengkapnya, lihat Peran terkait layanan.

    Penagihan

    Metrik dasbor untuk ApsaraMQ for RocketMQ merupakan metrik dasar dalam Managed Service for Prometheus. Karena metrik ini gratis, fitur dasbor juga tidak dikenai biaya.

    Untuk informasi lebih lanjut, lihat Metrik dan Pay-as-you-go.

    Konsep utama

    Sebelum melihat metrik dasbor, Anda perlu memahami konsep berikut terkait keterlambatan konsumen (consumer lag).

    队列消息状态

    Gambar di atas menunjukkan status pesan dalam antrian untuk topik tertentu. Message Queue for RocketMQ mengumpulkan statistik jumlah dan waktu pemrosesan pesan pada berbagai tahap. Metrik ini secara langsung mencerminkan laju pemrosesan pesan dan consumer lag. Memantau metrik ini membantu Anda mengidentifikasi potensi anomali dalam konsumsi pesan secara cepat.

    Kategori

    Metrik

    Deskripsi

    Rumus perhitungan

    Metrik jumlah pesan

    inflight messages

    Pesan yang sedang diproses oleh klien konsumen tetapi belum dikonfirmasi (acknowledged).

    offset pesan terakhir yang ditarik - offset pesan terakhir yang dikomit

    ready messages

    Pesan di server Message Queue for RocketMQ yang siap dikonsumsi.

    Offset pesan maksimum - offset pesan terakhir yang ditarik

    consumer lag

    Jumlah total pesan yang belum diproses.

    Jumlah inflight messages + Jumlah ready messages

    Metrik latensi pesan

    ready time

    • Untuk pesan normal dan pesan terurut: Waktu saat pesan disimpan di server.

    • Untuk pesan terjadwal/tertunda: Waktu saat periode terjadwal atau penundaan berakhir.

    • Untuk pesan transaksional: Waktu saat transaksi dikomit.

    Tidak berlaku

    ready message queue time

    Selisih antara waktu saat ini dan ready time dari pesan ready tertua.

    Metrik ini menunjukkan seberapa cepat konsumen menarik pesan.

    Waktu saat ini - Ready time dari pesan ready tertua

    consumer lag time

    Selisih antara waktu saat ini dan ready time dari pesan yang belum dikonfirmasi tertua.

    Metrik ini menunjukkan seberapa cepat konsumen memproses pesan.

    Waktu saat ini - Ready time dari pesan yang belum dikonfirmasi tertua

    Metrik

    Dasbor untuk Message Queue for Apache RocketMQ menyediakan metrik berikut:

    • Produsen: Lihat metrik untuk suatu topik, seperti jumlah pesan terkirim, tingkat keberhasilan pengiriman, dan waktu respons pengiriman pesan.

    • Konsumen: Lihat metrik terkait langganan kelompok terhadap topik tertentu, seperti jumlah pesan diterima, tingkat keberhasilan konsumsi, dan consumer lag.

    • Ikhtisar 20 teratas instans: Lihat 20 nilai teratas untuk metrik tertentu dalam suatu instans, beserta topik atau kelompok terkaitnya.

    • Ikhtisar metrik penagihan: Lihat metrik untuk instans tertentu, seperti TPS kirim dan terima, jumlah pemanggilan API, dan ukuran rata-rata pesan. Metrik ini dapat membantu Anda memperkirakan biaya penagihan.

    Penting

    Semua metrik dikumpulkan dengan interval 1 menit. Anda dapat mengkueri data hingga 15 hari terakhir di Message Queue for Apache RocketMQ. Rentang waktu maksimum untuk satu kueri adalah 24 jam.

    Produsen

    Metrik

    Deskripsi

    Laju pengiriman pesan

    Laju pesan yang dikirim dan pemanggilan API ke suatu topik.

    Unit:

    • Laju pesan: pesan/detik

    • Tingkat pemanggilan API: panggilan/detik

    Laju pengiriman pesan maksimum

    Laju pengiriman pesan maksimum.

    Unit: pesan/detik.

    Total pesan terkirim

    Jumlah total pesan yang dikirim dalam instans yang ditentukan.

    Unit: pesan.

    Tingkat keberhasilan pemanggilan API pengiriman

    Persentase pemanggilan API yang berhasil untuk mengirim pesan ke suatu topik.

    Waktu respons pengiriman pesan

    Waktu yang dibutuhkan untuk mengirim pesan ke suatu topik.

    Unit: ms.

    Konsumen

    Metrik

    Deskripsi

    Tingkat keberhasilan konsumsi rata-rata

    Persentase pesan yang berhasil dikonsumsi oleh suatu kelompok.

    Consumer lag (ready + inflight)

    Jumlah total pesan yang tertunda (backlogged) untuk suatu kelompok.

    Unit: pesan.

    Inflight messages

    Jumlah pesan yang telah dikirimkan ke klien konsumen tetapi belum dikonfirmasi.

    Unit: pesan.

    Ready messages

    Jumlah pesan di server Message Queue for Apache RocketMQ yang tersedia untuk dikonsumsi.

    Metrik ini menunjukkan volume pesan yang belum mulai diproses oleh konsumen.

    Unit: pesan.

    Waktu antrian pesan ready

    Waktu yang telah berlalu sejak pesan ready tertua tersedia untuk dikonsumsi.

    Metrik ini merupakan indikator utama penundaan pemrosesan pesan, sehingga sangat penting bagi aplikasi yang sensitif terhadap waktu.

    Nilai ikhtisar menunjukkan waktu antrian pesan ready rata-rata untuk instans tersebut, sedangkan grafik menampilkan waktu antrian pesan ready untuk kelompok tertentu yang berlangganan topik tertentu.

    Unit: ms.

    Laju penerimaan pesan

    Laju di mana suatu kelompok mengonsumsi pesan.

    Unit: pesan/detik

    Laju penerimaan pesan maksimum

    Laju konsumsi pesan maksimum.

    Unit: pesan/detik

    Total pesan diterima

    Jumlah total pesan yang dikonsumsi oleh suatu kelompok.

    Unit: pesan.

    Consumer lag

    Jumlah pesan yang tertunda (backlogged) untuk suatu kelompok. Ini mencakup baik ready messages maupun inflight messages.

    Unit: pesan.

    Waktu pemrosesan pesan

    Waktu yang dibutuhkan oleh suatu kelompok untuk memproses pesan, dari awal konsumsi hingga selesai.

    Unit: ms.

    Waktu tunggu di sisi konsumen

    Jumlah waktu sejak pesan tiba di klien konsumen hingga konsumsi dimulai.

    Unit: ms.

    Tingkat keberhasilan konsumsi

    Tingkat keberhasilan konsumsi pesan.

    Rasio protokol klien konsumen

    Proporsi pesan yang dikonsumsi oleh setiap protokol klien.

    20 Teratas Instans

    Metrik

    Deskripsi

    20 topik teratas berdasarkan laju pengiriman pesan

    20 topik dengan laju pengiriman pesan tertinggi.

    Unit: pesan/detik.

    20 kelompok teratas berdasarkan laju penerimaan pesan

    20 kelompok dengan laju konsumsi pesan tertinggi.

    Unit: pesan/detik.

    20 kelompok teratas berdasarkan jumlah ready messages

    20 kelompok dengan jumlah ready messages terbesar.

    Unit: pesan.

    20 kelompok teratas berdasarkan waktu antrian pesan ready

    20 kelompok dengan waktu antrian pesan ready terlama.

    Unit: ms.

    20 kelompok teratas berdasarkan consumer lag (ready + inflight)

    20 kelompok dengan consumer lag terbesar.

    Unit: pesan.

    Metrik penagihan

    Catatan

    Metrik penagihan berikut memperhitungkan pengali untuk pesan besar dan fitur lanjutan.

    • Pengali pesan besar: Satu pemanggilan API dihitung untuk setiap ukuran pesan 4 KB. Misalnya, mengirim pesan 16 KB dihitung sebagai empat pemanggilan API (16 KB / 4 KB = 4).

    • Pengali pesan fitur lanjutan: Pemanggilan API untuk fitur lanjutan, seperti pesan terurut, pesan terjadwal/tertunda, dan pesan transaksional, dihitung lima kali lipat dibandingkan pesan normal.

    Metrik

    Deskripsi

    TPS kirim maksimum

    Transaksi per detik (TPS) maksimum untuk produksi pesan. Metrik ini membantu Anda memperkirakan spesifikasi TPS puncak yang dibutuhkan untuk instans Anda.

    Unit: TPS.

    Max Receive TPS

    TPS maksimum untuk konsumsi pesan. Metrik ini membantu Anda memperkirakan spesifikasi TPS puncak yang dibutuhkan untuk instans Anda.

    Unit: TPS.

    TPS maksimum

    TPS gabungan maksimum untuk produksi dan konsumsi pesan. Metrik ini membantu Anda memperkirakan spesifikasi TPS puncak yang dibutuhkan untuk instans Anda.

    Unit: TPS.

    Total pemanggilan API

    Jumlah total pemanggilan API. Metrik ini membantu Anda memperkirakan penggunaan pemanggilan API untuk keperluan penagihan.

    Unit: panggilan.

    Ukuran rata-rata pesan

    Ukuran rata-rata semua pesan yang diproduksi.

    Unit: byte.

    TPS kirim dan terima

    TPS gabungan untuk produksi dan konsumsi pesan.

    Unit: TPS.

    Total pemanggilan API per hari

    Total harian pemanggilan API untuk produksi dan konsumsi pesan.

    Unit: panggilan.

    Metrik

    Penting

    Semua metrik throughput pesan (TPS), permintaan, dan jumlah pesan menggunakan pesan normal 4 KB sebagai garis dasar. Nilai akhir dikalikan dengan faktor berdasarkan ukuran pesan aktual dan jenis pesan lanjutan.

    Tabel berikut menjelaskan bidang-bidang dalam metrik.

    Bidang

    Nilai

    Jenis metrik

    Gauge: Metrik yang nilainya dapat naik atau turun. Metrik ini merepresentasikan pengukuran sesaat, seperti TPS pemanggilan API.

    Label

    • instance_id: ID instans Message Queue for Apache RocketMQ.

    • topic: nama topik.

    • message_type: Jenis pesan. normal menunjukkan pesan normal, fifo menunjukkan pesan FIFO, transaction menunjukkan pesan transaksional, dan delay menunjukkan pesan tertunda/terjadwal.

    • uid: ID akun Alibaba Cloud Anda.

    • protocol_type: Jenis protokol. Nilai yang valid adalah tcp dan http.

    Metrik sisi server

    Jenis metrik

    Nama metrik

    Unit

    Deskripsi

    Label

    Gauge

    rocketmq_instance_requests_threshold

    count/s

    Ambang batas pembatasan kecepatan (throttling) untuk instans.

    • uid

    • instance_id

    Gauge

    rocketmq_instance_requests_max

    count/s

    Transaksi per detik (TPS) maksimum instans, tidak termasuk permintaan yang dibatasi.

    Nilai ini merupakan TPS puncak yang tercatat dalam interval satu menit.

    • uid

    • instance_id

    Metrik produsen

    Jenis metrik

    Nama metrik

    Unit

    Deskripsi

    Label

    Gauge

    rocketmq_producer_requests

    (Metrik tagihan)

    count

    Jumlah pemanggilan API yang dikenai biaya untuk mengirim pesan.

    • uid

    • instance_id

    • topic

    • message_type="normal|fifo|transaction|delay"

    Gauge

    rocketmq_producer_messages

    message

    Jumlah pesan terkirim.

    • uid

    • instance_id

    • topic

    • message_type="normal|fifo|transaction|delay"

    Gauge

    rocketmq_producer_message_size_bytes

    byte

    Ukuran total pesan terkirim.

    • uid

    • instance_id

    • topic

    • message_type="normal|fifo|transaction|delay"

    Gauge

    rocketmq_producer_send_success_rate

    %

    Tingkat keberhasilan pengiriman pesan.

    • uid

    • instance_id

    • topic

    Gauge

    rocketmq_producer_failure_api_calls

    count

    Jumlah pemanggilan API gagal untuk mengirim pesan.

    • uid

    • instance_id

    • topic

    Gauge

    rocketmq_producer_send_rt_milliseconds_avg

    ms

    Waktu respons rata-rata untuk mengirim pesan.

    • uid

    • instance_id

    • topic

    Gauge

    rocketmq_producer_send_rt_milliseconds_min

    ms

    Waktu respons minimum untuk mengirim pesan.

    • uid

    • instance_id

    • topic

    Gauge

    rocketmq_producer_send_rt_milliseconds_max

    ms

    Waktu respons maksimum untuk mengirim pesan.

    • uid

    • instance_id

    • topic

    Gauge

    rocketmq_producer_send_rt_milliseconds_p95

    ms

    Persentil ke-95 waktu respons untuk mengirim pesan.

    • uid

    • instance_id

    • topic

    Gauge

    rocketmq_producer_send_rt_milliseconds_p99

    ms

    Persentil ke-99 waktu respons untuk mengirim pesan.

    • uid

    • instance_id

    • topic

    Metrik konsumen

    Jenis metrik

    Nama metrik

    Unit

    Deskripsi

    Label

    Gauge

    rocketmq_consumer_requests

    count

    Jumlah pemanggilan API untuk mengonsumsi pesan.

    • uid

    • instance_id

    • topic

    • client_group

    • protocol_type="tcp|http"

    Gauge

    rocketmq_consumer_send_back_requests

    count

    Jumlah pemanggilan API untuk mengembalikan pesan setelah kegagalan konsumsi.

    • uid

    • instance_id

    • topic

    • group_id

    Gauge

    rocketmq_consumer_send_back_messages

    message

    Jumlah pesan yang dikembalikan setelah kegagalan konsumsi.

    • uid

    • instance_id

    • topic

    • group_id

    Gauge

    rocketmq_consumer_messages

    message

    Jumlah pesan yang dikonsumsi.

    • uid

    • instance_id

    • topic

    • client_group

    • protocol_type="tcp|http"

    Gauge

    rocketmq_consumer_message_size_bytes

    byte

    Ukuran total pesan yang dikonsumsi.

    • uid

    • instance_id

    • topic

    • client_group

    • protocol_type="tcp|http"

    Gauge

    rocketmq_consumer_ready_and_inflight_messages

    message

    Total consumer lag, dihitung sebagai jumlah ready messages dan in-flight messages.

    • uid

    • instance_id

    • topic

    • group_id

    Gauge

    rocketmq_consumer_ready_messages

    message

    Jumlah pesan dalam antrian yang menunggu untuk ditarik oleh konsumen.

    Dihitung sebagai: maxOffset - lastPullOffset

    • uid

    • instance_id

    • topic

    • group_id

    Gauge

    rocketmq_consumer_inflight_messages

    message

    Jumlah pesan yang ditarik oleh konsumen tetapi belum dikonfirmasi.

    Dihitung sebagai: lastPullOffset - committedOffset

    • uid

    • instance_id

    • topic

    • group_id

    Gauge

    rocketmq_consumer_queue_time_milliseconds

    ms

    Waktu antrian pesan.

    • uid

    • instance_id

    • topic

    • group_id

    Gauge

    rocketmq_consumer_message_await_time_milliseconds_avg

    ms

    Waktu rata-rata pesan menunggu di buffer klien konsumen sebelum diproses.

    • uid

    • instance_id

    • topic

    • group_id

    Gauge

    rocketmq_consumer_message_await_time_milliseconds_min

    ms

    Waktu minimum pesan menunggu di buffer klien konsumen sebelum diproses.

    • uid

    • instance_id

    • topic

    • group_id

    Gauge

    rocketmq_consumer_message_await_time_milliseconds_max

    ms

    Waktu maksimum pesan menunggu di buffer klien konsumen sebelum diproses.

    • uid

    • instance_id

    • topic

    • group_id

    Gauge

    rocketmq_consumer_message_await_time_milliseconds_p95

    ms

    Persentil ke-95 waktu pesan menunggu di buffer klien konsumen sebelum diproses.

    • uid

    • instance_id

    • topic

    • group_id

    Gauge

    rocketmq_consumer_message_await_time_milliseconds_p99

    ms

    Persentil ke-99 waktu pesan menunggu di buffer klien konsumen sebelum diproses.

    • uid

    • instance_id

    • topic

    • group_id

    Gauge

    rocketmq_consumer_message_process_time_milliseconds_avg

    ms

    Waktu rata-rata yang dihabiskan konsumen untuk memproses pesan.

    • uid

    • instance_id

    • topic

    • group_id

    Gauge

    rocketmq_consumer_message_process_time_milliseconds_min

    ms

    Waktu minimum yang dihabiskan konsumen untuk memproses pesan.

    • uid

    • instance_id

    • topic

    • group_id

    Gauge

    rocketmq_consumer_message_process_time_milliseconds_max

    ms

    Waktu maksimum yang dihabiskan konsumen untuk memproses pesan.

    • uid

    • instance_id

    • topic

    • group_id

    Gauge

    rocketmq_consumer_message_process_time_milliseconds_p95

    ms

    Persentil ke-95 waktu pemrosesan pesan.

    • uid

    • instance_id

    • topic

    • group_id

    Gauge

    rocketmq_consumer_message_process_time_milliseconds_p99

    ms

    Persentil ke-99 waktu pemrosesan pesan.

    • uid

    • instance_id

    • topic

    • group_id

    Gauge

    rocketmq_consumer_consume_success_rate

    %

    Tingkat keberhasilan konsumsi pesan.

    • uid

    • instance_id

    • topic

    • group_id

    Gauge

    rocketmq_consumer_failure_api_calls

    count

    Jumlah pemanggilan API gagal untuk mengonsumsi pesan.

    • uid

    • instance_id

    • topic

    • group_id

    Gauge

    rocketmq_consumer_to_dlq_messages

    message

    Jumlah pesan yang dikirim ke dead-letter queue.

    • uid

    • instance_id

    • topic

    • group_id

    Dasbor

    1. Masuk ke Konsol Message Queue for Apache RocketMQ. Dari panel navigasi kiri, klik Instances.

    2. Di bilah menu atas, pilih wilayah, misalnya China (Hangzhou). Kemudian, di daftar instans, klik instans target.

    3. Anda dapat melihat dasbor dengan salah satu cara berikut:

      • Halaman Instance Details: Di halaman Instance Details, klik tab Dashboard.

      • Tab Dashboard: Di panel navigasi kiri, klik Dashboard.

      • Halaman Topic Details: Dari panel navigasi kiri, klik Topics. Di daftar topik, klik topik target. Di halaman Topic Details, klik tab Topic Overview.

      • Halaman Group Details: Dari panel navigasi kiri, klik Groups. Di daftar kelompok, klik kelompok target. Di halaman Group Details, klik tab Group Overview.

    FAQ Dasbor

    Akses data metrik dasbor

    1. Gunakan akun root Anda untuk masuk ke Konsol ARMS.

    2. Di panel navigasi kiri, klik Access Center.

    3. Di halaman Access Center, masukkan RocketMQ di kotak pencarian dan klik ikon pencarian.

    4. Dalam hasil pencarian, pilih layanan cloud yang ingin Anda integrasikan, misalnya Alibaba Cloud Message Queue for RocketMQ. Untuk informasi lebih lanjut tentang prosedur integrasi, lihat Langkah 1: Integrasi data pemantauan dari layanan cloud.

    5. Setelah integrasi berhasil, klik Integration Management di panel navigasi kiri.

    6. Di daftar Cloud Service Environment, klik nama lingkungan target untuk membuka halaman detailnya.

    7. Di tab Component Management, pada bagian Basic Information, klik wilayah layanan cloud di samping Prometheus instance.

    8. Halaman ini menyediakan berbagai metode untuk mengakses data.{key, select, RAM {RAM} Overview {Overview} Identities {Identities} Users {Users} Groups {Groups} Roles {Roles} Settings {Settings} Permissions {Permissions} Grants {Grants} Troubleshoot {Troubleshooting} Policies {Policies} Integrations {Integrations} Providers {SSO} Applications {OAuth (Preview)} CloudSSO {CloudSSO} AccessAnalyzing {Access Analysis} Analyzers {Analyzers} Findings {Findings} Beta {Beta} Governance {Cloud Governance} other {{key}} }

    Impor data ke Grafana yang dikelola sendiri

    Semua data metrik untuk Alibaba Cloud Message Queue for RocketMQ disimpan di Layanan Prometheus Alibaba Cloud Anda. Ikuti langkah-langkah dalam Bagaimana cara mendapatkan data metrik dasbor? untuk mengintegrasikan layanan cloud dan mendapatkan nama lingkungan serta titik akhir API HTTP. Kemudian, gunakan API tersebut untuk mengimpor data ini ke Grafana yang Anda kelola sendiri. Untuk informasi lebih lanjut, lihat Gunakan titik akhir API HTTP untuk menghubungkan Grafana atau aplikasi yang dikelola sendiri guna mengakses data Prometheus.

    TPS rata-rata dan maksimum

    • TPS rata-rata = Total jumlah permintaan dalam periode 1 menit / 60 detik

    • TPS maksimum: Sistem mengambil sampel nilai TPS sekali per detik selama periode 1 menit. TPS maksimum adalah nilai tertinggi di antara 60 sampel tersebut.

    Contoh:

    Asumsikan suatu instans menghasilkan 60 pesan dalam satu menit (semuanya adalah pesan normal berukuran 4 KB).

    TPS rata-rata instans = 60 permintaan / 60 detik = 1 permintaan/detik

    TPS maksimum instans dihitung sebagai berikut:

    • Jika ke-60 pesan dikirim dalam detik pertama, TPS setiap detik dalam menit tersebut adalah 60, 0, 0, ..., 0.

      TPS maksimum instans adalah 60 permintaan/detik.

    • Jika 40 pesan dikirim pada detik pertama dan 20 pesan dikirim pada detik kedua, TPS setiap detik dalam menit tersebut adalah 40, 20, 0, 0, ..., 0.

      TPS maksimum instans adalah 40 permintaan/detik.