springboot redis队列监听

在Spring Boot中使用Redis队列监听可以实现异步消息处理和任务调度。下面是一个简单的示例：

1. 首先，确保你的Spring Boot项目中已经添加了Redis和Spring Data Redis的依赖。

2. 创建一个消息监听器类，用于处理接收到的消息。可以使用`@Component`注解将其声明为一个Spring组件。

@Component
public class MessageListener {

    @Autowired
    private RedisTemplate<String, String> redisTemplate;

    @Autowired
    private TaskExecutor taskExecutor;

    @Autowired
    private MessageService messageService;

    @PostConstruct
    public void init() {
        taskExecutor.execute(this::listen);
    }

    public void listen() {
        while (true) {
            String message = redisTemplate.opsForList().rightPop("messageQueue", 1, TimeUnit.SECONDS);
            if (message != null) {
                // 处理接收到的消息
                messageService.processMessage(message);
            }
        }
    }
}

在上面的代码中，我们使用`RedisTemplate`来操作Redis，通过`rightPop`方法从名为"messageQueue"的列表中获取消息。如果获取到了消息，则调用`messageService`来处理消息。

3. 创建一个消息处理服务类，用于实际处理接收到的消息。

@Service
public class MessageService {

    public void processMessage(String message) {
        // 处理接收到的消息逻辑
        System.out.println("Received message: " + message);
    }
}

在上面的代码中，我们只是简单地打印接收到的消息，你可以根据实际需求进行相应的处理。

4. 在需要发送消息的地方，使用`RedisTemplate`将消息发送到队列中。

@Autowired
private RedisTemplate<String, String> redisTemplate;

public void sendMessage(String message) {
    redisTemplate.opsForList().leftPush("messageQueue", message);
}

在上面的代码中，我们使用`leftPush`方法将消息推送到名为"messageQueue"的列表的左侧。

这样，当有消息被推送到队列中时，监听器会自动从队列中获取消息并进行处理。