重构代码，下沉埋点信息到Protocol工程
This commit is contained in:
zhangxin10
parent
befeb5929e
commit
24cc200f85
|
|
@ -0,0 +1,129 @@
|
|||
package com.ai.cloud.skywalking.protocol;
|
||||
|
||||
|
||||
import java.io.ByteArrayOutputStream;
|
||||
import java.io.IOException;
|
||||
import java.util.logging.Level;
|
||||
import java.util.logging.Logger;
|
||||
|
||||
public class Span extends SpanData {
|
||||
|
||||
private Logger logger = Logger.getLogger(Span.class.getName());
|
||||
|
||||
public Span() {
|
||||
}
|
||||
|
||||
public Span(String traceId, String applicationID) {
|
||||
this.traceId = traceId;
|
||||
this.applicationId = applicationID;
|
||||
}
|
||||
|
||||
public Span(String originData) {
|
||||
String[] fieldValues = originData.split(SPILT_REGEX);
|
||||
traceId = fieldValues[0].trim();
|
||||
parentLevel = fieldValues[1].trim();
|
||||
levelId = Integer.valueOf(fieldValues[2]);
|
||||
viewPointId = fieldValues[3].trim();
|
||||
startDate = Long.valueOf(fieldValues[4]);
|
||||
cost = Long.parseLong(fieldValues[5]);
|
||||
address = fieldValues[6].trim();
|
||||
statusCode = Byte.valueOf(fieldValues[7].trim());
|
||||
//异常情况才会存在exceptionStack
|
||||
if (statusCode == 1) {
|
||||
exceptionStack = fieldValues[8].trim().replaceAll(SpanData.EXCEPTION_SPILT_PATTERN,
|
||||
SpanData.NEW_LINE_CHARACTER_PATTERN);
|
||||
}
|
||||
spanType = fieldValues[9].charAt(0);
|
||||
isReceiver = Boolean.valueOf(fieldValues[10]);
|
||||
businessKey = fieldValues[11].trim();
|
||||
processNo = fieldValues[12].trim();
|
||||
applicationId = fieldValues[13].trim();
|
||||
this.originData = originData;
|
||||
}
|
||||
|
||||
|
||||
@Override
|
||||
public String toString() {
|
||||
StringBuilder toStringValue = new StringBuilder();
|
||||
toStringValue.append(traceId + SPAN_FIELD_SPILT_PATTERN);
|
||||
|
||||
if (isNonBlank(parentLevel)) {
|
||||
toStringValue.append(parentLevel + SPAN_FIELD_SPILT_PATTERN);
|
||||
} else {
|
||||
toStringValue.append(" " + SPAN_FIELD_SPILT_PATTERN);
|
||||
}
|
||||
|
||||
toStringValue.append(levelId + SPAN_FIELD_SPILT_PATTERN);
|
||||
|
||||
if (isNonBlank(viewPointId)) {
|
||||
toStringValue.append(viewPointId + SPAN_FIELD_SPILT_PATTERN);
|
||||
} else {
|
||||
toStringValue.append(" " + SPAN_FIELD_SPILT_PATTERN);
|
||||
}
|
||||
|
||||
toStringValue.append(startDate + SPAN_FIELD_SPILT_PATTERN);
|
||||
toStringValue.append(cost + SPAN_FIELD_SPILT_PATTERN);
|
||||
|
||||
if (isNonBlank(address)) {
|
||||
toStringValue.append(address + SPAN_FIELD_SPILT_PATTERN);
|
||||
} else {
|
||||
toStringValue.append(" " + SPAN_FIELD_SPILT_PATTERN);
|
||||
}
|
||||
|
||||
toStringValue.append(statusCode + SPAN_FIELD_SPILT_PATTERN);
|
||||
|
||||
if (isNonBlank(exceptionStack)) {
|
||||
toStringValue.append(exceptionStack.replaceAll(NEW_LINE_CHARACTER_PATTERN, EXCEPTION_SPILT_PATTERN)
|
||||
+ SPAN_FIELD_SPILT_PATTERN);
|
||||
} else {
|
||||
toStringValue.append(" " + SPAN_FIELD_SPILT_PATTERN);
|
||||
}
|
||||
|
||||
toStringValue.append(spanType + SPAN_FIELD_SPILT_PATTERN);
|
||||
toStringValue.append(isReceiver + SPAN_FIELD_SPILT_PATTERN);
|
||||
|
||||
|
||||
if (isNonBlank(businessKey)) {
|
||||
toStringValue.append(businessKey.replaceAll(NEW_LINE_CHARACTER_PATTERN,
|
||||
BUSINESSKEY_SPILT_PATTERN) + SPAN_FIELD_SPILT_PATTERN);
|
||||
} else {
|
||||
toStringValue.append(" " + SPAN_FIELD_SPILT_PATTERN);
|
||||
}
|
||||
|
||||
if (isNonBlank(processNo)) {
|
||||
toStringValue.append(processNo + SPAN_FIELD_SPILT_PATTERN);
|
||||
} else {
|
||||
toStringValue.append(" " + SPAN_FIELD_SPILT_PATTERN);
|
||||
}
|
||||
|
||||
if (isNonBlank(applicationId)) {
|
||||
toStringValue.append(applicationId);
|
||||
} else {
|
||||
toStringValue.append(" " + SPAN_FIELD_SPILT_PATTERN);
|
||||
}
|
||||
|
||||
return toStringValue.toString();
|
||||
}
|
||||
|
||||
protected boolean isNonBlank(String str) {
|
||||
return str != null && str.length() > 0;
|
||||
}
|
||||
|
||||
public void handleException(Throwable e, int maxExceptionStackLength) {
|
||||
this.statusCode = 1;
|
||||
ByteArrayOutputStream buf = new ByteArrayOutputStream();
|
||||
StringBuilder expMessage = new StringBuilder();
|
||||
Throwable causeException = e;
|
||||
while (causeException != null && (causeException.getCause() != null || expMessage.length() < maxExceptionStackLength)) {
|
||||
causeException.printStackTrace(new java.io.PrintWriter(buf, true));
|
||||
expMessage.append(buf.toString());
|
||||
causeException = causeException.getCause();
|
||||
}
|
||||
try {
|
||||
buf.close();
|
||||
} catch (IOException e1) {
|
||||
logger.log(Level.ALL, "Close exception stack input stream failed");
|
||||
}
|
||||
this.exceptionStack = expMessage.toString();
|
||||
}
|
||||
}
|
||||
|
|
@ -0,0 +1,99 @@
|
|||
package com.ai.cloud.skywalking.protocol;
|
||||
|
||||
public abstract class SpanData {
|
||||
|
||||
protected static final String SPAN_FIELD_SPILT_PATTERN = "^~";
|
||||
protected static final String BUSINESSKEY_SPILT_PATTERN = "~^";
|
||||
protected static final String SPILT_REGEX = "\\^\\~";
|
||||
protected static final String NEW_LINE_CHARACTER_PATTERN = "\\n";
|
||||
protected static final String EXCEPTION_SPILT_PATTERN = "^";
|
||||
|
||||
protected String traceId;
|
||||
protected String parentLevel;
|
||||
protected int levelId;
|
||||
protected String viewPointId;
|
||||
protected long startDate;
|
||||
protected long cost;
|
||||
protected String address;
|
||||
protected byte statusCode = 0;
|
||||
protected String exceptionStack;
|
||||
protected char spanType;
|
||||
protected boolean isReceiver = false;
|
||||
protected String businessKey;
|
||||
protected String processNo;
|
||||
protected String applicationId;
|
||||
protected String originData;
|
||||
|
||||
|
||||
public String getTraceId() {
|
||||
return traceId;
|
||||
}
|
||||
|
||||
public String getParentLevel() {
|
||||
return parentLevel;
|
||||
}
|
||||
|
||||
public void setParentLevel(String parentLevel) {
|
||||
this.parentLevel = parentLevel;
|
||||
}
|
||||
|
||||
public int getLevelId() {
|
||||
return levelId;
|
||||
}
|
||||
|
||||
public void setLevelId(int levelId) {
|
||||
this.levelId = levelId;
|
||||
}
|
||||
|
||||
public String getViewPointId() {
|
||||
return viewPointId;
|
||||
}
|
||||
|
||||
public void setViewPointId(String viewPointId) {
|
||||
this.viewPointId = viewPointId;
|
||||
}
|
||||
|
||||
public long getStartDate() {
|
||||
return startDate;
|
||||
}
|
||||
|
||||
public void setStartDate(long startDate) {
|
||||
this.startDate = startDate;
|
||||
}
|
||||
|
||||
public void setCost(long cost) {
|
||||
this.cost = cost;
|
||||
}
|
||||
|
||||
public void setAddress(String address) {
|
||||
this.address = address;
|
||||
}
|
||||
|
||||
public char getSpanType() {
|
||||
return spanType;
|
||||
}
|
||||
|
||||
public void setSpanType(char spanType) {
|
||||
this.spanType = spanType;
|
||||
}
|
||||
|
||||
public boolean isReceiver() {
|
||||
return isReceiver;
|
||||
}
|
||||
|
||||
public void setReceiver(boolean receiver) {
|
||||
isReceiver = receiver;
|
||||
}
|
||||
|
||||
public void setBusinessKey(String businessKey) {
|
||||
this.businessKey = businessKey;
|
||||
}
|
||||
|
||||
public void setProcessNo(String processNo) {
|
||||
this.processNo = processNo;
|
||||
}
|
||||
|
||||
public String getOriginData() {
|
||||
return originData;
|
||||
}
|
||||
}
|
||||
Loading…
Reference in New Issue