springboot redis 排队

Spring Boot 和 Redis 结合可以方便地实现消息队列的功能，特别是用于服务间的异步通信。Redis 提供了多种数据结构如列表（List）、集合（Set）和有序集合（Sorted Set），其中 List 非常适合实现消息队列。

例如，你可以使用 Spring Boot 的 `@RabbitListener` 注解来创建一个消费者，它会从 Redis 的一个列表中读取消息。当有新的任务需要处理时，可以在生产者那里将任务添加到这个列表中。这种方式简单高效，因为 Redis 的读写操作速度非常快。

以下是简单的步骤：

1. 添加依赖：在 `pom.xml` 中添加 Spring Boot 的 RabbitMQ 和 Redis 相关依赖。

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

2. 创建消费者（consumer）：

import org.springframework.amqp.annotation.RabbitListener;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Component;

@Component
public class MessageConsumer {

    private final RedisTemplate<String, Object> redisTemplate;

    public MessageConsumer(RedisTemplate<String, Object> redisTemplate) {
        this.redisTemplate = redisTemplate;
    }

    @RabbitListener(queues = "myQueue")
    public void handle(String message) {
        // 处理接收到的消息
    }
}

3. 生产者（producer）：

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.stereotype.Service;

@Service
public class MessageProducer {

    private final RabbitTemplate rabbitTemplate;
    private final RedisTemplate<String, Object> redisTemplate;

    @Autowired
    public MessageProducer(RabbitTemplate rabbitTemplate, RedisTemplate<String, Object> redisTemplate) {
        this.rabbitTemplate = rabbitTemplate;
        this.redisTemplate = redisTemplate;
    }

    public void sendMessage(String message) {
        // 将消息放入Redis队列
        redisTemplate.opsForList().leftPush("myQueue", message);
        
        // 或者直接发送给 RabbitMQ，不过通常生产者不会直接操作 Redis
        // rabbitTemplate.convertAndSend("myQueue", message);
    }
}