快速开始

引入依赖

<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);
    }
}