diff --git a/samples/skywalking-auth/src/main/resources/sky-walking.auth b/samples/skywalking-auth/src/main/resources/sky-walking.auth index e92c0eea8d8561623adf2905c57f9478750335d0..9bd8bd8c6c21e6e4bce71d78e4f0dc0b29e9b7f6 100644 --- a/samples/skywalking-auth/src/main/resources/sky-walking.auth +++ b/samples/skywalking-auth/src/main/resources/sky-walking.auth @@ -1,34 +1,38 @@ #skyWalking用户ID skywalking.user_id=123 +#skyWalking应用ID +skywalking.application_id=test #是否打印数据 buriedpoint.printf=false +#埋点异常的最大长度 +buriedpoint.max_exception_stack_length=4000 +#业务字段的最大长度 +buriedpoint.businesskey_max_length=300 + #发送的最大长度 sender.max_sender_length=8000 -#服务端的读取步长 -sender.read_step_length=256 +#最大发送者的连接数阀比例 +sender.connect_percent=100 +#当没有Sender时,尝试获取sender的等待周期 +sender.retry_get_sender_wait_interval=2000 +#是否开启发送消息 +sender.is_off=false +#发送服务端配置 +sender.servers_addr=127.0.0.1:34000 + #最大消费线程数 consumer.max_consumer=2 #消费者最大等待时间 consumer.max_wait_time=5 #发送失败等待时间 consumer.consumer_fail_retry_wait_interval=50 + #每个Buffer的最大个数 buffer.buffer_max_size=18000 #Buffer池的最大长度 buffer.pool_size=5 -#最大发送者的连接数阀比例 -sender.connect_percent=100 -#当没有Sender时,尝试获取sender的等待周期 -sender.retry_get_sender_wait_interval=2000 -#是否开启发送消息 -sender.is_off=false -#发送服务端配置 -sender.servers_addr=127.0.0.1:34000 -#埋点异常的最大长度 -buriedpoint.max_exception_stack_length=4000 + #发送检查线程检查周期 senderchecker.check_polling_time=200 -#业务字段的最大长度 -businesskey.max_length=300 \ No newline at end of file diff --git a/skywalking-api/src/main/java/com/ai/cloud/skywalking/api/BusinessKeyAppender.java b/skywalking-api/src/main/java/com/ai/cloud/skywalking/api/BusinessKeyAppender.java index 68eb7701ac1e8372103c3533105bda667557cf1c..efe9cc94e4fcfc22578b131bf8d656274bf23b09 100644 --- a/skywalking-api/src/main/java/com/ai/cloud/skywalking/api/BusinessKeyAppender.java +++ b/skywalking-api/src/main/java/com/ai/cloud/skywalking/api/BusinessKeyAppender.java @@ -24,10 +24,10 @@ public final class BusinessKeyAppender { if (spanData == null) { return; } - if (businessKey.length() <= Config.BusinessKey.MAX_LENGTH) { + if (businessKey.length() <= Config.BuriedPoint.BUSINESSKEY_MAX_LENGTH) { spanData.setBusinessKey(businessKey); return; } - spanData.setBusinessKey(businessKey.substring(0, Config.BusinessKey.MAX_LENGTH)); + spanData.setBusinessKey(businessKey.substring(0, Config.BuriedPoint.BUSINESSKEY_MAX_LENGTH)); } } 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 8eb6b850aac6b2020532e3bc888f3820e8ed5ead..0149406a32fb570ce5532720f4d6f009e210a3a7 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 @@ -2,64 +2,60 @@ package com.ai.cloud.skywalking.conf; public class Config { - public static class SkyWalking { - public static String USER_ID; + public static class SkyWalking { + public static String USER_ID; - public static String APPLICATION_ID; - } + public static String APPLICATION_ID; + } - public static class BuriedPoint { - //是否打印埋点信息 - public static boolean PRINTF = false; + public static class BuriedPoint { + // 是否打印埋点信息 + public static boolean PRINTF = false; - public static int MAX_EXCEPTION_STACK_LENGTH = 4000; - } + public static int MAX_EXCEPTION_STACK_LENGTH = 4000; - public static class Consumer { - //最大消费线程数 - public static int MAX_CONSUMER = 2; - //消费者最大等待时间 - public static long MAX_WAIT_TIME = 5L; + // Business Key 最大长度 + public static int BUSINESSKEY_MAX_LENGTH = 300; + } - // - public static long CONSUMER_FAIL_RETRY_WAIT_INTERVAL = 50L; - } + public static class Consumer { + // 最大消费线程数 + public static int MAX_CONSUMER = 2; + // 消费者最大等待时间 + public static long MAX_WAIT_TIME = 5L; - public static class Buffer { - // 每个Buffer的最大个数 - public static int BUFFER_MAX_SIZE = 18000; + // + public static long CONSUMER_FAIL_RETRY_WAIT_INTERVAL = 50L; + } - // Buffer池的最大长度 - public static int POOL_SIZE = 5; - } + public static class Buffer { + // 每个Buffer的最大个数 + public static int BUFFER_MAX_SIZE = 18000; - public static class Sender { - // 最大发送者的连接数阀比例 - public static int CONNECT_PERCENT = 50; + // Buffer池的最大长度 + public static int POOL_SIZE = 5; + } - // 发送服务端配置 - public static String SERVERS_ADDR; + public static class Sender { + // 最大发送者的连接数阀比例 + public static int CONNECT_PERCENT = 50; - // 是否开启发送 - public static boolean IS_OFF = false; + // 发送服务端配置 + public static String SERVERS_ADDR; - // 发送的最大长度 - public static int MAX_SEND_LENGTH = 1800; + // 是否开启发送 + public static boolean IS_OFF = false; + // 发送的最大长度 + public static int MAX_SEND_LENGTH = 1800; - public static long RETRY_GET_SENDER_WAIT_INTERVAL = 2000L; + public static long RETRY_GET_SENDER_WAIT_INTERVAL = 2000L; - } + } - public static class SenderChecker { + public static class SenderChecker { - //检查周期时间 - public static long CHECK_POLLING_TIME = 200L; - } - - - public static class BusinessKey { - //Business Key 最大长度 - public static int MAX_LENGTH = 300; - } + // 检查周期时间 + public static long CHECK_POLLING_TIME = 200L; + } } \ No newline at end of file diff --git a/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/conf/Config.java b/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/conf/Config.java index f3d3e0e06cbbd3038a26c0eaa0cf27204f16c9d3..5c55e4f9280fe45eddd358ddda0050db22106106 100644 --- a/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/conf/Config.java +++ b/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/conf/Config.java @@ -41,9 +41,7 @@ public class Config { public static int MAX_THREAD_NUMBER = 1; // 定位文件时,每次读取偏移量跳过大小 - public static int OFFSET_FILE_SKIP_LENGTH = 2048; - - // 每次读取文件偏移量大小 + public static int STEP_SIZE_FOR_LOCATING_FILE_OFFSET = 2048; // 处理文件完成之后,等待时间 public static long SWITCH_FILE_WAIT_TIME = 5000L; diff --git a/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/persistance/PersistenceThread.java b/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/persistance/PersistenceThread.java index 68550d6c3f2998897ad3e31132e761e704b63caa..61fd18529f6051373d8a8b68e16bff60b2e027e4 100644 --- a/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/persistance/PersistenceThread.java +++ b/skywalking-server/src/main/java/com/ai/cloud/skywalking/reciever/persistance/PersistenceThread.java @@ -144,10 +144,10 @@ public class PersistenceThread extends Thread { FileRegisterEntry.FileRegisterEntryStatus.REGISTER)); offset = 0; } else { - char[] cha = new char[OFFSET_FILE_SKIP_LENGTH]; + char[] cha = new char[STEP_SIZE_FOR_LOCATING_FILE_OFFSET]; int length = 0; - while (length + OFFSET_FILE_SKIP_LENGTH < offset) { - length += OFFSET_FILE_SKIP_LENGTH; + while (length + STEP_SIZE_FOR_LOCATING_FILE_OFFSET < offset) { + length += STEP_SIZE_FOR_LOCATING_FILE_OFFSET; bufferedReader.read(cha); } bufferedReader.read(cha, 0, Math.abs(offset - length)); diff --git a/skywalking-server/src/main/resources/config.properties b/skywalking-server/src/main/resources/config.properties index 6b7967f03ca37b66839267b4f5a4b50ab3671bce..9d5284d229f50f1cc2b0e981b9a640c8f8fc5c4c 100644 --- a/skywalking-server/src/main/resources/config.properties +++ b/skywalking-server/src/main/resources/config.properties @@ -19,9 +19,7 @@ buffer.flush_number_of_cache=30 #最大持久化的线程数量 persistence.max_thread_number=3 #定位文件时,每次读取偏移量跳过大小 -persistence.offset_file_skip_length=20480 -#每次读取文件偏移量大小 -persistence.offset_file_read_buffer_size=20480 +persistence.step_size_for_location_file_offset=20480 #处理文件完成之后,等待时间(单位:毫秒) persistence.switch_file_wait_time=5000 #追加EOF标志位的线程数量