RabbitMq整合SpringBoot(二)

rabbitmq在安装好之后就可以开始项目编码啦,springboot项目整合rabbitmq的也是很简单的。

1、前提安装好rabbitmq。

2、pom.xml添加rabbitmq依赖。这个spring-boot-starter-amqp里面的amqp指的是高级消息队列协议,而rabbitmq就是amqp协议的一种实现中间件。
RabbitMq整合SpringBoot(二)

3、添加配置信息,这里示例用的yml文件,springboot支持yml和properties这两种格式文件。properties一般格式key=value,yml格式key:value;yml每一级之间用":"分隔,而且是逐级换行缩进。

这里yml配置里配置了rabbitmq的安装地址、端口以及账户信息、发布者确认等。
RabbitMq整合SpringBoot(二)
4、接下来写的是一个最简单的,单一生产者和单一消费者,生产者说白了就是消息制造,消费者就是消息接收。明确一点我们提到的消息指的是各个服务之间要传递的数据。

5、创建消费者类, 由@RabbitListener(queues = “hello-queue-test”)来监听"hello-queue-test"队列的信息。消息有一个收一个。
RabbitMq整合SpringBoot(二)

6、创建生产者类。

RabbitMq整合SpringBoot(二)

7、定义配置类,创建消息队列,Queue(队列)是RabbitMQ的内部对象,专门用来存储消息的,rabbitmq消息传递中的重要一环。

RabbitMq整合SpringBoot(二)

8、写过controller来测试一下,
RabbitMq整合SpringBoot(二)

9、在postman上测试下接口,

RabbitMq整合SpringBoot(二)

10、后台可以看到打印信息了。
RabbitMq整合SpringBoot(二)

11、rabbitmq的后台可以看到新增的queue。
RabbitMq整合SpringBoot(二)

这个就是最简单的消息传送模式,结果也都搞出来了,接下来再学习其他模式。