#在单个请求中处理的消息个数，他应该大于等于事务数量(unack的最大数量)

spring.rabbitmq.listener.simple.prefetch=2

#在@RabbitListener(queues = { HighDeviceMessage.QUEUE_NAME },concurrency = "${spring.rabbitmq.highdevice.concurrency}")配置的占位符配置

spring.rabbitmq.highdevice.concurrency=2-5

@Component

public class HighDeviceMessageHandler {

//    @RabbitListener(queues = { HighDeviceMessage.QUEUE_NAME },ackMode ="MANUAL",concurrency = "1-10")

    @RabbitListener(queues = { HighDeviceMessage.QUEUE_NAME },ackMode ="MANUAL",concurrency = "${spring.rabbitmq.highdevice.concurrency}")

    public void handle(String msgStr, Channel channel,@Headers Map<String,Object> headers) {

        try {

            log.info("休息3秒");

            log.info("handle HighDeviceMessage:{}---",msgStr);

            TimeUnit.SECONDS.sleep(3);

            long deliveryTag = (Long)headers.get(AmqpHeaders.DELIVERY_TAG);

            //手工ack

            channel.basicAck(deliveryTag,true);

        } catch (Exception e) {

            log.error("handle HighDeviceMessage err", e);

        }

    }

}