software/glogcenter
1
0
Fork 0
mirror of https://github.com/gotoeasy/glogcenter.git synced 2025-09-15 12:58:34 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix: #9 特殊字符处理

Browse Source
This commit is contained in:
gotoeasy 2023-05-16 21:19:29 +08:00
parent 8d0e36f1b5
commit 522745cbc5
2 changed files with 93 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

48
glc-logback-appender/src/main/java/top/gotoeasy/framework/glc/logback/appender/GlcAmqpAppender.java
View File

@ -1,6 +1,8 @@
package top.gotoeasy.framework.glc.logback.appender;
import java.text.CharacterIterator;
import java.text.SimpleDateFormat;
import java.text.StringCharacterIterator;
import java.util.Date;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
@ -88,6 +90,10 @@ public class GlcAmqpAppender extends AppenderBase<ILoggingEvent> {
* @param text 日志
*/
protected void sendToRabbitMQ(String text) {
if (text == null) {
return; // ignore
}
try {
if (channel == null) {
initConnectionChannel();
@ -234,8 +240,46 @@ public class GlcAmqpAppender extends AppenderBase<ILoggingEvent> {
}
private String encodeStr(String str) {
return "\"" + str.replaceAll("\"", "\\\\\"").replaceAll("\t", "\\\\t").replaceAll("\r", "\\\\r")
.replaceAll("\n", "\\\\n") + "\"";
StringBuilder buf = new StringBuilder();
buf.append('"');
CharacterIterator it = new StringCharacterIterator(str);
for (char c = it.first(); c != CharacterIterator.DONE; c = it.next()) {
if (c == '"')
buf.append("\\\"");
else if (c == '\\')
buf.append("\\\\");
else if (c == '/')
buf.append("\\/");
else if (c == '\b')
buf.append("\\b");
else if (c == '\f')
buf.append("\\f");
else if (c == '\n')
buf.append("\\n");
else if (c == '\r')
buf.append("\\r");
else if (c == '\t')
buf.append("\\t");
else if (Character.isISOControl(c)) {
addUnicode(buf, c);
} else {
buf.append(c);
}
}
buf.append('"');
return buf.toString();
}
static final char[] hex = "0123456789ABCDEF".toCharArray();
private void addUnicode(StringBuilder buf, char c) {
buf.append("\\u");
int n = c;
for (int i = 0; i < 4; ++i) {
int digit = (n & 0xf000) >> 12;
buf.append(hex[digit]);
n <<= 4;
}
}
private static String getDateString() {

50
glc-logback-appender/src/main/java/top/gotoeasy/framework/glc/logback/appender/GlcHttpJsonAppender.java
View File

@ -3,7 +3,9 @@ package top.gotoeasy.framework.glc.logback.appender;
import java.io.DataOutputStream;
import java.net.HttpURLConnection;
import java.net.URL;
import java.text.CharacterIterator;
import java.text.SimpleDateFormat;
import java.text.StringCharacterIterator;
import java.util.Date;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
@ -60,10 +62,14 @@ public class GlcHttpJsonAppender extends AppenderBase<ILoggingEvent> {
* @param text 日志
*/
protected void submitToGlogCenter(String text) {
if (text == null) {
return; // ignore
}
DataOutputStream dos = null;
String body = null;
try {
String body = "{" + encodeStr("text") + ":" + encodeStr(text.trim());
body = "{" + encodeStr("text") + ":" + encodeStr(text.trim());
body += "," + encodeStr("date") + ":" + encodeStr(getDateString());
body += "," + encodeStr("system") + ":" + encodeStr(getSystem());
body += "}";
@ -190,8 +196,46 @@ public class GlcHttpJsonAppender extends AppenderBase<ILoggingEvent> {
}
private String encodeStr(String str) {
return "\"" + str.replaceAll("\"", "\\\\\"").replaceAll("\t", "\\\\t").replaceAll("\r", "\\\\r")
.replaceAll("\n", "\\\\n") + "\"";
StringBuilder buf = new StringBuilder();
buf.append('"');
CharacterIterator it = new StringCharacterIterator(str);
for (char c = it.first(); c != CharacterIterator.DONE; c = it.next()) {
if (c == '"')
buf.append("\\\"");
else if (c == '\\')
buf.append("\\\\");
else if (c == '/')
buf.append("\\/");
else if (c == '\b')
buf.append("\\b");
else if (c == '\f')
buf.append("\\f");
else if (c == '\n')
buf.append("\\n");
else if (c == '\r')
buf.append("\\r");
else if (c == '\t')
buf.append("\\t");
else if (Character.isISOControl(c)) {
addUnicode(buf, c);
} else {
buf.append(c);
}
}
buf.append('"');
return buf.toString();
}
static final char[] hex = "0123456789ABCDEF".toCharArray();
private void addUnicode(StringBuilder buf, char c) {
buf.append("\\u");
int n = c;
for (int i = 0; i < 4; ++i) {
int digit = (n & 0xf000) >> 12;
buf.append(hex[digit]);
n <<= 4;
}
}
private static String getDateString() {