RabbitMQ交换器和队列声明以及绑定详解（二）

不念不忘少年蓝@ 2022-09-01 08:58 315阅读 0赞

### 连接RabbitMQ ###

ConnectionFactory factory = new ConnectionFactory();
            factory.setHost("localhost");
            factory.setPort(AMQP.PROTOCOL.PORT);
            factory.setUsername("guest");
            factory.setPassword("guest");
            Connection connection = factory.newConnection();
            Channel channel = connection.createChannel();

在创建Channel之后，就可以使用Channel来发送消息。

Connection可以用来创建多个Channel实例，但是Channel实例不能再线程间共享，应用程序应该为每一个线程开辟一个Channel。

### 使用交换器和队列 ###

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

上面创建了一个持久化的、非自动删除的、绑定类型为direct的交换器。同时创建了一个非持久化的、排他、自动删除的队列。上面声明的队列具有如下特性：只对当前应用中的同一个Connection层面可用，同一个Connection的不同Channel可公用，并且会在应用连接关闭的时候自动删除。

channel.exchangeDeclare(exchangeName, ExchangeTypes.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：交换器的名称。

type：交换器的类型，常见的由direct、topic、fanout。

durable：设置是否持久化。durable设置为true为持久化，反之为非持久化。持久化可以将交换器存盘，在服务器重启的时候不会丢失相关信息。

autoDelete：试着是否自动删除。设置为true则表示自动删除。自动删除的前提是至少有一个队列或者交换器与这个交换器绑定，之后所有与这个交换器绑定的队列或者交换器都与此解绑。

internal：设置是否是内置的。设置为true，则表示是内置的交换器，客户端程序无法直接发送消息到这个交换器中，只能通过交换器路由到交换器这种方式。

argument：其他的一些结构化参数。

其他的构造方法可以自己查看一下源码。

与exchangeDeclare相似的还有几个方法比如exchangeDeclareNoWait：

void exchangeDeclareNoWait(String exchange,
                                   String type,
                                   boolean durable,
                                   boolean autoDelete,
                                   boolean internal,
                                   Map<String, Object> arguments) throws IOException;

与exchangeDeclare不同的是这个方法没有返回值，而exchangeDeclare的返回值是Exchange.DeclareOk意思是再客户端声明一个交换器之后需要等待服务器返回Exchange.DeclareOk这个命令，而exchangeDeclareNoWait则不需要服务起返回任何值，就会存在声明完一个交换器之后（服务器还没有完成交换器的创建），那么客户端立刻使用此交换器就会发生异常，所以没有特殊的缘由和应用场景这个方法一般不会使用。

exchangeDeclarePassive方法是用来检测交换器是否存在。如果存在则返回正常，如果不存在则抛出异常。

Exchange.DeleteOk exchangeDelete(String exchange, boolean ifUnused) throws IOException;
    
        void exchangeDeleteNoWait(String exchange, boolean ifUnused) throws IOException;
    
        Exchange.DeleteOk exchangeDelete(String exchange) throws IOException;

这几个方法是用来删除交换器，exchange是交换器的名字，ifUnused用来设置是否在交换器没有被使用的情况下删除。如果isUnused设置为true，则表示此交换器只有在没有被使用的情况下才会被删除，false表示无论什么情况都删除。

### 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：是否是持久化。

exclusive：是否是排他。true排他，排他队列只对首次创建它的连接可见，并在连接断开的时候自动删除。这里需要直以三点他是基于连接可见的，同一个连接（Connection）的不同信道（Channel）是可以同时访问同一个连接常见的排他队列；如果一个连接创建了一个排他队列，其他连接不允许创建同名的排他队列；排他队列即使是持久化的，以但连接关闭或客户端退出，该队列都会被删除。

autoDelete：是否自动删除。true自动删除。自动删除的前提是至少有一个消费者连接到这个队列，之后所有与这个队列连接的客户端都断开时才会自动删除。

arguments：设置一些其他参数。

与exchangeDeclare相似的是，queueDeclare也有一个queueDeclareNoWait方法，以及queueDeclarePassive、queueDelete、queueDeleteNoWait方法。

### queueBind方法详解 ###

queueBind方法是将将交换器和队列绑定。

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

方法参数说明：

queue：队列名称。

exchange：交换器名称。

routingKey：用来绑定交换器和队列的路由键。

argment: 定义绑定的一些参数。

Queue.UnbindOk queueUnbind(String queue, String exchange, String routingKey) throws IOException;
    
    Queue.UnbindOk queueUnbind(String queue, String exchange, String routingKey, Map<String, Object> arguments) throws IOException;

这两个方法是将交换器和队列解绑。

### exchangeBind方法详解 ###

交换器不仅可以和队列绑定，也可以和交换器绑定，两者用法如出一辙，相应方法如下：

Exchange.BindOk exchangeBind(String destination, String source, String routingKey) throws IOException;
    
    Exchange.BindOk exchangeBind(String destination, String source, String routingKey, Map<String, Object> arguments) throws IOException;
    
    void exchangeBindNoWait(String destination, String source, String routingKey, Map<String, Object> arguments) throws IOException;

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