我在消费者和生产者上启用了ACK,正在向服务器发送2000条消息。我看到的是消费者只收到了大约1700条消息。有人能说出哪里出了问题吗?
我正在运行rabbitmq-c库中提供的示例代码
./amqp_producer localhost 5672 1000
1000ms:自上次报告以来发送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 ms:自上次报告(999 Hz)以来接收的727 - 724毫秒:自上次报告(1001 Hz)以来接收的1727 - 1000
在2000个消费者中,只有1727个被接收到。消费者将no-ack标志设置为0。
发布于 2017-01-18 21:48:20
这只是显示问题。在提供的库中显示来自amqp_consumer.cc的摘要时出现错误,该库增加了错误收集下一个摘要的时间戳。
https://stackoverflow.com/questions/41720312
复制相似问题