一、该问题的重现步骤是什么?
1. 想使用Redis实现消息的发布订阅(类似mq), 看到框架封装了BladeRedis,这块有没有简便的方法示例代码
2.
3.
二、你期待的结果是什么?实际看到的又是什么?
三、你正在使用的是什么产品,什么版本?在什么操作系统上?
bladex 4.4
四、请提供详细的错误堆栈信息,这很重要。
五、若有更多详细信息,请在下面提供。
大概用法类似这样
/**
* 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("服务端订阅刷新事件成功");
}
扫一扫访问 Blade技术社区 移动端