redis的发布订阅怎么使用？

@RPubSubListener

这个咋用呀

这个监听不了，是不是有其他的配置？

2条回答

c2222

2025-12-11 10:43

还有这个bean注入不了，我自己写了个bean才注入的

0 讨论(0)
评论:

提交评论
- 加载中...

admin - BladeX作者

2025-12-11 13:34

大概用法类似这样


/**
 * redis发布订阅工具
 */
private final RPubSubPublisher pubSubPublisher;

/**
 * 发送重新加载指令
 */
private void pubReloadEvent() {
    pubSubPublisher.publish(IotCacheConstant.SERVER_RELAY_RELOAD, null);
}

/**
 * 监听重新加载命令
 */
@RPubSubListener(IotCacheConstant.SERVER_RELAY_RELOAD)
public void subReloadEvent(RPubSubEvent<String> event) {
    log.info("监听到服务端订阅刷新事件");
    this.reloadCache();
    log.info("服务端订阅刷新事件成功");
}