spring-boot-starter-amqp 使用例子
时间: 2023-08-24 11:06:09 浏览: 61
下面是一个使用 Spring Boot AMQP Starter 的例子:
首先,需要在 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
```
然后,定义一个消息发送者和一个消息接收者:
```java
@Component
public class MessageSender {
private final RabbitTemplate rabbitTemplate;
public MessageSender(RabbitTemplate rabbitTemplate) {
this.rabbitTemplate = rabbitTemplate;
}
public void sendMessage(String message) {
rabbitTemplate.convertAndSend("my-exchange", "my-routing-key", message);
}
}
@Component
public class MessageReceiver {
@RabbitListener(queues = "my-queue")
public void receiveMessage(String message) {
System.out.println("Received message: " + message);
}
}
```
最后,在启动类中添加 @EnableRabbit 注解启用 RabbitMQ 支持:
```java
@SpringBootApplication
@EnableRabbit
public class MyApp {
public static void main(String[] args) {
SpringApplication.run(MyApp.class, args);
}
}
```
这样就完成了一个简单的 RabbitMQ 应用程序。