SpringBoot Redis 队列自动消费指南

在 Spring Boot 中，可以使用 Redis 作为消息队列，并通过定时任务或消息驱动方式来自动消费消息。

首先，确保你的 Spring Boot 项目中已经添加了 Redis 的依赖。可以在 pom.xml 文件中添加以下依赖：

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

接下来，创建一个 Redis 消息发布者和消息订阅者的类。

@Component
public class RedisMessagePublisher {

    @Autowired
    private RedisTemplate<String, String> redisTemplate;

    public void publish(String channel, String message) {
        redisTemplate.convertAndSend(channel, message);
    }
}

@Component
public class RedisMessageSubscriber {

    @Autowired
    private RedisTemplate<String, String> redisTemplate;

    @Autowired
    private MessageListenerAdapter messageListenerAdapter;

    private RedisMessageListenerContainer container;

    @PostConstruct
    public void init() {
        container = new RedisMessageListenerContainer();
        container.setConnectionFactory(redisTemplate.getConnectionFactory());
        container.addMessageListener(messageListenerAdapter, new ChannelTopic('your-channel-name'));
        container.start();
    }

    @PreDestroy
    public void destroy() {
        container.stop();
    }

    @SuppressWarnings("unused")
    public void onMessage(String message) {
        // 处理消息
    }
}

在上面的代码中，RedisMessagePublisher 类用于发布消息，RedisMessageSubscriber 类用于订阅消息。在 RedisMessageSubscriber 类中，通过 @PostConstruct 注解在初始化时创建一个 RedisMessageListenerContainer，并设置消息监听器和订阅的频道名称。@PreDestroy 注解用于在销毁时停止 RedisMessageListenerContainer。

最后，在需要自动消费消息的地方，可以使用 @Scheduled 注解创建一个定时任务来消费消息。

@Component
public class MessageConsumer {

    @Autowired
    private RedisTemplate<String, String> redisTemplate;

    @Scheduled(fixedDelay = 1000) // 每隔1秒执行一次
    public void consumeMessage() {
        String message = redisTemplate.opsForList().leftPop('your-queue-name');
        if (message != null) {
            // 处理消息
        }
    }
}

在上面的代码中，使用 @Scheduled 注解创建了一个定时任务，通过 redisTemplate 的 leftPop 方法从队列中取出消息并进行处理。

这样就可以实现自动消费 Redis 队列中的消息了。