在Spring Boot中嵌入RabbitMQ可以通过添加相应的依赖来完成。首先需要在pom.xml文件中引入spring-boot-starter-amqp依赖:
然后,在application.properties或者application.yml配置文件中设置RabbitMQ连接信息:
最后,创建消息发送者(Producer)和消息接收者(Consumer)类,并使用@Autowired注解将其自动装载到Spring容器中。示例如下:
-
创建消息发送者类:
-
创建消息接收者类:
当调用MessageSender
的send()
方法时,会向"myQueue"队列发送消息;
而MessageReceiver
则会监听该队列,并处理接收到的消息。