SpringBoot使用redis进行发布订阅消息

redis不仅是一个非常强大的非关系型数据库,它同时还拥有消息中间件的pub/sub功能,在spring boot中进行如下设置就可以使用redis的pub/sub功能

1、新建一个消息发布者,设置主题为topic

/**
 * @author Gjing
 *
 * 消息发送者
 **/
@RestController
public class PubController {

    @Resource
    private StringRedisTemplate stringRedisTemplate;

    private static AtomicInteger count = new AtomicInteger();

    @PostMapping("/message")
    public void sendMessage() {
        int i = count.incrementAndGet();
        stringRedisTemplate.convertAndSend("topic", "消息" + i);
    }
}

2、定义消息监听者

/**
 * @author Gjing
 *
 * 消息监听者
 **/
@Slf4j
public class Receiver {

    public void receiveMessage(String message) {
        log.info("监听者1收到消息:{}", message);
    }
}

3、定义配置类,配置redis监听者容器和监听者适配器

/**
 * @author Gjing
 **/
@Configuration
public class RedisConfiguration {

    /**
     * 消息适配器
     *
     * 绑定消息监听者和接收监听的方法,必须要注入这个监听器,不然会报错
     * @return MessageListenerAdapter
     */
    @Bean
    public MessageListenerAdapter listenerAdapter() {
        return new MessageListenerAdapter(new Receiver(), "receiveMessage");
    }

    /**
     * 定义消息监听者容器
     * @param connectionFactory 连接工厂
     * @param listenerAdapter 消息处理器
     * @return RedisMessageListenerContainer
     */
    @Bean
    public RedisMessageListenerContainer container(RedisConnectionFactory connectionFactory,
                                                   MessageListenerAdapter listenerAdapter) {
        RedisMessageListenerContainer listenerContainer = new RedisMessageListenerContainer();
        listenerContainer.setConnectionFactory(connectionFactory);
        listenerContainer.addMessageListener(listenerAdapter, new PatternTopic("topic"));
        return listenerContainer;
    }

}

运行结果

SpringBoot使用redis进行发布订阅消息

以上为个人观点,如有误欢迎各位指正

上一篇:Eclipse 代理


下一篇:python接口自动化测试(八)-unittest-生成测试报告