[大数据]RabbitMQ-Queue

主要讨论队列声明的各个参数（本文基于SpringBoot集成）

1.通过RabbitMQ-Manager界面添加queue设置参数

2.通过Bena注入添加queue设置参数

@Configuration
public class RabbitmqConfig {
    @Bean
    public Queue queueWork_test() {
        return new Queue("queue_work_test", true, false, false, null);
    }
}

3.详解queue的各个参数

Queue(String name, boolean durable,boolean exclusive, boolean autoDelete, Map<String, Object> arguments) 

1. name: 队列名称。

2. durable： 队列是否持久化。 队列默认是存放到内存中的，rabbitmq重启则丢失，若想重启之后还存在则队列要持久化，保存到Erlang自带的Mnesia数据库中，当rabbitmq重启之后会读取该数据库

3. exclusive：是否排他的队列。有两个作用，
   一： 当连接关闭时connection.close()该队列是否会自动删除；
   二：设置队列是否是私有的，如果非排他(false)的，可以使用两个消费者都访问同一个队列，没有任何问题，如果是排他的，会对当前队列加锁，其他通道channel是不能访问的，如果强制访问会报异常：com.rabbitmq.client.ShutdownSignalException: channel error; protocol method: #method<channel.close>(reply-code=405, reply-text=RESOURCE_LOCKED - cannot obtain exclusive access to locked queue ‘queue_name’ in vhost ‘/’, class-id=50, method-id=20)一般等于true的话用于一个队列只能有一个消费者来消费的场景

4. autoDelete：是否自动删除，当最后一个消费者断开连接之后队列是否自动被删除，可以通过RabbitMQ Management，查看某个队列的消费者数量，当consumers = 0时队列就会自动删除

5. arguments： 队列中的消息什么时候会自动被删除 （设置死信交换器和死信队列等设置）
   一：Message TTL(x-message-ttl)：设置队列中的所有消息的生存周期(统一为整个队列的所有消息设置生命周期), 也可以在发布消息的时候单独为某个消息指定剩余生存时间,单位毫秒, 类似于redis中的ttl，生存时间到了，消息会被从队里中删除，注意是消息被删除，而不是队列被删除， 特性Features=TTL, 单独为某条消息设置过期时间AMQP.BasicProperties.Builder properties = new AMQP.BasicProperties().builder().expiration(“6000”);
   channel.basicPublish(EXCHANGE_NAME, “”, properties.build(), message.getBytes(“UTF-8”));
   二：Auto Expire(x-expires): 当队列在指定的时间没有被访问(consume, basicGet, queueDeclare…)就会被删除,Features=Exp
   三：Max Length(x-max-length): 限定队列的消息的最大值长度，超过指定长度将会把最早的几条删除掉， 类似于mongodb中的固定集合，例如保存最新的100条消息, Feature=Lim
   四：Max Length Bytes(x-max-length-bytes): 限定队列最大占用的空间大小， 一般受限于内存、磁盘的大小, Features=Lim B
   五：Dead letter exchange(x-dead-letter-exchange)： 当队列消息长度大于最大长度、或者过期的等，将从队列中删除的消息推送到指定的交换机中去而不是丢弃掉,Features=DLX
   六：Dead letter routing key(x-dead-letter-routing-key)：将删除的消息推送到指定交换机的指定路由键的队列中去, Feature=DLK
   七：Maximum priority(x-max-priority)：优先级队列，声明队列时先定义最大优先级值(定义最大值一般不要太大)，在发布消息的时候指定该消息的优先级， 优先级更高（数值更大的）的消息先被消费,
   八：Lazy mode(x-queue-mode=lazy)： Lazy Queues: 先将消息保存到磁盘上，不放在内存中，当消费者开始消费的时候才加载到内存中
   Master locator(x-queue-master-locator)

4.避坑

1：IOC创建的queue不会启动就创建，而是出现消息投递才会创建
2：同名队列IOC多次，设置参数与上一次不同，则会失败，必须删除同名队列，才能成功