0

我有一个发送消息 15 秒的生产者。我想调查发送到代理的消息总数。我采用的第一种方法涉及“手动”计数消息,即:

// ...
private int sentMessages = 0;

@Override
public void run() {
   sendMessage(msg));
   sentMessages++;
}

我使用的第二种方法涉及分析生产者的指标。

我比较了产生的消息的数量,我观察到的明显不同的结果让我感到困惑。sendMessages等于 ,65243而生产者的record-sent-total等于47883

他们之间如此巨大差异背后的原因可能是什么?

4

1 回答 1

0

我相信 sendMessage(msg) 以异步方式处理。所以有些消息可能无法发送。尝试根据成功响应更新 sentMessages 计数。

于 2021-12-28T16:42:19.290 回答