原文网址：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：用在类上
- 需配合 @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
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); }版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请联系我们举报，一经查实，本站将立刻删除。
发布者：全栈程序员-站长，转载请注明出处：https://javaforall.net/207078.html原文链接：https://javaforall.net
