rabbitMQ读取一个值也会清除que中的其他值

Question

我的问题是：

我想将2个对象写入RabbitMQ并且只读取1个（这是一个测试，以确保如果读取器突然停止，例如ctrl c，我的数据会保留在RabbitMQ中）。我写入MQ没有问题，但是当我只读取一个对象并关闭连接时，另一个对象也会消失。我不知道为什么会发生这种情况。

我遵循了在这里给出的指示

创建频道:

 ConnectionFactory factory = new ConnectionFactory();
 factory.setHost("127.0.0.1");
 factory.setPort(5672);
 Connection connection = factory.newConnection();
 Channel channel =  connection.createChannel();

写入RabbitMQ（写入MQ没有问题）

channel.queueDeclare("myque", false, false, false, null);
channel.basicPublish("", "myque", null, "one".getBytes("UTF-8"));
channel.basicPublish("", "myque", null, "two".getBytes("UTF-8"));

我阅读的方式是：

QueueingConsumer consumer =new QueueingConsumer(channel);
channel.basicConsume("queuethroughProxy", true, consumer);
//while(true){
   QueueingConsumer.Delivery delivery = consumer.nextDelivery();
   String message = new String(delivery.getBody());
   System.out.println("message is : " + message);
//}
connection.close();

我不太确定我在这里做错了什么。

Answer 1

我猜你是迷糊在线上了

< code>QueueingConsumer。delivery delivery = consumer . nextdelivery()；

人们可能会认为是调用消费者。nextDelivery（）将从代理获取下一条消息。

但是如果你看到文档中说：“由于服务器将异步推送消息，我们提供了一个对象形式的回调，它将缓冲消息，直到我们准备好使用它们。这就是QueueingConsumer所做的。”

由于启用了auto_ack，一旦消费者被创建，服务器将立即将2条消息推送给消费者。consumer.next交付（）只是遍历客户端已经收到的消息。

Answer 2

你在这里犯了两个错误。

1. 未设置频道。基本Qos（1）--

这些是您丢失队列中所有消息的原因，尽管您消耗了一个。

你可以在这里参考我的博客来了解更多的细节。