想使用BladeRedis做发布订阅

Blade 未结 1 21

一、该问题的重现步骤是什么?

1.  想使用Redis实现消息的发布订阅(类似mq), 看到框架封装了BladeRedis,这块有没有简便的方法示例代码

2. 

3.


二、你期待的结果是什么?实际看到的又是什么?


三、你正在使用的是什么产品,什么版本?在什么操作系统上?

bladex 4.4

四、请提供详细的错误堆栈信息,这很重要。


五、若有更多详细信息,请在下面提供。

1条回答
  • 大概用法类似这样

    /**
     * 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("服务端订阅刷新事件成功");
    }



    0 讨论(0)
提交回复