Broker同步或异步调度消息到消费者都是可配置的。可以通过uri链接、Connection 和 ConnectionFactory 的形式配置，这种方式的配置可以替代以前那种只能通过在Broker端方式的配置。

无论同步或异步发送消息都是非常有意义的，因为针对消费比较快的消费者，我们使用同步（可以减少异步发送消息时产生的上下文切换），针对消费比较慢的消费者，我们使用异步。同步发送消息的缺点是，对于生产者发送的消息，如果消费者消费的比较慢，那么生产者就会被阻塞。

默认配置是异步发送（displayatchAsync=true），这种配置也保证了MQ的高性能。建议不要修改成同步，除非你非常确定，几乎不存在慢速消费者，这时同步才会提高吞吐率。

通过 ConnectionFactory 设置异步

((PMQConnectionFactory)connectionFactory).setDispatchAsync(true);

通过 Connection 设置异步：

queue = new PMQQueue("PMQ.QUEUE?consumer.dispatchAsync=false");
consumer = session.createConsumer(queue);

注：在此处设置的异步，将会覆盖 ConnectionFactory 的配置。

在代理端（Broker）强制同步

可以在代理端设置 disableAsyncDispatch 来关闭异步，一旦针对某个通信通道关闭了异步发送，客户端将不能再开启异步。

<transportConnector name="openwire" uri="tcp://0.0.0.0:61616" 
                                    disableAsyncDispatch="true"/>

3.3.7 同步和异步调度

results matching ""