springboot项目推送 rabbitmq消息代码
时间: 2023-11-17 09:04:20 浏览: 91
首先,需要在 pom.xml 文件中添加以下依赖:
```xml
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
```
接着,在 application.properties 文件中添加 RabbitMQ 的配置信息:
```properties
spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest
```
然后,在代码中注入 RabbitTemplate 类,并发送消息:
```java
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("queue-name", message);
}
}
```
其中,`queue-name` 表示消息发送到的队列的名称,`message` 表示要发送的消息内容。可以根据实际情况修改。
最后,需要在启动类上添加 `@EnableRabbit` 注解开启 RabbitMQ 功能:
```java
import org.springframework.amqp.rabbit.annotation.EnableRabbit;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
@EnableRabbit
public class Application {
public static void main(String[] args) {
SpringApplication.run(Application.class, args);
}
}
```
以上是一个简单的 RabbitMQ 消息发送的示例代码,可以根据具体业务需求进行适当修改。
阅读全文