SpringAMQP快速入门

news2025/1/11 6:14:57

介绍
Spring AMQP 项目将核心 Spring 概念应用于基于 AMQP 的消息传递解决方案的开发
它提供了一个“模板”作为发送和接收消息的高级抽象
它还通过“侦听器容器”为消息驱动的 POJO 提供支持
这些库促进了 AMQP 资源的管理，同时促进了依赖注入和声明性配置的使用
包含两部分，其中spring-amqp是基础抽象，spring-rabbit是底层的默认实现
SpringAMQP提供了三个功能：
- 自动声明队列、交换机及其绑定关系
- 基于注解的监听器模式，异步接收消息
- 封装了RabbitTemplate工具，用于发送消息
入门案例
利用SpringAMQP实现HelloWorld中的基础消息队列功能
流程如下：
1. 在父工程中引入 spring-amqp 的依赖
因为publisher和consumer服务都需要amqp依赖
因此这里把依赖直接放到父工程中：
2.在publisher服务中利用RabbitTemplate发送消息到simple.queue这个队列
(1)在publisher服务中编写application.yml，添加mq连接信息：
(2)在publisher服务中新建一个测试类，编写测试方法
3.在consumer服务中配置rabbitmq,编写消费逻辑，绑定simple.queue这个队列
(1)配置rabbitmq地址
(2)编写消费逻辑
测试成功