[大数据]RabbitMQ交换器和队列声明以及绑定详解（二）

连接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交换器可以看作是一个队列。