SpringBoot+Redis实现简单的发布/订阅

Li_XiaoJin

发布于 2022-06-12 11:11:31

2.3K0

Redis 常被用作缓存服务器，它还可以用来实现消息队列，这里介绍 SpringBoot+Redis实现简单的发布/订阅

1、引入依赖

首先要在 pom 文件中引入相关依赖

        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-redis</artifactId>
        </dependency>

2、创建监听器

创建 RedisListener 实现 MessageListener，重写 onMessage 方法

@Slf4j
@Service
public class RedisListener implements MessageListener {

    @Override
    public void onMessage(Message message, byte[] pattern) {
        log.info("onMessage,{}", message.toString());
        String channel = new String(message.getChannel());
        log.info("channel:" + channel);
        String messageContext = new String(message.getBody());
        log.info("消息内容：" + messageContext);
    }
}

3、订阅 topic

@Configuration
public class RedisConfig {

    @Bean
    RedisMessageListenerContainer redisMessageListenerContainer(
            RedisConnectionFactory redisConnectionFactory, RedisListener redisListener) {
        RedisMessageListenerContainer redisMessageListenerContainer = new RedisMessageListenerContainer();
        redisMessageListenerContainer.setConnectionFactory(redisConnectionFactory);
        //订阅topic - subscribe
        redisMessageListenerContainer.addMessageListener(redisListener,new ChannelTopic("lixj:message"));
        return redisMessageListenerContainer;
    }
}

4、测试类

编写简单的测试类

@RestController
public class TestController {

    @Resource
    private StringRedisTemplate stringRedisTemplate;

    @GetMapping(value = "/test/message/send")
    public String send(@RequestParam String message) {
        stringRedisTemplate.convertAndSend("lixj:message", message);
        return "success";
    }

}

测试结果：