快速开始
引入依赖
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
在application.yml文件中配置rabbitmq的相关配置:
spring:
rabbitmq:
addresses: localhost:5672 # RabbitMQ服务地址
virtual-host: / # RabbitMQ虚拟主机
username: admin # RabbitMQ用户名
password: 123456 # RabbitMQ密码
发布者
创建一个controller
,实现发送消息的逻辑,在这里我们直接将消息发送到队列中:
@RequiredArgsConstructor
@RestController
public class RabbitMqController {
private final RabbitTemplate rabbitTemplate;
@GetMapping("/send")
public String send() {
// 队列名称
String queueName = "test.queue";
// 消息内容
String message = "hello world";
// 发送消息
rabbitTemplate.convertAndSend(queueName, message);
return "send";
}
}
消费者
另外在开启一个服务,来消费消息。
@Slf4j
@Component
public class RabbitMqListener {
@RabbitListener(queues = "test.queue")
public void receive(String message) {
log.info("接收到消息:{}", message);
}
}
最后更新于
这有帮助吗?