如何使消费者与rabbitmq同步

Question

在RabbitMQ级别上是否有任何机制允许我使用下一个消息直到上一个消息被加密为止？还是必须在服务器之间开发某种锁定机制？

Answer 1

我只是引用了rabbitmq文档中的几个要点，我认为这些要点能够满足您的要求。

1. 第一参考文件-https://www.rabbitmq.com/consumer-priority.html

通常，连接到队列的活动使用者以循环方式从队列接收消息。在使用使用者优先级时，如果存在多个具有相同高优先级的活动使用者，则会循环传递消息。

正如您所提到的，您将在一台机器上拥有一个消费者，这就更容易了。

只需设置每个使用者的使用者预取限制1。因此服务器在要求确认之前只向使用者传递一条消息。并在消息完全处理后发送基本ack。

Channel channel = ...;
Consumer consumer = ...;
channel.basicQos(1); // Per consumer limit

Consumer consumer = new DefaultConsumer(channel) {
            @Override
            public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {

                System.out.println("received message");
                // process the message .. time consuming

                // after processing send the basic ack so that next message can be received from queue
                channel.basicAck(envelope.getDeliveryTag(), false);
        };

 channel.basicConsume("my-queue", false, consumer);

希望这能帮上忙。

channel.basicQos(x);

channel.basicQos(x, true);

限制x适用于整个信道，而不是信道上的单个/每个消费者。

在您的情况下，每个频道上只有一个消费者。所以渠道限制实际上对你的案例没有任何影响。

更多更新-