=====这是一个广告位,招租中,联系qq 78315851====
2 条回复 A 作者 M 管理员
  1. RocketMQ 提供了一些 Metrics 指标用于表示 TPS (Transaction Per Second) 性能数据,具体如下:

    1. rocketmq_producer_transaction_put_msg_succ_count: 表示成功提交事务消息的数量。
    2. rocketmq_consumer_get_trans_msg_num: 表示消费者收到事务消息的数量。
    3. rocketmq_store_get_transactionmsg_size: 表示事务消息的数量。
    4. rocketmq_producer_batch_msg_succ_count: 表示成功提交批量事务消息的数量。
  2. 在RocketMQ 5.1.4中,生产消息的TPS(每秒事务数)可以通过”Producer Send Success Count”这个指标进行衡量。这个指标代表了每秒钟生产者成功发送消息的数量。这些Metrics指标以Prometheus格式公开,覆盖了Broker、Proxy和Producer等多个阶段的信息。

  3. 可以通过 rocketmq_messages_in_total 计算下
    “rocketmq_broker_permission”,
    “rocketmq_consumer_inflight_messages”,
    “rocketmq_consumer_lag_latency_milliseconds”,
    “rocketmq_consumer_lag_messages”,
    “rocketmq_consumer_queueing_latency_milliseconds”,
    “rocketmq_consumer_ready_messages”,
    “rocketmq_message_size_bucket”,
    “rocketmq_message_size_count”,
    “rocketmq_message_size_sum”,
    “rocketmq_messages_in_total”,
    “rocketmq_messages_out_total”,
    “rocketmq_pop_buffer_scan_time_consume_milliseconds_bucket”,
    “rocketmq_pop_buffer_scan_time_consume_milliseconds_count”,
    “rocketmq_pop_buffer_scan_time_consume_milliseconds_sum”,
    “rocketmq_pop_checkpoint_buffer_size”,
    “rocketmq_pop_offset_buffer_size”,
    “rocketmq_pop_revive_lag_milliseconds”,
    “rocketmq_pop_revive_latency_milliseconds”,
    “rocketmq_pop_revive_out_message_total”,
    “rocketmq_processor_watermark”,
    “rocketmq_producer_connections”,
    “rocketmq_proxy_up”,
    “rocketmq_rpc_latency_milliseconds_bucket”,
    “rocketmq_rpc_latency_milliseconds_count”,
    “rocketmq_rpc_latency_milliseconds_sum”,
    “rocketmq_storage_dispatch_behind_bytes”,
    “rocketmq_storage_flush_behind_bytes”,
    “rocketmq_storage_message_reserve_time_milliseconds”,
    “rocketmq_storage_size_bytes”,
    “rocketmq_throughput_in_total”,
    “rocketmq_throughput_out_total”,
    “rocketmq_timer_dequeue_lag”,
    “rocketmq_timer_dequeue_latency_milliseconds”,
    “rocketmq_timer_enqueue_lag”,
    “rocketmq_timer_enqueue_latency_milliseconds”,
    “rocketmq_timing_messages”,
    此回答整理自钉群“群2-Apache RocketMQ 中国开发者钉钉群”