RedisTemplate发布订阅

RedisTemplate是Spring Data Redis提供的一个工具类，用于与Redis进行交互。它提供了一系列的方法来操作Redis的数据结构，包括发布和订阅功能。

要使用RedisTemplate进行发布订阅，首先需要配置Redis的连接信息，并创建一个RedisTemplate实例。可以通过配置文件或者编程方式进行配置。以下是一个示例的配置文件：

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

创建RedisTemplate实例的方式有多种，这里以常用的Java配置方式为例：

@Configuration
public class RedisConfig {
    @Value("${spring.redis.host}")
    private String host;
    
    @Value("${spring.redis.port}")
    private int port;
    
    @Bean
    public JedisConnectionFactory jedisConnectionFactory() {
        RedisStandaloneConfiguration config = new RedisStandaloneConfiguration();
        config.setHostName(host);
        config.setPort(port);
        return new JedisConnectionFactory(config);
    }

    @Bean
    public RedisTemplate<String, Object> redisTemplate() {
        RedisTemplate<String, Object> template = new RedisTemplate<>();
        template.setConnectionFactory(jedisConnectionFactory());
        template.setDefaultSerializer(new StringRedisSerializer());
        template.setEnableDefaultSerializer(true);
        return template;
    }
}

接下来就可以使用RedisTemplate发布和订阅消息了。Redis的发布订阅模式使用了一对通道（channel）来进行消息的传递。发送方通过发布消息到指定的通道，接收方通过订阅该通道来接收消息。

以下是一个示例代码：

@Autowired
private RedisTemplate<String, Object> redisTemplate;

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

public void subscribeChannel(String channel) {
    redisTemplate.execute(new RedisCallback<Object>() {
        @Override
        public Object doInRedis(RedisConnection connection) throws DataAccessException {
            connection.subscribe(new 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);
                }
            }, channel.getBytes());
            return null;
        }
    });
}

上述代码中，`publishMessage`方法用于发布消息到指定的通道，`subscribeChannel`方法用于订阅指定的通道并处理接收到的消息。

需要注意的是，Redis的发布订阅模式是异步的，即发送方发布消息后并不会等待接收方处理，所以接收方需要单独开启一个线程或使用异步框架来处理接收到的消息。

希望以上信息对你有帮助！如果还有其他问题，请继续提问。