Commit dce8a1a8 authored by 张国敬's avatar 张国敬

清理日志

parent b4e88aae
...@@ -83,7 +83,6 @@ public class ConfigCenterHelper { ...@@ -83,7 +83,6 @@ public class ConfigCenterHelper {
@Override @Override
public Result<SellerConfigResponse> load(String key) throws Exception { public Result<SellerConfigResponse> load(String key) throws Exception {
SellerConfigQuery query = parseSellerConfigQuery(key); SellerConfigQuery query = parseSellerConfigQuery(key);
logger.info("ConfigCenterHelper:: load seller config from inner api, query:{}", query);
return configCenterInnerApi.querySellerConfig(query); return configCenterInnerApi.querySellerConfig(query);
} }
}; };
...@@ -97,7 +96,6 @@ public class ConfigCenterHelper { ...@@ -97,7 +96,6 @@ public class ConfigCenterHelper {
@Override @Override
public Result<StoreConfigResponse> load(String key) throws Exception { public Result<StoreConfigResponse> load(String key) throws Exception {
StoreConfigQuery query = parseStoreConfigQuery(key); StoreConfigQuery query = parseStoreConfigQuery(key);
logger.info("ConfigCenterHelper:: load store config from inner api, query:{}", query);
return configCenterInnerApi.queryStoreConfig(query); return configCenterInnerApi.queryStoreConfig(query);
} }
}; };
...@@ -186,7 +184,6 @@ public class ConfigCenterHelper { ...@@ -186,7 +184,6 @@ public class ConfigCenterHelper {
Result<SellerConfigResponse> result = sellerConfigJvmCache.get(key); Result<SellerConfigResponse> result = sellerConfigJvmCache.get(key);
return result; return result;
} catch (Exception e) { } catch (Exception e) {
logger.error("query seller config by config-center SDK error, query:{}", query);
logger.error("query seller config by config-center SDK error", e); logger.error("query seller config by config-center SDK error", e);
return ResultUtils.failure(ERROR_QUERY_SELLER_FAIL); return ResultUtils.failure(ERROR_QUERY_SELLER_FAIL);
} }
...@@ -216,7 +213,6 @@ public class ConfigCenterHelper { ...@@ -216,7 +213,6 @@ public class ConfigCenterHelper {
Result<StoreConfigResponse> result = storeConfigJvmCache.get(key); Result<StoreConfigResponse> result = storeConfigJvmCache.get(key);
return result; return result;
} catch (Exception e) { } catch (Exception e) {
logger.error("query store config by config-center SDK error, query:{}", query);
logger.error("query store config by config-center SDK error", e); logger.error("query store config by config-center SDK error", e);
return ResultUtils.failure(ERROR_QUERY_STORE_FAIL); return ResultUtils.failure(ERROR_QUERY_STORE_FAIL);
} }
...@@ -229,7 +225,6 @@ public class ConfigCenterHelper { ...@@ -229,7 +225,6 @@ public class ConfigCenterHelper {
public void removeSellerConfigCache(SellerConfigQuery query) { public void removeSellerConfigCache(SellerConfigQuery query) {
String key = buildSellerConfigCacheKey(query); String key = buildSellerConfigCacheKey(query);
sellerConfigJvmCache.invalidate(key); sellerConfigJvmCache.invalidate(key);
logger.info(" removeStoreConfigCache:: remove seller config cache, query:{}", query);
} }
/** /**
...@@ -239,7 +234,6 @@ public class ConfigCenterHelper { ...@@ -239,7 +234,6 @@ public class ConfigCenterHelper {
public void removeStoreConfigCache(StoreConfigQuery query) { public void removeStoreConfigCache(StoreConfigQuery query) {
String key = buildStoreConfigCacheKey(query); String key = buildStoreConfigCacheKey(query);
storeConfigJvmCache.invalidate(key); storeConfigJvmCache.invalidate(key);
logger.info(" removeStoreConfigCache:: remove store config cache, query:{}", query);
} }
......
...@@ -42,7 +42,6 @@ public class SubMessageListener { ...@@ -42,7 +42,6 @@ public class SubMessageListener {
configCenterHelper.removeStoreConfigCache(query); configCenterHelper.removeStoreConfigCache(query);
} }
} catch (Exception e) { } catch (Exception e) {
logger.error("SubMessageListener[onMessage] handle sub message error, channel:{}, message:{}", channel, message);
logger.error("SubMessageListener[onMessage] handle sub message error", e); logger.error("SubMessageListener[onMessage] handle sub message error", e);
} }
} }
......
...@@ -103,17 +103,15 @@ public class ZipkinHelper { ...@@ -103,17 +103,15 @@ public class ZipkinHelper {
public void startRootTracing(String spanName) { public void startRootTracing(String spanName) {
try { try {
if (! zipkinEnabled) { if (! zipkinEnabled) {
logger.info("startRootTracing:: need_not start zipkin enabled switch is off, see property zm.zipkin.enabled"); logger.debug("startRootTracing:: need_not start zipkin enabled switch is off, see property zm.zipkin.enabled");
return; return;
} }
if (tracing == null) { if (tracing == null) {
logger.info("startRootTracing:: zipkin tracing is null");
return; return;
} }
HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest(); HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest();
if (request == null) { if (request == null) {
logger.info("startRootTracing:: zipkin request is null");
return; return;
} }
...@@ -124,7 +122,7 @@ public class ZipkinHelper { ...@@ -124,7 +122,7 @@ public class ZipkinHelper {
String qmOpenTracing = request.getHeader(QM_OPEN_TRACING); String qmOpenTracing = request.getHeader(QM_OPEN_TRACING);
if (StringUtils.isEmpty(qmTraceId) || StringUtils.isEmpty(zipkinTraceId) if (StringUtils.isEmpty(qmTraceId) || StringUtils.isEmpty(zipkinTraceId)
|| ! QM_OPEN_TRACING_ENABLE.equals(qmOpenTracing)) { || ! QM_OPEN_TRACING_ENABLE.equals(qmOpenTracing)) {
logger.info("startRootTracing:: need_not start zipkin trace for empty qmTraceId, zipkinTraceId:{}, " + logger.debug("startRootTracing:: need_not start zipkin trace for empty qmTraceId, zipkinTraceId:{}, " +
"qmTraceId:{}, qmOpenTracing:{}", zipkinTraceId, qmTraceId, qmOpenTracing); "qmTraceId:{}, qmOpenTracing:{}", zipkinTraceId, qmTraceId, qmOpenTracing);
return; return;
} }
...@@ -156,9 +154,6 @@ public class ZipkinHelper { ...@@ -156,9 +154,6 @@ public class ZipkinHelper {
traceInfo.setQmTraceId(qmTraceId); traceInfo.setQmTraceId(qmTraceId);
traceInfo.setQmOpenTracing(qmOpenTracing); traceInfo.setQmOpenTracing(qmOpenTracing);
ZipkinThreadLocal.set(traceInfo); ZipkinThreadLocal.set(traceInfo);
logger.info("startRootTracing:: start zipkin trace success, spanName:{}, zipkinTraceId:{}, " +
"qmTraceId:{}, qmOpenTracing:{}, rootSpan.traceId:{}", spanName, zipkinTraceId, qmTraceId,
qmOpenTracing, rootSpan.context().traceIdString());
} catch (Exception e) { } catch (Exception e) {
logger.error("startRootTracing:: start zipkin trace error, {}", e); logger.error("startRootTracing:: start zipkin trace error, {}", e);
} }
...@@ -171,7 +166,7 @@ public class ZipkinHelper { ...@@ -171,7 +166,7 @@ public class ZipkinHelper {
public void startChildTracing(String spanName) { public void startChildTracing(String spanName) {
try { try {
if (! zipkinEnabled) { if (! zipkinEnabled) {
logger.info("startChildTracing:: need_not start zipkin enabled switch is off, see property zm.zipkin.enabled"); logger.debug("startChildTracing:: need_not start zipkin enabled switch is off, see property zm.zipkin.enabled");
return; return;
} }
if (tracing == null) { if (tracing == null) {
...@@ -190,9 +185,6 @@ public class ZipkinHelper { ...@@ -190,9 +185,6 @@ public class ZipkinHelper {
.start(); .start();
traceInfo.setCurrentTraceSpan(childSpan); traceInfo.setCurrentTraceSpan(childSpan);
logger.info("startChildTracing:: start zipkin trace success, spanName:{}, rootSpan.traceId:{}, " +
"qmTraceId:{}", spanName, rootSpan.context().traceIdString(), traceInfo.getQmTraceId());
} }
} catch (Exception e) { } catch (Exception e) {
logger.error("startChildTracing:: zipkin start zipkin trace error, {}", e); logger.error("startChildTracing:: zipkin start zipkin trace error, {}", e);
...@@ -248,8 +240,6 @@ public class ZipkinHelper { ...@@ -248,8 +240,6 @@ public class ZipkinHelper {
Optional.ofNullable(tags.getMobile()).ifPresent(val -> span.tag(ZipkinHelper.SPAN_TAG_SELLER_MOBILE, val)); Optional.ofNullable(tags.getMobile()).ifPresent(val -> span.tag(ZipkinHelper.SPAN_TAG_SELLER_MOBILE, val));
Optional.ofNullable(tags.getSellerId()).ifPresent(val -> span.tag(ZipkinHelper.SPAN_TAG_SELLER_STORE_ID, val)); Optional.ofNullable(tags.getSellerId()).ifPresent(val -> span.tag(ZipkinHelper.SPAN_TAG_SELLER_STORE_ID, val));
Optional.ofNullable(tags.getSellerName()).ifPresent(val -> span.tag(ZipkinHelper.SPAN_TAG_SELLER_STORE_NAME, val)); Optional.ofNullable(tags.getSellerName()).ifPresent(val -> span.tag(ZipkinHelper.SPAN_TAG_SELLER_STORE_NAME, val));
logger.info("setRootSellerTags:: set zipkin tags success, tags:{}", JSON.toJSONString(tags));
} catch (Exception e) { } catch (Exception e) {
logger.error("setRootSellerTags:: set zipkin tags error, {}", e); logger.error("setRootSellerTags:: set zipkin tags error, {}", e);
} }
...@@ -277,8 +267,6 @@ public class ZipkinHelper { ...@@ -277,8 +267,6 @@ public class ZipkinHelper {
Optional.ofNullable(tags.getSellerId()).ifPresent(val -> span.tag(ZipkinHelper.SPAN_TAG_USER_STORE_ID, val)); Optional.ofNullable(tags.getSellerId()).ifPresent(val -> span.tag(ZipkinHelper.SPAN_TAG_USER_STORE_ID, val));
Optional.ofNullable(tags.getSellerName()).ifPresent(val -> span.tag(ZipkinHelper.SPAN_TAG_USER_STORE_NAME, val)); Optional.ofNullable(tags.getSellerName()).ifPresent(val -> span.tag(ZipkinHelper.SPAN_TAG_USER_STORE_NAME, val));
Optional.ofNullable(tags.getSellerType()).ifPresent(val -> span.tag(ZipkinHelper.SPAN_TAG_USER_SELLER_TYPE, val)); Optional.ofNullable(tags.getSellerType()).ifPresent(val -> span.tag(ZipkinHelper.SPAN_TAG_USER_SELLER_TYPE, val));
logger.info("setRootSellerTags:: set zipkin tags success, tags:{}", JSON.toJSONString(tags));
} catch (Exception e) { } catch (Exception e) {
logger.error("setRootSellerTags:: set zipkin tags error, {}", e); logger.error("setRootSellerTags:: set zipkin tags error, {}", e);
} }
...@@ -311,7 +299,6 @@ public class ZipkinHelper { ...@@ -311,7 +299,6 @@ public class ZipkinHelper {
Optional.ofNullable(result.getCode()).ifPresent(val -> span.tag(ZipkinHelper.SPAN_TAG_RESULT_CODE, val + "")); Optional.ofNullable(result.getCode()).ifPresent(val -> span.tag(ZipkinHelper.SPAN_TAG_RESULT_CODE, val + ""));
Optional.ofNullable(result.getMessage()).ifPresent(val -> span.tag(ZipkinHelper.SPAN_TAG_RESULT_MESSAGE, val)); Optional.ofNullable(result.getMessage()).ifPresent(val -> span.tag(ZipkinHelper.SPAN_TAG_RESULT_MESSAGE, val));
} }
logger.info("setRootTraceTags:: set zipkin tags success, tags:{}", JSON.toJSONString(tags));
} catch (Exception e) { } catch (Exception e) {
logger.error("setRootTraceTags:: set zipkin tags error, {}", e); logger.error("setRootTraceTags:: set zipkin tags error, {}", e);
} }
...@@ -344,7 +331,6 @@ public class ZipkinHelper { ...@@ -344,7 +331,6 @@ public class ZipkinHelper {
Optional.ofNullable(result.getCode()).ifPresent(val -> span.tag(ZipkinHelper.SPAN_TAG_RESULT_CODE, val + "")); Optional.ofNullable(result.getCode()).ifPresent(val -> span.tag(ZipkinHelper.SPAN_TAG_RESULT_CODE, val + ""));
Optional.ofNullable(result.getMessage()).ifPresent(val -> span.tag(ZipkinHelper.SPAN_TAG_RESULT_MESSAGE, val)); Optional.ofNullable(result.getMessage()).ifPresent(val -> span.tag(ZipkinHelper.SPAN_TAG_RESULT_MESSAGE, val));
} }
logger.info("setChildQapiTraceTags:: set zipkin tags success");
} catch (Exception e) { } catch (Exception e) {
logger.error("setChildQapiTraceTags:: set zipkin tags error, {}", e); logger.error("setChildQapiTraceTags:: set zipkin tags error, {}", e);
} }
...@@ -370,8 +356,6 @@ public class ZipkinHelper { ...@@ -370,8 +356,6 @@ public class ZipkinHelper {
Optional.ofNullable(tags.getTag()).ifPresent(val -> span.tag(ZipkinHelper.SPAN_TAG_MQ_TAG, val)); Optional.ofNullable(tags.getTag()).ifPresent(val -> span.tag(ZipkinHelper.SPAN_TAG_MQ_TAG, val));
Optional.ofNullable(tags.getKey()).ifPresent(val -> span.tag(ZipkinHelper.SPAN_TAG_MQ_KEY, val)); Optional.ofNullable(tags.getKey()).ifPresent(val -> span.tag(ZipkinHelper.SPAN_TAG_MQ_KEY, val));
Optional.ofNullable(tags.getMessageId()).ifPresent(val -> span.tag(ZipkinHelper.SPAN_TAG_MQ_MESSAGE_ID, val)); Optional.ofNullable(tags.getMessageId()).ifPresent(val -> span.tag(ZipkinHelper.SPAN_TAG_MQ_MESSAGE_ID, val));
logger.info("setChildMqTraceTags:: set zipkin tags success");
} catch (Exception e) { } catch (Exception e) {
logger.error("setChildMqTraceTags:: set zipkin tags error, {}", e); logger.error("setChildMqTraceTags:: set zipkin tags error, {}", e);
} }
...@@ -397,8 +381,6 @@ public class ZipkinHelper { ...@@ -397,8 +381,6 @@ public class ZipkinHelper {
Optional.ofNullable(tags.getMethod()).ifPresent(val -> span.tag(ZipkinHelper.SPAN_TAG_DB_METHOD, val)); Optional.ofNullable(tags.getMethod()).ifPresent(val -> span.tag(ZipkinHelper.SPAN_TAG_DB_METHOD, val));
Optional.ofNullable(tags.getStatement()).ifPresent(val -> span.tag(ZipkinHelper.SPAN_TAG_DB_STATEMENT, val)); Optional.ofNullable(tags.getStatement()).ifPresent(val -> span.tag(ZipkinHelper.SPAN_TAG_DB_STATEMENT, val));
Optional.ofNullable(tags.getParams()).ifPresent(val -> span.tag(ZipkinHelper.SPAN_TAG_DB_PARAM, val)); Optional.ofNullable(tags.getParams()).ifPresent(val -> span.tag(ZipkinHelper.SPAN_TAG_DB_PARAM, val));
logger.info("setChildDbTraceTags:: set zipkin tags success");
} catch (Exception e) { } catch (Exception e) {
logger.error("setChildDbTraceTags:: set zipkin tags error, {}", e); logger.error("setChildDbTraceTags:: set zipkin tags error, {}", e);
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment