我使用python脚本(3.5.2)和RabbitMQ工作队列来处理数据。有一个队列,其中充满了外部系统的用户请求。这些用户请求将由我的python脚本处理,每个用户请求都会产生几条输出消息。我使用acknoledge功能来确保传入的消息只有在处理之后才会被删除。这确保了如果工作人员偶尔死亡,消息将被重新分配。但是,如果工作线程在发送消息过程中死亡,则此用户请求的一些消息可能已经发送到队列,而其他消息将不会发送。有没有办法自动发送多条消息,即发送所有消息或不发送消息?
发布于 2016-12-10 05:20:34
是的,存在将响应请求的所有消息包装为事务。
https://stackoverflow.com/questions/41064321
复制相似问题