7x31/SOP
1
0
Fork 0
mirror of https://gitee.com/durcframework/SOP.git synced 2025-08-11 21:57:56 +08:00
Code Issues Packages Projects Releases Wiki Activity

文档刷新逻辑

Browse Source
This commit is contained in:
tanghc
2019-08-09 19:25:42 +08:00
parent 1f71312184
commit 277cbaa913
1 changed files with 6 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
sop-website/website-server/src/main/java/com/gitee/sop/websiteserver/manager/DocManagerImpl.java
View File

@@ -11,8 +11,10 @@ import com.gitee.sop.websiteserver.bean.DocItem;
import com.gitee.sop.websiteserver.bean.ZookeeperContext; import com.gitee.sop.websiteserver.bean.ZookeeperContext;
import lombok.Data; import lombok.Data;
import lombok.extern.slf4j.Slf4j; import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.math.NumberUtils;
import org.apache.curator.framework.recipes.cache.TreeCacheEvent; import org.apache.curator.framework.recipes.cache.TreeCacheEvent;
import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.core.env.Environment; import org.springframework.core.env.Environment;
import org.springframework.http.HttpStatus; import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity; import org.springframework.http.ResponseEntity;
@@ -65,6 +67,9 @@ public class DocManagerImpl implements DocManager {
@Autowired @Autowired
private RegistryService registryService; private RegistryService registryService;
@Value("${doc.refresh-seconds:60}")
private String refreshSeconds;
private volatile boolean listenInited; private volatile boolean listenInited;
@Override @Override
@@ -169,7 +174,7 @@ public class DocManagerImpl implements DocManager {
ZKServiceInfo serviceInfo = JSON.parseObject(serviceInfoJson, ZKServiceInfo.class); ZKServiceInfo serviceInfo = JSON.parseObject(serviceInfoJson, ZKServiceInfo.class);
String serviceId = serviceInfo.getServiceId(); String serviceId = serviceInfo.getServiceId();
log.info("微服务[{}]推送更新", serviceId); log.info("微服务[{}]推送更新", serviceId);
Msg msg = new Msg(id, 1000 * 20); Msg msg = new Msg(id, 1000 * NumberUtils.toInt(refreshSeconds, 60));
msg.serviceId = serviceId; msg.serviceId = serviceId;
// 延迟20秒执行 // 延迟20秒执行
queue.offer(msg); queue.offer(msg);