spring boot redis 消息队列监听

在Spring Boot中使用Redis作为消息队列的监听器，可以通过Spring Data Redis提供的功能来实现。以下是一个基本的示例：

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

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

接下来，创建一个消息监听器类，用于接收和处理Redis消息。可以使用`@Component`注解将该类声明为Spring组件，并使用`@RedisListener`注解指定要监听的队列名称。

import org.springframework.data.redis.connection.Message;
import org.springframework.data.redis.connection.MessageListener;
import org.springframework.stereotype.Component;

@Component
public class RedisMessageListener implements MessageListener {

    @Override
    public void onMessage(Message message, byte[] pattern) {
        String channel = new String(message.getChannel());
        String body = new String(message.getBody());
        
        // 处理接收到的消息
        System.out.println("Received message: " + body + " from channel: " + channel);
    }
}

然后，在需要发送消息的地方，可以使用`RedisTemplate`来发送消息到指定的队列。可以使用`convertAndSend`方法来发送消息。

import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.stereotype.Service;

@Service
public class MessageService {

    private final RedisTemplate<String, String> redisTemplate;

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

    public void sendMessage(String message) {
        redisTemplate.convertAndSend("queue-name", message);
    }
}

最后，在启动类上添加`@EnableRedisRepositories`注解，以启用Spring Data Redis的功能。

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.data.redis.repository.configuration.EnableRedisRepositories;

@SpringBootApplication
@EnableRedisRepositories
public class Application {

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

现在，当消息发送到指定的Redis队列时，监听器类中的`onMessage`方法将被自动调用，可以在该方法中进行消息的处理逻辑。

请注意，以上示例只是一个基本的演示，实际的应用中可能需要更多的配置和处理逻辑。