RabbitMQ项目使用之死信队列

rabbitmq的三种模式：

一. Fanout Exchange  广播

所有发送到Fanout Exchange的消息都会被转发到与该Exchange 绑定(Binding)的所有Queue上。Fanout Exchange  不需要处理RouteKey 。只需要简单的将队列绑定到exchange 上。这样发送到exchange的消息都会被转发到与该交换机绑定的所有队列上。类似子网广播，每台子网内的主机都获得了一份复制的消息。所以，Fanout Exchange 转发消息是最快的。

二. Direct Exchange  点对点

所有发送到Direct Exchange的消息被转发到RouteKey中指定的Queue。Direct模式,可以使用rabbitMQ自带的Exchange：default Exchange 。所以不需要将Exchange进行任何绑定(binding)操作 。消息传递时，RouteKey必须完全匹配，才会被队列接收，否则该消息会被抛弃。

三. Topic Exchange  模糊匹配

所有发送到Topic Exchange的消息被转发到所有关心RouteKey中指定Topic的Queue上，Exchange 将RouteKey 和某Topic 进行模糊匹配。此时队列需要绑定一个Topic。可以使用通配符进行模糊匹配，符号“#”匹配一个或多个词，符号“*”匹配不多不少一个词。因此“log.#”能够匹配到“log.info.oa”，但是“log.*” 只会匹配到“log.error”。所以，Topic Exchange 使用非常灵活。

死信队列实现：

   详见官网说明： http://www.rabbitmq.com/ttl.html

在声明期间使用x参数为队列定义消息TTL

 如：spring 中配置如下：

<rabbit:connection-factory id="connectionFactory" host="47.104.203.101" password="admin"
                           username="admin" port="5672"
                           channel-cache-size="30" virtual-host="/citpay"
                           publisher-confirms="true"
                           publisher-returns="true"/>


<rabbit:template id="amqpTemplate" connection-factory="connectionFactory" mandatory="true"
                 confirm-callback="payOrderConfirmCallBack"
                 return-callback="payOrderReturnCallBack"/>

<rabbit:admin connection-factory="connectionFactory" />

<rabbit:queue id="pay_order_queue" name="citpay.pay_order_queue" durable="true" auto-delete="false" >
  <rabbit:queue-arguments>
      <entry key="x-message-ttl">
          <value type="java.lang.Long">5000</value>
      </entry>
      <entry key="x-dead-letter-exchange">
          <value type="java.lang.String">citpay.pay_order_dead_exchange</value>
      </entry>
  </rabbit:queue-arguments>
</rabbit:queue>

<rabbit:direct-exchange name="citpay.direct_pay_order_exchange" id="direct_pay_order_exchange" durable="true" auto-delete="false">
    <rabbit:bindings>
        <rabbit:binding queue="citpay.pay_order_queue" key="pay_order_routekey"/>
    </rabbit:bindings>
</rabbit:direct-exchange>

<rabbit:queue id="pay_dead_order_queue" name="citpay.pay_dead_order_queue" durable="true" auto-delete="false"></rabbit:queue>

<rabbit:direct-exchange name="citpay.pay_order_dead_exchange" id="pay_order_dead_exchange" durable="true" auto-delete="false">
    <rabbit:bindings>
        <rabbit:binding queue="citpay.pay_dead_order_queue" key="pay_order_routekey"/>
    </rabbit:bindings>
</rabbit:direct-exchange>


<rabbit:listener-container
        connection-factory="connectionFactory" acknowledge="manual" max-concurrency="1" >
    <rabbit:listener queues="citpay.pay_dead_order_queue"
                     ref="payOrderDeadReceiveConfirmListener" />
</rabbit:listener-container>

使用策略为队列定义队列TTL

  命令形式：
   rabbitmqctl set_policy expiry“。*”‘{“expires”：1800000}‘ -  apply-to queues

        管理控制台设置策略：