diff --git a/samples/skywalking-auth/src/main/resources/sky-walking.auth b/samples/skywalking-auth/src/main/resources/sky-walking.auth index 5ff5360490afa9027008aa2e6329e9791ed8bf13..f58575d058831306976e9a21648ba30d972a2360 100644 --- a/samples/skywalking-auth/src/main/resources/sky-walking.auth +++ b/samples/skywalking-auth/src/main/resources/sky-walking.auth @@ -26,8 +26,8 @@ sender.max_copy_num=2 sender.max_send_length=20000 #当没有Sender时,尝试获取sender的等待周期 sender.retry_get_sender_wait_interval=2000 -#是否开启发送消息 -sender.is_off=false + + #最大消费线程数 diff --git a/samples/skywalking-example/account-application/account-impl/src/main/resources/sky-walking.auth b/samples/skywalking-example/account-application/account-impl/src/main/resources/sky-walking.auth index d334a01a2244deb1b7bf2e57e21b14dead65990c..ddb8386c379a9851f6dca8b3552e8de5a1d391ae 100644 --- a/samples/skywalking-example/account-application/account-impl/src/main/resources/sky-walking.auth +++ b/samples/skywalking-example/account-application/account-impl/src/main/resources/sky-walking.auth @@ -4,7 +4,7 @@ buriedpoint.businesskey_max_length=300 sender.retry_get_sender_wait_interval=2000 buffer.pool_size=5 senderchecker.check_polling_time=200 -sender.is_off=false + sender.max_send_length=20000 consumer.max_consumer=2 consumer.max_wait_time=5 diff --git a/samples/skywalking-example/mail-application/src/main/resources/sky-walking.auth b/samples/skywalking-example/mail-application/src/main/resources/sky-walking.auth index 5f84b69795c0ad3e1703e00d43d42507d34b6fd2..bdddccca31a318d9552b6b0e102d0ddff6622ad1 100644 --- a/samples/skywalking-example/mail-application/src/main/resources/sky-walking.auth +++ b/samples/skywalking-example/mail-application/src/main/resources/sky-walking.auth @@ -4,7 +4,7 @@ buriedpoint.businesskey_max_length=300 sender.retry_get_sender_wait_interval=2000 buffer.pool_size=5 senderchecker.check_polling_time=200 -sender.is_off=false + sender.max_send_length=20000 consumer.max_consumer=2 consumer.max_wait_time=5 diff --git a/samples/skywalking-example/order-application/order-impl/src/main/resources/sky-walking.auth b/samples/skywalking-example/order-application/order-impl/src/main/resources/sky-walking.auth index b620af0ee0318a71294c69c2da33c6ad873c9ce9..bdafe6b6099f93b5a2b5e1568fdb86b9d8fb7799 100644 --- a/samples/skywalking-example/order-application/order-impl/src/main/resources/sky-walking.auth +++ b/samples/skywalking-example/order-application/order-impl/src/main/resources/sky-walking.auth @@ -4,7 +4,7 @@ buriedpoint.businesskey_max_length=300 sender.retry_get_sender_wait_interval=2000 buffer.pool_size=5 senderchecker.check_polling_time=200 -sender.is_off=false + sender.max_send_length=20000 consumer.max_consumer=2 consumer.max_wait_time=5 diff --git a/samples/skywalking-example/resources-application/resource-impl/src/main/resources/sky-walking.auth b/samples/skywalking-example/resources-application/resource-impl/src/main/resources/sky-walking.auth index 6dcf7f7cfd3ec93f38109e3c7356cffab7d7b997..9427a511c2028b21d81cabef60335eceb71e7c46 100644 --- a/samples/skywalking-example/resources-application/resource-impl/src/main/resources/sky-walking.auth +++ b/samples/skywalking-example/resources-application/resource-impl/src/main/resources/sky-walking.auth @@ -4,7 +4,7 @@ buriedpoint.businesskey_max_length=300 sender.retry_get_sender_wait_interval=2000 buffer.pool_size=5 senderchecker.check_polling_time=200 -sender.is_off=false + sender.max_send_length=20000 consumer.max_consumer=2 consumer.max_wait_time=5 diff --git a/samples/skywalking-example/web-application/src/main/resources/sky-walking.auth b/samples/skywalking-example/web-application/src/main/resources/sky-walking.auth index 533edb6ac3d5c9aa0b7be73ed79ac6c68f5a35f8..495cfed620cf5cf624529fe49adb17c5037bbdb3 100644 --- a/samples/skywalking-example/web-application/src/main/resources/sky-walking.auth +++ b/samples/skywalking-example/web-application/src/main/resources/sky-walking.auth @@ -4,7 +4,7 @@ buriedpoint.businesskey_max_length=300 sender.retry_get_sender_wait_interval=2000 buffer.pool_size=5 senderchecker.check_polling_time=200 -sender.is_off=false + sender.max_send_length=20000 consumer.max_consumer=2 consumer.max_wait_time=5 diff --git a/skywalking-api/src/main/java/com/ai/cloud/skywalking/buriedpoint/LocalBuriedPointSender.java b/skywalking-api/src/main/java/com/ai/cloud/skywalking/buriedpoint/LocalBuriedPointSender.java index fcfbb0620a5b0d34dcf602ed8929dc2dc38ca717..de3c9632bd4e75b081893c1554a7e0048b6a47fd 100644 --- a/skywalking-api/src/main/java/com/ai/cloud/skywalking/buriedpoint/LocalBuriedPointSender.java +++ b/skywalking-api/src/main/java/com/ai/cloud/skywalking/buriedpoint/LocalBuriedPointSender.java @@ -59,10 +59,7 @@ public class LocalBuriedPointSender extends ApplicationExceptionHandler + "\tbusinessKey:" + spanData.getBusinessKey()); } - // 存放到本地发送进程中 - if (!Config.Sender.IS_OFF) { - ContextBuffer.save(spanData); - } + ContextBuffer.save(spanData); } catch (Throwable t) { logger.error(t.getMessage(), t); } diff --git a/skywalking-api/src/main/java/com/ai/cloud/skywalking/buriedpoint/ThreadBuriedPointSender.java b/skywalking-api/src/main/java/com/ai/cloud/skywalking/buriedpoint/ThreadBuriedPointSender.java index 79b6be4c5b9ad65fd8d86f28b9792f29b7ac4fdc..7b0a625d62506c1b8ae9082b1f5706c0af8ceb38 100644 --- a/skywalking-api/src/main/java/com/ai/cloud/skywalking/buriedpoint/ThreadBuriedPointSender.java +++ b/skywalking-api/src/main/java/com/ai/cloud/skywalking/buriedpoint/ThreadBuriedPointSender.java @@ -22,59 +22,62 @@ import com.ai.cloud.skywalking.util.TraceIdGenerator; * */ @Deprecated -public class ThreadBuriedPointSender extends ApplicationExceptionHandler implements IBuriedPointSender { - private static Logger logger = LogManager.getLogger(ThreadBuriedPointSender.class); +public class ThreadBuriedPointSender extends ApplicationExceptionHandler + implements IBuriedPointSender { + private static Logger logger = LogManager + .getLogger(ThreadBuriedPointSender.class); - private Span span; + private Span span; - public ThreadBuriedPointSender(int threadSeqId) { - if (!AuthDesc.isAuth()) - return; - Span spanData; - // 从ThreadLocal中取出上下文 - final Span parentSpanData = Context.getLastSpan(); - if (parentSpanData == null) { - spanData = new Span(TraceIdGenerator.generate(), Config.SkyWalking.APPLICATION_CODE, - Config.SkyWalking.USER_ID); - } else { - // 如果不为空，则将当前的Context存放到上下文 - spanData = new Span(parentSpanData.getTraceId(), Config.SkyWalking.APPLICATION_CODE, - Config.SkyWalking.USER_ID); - spanData.setParentLevel(parentSpanData.getParentLevel() + "." + parentSpanData.getLevelId()); - spanData.setLevelId(threadSeqId); - } - this.span = spanData; - } + public ThreadBuriedPointSender(int threadSeqId) { + if (!AuthDesc.isAuth()) + return; + Span spanData; + // 从ThreadLocal中取出上下文 + final Span parentSpanData = Context.getLastSpan(); + if (parentSpanData == null) { + spanData = new Span(TraceIdGenerator.generate(), + Config.SkyWalking.APPLICATION_CODE, + Config.SkyWalking.USER_ID); + } else { + // 如果不为空，则将当前的Context存放到上下文 + spanData = new Span(parentSpanData.getTraceId(), + Config.SkyWalking.APPLICATION_CODE, + Config.SkyWalking.USER_ID); + spanData.setParentLevel(parentSpanData.getParentLevel() + "." + + parentSpanData.getLevelId()); + spanData.setLevelId(threadSeqId); + } + this.span = spanData; + } - public ContextData beforeSend(Identification id) { - if (!AuthDesc.isAuth()) - return new EmptyContextData(); + public ContextData beforeSend(Identification id) { + if (!AuthDesc.isAuth()) + return new EmptyContextData(); - if (this.span == null) { - return null; - } - span.setStartDate(System.currentTimeMillis()); - span.setViewPointId(id.getViewPoint()); - span.setProcessNo(BuriedPointMachineUtil.getProcessNo()); - Context.append(span); - return new ContextData(span); - } + if (this.span == null) { + return null; + } + span.setStartDate(System.currentTimeMillis()); + span.setViewPointId(id.getViewPoint()); + span.setProcessNo(BuriedPointMachineUtil.getProcessNo()); + Context.append(span); + return new ContextData(span); + } - public void afterSend() { - Span span = Context.removeLastSpan(); - if (span == null) { - return; - } - // 填上必要信息 - span.setCost(System.currentTimeMillis() - span.getStartDate()); - if (Config.BuriedPoint.PRINTF) { - logger.debug("viewpointId:" + span.getViewPointId() + "\tParentLevelId:" + span. - getParentLevel() + "\tLevelId:" + span.getLevelId()); - } - // 存放到本地发送进程中 - if (!Config.Sender.IS_OFF) { - ContextBuffer.save(span); - } - } + public void afterSend() { + Span span = Context.removeLastSpan(); + if (span == null) { + return; + } + // 填上必要信息 + span.setCost(System.currentTimeMillis() - span.getStartDate()); + if (Config.BuriedPoint.PRINTF) { + logger.debug("viewpointId:" + span.getViewPointId() + + "\tParentLevelId:" + span.getParentLevel() + "\tLevelId:" + + span.getLevelId()); + } + ContextBuffer.save(span); + } } diff --git a/skywalking-api/src/main/java/com/ai/cloud/skywalking/buriedpoint/ThreadFactoryBuriedPointSender.java b/skywalking-api/src/main/java/com/ai/cloud/skywalking/buriedpoint/ThreadFactoryBuriedPointSender.java index ff09f42bd9dd515ea4cc23fce7fed8c3b1e4c03c..c5a0ec76f3ee86e28955d2240f42fe4fc2aaaa2d 100644 --- a/skywalking-api/src/main/java/com/ai/cloud/skywalking/buriedpoint/ThreadFactoryBuriedPointSender.java +++ b/skywalking-api/src/main/java/com/ai/cloud/skywalking/buriedpoint/ThreadFactoryBuriedPointSender.java @@ -21,38 +21,38 @@ import com.ai.cloud.skywalking.util.ContextGenerator; * */ @Deprecated -public class ThreadFactoryBuriedPointSender extends ApplicationExceptionHandler implements IBuriedPointSender { - private static Logger logger = LogManager.getLogger(ThreadBuriedPointSender.class); +public class ThreadFactoryBuriedPointSender extends ApplicationExceptionHandler + implements IBuriedPointSender { + private static Logger logger = LogManager + .getLogger(ThreadBuriedPointSender.class); - public ContextData beforeSend(Identification id) { - if (!AuthDesc.isAuth()) - return new EmptyContextData(); + public ContextData beforeSend(Identification id) { + if (!AuthDesc.isAuth()) + return new EmptyContextData(); - Span spanData = ContextGenerator.generateSpanFromThreadLocal(id); - // 将新创建的Context存放到ThreadLocal栈中。 - Context.append(spanData); - // 并将当前的Context返回回去 - return new ContextData(spanData); - } + Span spanData = ContextGenerator.generateSpanFromThreadLocal(id); + // 将新创建的Context存放到ThreadLocal栈中。 + Context.append(spanData); + // 并将当前的Context返回回去 + return new ContextData(spanData); + } - public void afterSend() { - if (!AuthDesc.isAuth()) - return; + public void afterSend() { + if (!AuthDesc.isAuth()) + return; - // 获取上下文的栈顶中的元素 - Span spanData = Context.removeLastSpan(); - if (spanData == null) { - return; - } - // 填上必要信息 - spanData.setCost(System.currentTimeMillis() - spanData.getStartDate()); - if (Config.BuriedPoint.PRINTF) { - logger.debug("viewpointId:" + spanData.getViewPointId() + "\tParentLevelId:" + spanData. - getParentLevel() + "\tLevelId:" + spanData.getLevelId()); - } - // 存放到本地发送进程中 - if (!Config.Sender.IS_OFF) { - ContextBuffer.save(spanData); - } - } + // 获取上下文的栈顶中的元素 + Span spanData = Context.removeLastSpan(); + if (spanData == null) { + return; + } + // 填上必要信息 + spanData.setCost(System.currentTimeMillis() - spanData.getStartDate()); + if (Config.BuriedPoint.PRINTF) { + logger.debug("viewpointId:" + spanData.getViewPointId() + + "\tParentLevelId:" + spanData.getParentLevel() + + "\tLevelId:" + spanData.getLevelId()); + } + ContextBuffer.save(spanData); + } } diff --git a/skywalking-api/src/main/java/com/ai/cloud/skywalking/conf/Config.java b/skywalking-api/src/main/java/com/ai/cloud/skywalking/conf/Config.java index cc8a95f152c92f6b34c407ec2a1058849c396ddb..c6ccb229297014e67fd39553fe01cd0e9e98eb79 100644 --- a/skywalking-api/src/main/java/com/ai/cloud/skywalking/conf/Config.java +++ b/skywalking-api/src/main/java/com/ai/cloud/skywalking/conf/Config.java @@ -52,9 +52,6 @@ public class Config { // 发送服务端配置 public static String SERVERS_ADDR = "127.0.0.1:34000"; - // 是否开启发送 - public static boolean IS_OFF = false; - // 最大发送副本数量 public static int MAX_COPY_NUM = 2; diff --git a/skywalking-api/src/test/resources/sky-walking.auth b/skywalking-api/src/test/resources/sky-walking.auth index 5b8bfafcf27fa4b4d617d18751fc37b2aaa85a7d..95aa1d9766732774a9b1c8c49a23eaf494361d5e 100644 --- a/skywalking-api/src/test/resources/sky-walking.auth +++ b/skywalking-api/src/test/resources/sky-walking.auth @@ -26,8 +26,8 @@ sender.max_copy_num=2 sender.max_send_length=20000 #当没有Sender时,尝试获取sender的等待周期 sender.retry_get_sender_wait_interval=2000 -#是否开启发送消息 -sender.is_off=false + + #最大消费线程数 diff --git a/skywalking-sdk-plugin/dubbo-plugin/src/test/resources/sky-walking.auth b/skywalking-sdk-plugin/dubbo-plugin/src/test/resources/sky-walking.auth index c794ea37c6eab65dc8961cf7d320e10a00f84871..cc8b1c7bb0cf8189c2b37c961c1265a44a7b644f 100644 --- a/skywalking-sdk-plugin/dubbo-plugin/src/test/resources/sky-walking.auth +++ b/skywalking-sdk-plugin/dubbo-plugin/src/test/resources/sky-walking.auth @@ -26,8 +26,8 @@ sender.max_copy_num=2 sender.max_send_length=20000 #当没有Sender时,尝试获取sender的等待周期 sender.retry_get_sender_wait_interval=2000 -#是否开启发送消息 -sender.is_off=false + + #最大消费线程数 diff --git a/skywalking-sdk-plugin/httpClient-4.x-plugin-dubbox-rest-attachment/src/test/resources/sky-walking.auth b/skywalking-sdk-plugin/httpClient-4.x-plugin-dubbox-rest-attachment/src/test/resources/sky-walking.auth index c794ea37c6eab65dc8961cf7d320e10a00f84871..cc8b1c7bb0cf8189c2b37c961c1265a44a7b644f 100644 --- a/skywalking-sdk-plugin/httpClient-4.x-plugin-dubbox-rest-attachment/src/test/resources/sky-walking.auth +++ b/skywalking-sdk-plugin/httpClient-4.x-plugin-dubbox-rest-attachment/src/test/resources/sky-walking.auth @@ -26,8 +26,8 @@ sender.max_copy_num=2 sender.max_send_length=20000 #当没有Sender时,尝试获取sender的等待周期 sender.retry_get_sender_wait_interval=2000 -#是否开启发送消息 -sender.is_off=false + + #最大消费线程数 diff --git a/skywalking-sdk-plugin/httpClient-4.x-plugin/src/test/resources/sky-walking.auth b/skywalking-sdk-plugin/httpClient-4.x-plugin/src/test/resources/sky-walking.auth index c794ea37c6eab65dc8961cf7d320e10a00f84871..cc8b1c7bb0cf8189c2b37c961c1265a44a7b644f 100644 --- a/skywalking-sdk-plugin/httpClient-4.x-plugin/src/test/resources/sky-walking.auth +++ b/skywalking-sdk-plugin/httpClient-4.x-plugin/src/test/resources/sky-walking.auth @@ -26,8 +26,8 @@ sender.max_copy_num=2 sender.max_send_length=20000 #当没有Sender时,尝试获取sender的等待周期 sender.retry_get_sender_wait_interval=2000 -#是否开启发送消息 -sender.is_off=false + + #最大消费线程数 diff --git a/skywalking-sdk-plugin/jedis-2.x-plugin/src/test/resources/sky-walking.auth b/skywalking-sdk-plugin/jedis-2.x-plugin/src/test/resources/sky-walking.auth index c794ea37c6eab65dc8961cf7d320e10a00f84871..cc8b1c7bb0cf8189c2b37c961c1265a44a7b644f 100644 --- a/skywalking-sdk-plugin/jedis-2.x-plugin/src/test/resources/sky-walking.auth +++ b/skywalking-sdk-plugin/jedis-2.x-plugin/src/test/resources/sky-walking.auth @@ -26,8 +26,8 @@ sender.max_copy_num=2 sender.max_send_length=20000 #当没有Sender时,尝试获取sender的等待周期 sender.retry_get_sender_wait_interval=2000 -#是否开启发送消息 -sender.is_off=false + + #最大消费线程数 diff --git a/skywalking-sdk-plugin/mysql-plugin/src/test/resources/sky-walking.auth b/skywalking-sdk-plugin/mysql-plugin/src/test/resources/sky-walking.auth index c794ea37c6eab65dc8961cf7d320e10a00f84871..cc8b1c7bb0cf8189c2b37c961c1265a44a7b644f 100644 --- a/skywalking-sdk-plugin/mysql-plugin/src/test/resources/sky-walking.auth +++ b/skywalking-sdk-plugin/mysql-plugin/src/test/resources/sky-walking.auth @@ -26,8 +26,8 @@ sender.max_copy_num=2 sender.max_send_length=20000 #当没有Sender时,尝试获取sender的等待周期 sender.retry_get_sender_wait_interval=2000 -#是否开启发送消息 -sender.is_off=false + + #最大消费线程数 diff --git a/skywalking-sdk-plugin/spring-plugin/src/test/resources/sky-walking.auth b/skywalking-sdk-plugin/spring-plugin/src/test/resources/sky-walking.auth index c794ea37c6eab65dc8961cf7d320e10a00f84871..cc8b1c7bb0cf8189c2b37c961c1265a44a7b644f 100644 --- a/skywalking-sdk-plugin/spring-plugin/src/test/resources/sky-walking.auth +++ b/skywalking-sdk-plugin/spring-plugin/src/test/resources/sky-walking.auth @@ -26,8 +26,8 @@ sender.max_copy_num=2 sender.max_send_length=20000 #当没有Sender时,尝试获取sender的等待周期 sender.retry_get_sender_wait_interval=2000 -#是否开启发送消息 -sender.is_off=false + + #最大消费线程数