rabbitmq优先级队列_rabbitmq 优先级队列

实现优先级队列

1.队列需设置为优先级队列

2.消息需设置优先级

注： 消费者需等消息全部进入队列后再消费，消息才能进行优先级排队

(1)队列设置为优先级队列

    //声明队列
    @Bean
    public Queue confirmQueue(){
        Map<String,Object> params = new HashMap<>();
        //最大优先级为10
        params.put("x-max-priority",10);
        return new Queue(CONFIRM_QUEUE_NAME,true,false,false,params);
    }
1
2
3
4
5
6
7
8

(2)消息设置优先级

    @GetMapping("/Message/{message1}/{message2}")
    public void Message(@PathVariable String message1,@PathVariable String message2){
        //消息1
        rabbitTemplate.convertAndSend(ConfirmConfig.CONFIRM_EXCHANGE_NAME,ConfirmConfig.CONFIRM_ROUTING_KEY,
                message1,msg -> {
            //设置优先级，数字越大优先级越高
            msg.getMessageProperties().setPriority(1);
            return msg;
                });
        //消息2
        rabbitTemplate.convertAndSend(ConfirmConfig.CONFIRM_EXCHANGE_NAME,ConfirmConfig.CONFIRM_ROUTING_KEY,
                message2,msg -> {
                    msg.getMessageProperties().setPriority(2);
                    return msg;
                });
    }
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16

当消息进入队列后，开启消费者，消费者会根据优先级消费消息2再消费消息1。