RabbitMq 之exchangeDeclare 方法详解

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

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

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

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

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

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

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

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

Exchange.DeclareOk exchangeDeclarePassive(String name) throws IOException;

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

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

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

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

最后编辑于：2019.07.21 18:22:17