问题标签 [message-ack]

我在为新的 SO 文档项目记录 Kombu 时偶然发现了这个问题。

考虑以下消费者 Mixin的 Kombu 代码：

代码失败：

因为消息被 ACK 了两次， onprint_even_characters()和print_odd_characters()。

一个可行的简单解决方案是仅确认最后一个回调函数，但如果我想在其他队列或连接上使用相同的函数，它会破坏模块化。

如何确认发送到多个回调函数的排队 Kombu 消息？

使用主题交换，我想要一个具有以下功能的发布/订阅消息模式：

1. 实施了“出版商确认”。
2. 让消费者在处理完每条消息后也对其进行确认。
3. 使用路由键将消息路由到一个或多个消费者。
4. 拥有持久的消费者队列，因此如果消费者应用程序暂时关闭，它可以在恢复时从其队列中获取消息。

所以我创建了 2 个控制台应用程序（发送和接收）来测试上述内容。

发送

出版商

}

收到

问题是我的Send程序中的OnBasicAcks只为第一条消息调用一次。