RabbitMQ消费的两种方式_rabbitmq如何消费

1、主动拉取消费

  @Resource
    private RabbitTemplate rabbitTemplate;
    public void  consumer(){
        rabbitTemplate.execute(channel -> {
            List list = new ArrayList();
            while (true) {
                GetResponse response = channel.basicGet("消费的对列名称", true);
                byte[] b = response.getBody();
                String json = new String(b);
                log.error(json);
                list.add(json);
            }
            return null;
        });
    }
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15

2、监听方式进行消费

  @RabbitListener(queuesToDeclare = @Queue(value = “消费的对列名称”))
    private void modelConvert(String content){
    业务逻辑代码
    }
1
2
3
4

提示：queuesToDeclare 标记会对没有创建的对列进行自动创建。