大概用法类似这样
/**
* redis发布订阅工具
*/
private final RPubSubPublisher pubSubPublisher;
/**
* 发送重新加载指令
*/
private void pubReloadEvent() {
pubSubPublisher.publish(IotCacheConstant.SERVER_RELAY_RELOAD, null);
}
/**
* 监听重新加载命令
*/
@RPubSubListener(IotCacheConstant.SERVER_RELAY_RELOAD)
public void subReloadEvent(RPubSubEvent event) {
log.info("监听到服务端订阅刷新事件");
this.reloadCache();
log.info("服务端订阅刷新事件成功");
}
扫一扫访问 Blade技术社区 移动端