如何在Rabbit.js中实现非阻塞PUSH消息？

Question

我的应用程序当前使用RabbitMQ排队和处理消息以启动数据流并将流数据传递到处理区域。

由于我们只希望一个客户端使用数据流，只有一个客户端处理流数据，因此我正在使用PUSH消息。

我发现的问题是，如果我确认PUSH消息启动数据流并且该过程失败，则不会重新发送消息。如果我不承认该消息，则在我确认数据流消息或过程中断之前，不会收到其他任何PUSH消息。

我查看了REQUEST/REPLY消息，但是我认为同样的问题可能适用于这里，如果流程/服务器死亡，我需要自动重新请求。

是否可以使用非阻塞PUSH消息？

Answer 1

也许值是消费者的“qos”/预取设置：https://www.rabbitmq.com/consumer-prefetch.html可以将该值设置为大于1，以允许单个消费者一次获取多条消息。这是否会导致您正在查找的非阻塞PUSH（只读）消息？