RabbitMQ知识点整理7-queueDeclare方法详解

queueDeclare方法相对于exchangeDeclare方法而言, 重载的方法个数就少很多, 只有两个重载方法

1.Queue.DeclareOk queueDeclare() throws IOException;
2.Queue.DeclareOk queueDeclare(String queue, boolean durable, boolean exclusive, boolean autoDelete,
                                 Map<String, Object> arguments) throws IOException;

不带任何参数的queueDeclare 方法默认创建一个由RabbitMQ 命名的(类似这种amq.gen-LhQzlgv3GhDOv8PIDabOXA 名称，这种队列也称之为匿名队列)、排他的、自动删除的、非持久化的队列。

方法的参数详细说明如下:

queue: 队列的名称

durable: 设置是否持久化, true表示队列为持久化, 持久化的队列会存盘, 在服务器重启的时候会保证不丢失相关信息

exclusive: 设置是否排他, true表示队里为排他的, 如果一个队列被设置为排他队列, 该队列仅对首次声明它的连接可见, 并在连接断开时自动删除, (这里需要注意三点:1.排他队列是基于连接Connection可见的, 同一个连接的不同信道Channel是可以同时访问同一连接创建的排他队列;"首次"是指如果一个连接己经声明了一个排他队列，其他连接是不允许建立同名的排他队列的，这个与普通队列不同;即使该队列是持久化的，一旦连接关闭或者客户端退出，该排他队列都会被自动删除，这种队列适用于一个客户端同时发送和读取消息的应用场景)

autoDelete: 设置是否自动删除。为true 则设置队列为自动删除。自动删除的前提是, 至少有一个消费者连接到这个队列，之后所有与这个队列连接的消费者都断开时，才会自动删除。不能把这个参数错误地理解为: "当连接到此队列的所有客户端断开时，这个队列自动删除"，因为生产者客户端创建这个队列，或者没有消费者客户端与这个队列连接时，都不会自动删除这个队列。

arguments: 设置队列的其他一些参数, 如 x-message-ttl等

注意: 生产者和消费者都能够使用queueDeclare 来声明一个队列，但是如果消费者在同一个信道上订阅了另一个队列，就无法再声明队列了。必须先取消订阅，然后将信道直为"传输"模式，之后才能声明队列。

对应于exchangeDeclareNoWait方法, 这里也有一个queueDeclareNoWait方法:

void queueDeclareNoWait(String queue, boolean durable, boolean exclusive, boolean autoDelete,
                            Map<String, Object> arguments) throws IOException;

方法的返回值也是void, 表示不需要服务器的任何返回, 同时也需要注意, 在调用完queueDeclareNoWait方法之后, 紧接着使用声明的队列时有可能发生异常情况

同样这里还有一个queueDeclarePassive的方法, 也比较常用, 这个方法用来检测相应的队列是否存在, 如果存在则正常返回, 如果不存在则抛出异常, 404 channel excaption, 同时Channel也会被关闭, 方法定义如下:

Queue.DeclareOk queueDeclarePassive(String queue) throws IOException;

与交换器对应，关于队列也有删除的相应方法:

1.Queue.DeleteOk queueDelete(String queue) throws IOException;
2.Queue.DeleteOk queueDelete(String queue, boolean ifUnused, boolean ifEmpty) throws IOException;
3.void queueDeleteNoWait(String queue, boolean ifUnused, boolean ifEmpty) throws IOException;

其中queue表示队列的名称, ifUnused可以参考 RabbitMQ知识点整理6-exchangeDeclare方法详解 中, ifEmpty设置为true表示在队列为空(队列里面没有任何消息堆积)的情况下才能够删除。

与队列相关的还有一个有意思的方法一queuePurge ，区别于queueDelete ，这个方法用来清空队列中的内容，而不删除队列本身，具体定义如下:

Queue.PurgeOk queuePurge(String queue) throws IOException;