SpringBoot整合RabbitMQ系列--注解的使用

以你之姓@ 2023-09-29 16:07 7阅读 0赞

原文网址：[SpringBoot整合RabbitMQ系列--注解的使用\_IT利刃出鞘的博客-CSDN博客][SpringBoot_RabbitMQ_--_IT_-CSDN]

## 简介 ##

本文用实例介绍SpringBoot中RabbitMQ相关的注解。

## @RabbitListener ##

### 用法1：用在方法上 ###

**说明**

当监听到队列中有消息时则会进行接收并处理。如果队列不存在，会报错。

**代码示例**

@Component
    public class Receiver {
        //也可监听多个队列：@RabbitListener(queues = {"hello", "hi"})
        @RabbitListener(queues = "hello")
        public void process(String hello) {
            System.out.println ("Receiver : "  + hello);
        }
    }

@RabbitListener 的 bindings 属性声明 Binding（若 RabbitMQ 中不存在该绑定所需要的 Queue、Exchange、RouteKey 则报错）

@RabbitListener(bindings = @QueueBinding(
            exchange = @Exchange(value = "topic.exchange",durable = "true",type = "topic"),
            value    = @Queue(value = "consumer_queue",durable = "true"),
            key = "key.#"
    ))
    public void processMessage1(Message message) {
        System.out.println(message);
    }

### 用法2：用在类上 ###

1.  需配合 @RabbitHandler 注解一起使用
2.  @RabbitListener 标注在类上面表示当有收到消息的时候，就交给 @RabbitHandler 的方法处理，具体使用哪个方法处理，根据 MessageConverter 转换后的参数类型判断。

@Component
    @RabbitListener(queues = "consumer_queue")
    public class Receiver {
        @RabbitHandler
        public void processMessage1(String message) {
            System.out.println(message);
        }
    
        @RabbitHandler
        public void processMessage2(byte[] message) {
            System.out.println(new String(message));
        }
    }

## @Payload 与 @Headers ##

**简介**

1.  @Headers 必须通过Map接收。
2.  @Header("amqp\_receivedRoutingKey") String routingKey 直接获取header中某一个key

### 用法1：获得bod和所有header ###

@RabbitListener(queues = "debug")
    public void processMessage1(@Payload String body, @Headers Map<String,Object> headers) {
        System.out.println("body：" + body);
        System.out.println("Headers：" + headers);
    }

### 用法2：获得body和所有header ###

@RabbitListener(queues = "debug")
    public void processMessage1(@Payload String body, @Header String token) {
        System.out.println("body：" + body);
        System.out.println("token：" + token);
    }

[SpringBoot_RabbitMQ_--_IT_-CSDN]: https://knife.blog.csdn.net/article/details/124996935