再更新部署base-service服务的时候,base-servie的pod出现一下错误信息
出现插入信息的时候数据重复,然后manage-service服务也出现错误
EurekaEventObserver这个类
@Override
public void receiveUpEvent(EurekaEventPayload payload) {
try {
String json = documentService.fetchSwaggerJsonByIp(payload);
if (StringUtils.isEmpty(json)) {
throw new RemoteAccessException("fetch swagger json data is empty, " + payload);
}
swaggerRefreshService.updateOrInsertSwagger(payload, json);
} catch (Exception e) {
LOGGER.warn("process swagger data exception skip: {}", payload, e);
}
try {
String actuatorJson = documentService.fetchActuatorJson(payload);
if (StringUtils.isEmpty(actuatorJson)) {
throw new RemoteAccessException("fetch actuator json data is empty, " + payload);
}
if (actuatorRefreshService.updateOrInsertActuator(payload.getAppName(), payload.getVersion(), actuatorJson)) {
LOGGER.info("actuator data saga apply success: {}", payload.getId());
} else {
LOGGER.info("actuator data not change skip: {}", payload.getId());
}
} catch (Exception e) {
LOGGER.warn("process actuator data exception skip: {}", payload, e);
}
try {
//这个接口报404
**String metadataJson = documentService.fetchMetadataJson(payload);**
if (StringUtils.isEmpty(metadataJson)) {
LOGGER.info("fetch metadata json data is empty skip: {}", payload.getId());
} else {
actuatorRefreshService.sendMetadataEvent(metadataJson, payload.getAppName());
}
} catch (Exception e) {
LOGGER.warn("process metadata data exception skip: {}", payload, e);
}
}