java - Spring RabbitListener 在发送消息后调用一个方法

Question

在我的接收器处理了特定数量的消息后，我需要停止 Rabbit 监听器并调用一个方法，然后再次启用监听器。

@RabbitListener(...)
public void sink(Message msg) {
    processMsg();

    if (condition) {
        rabbitListenerEndpointRegistry.stop();
        doTask();
        rabbitListenerEndpointRegistry.start();
    }
}

不幸的是，如果我停止接收器方法内的监听器，事务将失败并且消息将返回到队列。我正在寻找一种在事务完成且监听器不持有任何消息后调用方法的方法。

1. Receive a msg and process the msg
2. Finish the transaction and release the msg <- I don't want to receive any new msgs after this point
3. If the condition is satisfied stop the listener
4. Do a long running task
5. Start the listener

我无法转向手动事务管理，因为它需要对代码进行太多更改，并且在执行自定义任务时我无法保留任何消息，因为它是一个长时间运行的任务，并且我希望其他工作人员处理这段时间的消息。

Rabbit 工厂配置中的

setAfterReceivePostProcessors 和 setAdviceChain 在我的情况下不起作用，因为在这两种情况下，当监听器持有消息时都会调用该方法。

Answer 1

消息监听器容器似乎不适合您的应用程序；您需要一个“拉动”模型。

您可以使用 rabbitTemplate.receive() 或 receiveAndConvert() 方法来按需拉取消息。

如果您在事务之外使用它们，消息将立即得到确认；如果您希望在流程完成后确认消息，请在事务中运行它。