1

我在向服务器发送 2000 条消息的消费者和生产者上启用了 ACK。我看到的是消费者只收到了大约 1700 条消息。有人能告诉我出了什么问题吗?

我正在运行 rabbitmq-c 库中提供的示例代码

./amqp_producer 本地主机 5672 1000

1000 毫秒:自上次报告以来已发送 1000 - 1000 条 (999 Hz) 生产者 - 消息计数:2000 总时间,毫秒:2001 每秒总消息:999.083

root@ce-bras-mx240-e:/usr/sbin/rabbitmq_server-3.6.6 # sbin/rabbitmqctl list_connections send_cnt 列出连接... 2007 root@ce-bras-mx240-e:/usr/sbin/rabbitmq_server-3.6 .6 # sbin/rabbitmqctl list_channels messages_unacknowledged 列出频道 ... 0 # ./amqp_consumer localhost 5672 3275 ms:自上次报告以来收到 1 - 1 (0 Hz) 3275 ms:自上次报告以来收到 2 - 1 (1919 Hz) 3277 ms : 自上次报告以来收到 3 - 1 (656 Hz) 4001 毫秒: 自上次报告以来收到 727 - 724 (999 Hz) 5000 毫秒: 自上次报告以来收到 1727 - 1000 (1001 Hz)

2000 件中只有 1727 件在消费者处收到。消费者将 no-ack 标志设置为 0。

4

1 回答 1

1

这只是显示问题。在提供的库中显示来自 amqp_consumer.cc 的摘要时存在错误,它错误地增加了收集下一个摘要的时间戳。

于 2017-01-18T13:48:19.843 回答