Add File
This commit is contained in:
@@ -0,0 +1,200 @@
|
||||
/*
|
||||
* Copyright 2021 the original author or authors.
|
||||
* Licensed under the Apache License, Version 2.0 (the "License"); you may not
|
||||
* use this file except in compliance with the License. You may obtain a copy of
|
||||
* the License at http://www.apache.org/licenses/LICENSE-2.0 Unless required by
|
||||
* applicable law or agreed to in writing, software distributed under the
|
||||
* License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS
|
||||
* OF ANY KIND, either express or implied. See the License for the specific
|
||||
* language governing permissions and limitations under the License.
|
||||
*/
|
||||
package com.gitee.drinkjava2.frog.util;
|
||||
|
||||
import java.io.IOException;
|
||||
import java.io.OutputStream;
|
||||
import java.nio.charset.StandardCharsets;
|
||||
import java.text.SimpleDateFormat;
|
||||
import java.util.HashMap;
|
||||
import java.util.Map;
|
||||
import java.util.concurrent.ArrayBlockingQueue;
|
||||
import java.util.concurrent.BlockingQueue;
|
||||
|
||||
/**
|
||||
* Usually a logger tool is used like below:
|
||||
* Logger log = LoggerFactory.getLogger(Xxxx.class);
|
||||
* log.info("some msg");
|
||||
*
|
||||
* But to simplify, in this project directly use static method:
|
||||
* Logger.info("some msg");
|
||||
*
|
||||
* @Description: 简版控制台日志打印，从码云上合并来，见 https://gitee.com/drinkjava2/frog/pulls/4
|
||||
* @author 栾成翔
|
||||
* @Date: 2021/12/07
|
||||
*/
|
||||
@SuppressWarnings("all")
|
||||
public class Logger {
|
||||
private static final int SYSTEM_OUT_PRINT = 1; //如设为1，不使用log，直接System.out.print输出
|
||||
private static final int LOGGER_STYLE = 0; //风格设定， 0:不输出前缀, 1:输出时间、类、行号等前缀
|
||||
private static final String LEV_EL = "DEBUG";
|
||||
private static final int LEVEL_INT;
|
||||
private static final BlockingQueue<String> LOG_LIST = new ArrayBlockingQueue<>(256);
|
||||
private static final SimpleDateFormat FORMAT = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss,SSS");
|
||||
private static final OutputStream OUTPUT_STREAM = System.out;
|
||||
private static final String LINE_SEPARATOR = System.getProperty("line.separator");
|
||||
private static final String DELIM_STR = "{}";
|
||||
private static final String TAB = "\tat";
|
||||
private static final Map<String, Integer> LEVEL_MAP = new HashMap<>();
|
||||
|
||||
static {
|
||||
LEVEL_MAP.put("DEBUG", 1);
|
||||
LEVEL_MAP.put("INFO", 2);
|
||||
LEVEL_MAP.put("WARN", 3);
|
||||
LEVEL_MAP.put("ERROR", 4);
|
||||
LEVEL_INT = LEVEL_MAP.get(LEV_EL.toUpperCase());
|
||||
new Thread(() -> {
|
||||
while (true) {
|
||||
try {
|
||||
outPutConsole(LOG_LIST.take());
|
||||
} catch (InterruptedException e) {
|
||||
throw new RuntimeException(e);
|
||||
}
|
||||
}
|
||||
}).start();
|
||||
}
|
||||
|
||||
public static void debug(String msg) {
|
||||
printLog(LEVEL_MAP.get("DEBUG"), msg);
|
||||
}
|
||||
|
||||
public static void debug(String msg, Object params) {
|
||||
printLog(LEVEL_MAP.get("DEBUG"), msg, params);
|
||||
}
|
||||
|
||||
public static void debug(String msg, Object... params) {
|
||||
printLog(LEVEL_MAP.get("DEBUG"), msg, params);
|
||||
}
|
||||
|
||||
public static void info(String msg) {
|
||||
printLog(LEVEL_MAP.get("INFO"), msg);
|
||||
}
|
||||
|
||||
public static void info(String msg, Object params) {
|
||||
printLog(LEVEL_MAP.get("INFO"), msg, params);
|
||||
}
|
||||
|
||||
public static void info(String msg, Object... params) {
|
||||
printLog(LEVEL_MAP.get("INFO"), msg, params);
|
||||
}
|
||||
|
||||
public static void warn(String msg) {
|
||||
printLog(LEVEL_MAP.get("WARN"), msg);
|
||||
}
|
||||
|
||||
public static void warn(String msg, Object params) {
|
||||
printLog(LEVEL_MAP.get("WARN"), msg, params);
|
||||
}
|
||||
|
||||
public static void warn(String msg, Object... params) {
|
||||
printLog(LEVEL_MAP.get("WARN"), msg, params);
|
||||
}
|
||||
|
||||
public static void error(String msg) {
|
||||
printLog(LEVEL_MAP.get("ERROR"), msg);
|
||||
}
|
||||
|
||||
public static void error(String msg, Object params) {
|
||||
printLog(LEVEL_MAP.get("ERROR"), msg, params);
|
||||
}
|
||||
|
||||
public static void error(String msg, Object... params) {
|
||||
printLog(LEVEL_MAP.get("ERROR"), msg, params);
|
||||
}
|
||||
|
||||
public static void error(Object param) {
|
||||
printLog(LEVEL_MAP.get("ERROR"), "", param);
|
||||
}
|
||||
|
||||
private static void printLog(int levelInt, String msg, Object... params) {
|
||||
if (levelInt < LEVEL_INT)
|
||||
return;
|
||||
if (SYSTEM_OUT_PRINT == 1)
|
||||
System.out.print(generateMsg(getLevelStr(levelInt), msg, params));
|
||||
else
|
||||
try {
|
||||
LOG_LIST.put(generateMsg(getLevelStr(levelInt), msg, params));
|
||||
} catch (InterruptedException e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
}
|
||||
|
||||
private static String generateMsg(String levelStr, String msg, Object... params) {
|
||||
if (LOGGER_STYLE == 0)
|
||||
return formatMsg(msg + LINE_SEPARATOR, null, params);
|
||||
StackTraceElement stack = Thread.currentThread().getStackTrace()[4];
|
||||
String s = "{} [{}][{}#{} {}] - " + msg + LINE_SEPARATOR;
|
||||
Object[] args = new Object[5 + params.length];
|
||||
args[0] = FORMAT.format(System.currentTimeMillis());
|
||||
args[1] = levelStr;
|
||||
args[2] = stack.getClassName();
|
||||
args[3] = stack.getMethodName();
|
||||
args[4] = stack.getLineNumber();
|
||||
|
||||
Throwable throwable = null;
|
||||
if (params.length > 0) {
|
||||
final Object lastEntry = params[params.length - 1];
|
||||
if (lastEntry instanceof Throwable) {
|
||||
throwable = (Throwable) lastEntry;
|
||||
System.arraycopy(params, 0, args, 5, params.length - 1);
|
||||
} else {
|
||||
System.arraycopy(params, 0, args, 5, params.length);
|
||||
}
|
||||
}
|
||||
return formatMsg(s, throwable, args);
|
||||
}
|
||||
|
||||
private static String formatMsg(String msg, Throwable throwable, Object... params) {
|
||||
StringBuilder sb = new StringBuilder();
|
||||
int s;
|
||||
int i = 0;
|
||||
for (Object o : params) {
|
||||
s = msg.indexOf(DELIM_STR, i);
|
||||
if (s > -1) {
|
||||
sb.append(msg, i, s).append(o);
|
||||
i = s + 2;
|
||||
}
|
||||
}
|
||||
sb.append(msg, i, msg.length());
|
||||
if (null != throwable) {
|
||||
sb.append(throwable).append(LINE_SEPARATOR);
|
||||
StackTraceElement[] stack = throwable.getStackTrace();
|
||||
for (StackTraceElement element : stack) {
|
||||
sb.append(TAB).append(element).append(LINE_SEPARATOR);
|
||||
}
|
||||
}
|
||||
return sb.toString();
|
||||
}
|
||||
|
||||
private static void outPutConsole(String msg) {
|
||||
try {
|
||||
OUTPUT_STREAM.write(msg.getBytes(StandardCharsets.UTF_8));
|
||||
OUTPUT_STREAM.flush();
|
||||
} catch (IOException e) {
|
||||
e.printStackTrace();
|
||||
}
|
||||
}
|
||||
|
||||
private static String getLevelStr(int levelInt) {
|
||||
switch (levelInt){
|
||||
case 1:
|
||||
return "DEBUG";
|
||||
case 2:
|
||||
return "INFO";
|
||||
case 3:
|
||||
return "WARN";
|
||||
case 4:
|
||||
return "ERROR";
|
||||
default:
|
||||
throw new IllegalStateException("Level " + levelInt + " is unknown.");
|
||||
}
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user