关于rabbitmq:RabbitMQ-消费者获取队列消息的两种模式

订阅模式-Push API

消息中间件被动将音讯推送给订阅的消费者，实时性好。

利用能够通过订阅特定的队列，获取到 RabbitMQ 被动推送（主动投递）的队列音讯。通过在队列中注册一个消费者实现。订阅胜利后，RabbitMQ 将开始投递音讯。每一次音讯投递都会调用用户提供的处理程序。处理程序须要遵循特定的接口。

订阅胜利会返回订阅标识符，能够用来勾销订阅。

boolean autoAck = false;channel.basicConsume(queueName, autoAck, "myConsumerTag",     new DefaultConsumer(channel) {         @Override         public void handleDelivery(String consumerTag,                                    Envelope envelope,                                    AMQP.BasicProperties properties,                                    byte[] body)             throws IOException         {             String routingKey = envelope.getRoutingKey();             String contentType = properties.getContentType();             long deliveryTag = envelope.getDeliveryTag();             // (process the message components here ...)             channel.basicAck(deliveryTag, false);         }     });

检索模式-Pull API

消费者被动从消息中间件中拉取音讯，实时性差。

利用能够通过 basic.get 办法，一条一条地从 RabbitMQ 中拉取音讯，音讯以先进先出的程序被拉取，能够主动或手动确认。

不倡议应用检索模式，与订阅模式相比效率极低。尤其在音讯公布数量少、队列长时间为空的利用中会造成大量资源节约。

boolean autoAck = false;GetResponse response = channel.basicGet(queueName, autoAck);if (response == null) {    // No message retrieved.} else {    AMQP.BasicProperties props = response.getProps();    byte[] body = response.getBody();    long deliveryTag = response.getEnvelope().getDeliveryTag();    // (process the message components here ...)    channel.basicAck(deliveryTag, false);}