布朗熊
| 6天前 | 后端相关Spring 全家桶Redis
SpringBoot+Redis自定义注解实现发布订阅
前言 最近开发了一个内部消息组件,逻辑大体是通过定义注解 @MessageHub ,在启动时扫描全部bean中有使用了该注解的方法后台创建一个常驻线程代理消费数据,当线程消费到数据就回写到对应加了注解的方法里。 @Slf4j @Service public class RedisConsumerDemo { @MessageHub(topic = "${uptown.topic}", type = "REDIS_PUBSUB") public void consumer(Object message) { log.info("pubsub info {} ", message); } } 实现redis的队列、stream方式实现都很简单,唯独发布订阅方式,网上的demo全都是一个固定套路,通过redis容器注入监听器,而且回写非常死板。那么如何将这块的逻辑统一呢。 之前总结过消息组件的代码设计,这里贴一下链接: “https://juejin.cn/post/7204113113699729463