首先你的项目需要添加依赖。

如果有多个节点订阅了这个channel，如果这个channel有新消息，则所有的订阅者都能收到消息，就像广播一样，给订阅的节点全部广播通知。

1.Redis配置和订阅设置

@Slf4j
@Configuration
public class RedisConfig {
    public static final String CHANNEL = "imonline";
    /**
     * redis消息监听器容器
     * 可以添加多个监听不同话题的redis监听器，只需要把消息监听器和相应的消息订阅处理器绑定，该消息监听器
     * 通过反射技术调用消息订阅处理器的相关方法进行一些业务处理
     * @param connectionFactory
     * @return
     */
    @Bean
    public RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory, MessageListenerAdapter listenerAdapter) {
        RedisMessageListenerContainer container = new RedisMessageListenerContainer();
        container.setConnectionFactory(connectionFactory);
        // 监听msgToAll
        container.addMessageListener(listenerAdapter, new PatternTopic(RedisConfig.CHANNEL));
        log.info("Subscribed Redis channel: " + RedisConfig.CHANNEL);
        return container;
    }

    /**
     * 接收消息
     * @param redisReceiver
     * @return
     */
    @Bean
    public MessageListenerAdapter messageListenerAdapter(RedisReceiver redisReceiver){
        return new MessageListenerAdapter(redisReceiver,"receiveMessage");
    }

    @Bean
    public RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {
        RedisTemplate<Object, Object> redisTemplate = new RedisTemplate<>();
        redisTemplate.setConnectionFactory(redisConnectionFactory);

        // 使用Jackson2JsonRedisSerialize 替换默认序列化
        Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);

        ObjectMapper objectMapper = new ObjectMapper();
        objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
        objectMapper.enableDefaultTyping(ObjectMapper.DefaultTyping.NON_FINAL);

        jackson2JsonRedisSerializer.setObjectMapper(objectMapper);

        // 设置value的序列化规则和 key的序列化规则
        redisTemplate.setHashValueSerializer(jackson2JsonRedisSerializer);
        redisTemplate.setHashKeySerializer(new StringRedisSerializer());

        redisTemplate.setValueSerializer(jackson2JsonRedisSerializer);
        redisTemplate.setKeySerializer(new StringRedisSerializer());
        redisTemplate.afterPropertiesSet();
        return redisTemplate;
    }
}

2.消息接收

接收的字符串，如果是java对象就序列化成json字符串。

@Slf4j
@Component
public class RedisReceiver {

    @Autowired
    private WebSocketPool socketPool;

    @Autowired
    private RedisUtil redisUtil;

    public void receiveMessage(String message){
        log.info(message);
    }

}

3.发送消息

redisTemplate.convertAndSend(RedisConfig.CHANNEL, "我是消息");

对象类型