0
点赞
收藏
分享

微信扫一扫

SpringBoot整合RabbitMQ--注解--使用/实例

简介

        本文用实例介绍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);
}

举报

相关推荐

0 条评论