RabbitMQ整合springboot

 2023-03-26 19:18:16  阅读 0

一、添加依赖的用法

要使用RabbitMQ首先就要添加依赖,我们在Maven项目中,添加以下依赖:

xml复制代码

<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-amqp</artifactId> </dependency>

二、配置连接信息

在application.properties或application.yml文件中配置RabbitMQ连接信息,例如:

yml复制代码

spring: rabbitmq: host: localhost port: 5672 username: guest password: guest

三、定义消息发送者

创建一个类,实现消息发送逻辑,例如:

import org.springframework.amqp.rabbit.core.RabbitTemplate;
 import org.springframework.beans.factory.annotation.Autowired; 
import org.springframework.stereotype.Component;
 @Component public class MessageSender { 
@Autowired private RabbitTemplate rabbitTemplate; 
public void sendMessage(String message) { 
rabbitTemplate.convertAndSend("exchangeName", "routingKey", message); } }

四、定义消息接收者

创建一个类,实现消息接收逻辑,例如:

import org.springframework.amqp.rabbit.annotation.RabbitListener; 
import org.springframework.stereotype.Component;
 @Component public class MessageReceiver { 
@RabbitListener(queues = "queueName") 
public void receiveMessage(String message) { 
System.out.println("Received message: " + message); } }

 

通过以上步骤,即可完成Spring Boot和RabbitMQ的整合。

标签:

如本站内容信息有侵犯到您的权益请联系我们删除,谢谢!!


Copyright © 2020 All Rights Reserved 京ICP5741267-1号 统计代码