# 消息路由监控

{% hint style="success" %}

#### 消息路由监控

消息路由需要关注的一些信息，诸如消息同步TPS，消息延迟，消息堆积量，最新同步时间等
{% endhint %}

消息路由需要关注的一些信息

| **采集信息项** | **内容说明**              |
| --------- | --------------------- |
| 消息同步 TPS  | 每分钟统计一次消息同步的 TPS 值    |
| 消息延迟      | 当前同步到的位点和最新消息位点之间的时间差 |
| 消息堆积量     | 当前还没有来得及同步的消息数量       |
| 最新同步时间    | 最近一次消息同步发生的时间         |

对于获取并统计上面监控部分的信息，可以在**OpenMessaging Runtime**中通过Source/Sink Task中的接口方法—**poll()/put()**，进行监控项的计算，计算后再将这些信息进行持久化同步（通过“.Json”文件保存持久化），并回发给RMQ的Source集群的系统默认Topic（这里也需要再去定义一个系统默认Topic）。


---

# Agent Instructions: Querying This Documentation

If you need additional information that is not directly available in this page, you can query the documentation dynamically by asking a question.

Perform an HTTP GET request on the current page URL with the `ask` query parameter:

```
GET https://rocketmq-1.gitbook.io/rocketmq-connector/jia-gou-she-ji/lu-you-jian-kong.md?ask=<question>
```

The question should be specific, self-contained, and written in natural language.
The response will contain a direct answer to the question and relevant excerpts and sources from the documentation.

Use this mechanism when the answer is not explicitly present in the current page, you need clarification or additional context, or you want to retrieve related documentation sections.