我在向服务器发送 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。