多语言展示
当前在线:191今日阅读:26今日分享:39

springboot 集成RabbitMQ

这里简单记录springboot集成RabbitMQ,RabbitMQ的搭建使用docker容器搭建。
工具/原料
1

springboot

2

RabbitMQ

方法/步骤
1

启动部署一个mq服务,这里用docker部署的,可以参考,也可以自己在服务器上部署,部署时记得设置用户名和密码,最后启动的时候可以看到mq的节点名字

2

然后创建一个springboot,记得勾选RabbitMQ

3

如果是已有的项目,在pom.xml添加如下依赖即可    org.springframework.boot    spring-boot-starter-amqp

4

现在开始配置mq,在application.yml添加如下配置,图中是yml格式,下面是普通的格式spring.rabbitmq.host=mq所在服务的ip    spring.rabbitmq.port=14002    spring.rabbitmq.username= root    spring.rabbitmq.password= ********

5

配置添加好了之后,现在开始给mq添加个配置类,注意Queue的导包@Configurationpublic class MqConfig {    @Bean    public Queue helloQueue(){        return new Queue('hello');    }}

6

编写个测试发送类,主要代码rabbitTemplate.convertAndSend('hello',context);

7

在编写mq接收类,主要三个注解@Component@RabbitListener(queues = 'hello')@RabbitHandler

8

最后运行测试,先运行主程序,再运行测试类的发送mq方法,反过来是接收不到消息的

推荐信息