如何用springboot和RabbitMQ实现发送通知给用户的功能,可以给出示例代码吗
时间: 2023-02-08 14:24:40 浏览: 65
首先,你需要在 Spring Boot 项目中添加 RabbitMQ 的依赖。在 pom.xml 文件中添加如下依赖:
```xml
<dependency>
<groupId>org.springframework.amqp</groupId>
<artifactId>spring-rabbit</artifactId>
<version>2.2.2.RELEASE</version>
</dependency>
```
然后,你需要在 Spring Boot 配置文件中添加 RabbitMQ 的连接配置,如下:
```yml
spring:
rabbitmq:
host: localhost
port: 5672
username: guest
password: guest
```
接着,需要创建一个生产者(producer)类用于向 RabbitMQ 发送消息。
```java
@Service
public class RabbitMQProducer {
@Autowired
private RabbitTemplate rabbitTemplate;
public void send(String routingKey, String message) {
rabbitTemplate.convertAndSend(routingKey, message);
}
}
```
最后,在需要发送消息通知的地方调用该生产者的 send() 方法。
```java
@Autowired
private RabbitMQProducer rabbitMQProducer;
public void sendNotification(String userId, String message) {
rabbitMQProducer.send("notification", message);
}
```
代码仅供参考,具体实现还需根据需要自行调整。