spring boot redis 消息队列监听

在Spring Boot中，你可以使用Redis作为消息队列来实现消息的发布和订阅。下面是一个简单的示例，演示如何在Spring Boot中监听Redis消息队列：

首先，确保你的Spring Boot项目中已经配置了Redis的依赖。

创建一个消息监听器类，实现`MessageListener`接口，例如：

@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);
        // 处理接收到的消息
    }
}

接下来，创建一个配置类，配置Redis连接和消息监听器，例如：

@Configuration
public class RedisConfig {

    @Bean
    JedisConnectionFactory jedisConnectionFactory() {
        RedisStandaloneConfiguration configuration = new RedisStandaloneConfiguration();
        configuration.setHostName("localhost");
        configuration.setPort(6379);
        return new JedisConnectionFactory(configuration);
    }

    @Bean
    RedisMessageListenerContainer redisContainer() {
        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
        container.setConnectionFactory(jedisConnectionFactory());
        container.addMessageListener(redisMessageListener(), new ChannelTopic("your-channel-name"));
        return container;
    }

    @Bean
    MessageListenerAdapter redisMessageListener() {
        return new MessageListenerAdapter(new RedisMessageListener());
    }
}

在上面的配置中，你需要替换`localhost`和`6379`为你的Redis服务器的主机名和端口号，以及`your-channel-name`为你想要监听的Redis频道名称。

最后，启动你的Spring Boot应用程序，当有消息发布到Redis的指定频道时，`RedisMessageListener`中的`onMessage`方法将会被调用，你可以在其中处理接收到的消息。

希望以上信息能帮助到你！如果你还有其他问题，请随时提问。