springboot中使用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实现生产者和消费者的简单实现。