springboot实现redis的发布订阅

在Spring Boot中，可以通过使用Spring Data Redis和Spring Framework提供的一些组件来实现Redis的发布订阅。

首先，需要在pom.xml文件中添加以下依赖：

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

然后，在application.properties文件中配置Redis连接信息：

spring.redis.host=127.0.0.1
spring.redis.port=6379

接下来，创建一个Redis配置类，用于配置RedisTemplate和MessageListenerContainer：

@Configuration
public class RedisConfig {

    @Autowired
    private RedisConnectionFactory redisConnectionFactory;

    @Bean
    public RedisTemplate<String, Object> redisTemplate() {
        RedisTemplate<String, Object> redisTemplate = new RedisTemplate<>();
        redisTemplate.setConnectionFactory(redisConnectionFactory);
        redisTemplate.setDefaultSerializer(new StringRedisSerializer());
        redisTemplate.setKeySerializer(new StringRedisSerializer());
        redisTemplate.setValueSerializer(new JdkSerializationRedisSerializer());
        return redisTemplate;
    }

    @Bean
    public MessageListenerContainer messageListenerContainer() {
        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
        container.setConnectionFactory(redisConnectionFactory);
        return container;
    }
}

然后，创建一个Redis消息监听器，用于处理消息：

@Component
public class RedisMessageSubscriber implements MessageListener {

    @Override
    public void onMessage(Message message, byte[] pattern) {
        System.out.println("Received message: " + message.toString());
    }
}

最后，在需要监听Redis消息的地方，注入MessageListenerContainer和RedisMessageSubscriber，并使用它们来订阅频道：

@Service
public class MyService {

    @Autowired
    private MessageListenerContainer messageListenerContainer;

    @Autowired
    private RedisMessageSubscriber redisMessageSubscriber;

    public void subscribe(String channel) {
        messageListenerContainer.addMessageListener(redisMessageSubscriber, new ChannelTopic(channel));
    }
}

以上就是使用Spring Boot实现Redis的发布订阅的方法。