Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
apache
SkyWalking
提交
d3c032ae
S
SkyWalking
项目概览
apache
/
SkyWalking
上一次同步 1 年多
通知
302
Star
21345
Fork
6091
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
0
列表
看板
标记
里程碑
合并请求
0
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
S
SkyWalking
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
0
Issue
0
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
提交
Issue看板
前往新版Gitcode,体验更适合开发者的 AI 搜索 >>
提交
d3c032ae
编写于
1月 12, 2016
作者:
Z
zhangxin10
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
1.修改TID的生成规则,将SDKVersion号添加
上级
72c9d15f
变更
3
隐藏空白更改
内联
并排
Showing
3 changed file
with
79 addition
and
73 deletion
+79
-73
samples/skywalking-auth/src/main/resources/sky-walking.auth
samples/skywalking-auth/src/main/resources/sky-walking.auth
+2
-0
skywalking-api/src/main/java/com/ai/cloud/skywalking/conf/Config.java
...pi/src/main/java/com/ai/cloud/skywalking/conf/Config.java
+55
-53
skywalking-api/src/main/java/com/ai/cloud/skywalking/util/TraceIdGenerator.java
...n/java/com/ai/cloud/skywalking/util/TraceIdGenerator.java
+22
-20
未找到文件。
samples/skywalking-auth/src/main/resources/sky-walking.auth
浏览文件 @
d3c032ae
...
...
@@ -6,6 +6,8 @@ skywalking.application_code=test
skywalking.auth_system_env_name=SKYWALKING_RUN
#skywalking数据编码
skywalking.charset=UTF-8
#skywalking SDK的版本
skywalking.sdk_version=1.0a2
#是否打印数据
buriedpoint.printf=false
...
...
skywalking-api/src/main/java/com/ai/cloud/skywalking/conf/Config.java
浏览文件 @
d3c032ae
...
...
@@ -2,76 +2,78 @@ 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_CODE
=
""
;
public
static
String
APPLICATION_CODE
=
""
;
public
static
String
AUTH_SYSTEM_ENV_NAME
=
"SKYWALKING_RUN"
;
public
static
boolean
AUTH_OVERRIDE
=
false
;
public
static
String
AUTH_SYSTEM_ENV_NAME
=
"SKYWALKING_RUN"
;
public
static
String
CHARSET
=
"UTF-8"
;
}
public
static
boolean
AUTH_OVERRIDE
=
false
;
public
static
class
BuriedPoint
{
// 是否打印埋点信息
public
static
boolean
PRINTF
=
false
;
public
static
String
CHARSET
=
"UTF-8"
;
public
static
int
MAX_EXCEPTION_STACK_LENGTH
=
4000
;
public
static
String
SDK_VERSION
=
""
;
}
// Business Key 最大长度
public
static
int
BUSINESSKEY_MAX_LENGTH
=
300
;
// 使用逗号分离
public
static
String
EXCLUSIVE_EXCEPTIONS
=
""
;
}
public
static
class
BuriedPoint
{
// 是否打印埋点信息
public
static
boolean
PRINTF
=
false
;
public
static
class
Consumer
{
// 最大消费线程数
public
static
int
MAX_CONSUMER
=
2
;
// 消费者最大等待时间
public
static
long
MAX_WAIT_TIME
=
5L
;
public
static
int
MAX_EXCEPTION_STACK_LENGTH
=
4000
;
//
public
static
long
CONSUMER_FAIL_RETRY_WAIT_INTERVAL
=
50L
;
}
// Business Key 最大长度
public
static
int
BUSINESSKEY_MAX_LENGTH
=
300
;
public
static
class
Buffer
{
// 每个Buffer的最大个数
public
static
int
BUFFER_MAX_SIZE
=
20000
;
// 使用逗号分离
public
static
String
EXCLUSIVE_EXCEPTIONS
=
""
;
}
// Buffer池的最大长度
public
static
int
POOL_SIZE
=
5
;
}
public
static
class
Consumer
{
// 最大消费线程数
public
static
int
MAX_CONSUMER
=
2
;
// 消费者最大等待时间
public
static
long
MAX_WAIT_TIME
=
5L
;
public
static
class
Sender
{
// 最大发送者的连接数阀比例
public
static
int
CONNECT_PERCENT
=
50
;
//
public
static
long
CONSUMER_FAIL_RETRY_WAIT_INTERVAL
=
50L
;
}
// 发送服务端配置
public
static
String
SERVERS_ADDR
=
"127.0.0.1:34000;127.0.0.1:34001;127.0.0.1:34002"
;
public
static
class
Buffer
{
// 每个Buffer的最大个数
public
static
int
BUFFER_MAX_SIZE
=
20000
;
// 是否开启发送
public
static
boolean
IS_OFF
=
false
;
// 最大发送副本数量
public
static
int
MAX_COPY_NUM
=
2
;
// Buffer池的最大长度
public
static
int
POOL_SIZE
=
5
;
}
// 发送的最大长度
public
static
int
MAX_SEND_LENGTH
=
18500
;
public
static
class
Sender
{
// 最大发送者的连接数阀比例
public
static
int
CONNECT_PERCENT
=
50
;
public
static
long
RETRY_GET_SENDER_WAIT_INTERVAL
=
2000L
;
// 发送服务端配置
public
static
String
SERVERS_ADDR
=
"127.0.0.1:34000;127.0.0.1:34001;127.0.0.1:34002"
;
// 切换Sender的周期
public
static
long
SWITCH_SENDER_INTERVAL
=
10
*
60
*
1000
;
// 是否开启发送
public
static
boolean
IS_OFF
=
false
;
// 切换Sender之后,关闭Sender的倒计时
public
static
long
CLOSE_SENDER_COUNTDOWN
=
10
*
1000
;
// 最大发送副本数量
public
static
int
MAX_COPY_NUM
=
2
;
// Checker线程处理完成等待周期
public
static
long
CHECKER_THREAD_WAIT_INTERVAL
=
10
00
;
// 发送的最大长度
public
static
int
MAX_SEND_LENGTH
=
185
00
;
public
static
long
RETRY_FIND_CONNECTION_SENDER
=
1000
;
}
public
static
long
RETRY_GET_SENDER_WAIT_INTERVAL
=
2000L
;
// 切换Sender的周期
public
static
long
SWITCH_SENDER_INTERVAL
=
10
*
60
*
1000
;
// 切换Sender之后,关闭Sender的倒计时
public
static
long
CLOSE_SENDER_COUNTDOWN
=
10
*
1000
;
// Checker线程处理完成等待周期
public
static
long
CHECKER_THREAD_WAIT_INTERVAL
=
1000
;
public
static
long
RETRY_FIND_CONNECTION_SENDER
=
1000
;
}
}
\ No newline at end of file
skywalking-api/src/main/java/com/ai/cloud/skywalking/util/TraceIdGenerator.java
浏览文件 @
d3c032ae
package
com.ai.cloud.skywalking.util
;
import
com.ai.cloud.skywalking.conf.Config
;
import
java.util.UUID
;
public
final
class
TraceIdGenerator
{
private
static
final
ThreadLocal
<
Integer
>
ThreadTraceIdSequence
=
new
ThreadLocal
<
Integer
>();
private
static
final
String
PROCESS_UUID
;
static
{
String
uuid
=
UUID
.
randomUUID
().
toString
().
replaceAll
(
"-"
,
""
);
PROCESS_UUID
=
uuid
.
substring
(
uuid
.
length
()
-
7
);
}
private
static
final
ThreadLocal
<
Integer
>
ThreadTraceIdSequence
=
new
ThreadLocal
<
Integer
>();
private
static
final
String
PROCESS_UUID
;
static
{
String
uuid
=
UUID
.
randomUUID
().
toString
().
replaceAll
(
"-"
,
""
);
PROCESS_UUID
=
uuid
.
substring
(
uuid
.
length
()
-
7
);
}
private
TraceIdGenerator
()
{
}
public
static
String
generate
(){
Integer
seq
=
ThreadTraceIdSequence
.
get
();
if
(
seq
==
null
||
seq
==
10000
||
seq
>
10000
)
{
seq
=
0
;
}
seq
++;
ThreadTraceIdSequence
.
set
(
seq
);
return
System
.
currentTimeMillis
()
public
static
String
generate
()
{
Integer
seq
=
ThreadTraceIdSequence
.
get
();
if
(
seq
==
null
||
seq
==
10000
||
seq
>
10000
)
{
seq
=
0
;
}
seq
++;
ThreadTraceIdSequence
.
set
(
seq
);
return
Config
.
SkyWalking
.
SDK_VERSION
+
"."
+
System
.
currentTimeMillis
()
+
PROCESS_UUID
+
BuriedPointMachineUtil
.
getProcessNo
()
+
Thread
.
currentThread
().
getId
()
+
Thread
.
currentThread
().
getId
()
+
seq
;
}
}
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录