生产者发送消息的时候，需要通过exchange+queue，那么这个过程中就可能出现收不到或者是路由不成功的情况。
就需要通过发送返回状态来进行，完整性的处理。
一般我们在处理实际业务的时候，流程如下：
第一步：肯定是先把一些业务处理写入数据库
第二步：发送（Producer==>Exchange==>Queue==>Consumer)
能不能发送成功，就需要通过回调来了。
1、配制里加一下。
spring.rabbitmq.publisher-confirm-type=correlated spring.rabbitmq.publisher-returns=true
2、调用包，并且实现。
import org.springframework.amqp.rabbit.core.RabbitTemplate.ConfirmCallback;
import org.springframework.amqp.rabbit.core.RabbitTemplate.ReturnsCallback;
ReturnCallback(过时了) ==> ReturnsCallback
@Component public class mqProducer implements ConfirmCallback,ReturnsCallback {
/**
* 不管成功于否，都会调用。
*/ @Override public void confirm(CorrelationData correlationData, boolean ack, String cause) { System.err.println("correlationData: " + correlationData);
if(ack){
//成功，处理写库，更新业务。
}else{
//失败
} } /** * 如果消息未从路由成功发送到队列那么会走这个回调，这里会把消息的整个明细返回
* 也就是说出错了，才会调用哦。 */ @Override public void returnedMessage(ReturnedMessage returned) { System.err.println("ReturnedMessage: " + returned); } }
调用：
rabbitTemplate.setConfirmCallback(this); rabbitTemplate.setReturnsCallback(this); CorrelationData correlationData = new CorrelationData("id_"+System.currentTimeMillis()+""); rabbitTemplate.convertAndSend("exchange1", "queue1", msg, correlationData);
//只要将queue改为不存在，就可以成功调用 returnedMessage。