订阅发布配置类

  1. @Configuration
  2. public class RedisSubConfig {
  4.     /**
  5.      * 定义一个频道channel 订阅此频道都能收到消息
  6.      */
  7.     public static final String SUB_KEY = "chat";
  9.     /**
  10.      * redis消息监听器容器
  11.      * 可以添加多个监听不同话题的redis监听器，只需要把消息监听器和相应的消息订阅处理器绑定，该消息监听器
  12.      * 通过反射技术调用消息订阅处理器的相关方法进行一些业务处理
  13.      *
  14.      * @param connectionFactory
  15.      * @param listenerAdapter
  16.      * @return
  17.      */
  18.     @Bean
  19.     public RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory, MessageListenerAdapter listenerAdapter) {
  21.         RedisMessageListenerContainer container = new RedisMessageListenerContainer();
  22.         container.setConnectionFactory(connectionFactory);
  24.         //注册一个频道 listenerAdapter与下面的方法对应 如果有多个频道就需要add多个 
  25.         container.addMessageListener(listenerAdapter, new PatternTopic(RedisSubConfig.SUB_KEY));
  26.         return container;
  27.     }
  29.     /**
  30.      * 消息监听器适配器，绑定消息处理器，利用反射技术调用消息处理器的业务方法，有多个消费类就要写多个这样的方法
  31.      *
  32.      * @param receiver 对应的消费者类对象
  33.      * @return
  34.      */
  35.     @Bean
  36.     public MessageListenerAdapter listenerAdapter(RedisReceiver receiver) {
  37.         //绑定负责消费消息的类和方法名
  38.         return new MessageListenerAdapter(receiver, "receiveMessage");
  39.     }
  41. }

消息消费类

在配置好的类里的指定方法接收消息

  1. @Service
  2. @Slf4j
  3. public class RedisReceiver {
  5.     public void receiveMessage(String message) {
  6.         log.info("接收消息=====>：{}", message);
  7.     }
  8. }

消息发送方法

使用redisTemplate的方法实现

  1. @SpringBootTest(classes = WebSocketMicroApplication.class, webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
  2. public class WebSocketMicroTest {
  4.     @Resource
  5.     private RedisTemplate<String, Object> redisTemplate;
  7.     @Test
  8.     public void test1() {
  9.         //指定通道发送消息
  10.         redisTemplate.convertAndSend(RedisSubConfig.SUB_KEY, "hello");
  11.     }
  12. }