springboot集成redis 实现多个发布订阅

在Spring Boot中集成Redis并实现多个发布订阅是相对简单的。下面是一个简单的步骤指南：

1. 首先，在pom.xml文件中添加Redis和Spring Data Redis的依赖：

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

2. 在application.properties文件中配置Redis连接信息：

spring.redis.host=your_redis_host
spring.redis.port=your_redis_port

3. 创建一个Redis消息监听器，用于处理接收到的消息。可以实现MessageListener接口或使用注解方式，这里使用注解方式。

@Component
public class RedisMessageListener {

    @Autowired
    private RedisTemplate<String, String> redisTemplate;

    @Autowired
    private RedisMessagePublisher redisMessagePublisher;

    @EventListener
    public void handleMessage(Message message) {
        System.out.println("Received message: " + message.toString());
    }

    @Scheduled(fixedDelay = 1000)
    public void publishMessage() {
        redisMessagePublisher.publish("Hello from Redis!");
    }
}

4. 创建一个Redis消息发布器，用于发布消息。

@Component
public class RedisMessagePublisher {

    @Autowired
    private RedisTemplate<String, String> redisTemplate;

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

5. 启动应用程序，Redis将会自动连接并监听消息。在上面的示例中，每秒钟会向名为"channel"的频道发布一条消息，并由监听器接收并处理。

请根据你的具体需求对代码进行适当调整。这只是一个简单的示例，你可以根据实际情况进行扩展和优化。希望对你有所帮助！