多语言展示
当前在线:1802今日阅读:19今日分享:20

springboot中使用rabbitmq实现生产者消费者

最近研究了rabbitmq这个非常优秀非常流行的消息中间件,上篇写了如何在ubuntu下使用apt-get安装rabbitmq,这篇的内容是:怎么在springboot中实现一个简单的生产者消费者。
工具/原料
1

springboot

2

rabbitmq

方法/步骤
1

首先在pom.xml文件加入amqp依赖:spring-boot-starter-amqp。

2

然后在配置文件application.yml中加入rabbitmq服务器配置。

3

然后在启动类里注册一个队列bean,队列名称为my-queue。在下面的生产者和消费者里面都是使用这个队列名称。

4

编写生产者,把消息message发送到目的地QUEUE。

5

编写消费者,监听并接收从QUEUE发送的消息message,然后打印到控制台。

6

启动main方法,让消费者开始监听消息。然后在测试类中调用生产者发送消息。

7

生产者发送消息成功后,可以在控制台看到消费者已经成功打印了收到的消息。

8

以上就是springboot中使用rabbitmq实现生产者和消费者的简单实现。

注意事项
1

rabbitmq有非常丰富的功能,以上只是入门,以后会继续写一些rabbitmq高级功能的经验。

2

希望能帮到想要入门rabbitmq的同学,如果有问题可以发留言给我哦。

推荐信息