Spring Data Redis如何支持Pub/Sub消息模式

Spring Data Redis支持Pub/Sub消息模式，通過RedisMessageListenerContainer和RedisMessageListenerAdapter來實現消息的訂閱和發布。

要使用Pub/Sub消息模式，首先需要創建一個消息監聽器類，繼承MessageListener接口并實現onMessage方法來處理接收到的消息。

@Component
public class RedisMessageListener implements MessageListener {

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

然后在Spring配置類中配置RedisMessageListenerContainer和RedisMessageListenerAdapter來設置消息監聽器和訂閱的主題。

@Configuration
public class RedisConfig {

    @Bean
    public RedisMessageListenerContainer redisMessageListenerContainer(RedisConnectionFactory connectionFactory, RedisMessageListener messageListener) {
        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
        container.setConnectionFactory(connectionFactory);
        container.addMessageListener(new RedisMessageListenerAdapter(messageListener), new ChannelTopic("topic1"));
        return container;
    }
}

最后，在需要發布消息的地方，可以通過RedisTemplate來發布消息到指定的主題。

@Component
public class RedisMessagePublisher {

    @Autowired
    private RedisTemplate<String, String> redisTemplate;

    public void publishMessage(String topic, String message) {
        redisTemplate.convertAndSend(topic, message);
    }
}

這樣就可以實現在Spring Data Redis中使用Pub/Sub消息模式來進行消息的訂閱和發布。