RabbitMQ 面试篇

    @RabbitListener(queues = "boot_queue")
    public void getMessage(Message message, Channel channel) throws IOException {
        long qps = 10;
        // prefetchSize(消息大小，0是不限制)、prefechSize(消息数量)、global(true 表示此通道的消费者都适用此策略，false代表仅当前消费者)
        channel.basicQos(0,qps,false);
        System.out.println(message); // 这里 不只是输出 单个 发送的信息，而是 全部输出 消息里面的内容数据
        channel.basicAck(message.getMessageProperties().getDeliveryTag(), true);
    }复制

// 添加tagid，是否确认
channel.basicAck(message.getMessageProperties().getDeliveryTag(), true);复制