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

 时间:2024-10-26 10:30:08

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

  • Notepad++怎么对文本内容进行标记
  • linux怎么修改用户家目录下所有文件权限为777
  • 如何在360杀毒工具查看指定进程的日志
  • IntelliJ IDEA怎么进行代码对比
  • 如何切换svn的登陆账号?
  • 热门搜索
    黑米粥怎么煮 风向标怎么看 坐骨神经痛怎么治疗 怎么设置电脑不休眠 广州白云山怎么去 穿越火线怎么改名 屏幕保护程序怎么设置 支原体衣原体感染是怎么回事 对乙酰氨基酚片怎么样 南京医科大学怎么样