RabbitMq发送方确认
上一节中我们介绍通过事务机制来保证生产者将消息发送到broker中，但是其问题是每次都需要broker做出确认性的响应，因此对其效率有很大的影响，那么还有其他的方式可以做这件事，那么还效率高呐？这就是这里要介绍的发送方确认机制。
首先生产者将信道设置为confirm模式，进入确认模式之后。信道上边的消息就会被指定一个唯一的id，一旦消息被投递到所有匹配的队列之后，rabbitmq会发送一个basic.ack给生产者，这里返回的信息中包含唯一的id，这样生产者就知道了消息已经正确到达目的地。如果设置为持久化，那么在消息写入磁盘之后。rabbitmq才会将消息的basic.ack返回。当然也可以设置channel.basicAck的multiple参数，表示之前序号的消息均已经得到了处理。
相比于事务机制的阻塞模式，发送方确认机制最大的好处就是它是异步的。生产者发送一条消息，生产者就可以在等待信道返回确认的同时继续发送下一条消息。当消息最终得到确认之后，生产者应用程序便可以通过回调方法来处理该确认消息。如果broker因为自身导致消息丢失，那么会发送一条basic.nack。生产者据此进行相关的处理。大概得过程如下：
生产者确认机制我们之前的实例一直在用。这块的示例就是为了体现一下springboot下的相关配置。
/**
* template
* @param connectionFactory
* @return
*/
@Bean
public RabbitTemplate rabbitTemplate(CachingConnectionFactory connectionFactory) {
connectionFactory.setPublisherConfirms(true);
connectionFactory.setPublisherReturns(true);
RabbitTemplate rabbitTemplate = new RabbitTemplate(connectionFactory);
rabbitTemplate.setMandatory(true);
rabbitTemplate.setConfirmCallback((correlationData, ack, cause) -> log.info("消息发送成功:correlationData({}),ack({}),cause({})", correlationData, ack, cause));
rabbitTemplate.setReturnCallback((message, replyCode, replyText, exchange, routingKey) -> log.info("消息丢失:exchange({}),route({}),replyCode({}),replyText({}),message:{}", exchange, routingKey, replyCode, replyText, message));
return rabbitTemplate;
}本文参与 腾讯云自媒体同步曝光计划，分享自微信公众号。
原始发表：2021-03-12，如有侵权请联系 cloudcommunity@tencent.com 删除
评论
登录后参与评论
推荐阅读