SpringBoot——redis发布与订阅（二十一）

SpringBoot

引入依赖

1
2
3
4
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>

配置RedisTemplate

1
2
3
4
5
6
7
8
9
10
11
12
@Configuration
public class RedisConfig {

    @Bean
    public RedisTemplate<Object, Object> redisTemplate(RedisConnectionFactory redisConnectionFactory) {
        RedisTemplate<Object, Object> redisTemplate = new RedisTemplate<>();
        redisTemplate.setConnectionFactory(redisConnectionFactory);
        // 设置Key使用String序列化
        redisTemplate.setKeySerializer(new StringRedisSerializer());
        return redisTemplate;
    }
}

订阅监听类

订阅者

1
2
3
4
5
6
7
8
9
10
public class SubscribeListener implements MessageListener {
    /**
     * 订阅接收发布者的消息
     */
    @Override
    public void onMessage(Message message, byte[] pattern) {
        // 缓存消息是序列化的，需要反序列化。然而new String()可以反序列化，但静态方法valueOf()不可以
        System.out.println(new String(pattern) + "主题发布：" + new String(message.getBody()));
    }
}

发布者

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
@Component
public class PublishService {
    @Autowired
    StringRedisTemplate redisTemplate;

    /**
     * 发布方法
     * @param channel 消息发布订阅 主题
     * @param message 消息信息
     */
    public void publish(String channel, Object message) {
        // 该方法封装的 connection.publish(rawChannel, rawMessage);
        redisTemplate.convertAndSend(channel, message);
    }
}

添加监听主题

在RedisConfig中配置监听test-topic主题

1
2
3
4
5
6
7
8
@Bean
   public RedisMessageListenerContainer redisMessageListenerContainer(RedisConnectionFactory redisConnectionFactory) {
       RedisMessageListenerContainer container = new RedisMessageListenerContainer();
       container.setConnectionFactory(redisConnectionFactory);
       // 添加订阅者监听类，数量不限.PatternTopic定义监听主题,这里监听test-topic主题
       container.addMessageListener(new SubscribeListener(), new PatternTopic("test-topic"));
       return container;
   }

发布订阅测试

1
2
3
4
5
6
7
8
9
10
11
12
13
@RunWith(SpringRunner.class)
@SpringBootTest
public class RedisMqPsApplicationTests {
    @Autowired
    private PublishService service;

    @Test
    public void contextLoads() {
        for (int i = 0; i < 10; i++) {
            service.publish("test-topic", "hello~~~" + i);
        }
    }
}

本文标题:SpringBoot——redis发布与订阅（二十一）

文章作者:南有乔木

发布时间:2020-06-24, 14:04:58

最后更新:2020-06-24, 14:09:24

原始链接:http://yoursite.com/2020/06/24/SpringBoot%E2%80%94%E2%80%94redis%E5%8F%91%E5%B8%83%E4%B8%8E%E8%AE%A2%E9%98%85%EF%BC%88%E4%BA%8C%E5%8D%81%E4%B8%80%EF%BC%89/

许可协议: "署名-非商用-相同方式共享 4.0" 转载请保留原文链接及作者。

文章目录
  1. 1. 引入依赖
  2. 2. 配置RedisTemplate
  3. 3. 订阅监听类
  4. 4. 添加监听主题
  5. 5. 发布订阅测试
|