一手打造延时队列：RabbitMQ&Spring Boot&Docker强强联手，延时消息随心玩转！

后端

2022-12-02 06:55:13

使用 Docker/Docker Compose 安装 RabbitMQ 并实现延时消息

什么是延时消息？

延时消息是指在发送后经过一段时间才会被处理的消息。它们广泛应用于电商（订单超时）、系统定时任务和库存管理等场景。

使用 RabbitMQ 实现延时消息

RabbitMQ 是一款强大的消息队列系统，可以通过插件实现延时消息功能。其中，rabbitmq-delayed-message-exchange 插件是实现此功能的流行选择。

安装 RabbitMQ

步骤 1：安装 Docker 和 Docker Compose

安装 Docker：curl -fsSL https://get.docker.com -o get-docker.sh，sudo sh get-docker.sh
安装 Docker Compose：sudo curl -L "https://github.com/docker/compose/releases/download/1.29.2/docker-compose-$(uname -s)-$(uname -m)" -o /usr/local/bin/docker-compose，sudo chmod +x /usr/local/bin/docker-compose

步骤 2：创建 Docker Compose 配置文件

version: '3.7'

services:
  rabbitmq:
    image: rabbitmq:3.9.5-management
    ports:
      - "5672:5672"
      - "15672:15672"
    volumes:
      - ./data:/var/lib/rabbitmq

  rabbitmq-delayed-message-exchange:
    image: ghcr.io/rabbitmq/rabbitmq-delayed-message-exchange:latest
    depends_on:
      - rabbitmq
    environment:
      RABBITMQ_HOST: rabbitmq
      RABBITMQ_VHOST: /
      RABBITMQ_USER: user
      RABBITMQ_PASS: password
    volumes:
      - ./data:/var/lib/rabbitmq-delayed-message-exchange

步骤 3：启动 RabbitMQ

docker-compose up -d

步骤 4：安装 Delayed Message 插件

rabbitmq-plugins enable rabbitmq_delayed_message_exchange

使用 Spring Boot 集成 RabbitMQ

步骤 1：添加依赖

<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-amqp</artifactId>
</dependency>

步骤 2：配置 Spring Boot

@SpringBootApplication
public class Application {

    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }

    @Bean
    public ConnectionFactory connectionFactory() {
        return new CachingConnectionFactory("localhost", 5672);
    }

    @Bean
    public AmqpTemplate amqpTemplate() {
        return new RabbitTemplate(connectionFactory());
    }
}

步骤 3：发送延时消息

@PostMapping("/send-delayed-message")
public void sendDelayedMessage(@RequestBody Message message) {
    amqpTemplate.convertAndSend("delayed-exchange", "delayed-routing-key", message, m -> {
        m.getMessageProperties().setDelay(message.getDelay());
        return m;
    });
}

步骤 4：接收延时消息

@RabbitListener(queues = "delayed-queue")
public void receiveDelayedMessage(Message message) {
    System.out.println("Received delayed message: " + message);
}

总结

通过 Docker/Docker Compose 安装 RabbitMQ 并使用 Spring Boot 集成，我们可以轻松实现延时消息功能。rabbitmq-delayed-message-exchange 插件提供了简单易用的方式来实现这一功能。

常见问题解答