如何消费一条消息? [英] How to consume one message?
本文介绍了如何消费一条消息?的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!
问题描述
使用rabbitmq中的示例,消费者可以从队列中获取所有消息一度。如何使用一条消息并退出?
With example in rabbitmq, consumer get all messages from queue at one time. How to consume one message and exit?
QueueingConsumer consumer = new QueueingConsumer(channel);
channel.basicConsume(QUEUE_NAME, true, consumer);
while (true) {
QueueingConsumer.Delivery delivery = consumer.nextDelivery();
String message = new String(delivery.getBody());
System.out.println(" [x] Received '" + message + "'");
}
推荐答案
你必须声明basicQos设置从ACK到NACK状态一次获取一条消息并禁用自动ACK以明确给出确认。
You have to declare basicQos setting to get one message at a time from ACK to NACK status and disable auto ACK to give acknowledgement explicitly.
ConnectionFactory factory = new ConnectionFactory();
factory.setHost("localhost");
Connection connection = factory.newConnection();
Channel channel = connection.createChannel();
channel.basicQos(1);
channel.queueDeclare(QUEUE_NAME, true, false, false, null);
System.out.println("[*] waiting for messages. To exit press CTRL+C");
QueueingConsumer consumer = new QueueingConsumer(channel);
channel.basicConsume(QUEUE_NAME, consumer);
while(true) {
QueueingConsumer.Delivery delivery = consumer.nextDelivery();
int n = channel.queueDeclarePassive(QUEUE_NAME).getMessageCount();
System.out.println(n);
if(delivery != null) {
byte[] bs = delivery.getBody();
System.out.println(new String(bs));
//String message= new String(delivery.getBody());
channel.basicAck(delivery.getEnvelope().getDeliveryTag(), false);
//System.out.println("[x] Received '"+message);
}
}
希望有所帮助!
这篇关于如何消费一条消息?的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持IT屋!
查看全文