简介

? ? ? ? 本文用实例介绍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：用在类上

需配合 @RabbitHandler 注解一起使用
@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

简介

@Headers 必须通过Map接收。
@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);
}