RabbitMq 之exchangeDeclare 方法详解

Posted 2023-05-02

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

这个方法的返回值是 Exchange.DeclareOK 用来标识成功声明了一 交换器。
~ exchange 交换器的名称。
~ type 交换器的类型，常见的如 fanout direct topic
~ durable: 设置是否持久 durab 设置为 true 表示持久化， 反之是非持久 。持 可以将交换器存盘，在服务器重启 的时候不会丢失 关信息。
~ autoDelete 设置是否自动删除。 autoDelete 设置为 true 表示自动删除。自动 删除的前提是至少有 个队列或者交换器与这个交换器绑定 之后所有与这个交换器绑 定的队列或者交换器都与 解绑。注意不能错误地 这个参数理解为 "当与此交换器 连接的客户端都断开时 RabbitMQ 会自动 除本交换器
~ internal 设置是否是内置的。如果设置为 true ，则表示是内置的交换器，客户端程 序无法直接发送消息到这个交换器中，只能通过交换器路由到交换器这种方式。
~ argument 其他一些结构化参数，比如 ternate exchange

与exchangeDeclare 师出同门的还有几个方法， exchangeDeclareNoWait 方法：

这个 exchangeDeclareNoWait 比 exchangeDeclare 多设置了 nowait 参数，这个 nowait 参数指的是 不需要服务器返 回，注意这个方法的返回值是 void ，而普通的 exchangeDeclare 方法的返回值是 Exchange.DeclareOk，意思是在客户端声明了一个交换器之后，需要等待服务器的返回(服 务器会返回 Exchange Declare-Ok 这个 AMQP 命令)。

针对 "exchangeDeclareNoWait 不需要服务器任何返回值"这一点 考虑这样一种情况 在声明完一个交换器之后(实际服务器还并未完成交换器的创建) 那么此时客户端紧接着使用 这个交换器，必然会发生异常。如果没有特殊的缘由和应用场景，并不建议使用这个方法。

这里还有师出同门的另一个方法 exchangeDeclarePassive ，这个方法的定义如下：

这个方法在实际应用过程中还是非常有用的，它主要用来检测相应的交换器是否存在。如果 存在则正常返回:如果不存在则抛出异常 404 channel exception ，同时 Channel 也会被关闭。

有声明创建交换器的方法，当然也有删除交换器的方法。相应的方法如下

其中 exchange 表示交换器的名称，而 ifUnused 用来设置是否在交换器没有被使用的情 况下删除 如果 isUnused 设置为 true ，则只有在此交换器没有被使用的情况下才会被删除 如果设置 false ，则无论如何这个交换器都要被删除。

使用代码创建rabbitmq交换机和队列绑定

1、获取channel对象

2、声明（创建）对列

// 第一个参数，queueName:对列名称
channel.queueDeclare(queueName, false, false, false, null);

3、创建交换机

// 第一个参数，exchange：交换机名称
// 第二个参数，type：交换机的类型(direct/topic/fanout)
channel.exchangeDeclare(exchange, type);

4、绑定交换机和队列

//第一个参数，queueName:对列名称
//第二个参数，exchange：交换机名称
//第三个参数，routingKey：队列跟交换机绑定的键值
channel.queueBind(queueName, exchange, routingKey);