我是 RabbitMQ 的新手,目前正在处理 RabbitMQ 在我的 Web 应用程序中发布确认确认。对于每个新请求,将消息发送到 RabbitMQ 服务器以异步处理它,并启用确认以从 RMQ 服务器获取确认。
在本地尝试时,在第一个请求中一切正常,但在后续请求中,出现以下错误“每个 RabbitTemplate 仅支持一个ConfirmCallback”。
经过一些研究,如果我在设置确认回调之前添加检查(template.isConfirmListener()),则不会出现错误。但是,如果需要,我们如何覆盖不同请求的确认回调?这是预期的行为还是我在这里做错了什么?
环境:
- Spring Boot 版本 2.1.7.RELEASE
- Java 8
请找到以下代码。
Controller 文件
package com.example.apis;
import java.util.UUID;
import org.springframework.amqp.rabbit.connection.CorrelationData;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.amqp.rabbit.core.RabbitTemplate.ConfirmCallback;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.ResponseBody;
@Controller
public class ProducerController {
@Autowired
private RabbitTemplate template;
private String exchange = "test";
private String routingKey = "test";
@GetMapping("/send")
@ResponseBody
public String sendRequestToRMQ() {
template.convertAndSend(exchange, routingKey, "Test Message", getCorrelationData());
template.setMandatory(true);
template.setConfirmCallback(new ConfirmCallback() {
@Override
public void confirm(CorrelationData correlationData, boolean ack, String cause) {
System.out.println("Confirm Callback!");
System.out.println(correlationData.getId());
System.out.println(ack);
}
});
return "Success";
}
@GetMapping("/send1")
@ResponseBody
public String sendRequestToRMQ2() {
template.convertAndSend(exchange, routingKey, "Test Message", getCorrelationData());
template.setMandatory(true);
template.setConfirmCallback(new ConfirmCallback() {
@Override
public void confirm(CorrelationData correlationData, boolean ack, String cause) {
System.out.println("Confirm Callback!");
System.out.println(correlationData.getId());
System.out.println(ack);
}
});
return "Success";
}
private CorrelationData getCorrelationData() {
return new CorrelationData(UUID.randomUUID().toString());
}
}
配置文件
package com.example.conf;
import org.springframework.amqp.rabbit.connection.CachingConnectionFactory;
import org.springframework.amqp.rabbit.connection.ConnectionFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
@Configuration
public class ConnectionConfig {
@Value("${spring.rabbitmq.host:localhost}")
public String host;
@Value("${spring.rabbitmq.port:5672}")
public int port;
@Value("${spring.rabbitmq.username:guest}")
public String username;
@Value("${spring.rabbitmq.password:guest}")
public String password;
@Value("${spring.rabbitmq.virtual-host:/}")
public String virtualHost;
@Bean
public ConnectionFactory getConnectionFactory(){
CachingConnectionFactory factory=new CachingConnectionFactory();
factory.setHost(host);
factory.setPort(port);
factory.setUsername(username);
factory.setPassword(password);
factory.setVirtualHost(virtualHost);
factory.setPublisherConfirms(true);
factory.setPublisherReturns(true);
return factory;
}
}
请帮助我。谢谢
最佳答案
不,这是预期行为:只能将一个 ConfirmCallback
注入(inject)到 RabbitTemplate
中。您需要考虑只在 @PostConstrcut
中的某个位置执行一次,但不是针对每个请求。当然,您可能需要修改逻辑,因为现在将为 RabbitTemplate
发起的所有请求共享 ConfirmCallback
。
您可以考虑在常用 ConfirmCallback
中使用一些智能逻辑,根据 getCorrelationData()
将请求存储在 map 中,并从回调方法恢复该条目。
关于java - 如何修复后续请求中的错误 "Only one ConfirmCallback is supported by each RabbitTemplate",我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/57806703/