苏州建站公司优搜苏州聚尚网络,苏州市网站建设培训班,个人做网站的流程,免费推广渠道有哪些方式这是一些高级的内容。 RabbitMQ还是运行在网络上的#xff0c;倘若遇到了网络故障#xff0c;mq自己挂了#xff0c;出异常了#xff0c;都会造成最终状态不一致的问题。这就是可靠性问题。 可靠性#xff1a;一个消息发送出去之后#xff0c;至少被消费1次。 要解决这3个…这是一些高级的内容。 RabbitMQ还是运行在网络上的倘若遇到了网络故障mq自己挂了出异常了都会造成最终状态不一致的问题。这就是可靠性问题。 可靠性一个消息发送出去之后至少被消费1次。 要解决这3个问题
消息发送的时候丢了mq自己丢了消费者丢了 以上都失败了还得有一个兜底方案。这样尽可能万无一失了。
生产者重连
生产者连不上mq了此时发送直接失败。因此有了失败重连。 它会影响失败时候的性能因为mq主打不等所以生产环境建议禁用。
生产者确认
生产者开启确认机制后MQ收到消息后会返回消息给生产者
投递到MQ但是路由失败了。你的routingKey不对或者交换机没绑定。一般是开发人员的问题。投递到了MQ并且成功入队告知投递成功ACK。持久化消息入队成功完成持久化好后才会ACK。 其他情况都会返回NACK告知投递失败。
如何接收ack/nack
有同步和异步两个方法
先配置
Configuration
public class MqConfig implements ApplicationContextAware {Overridepublic void setApplicationContext(ApplicationContext applicationContext) throws BeansException {RabbitTemplate rabbitTemplate applicationContext.getBean(RabbitTemplate.class);rabbitTemplate.setReturnsCallback(new ReturnsCallback() {Overridepublic void returnedMessage(ReturnedMessage returned) {log.debug(收到消息的return callback);}});}
}Testvoid testConfirm() throws InterruptedException {CorrelationData correlationData new CorrelationData(UUID.randomUUID().toString());correlationData.getFuture().addCallback(new ListenableFutureCallbackCorrelationData.Confirm() {Overridepublic void onFailure(Throwable ex) {log.error(消息回调失败, ex);}Overridepublic void onSuccess(Confirm result) {log.debug(收到回执);if (result.isAck()) {log.debug(成功);} else {log.debug(失败);}}});rabbitTemplate.convertAndSend(hmall.direct11, blue11, hello,correlationData);Thread.sleep(2000);}情况总结
消息成功到达交换机但是没被路由返回ack但是有renturn消息。彻底成功持久化消息入队并且持久化成功返回ACK其他情况都会返回NACK告知投递失败。 注意nack是由 result.isAck() 为false返回出来的要关注这个选项。生产者确认有网络开销建议不开启。要开publisher-return 开这个就可以了。
数据持久化
消息发给mq但是mq自己挂了那么消息就丢失了。 或者mq内存空间有限消息积压引发mq阻塞。 mq在太满的时候会把消息存到硬盘上这个过程是阻塞的过程。 mq3.6之前用数据持久化解决
交换机的持久化
交换机持久化队列持久化 durable Spring 默认都是持久化的。 消息的持久化delivery_model 2 是消息的持久化。默认是1。 这个性能上不是很好。 接下来mq3.6之后有了惰性队列。 接收到消息后直接保存到磁盘。读消息就从磁盘中读取兵器加载到内存。内存只保存最近的2048条。在3.12之后所有队列都是Lazy Queue模式无法更改。 LazyQueue对写磁盘有优化。 消费者可靠性
消费者确认机制
消费者是否成功处理消息得有一个回执告诉到底是处理成功了还是失败了。
acknackreject
