3.使用交换器和队列

文章参考：Rabbit实战指南

声明一个交换器和队列

channel.exchangeDeclare(exchangeName,"direct",true);
String queueName = channel.queueDeclare().getQueue();
channel.queueBind(queueName,exchangeName,routingKey);

上面创建了一个持久化的、非自动删除的、绑定类型为direct的交换器，同时创建了一个非

持久化的、排他的、自动删除的队列（此队列名称由RabbitMQ自动生成）。这里的交换器和队列也没有设置特殊的参数。

上面代码也展示了如何使用路由键将队列和交换器绑定起来。上面声明的队列具有如下特性：

只对当前应用中同一个Connection层面可用，同一个Connection的的不同Channel可共用，并且会在应用连接断开时自动删除。

如果要在应用中共享一个队列，可以做如下声明

channel.exchangeDeclare(exchangeName,"direct",true);
channel.queueDeclare(queueName,true,false,false,null);
channel.queueBind(queueName,exchangeName,routingKey);

队列被声明为持久化的、非排他的、非自动删除的，而且也被分配到另一个确定的已知的名称。

exchangeDeclare方法

exchangeDeclare有多个重载方法，这些重载方法都是由下面这个方法中缺省的某些参数构成的。

Exchange.DeclareOk exchangeDeclare(String exchange,String type,boolean durable,boolean autoDelete,boolean internal,
 Map<String,Object> arguments) throws IOException;

这个方法返回值是Exchange.DeclareOK，用来标识成功声明了一个交换器。

• exchange:交换器名称
• type:交换器类型，常见的如fanout、direct、topic
• durable:设置是否持久化。durable设置为true标识持久化，反之是非持久化。持久化可以将交换器存盘，在服务器重启的时候不会丢失相关信息。
• autoDelete:设置是否自动删除。autoDelete设置为true则表示自动删除。自动删除的前提是至少有一个队列或者交换器与这个交换器绑定，之后所有与这个交换器绑定的队列或者交换器都与此解绑。
• internal：设置是否内置的。如果设置为true，则表示是内置的交换器，客户端程序无法直接发送消息到这个交换器中，只能通过交换器路由到交换器这种方式。
• argument：其他一些结构化参数，比如alternate-exchange。

queueDeclare方法

queueDeclare只有两个重载方法

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

不带任何参数的queueDeclare方法默认创建一个由RabbitMQ命名、排他的、自动删除的、非持久化的队列。

方法参数：

• queue：队列名称
• durable：设置是否持久化。为true则设置队列为持久化。持久化的队列会存盘，在服务器重启的时候可以保证不丢失相关信息。
• exclusive：设置是否排他。为true则设置队列为排他的。如果一个队列被声明为排他队列，该队列仅对首次声明它的连接可见，并在连接断开时自动删除。
  • 注意：
  • 排他队列是基于连接可见的，同一个连接（connection）的不同信道（channel）是可以同时访问同一连接创建的排他队列；
  • “首次”是指如果一个连接已经声明了一个排他队列，其他连接时不允许建立同名的排他队列的，这个与普通队列不同
  • 即使该队列是持久化的，一旦连接关闭或者客户端退出，该排他队列都会被自动删除，这种队列适合用于一个客户端同时发送和读取消息的场景。
• autoDelete：设置是否自动删除。为true则设置队列为自动删除。自动删除的前提是：至少有一个消费者连接到这个队列，之后所有与这个队列连接的消费者都断开时，才会自动删除。不能把这个参数错误地理解为：“当连接到此队列的所有客户端断开时，这个队列自动删除”，因为生产者客户端创建这个队列，或者没有消费者客户端与这个队列连接时，都不会自动删除这个队列。
• argument：设置队列的其他一些参数，如x-message-ttl、x-expires、x-max-length等

注意要点：

​ 生产者和消费者都可以使用queueDeclare来声明一个队列，但是如果消费者在同一个信道上订阅了另一个队列，就无法再声明队列了。必须先取消订阅，然后将信道设置为“传输”模式，之后才能声明队列

queueBind方法

​ 将队列和交换器绑定的方法如下，可以与前两节中的方法定义进行类比。

//(1)
Queue.BindOk queueBind(String queue,String exchange,String routingKey) throws IOException;
//(2)
Queue.BindOk queueBind(String queue,String exchange,String routingKey,Map<String,Object> arguments) throws IOException;
//(3)
void queueBindNoWait(String queue,String exchange,String routingKey,Map<String,Object> arguments) throws IOException;

方法参数详解：

• queue:队列名称
• exchange：交换机名称
• routingKey：用来绑定队列和交换机的路由键
• argument：定义绑定的一些参数

不仅可以将队列和交换器绑定起来，也可以将被绑定的队列和交换器进行解绑。方法如下：

//(1) 
Queue.UnbindOk queueUnbind(String queue,String exchange,String routingKey) throws IOException;
//(2)
Queue.UnbindOk queueUnbind(String queue,String exchange,Stirng routingKey,Map<String,Object> argument) throws IOException;

exchangeBind 方法

​ 不仅可以将交换机与队列绑定，也可以将交换器与交换器绑定，后者和前者的用法如出一辙。方法如下：

//(1)
Exchange.BinOk exchangeBind(String destination,String source, String routingKey)throws IOException;
//(2)
Exchange.BinOk exchangeBind(String destination,String source, String routingKey,Map<String,Object> arguments)throws IOException;
//(3)
void exchangeBindNoWait(String destination,String source,String routingKey, Map<String,Object> arguments) throws IOException;

​ 绑定之后，消息从source交换器转发到destination交换器，某种程度上说destination交换器可以看做一个队列。

channel.exchangeDeclare("source","direct",false,true,null);
channel.exchangeDeclare("destination","fanout",false,true,null);
channel.exchangeBind("destination","source","exKey");
channel.queueDeclare("queue",false,false,true,null);
channel.queueBind("queue","destination","");
channel.basicPublish("source","exKey",null,"exToExDemo".getBytes());

生产者发送消息至交换器source中，交换器source根据路由键找到与其匹配的另一个交换器destination中，进而存储在destination绑定的queue中。