RabbitMQ 高级特性——变乱

  
媒介

前面我们学习了 RabbitMQ 的耽误队列，通过耽误队列可以实现生产者生产的消息不是立刻被消耗者消耗。那么这篇文章我们未来学习 RabbitMQ 的变乱。
变乱

RabbitMQ 是基于 AMQP 协议实现的，该协议实现了变乱机制，因此 RabbitMQ 也支持变乱机制。Spring AMQP 也提供了对变乱相干的利用。RabbitMQ 变乱允许开辟者确保消息的发送和吸取是原子性的，要么全部乐成，要么全部失败。然而，必要明白的是，RabbitMQ 的变乱支持紧张会集在生产者（发送方）端，而且它大概不是处理惩罚高并发场景下的最佳实践，由于利用变乱会增长消息发送的耽误和复杂性。
那么我们来看看在 Spring 中怎样实现 RabbitMQ 变乱。
先来看看在没有变乱的环境下是否可以或许包管消息发送的原子性：

1. public static final String TRANS_EXCHANGE = "trans.exchange";
2. public static final String TRANS_QUEUE = "trans.queue";

复制代码

声明交换机、队列和绑定关系：

1. @Configuration
2. public class TransConfig {
3.    
4.    
5.     @Bean("transExchange")
6.     public Exchange transExchange() {
7.    
8.    
9.         return ExchangeBuilder.directExchange(Constants.TRANS_EXCHANGE).build();
10.     }
12.     @Bean("transQueue")
13.     public Queue transQueu

复制代码