服务完成对上一条消息的处理后，从队列中消费消息

Question

我正在做一个 POC 来使用 RabbitMQ，并且对如何有条件地监听队列有疑问！

我们正在消费来自队列的消息，一旦消费，消息将参与上传过程，根据文件大小，该过程需要更长的时间。并且随着文件的大小变大，有时我们调用的外部服务会耗尽内存，如果多条消息被消费并且上传过程正在继续之前的消息。

也就是说，我们只想在当前/上一条消息被完全处理后才使用队列中的下一条消息。我是 JMS 新手，想知道该怎么做。

我目前的想法是，当代码流完成上一条消息的处理时，代码流将手动从队列中拉出下一条消息，因为流知道它已经完成了处理，但是如果该侦听器仅在代码流中使用手动调用，它将如何提取第一条消息！

Answer 1

JMS spec 表示消息消费者按顺序工作：

用于创建消息消费者的会话序列化 执行在会话中注册的所有消息侦听器

如果您创建一个MessageListener 并将其用于您的消费者，JMS 规范规定侦听器的onMessage 将按顺序调用，即在侦听器处理完每条消息后每条消息调用一次。因此，实际上每条消息都在等待上一条消息完成。