add logtube support

CHANGELOG.md

@@ -3,7 +3,7 @@
 
 -------------------------------------------------------------------------------------------------------------
 
-# 5.6.6 (2021-05-24)
+# 5.6.6 (2021-05-26)
 
 ### 🐣新特性
 * 【cron   】     增加时间轮简单实现
@@ -16,12 +16,14 @@
 * 【core   】     IdCardUtil.isValidCard增加非空判断
 * 【json   】     JSONObject构造增加SortedMap判断（pr#333@Gitee）
 * 【core   】     Tuple增加部分方法（pr#333@Gitee）
+* 【log    】     增加LogTube支持
 
 ### 🐞Bug修复
 * 【core   】     修复XmlUtil中omitXmlDeclaration参数无效问题（issue#1581@Github）
 * 【core   】     修复NumberUtil.decimalFormat参数传错的问题（issue#I3SDS3@Gitee）
 * 【json   】     修复JSONArray.put方法不能覆盖值的问题
 * 【poi    】     修复sax方式读取xls无法根据sheet名称获取数据（issue#I3S4NH@Gitee）
+* 【core   】     修复路径中多个~都被替换的问题（pr#1599@Github）
 
 -------------------------------------------------------------------------------------------------------------
 # 5.6.5 (2021-05-08)

hutool-core/src/main/java/cn/hutool/core/exceptions/ExceptionUtil.java

@@ -150,7 +150,25 @@ public class ExceptionUtil {
 	 * @since 4.1.4
 	 */
 	public static StackTraceElement getStackElement(int i) {
-		return getStackElements()[i];
+		return Thread.currentThread().getStackTrace()[i];
+	}
+
+	/**
+	 * 获取指定层的堆栈信息
+	 *
+	 * @param fqcn 指定类名为基础
+	 * @param i 指定类名的类堆栈相对层数
+	 * @return 指定层的堆栈信息
+	 * @since 5.6.6
+	 */
+	public static StackTraceElement getStackElement(String fqcn, int i) {
+		final StackTraceElement[] stackTraceArray = Thread.currentThread().getStackTrace();
+		final int index = ArrayUtil.matchIndex((ele) -> StrUtil.equals(fqcn, ele.getClassName()), stackTraceArray);
+		if(index > 0){
+			return stackTraceArray[index + i];
+		}
+
+		return null;
 	}
 
 	/**
@@ -160,8 +178,8 @@ public class ExceptionUtil {
 	 * @since 4.1.4
 	 */
 	public static StackTraceElement getRootStackElement() {
-		final StackTraceElement[] stackElements = getStackElements();
-		return stackElements[stackElements.length - 1];
+		final StackTraceElement[] stackElements = Thread.currentThread().getStackTrace();
+		return Thread.currentThread().getStackTrace()[stackElements.length - 1];
 	}
 
 	/**

hutool-core/src/main/java/cn/hutool/core/io/FileUtil.java

@@ -1422,8 +1422,8 @@ public class FileUtil extends PathUtil {
 		pathToUse = StrUtil.removePrefixIgnoreCase(pathToUse, URLUtil.FILE_URL_PREFIX);
 
 		// 识别home目录形式，并转换为绝对路径
-		if (pathToUse.startsWith("~")) {
-			pathToUse = pathToUse.replaceFirst("~", getUserHomePath());
+		if (StrUtil.startWith(pathToUse, '~')) {
+			pathToUse = getUserHomePath() + pathToUse.substring(1);
 		}
 
 		// 统一使用斜杠

hutool-core/src/test/java/cn/hutool/core/exceptions/ExceptionUtilTest.java

@@ -26,6 +26,10 @@ public class ExceptionUtilTest {
 		Assert.assertEquals("main", ele.getMethodName());
 	}
 
+	@Test
+	public void getStackElementTest(){
+	}
+
 	@Test
 	public void convertTest() {
 		// RuntimeException e = new RuntimeException();

hutool-core/src/test/java/cn/hutool/core/io/FileUtilTest.java

@@ -168,6 +168,13 @@ public class FileUtilTest {
 		Assert.assertEquals(home + "/bar/", FileUtil.normalize("~/foo/../bar/"));
 	}
 
+	@Test
+	public void normalizeHomePathTest2() {
+		String home = FileUtil.getUserHomePath().replace('\\', '/');
+		// 多个~应该只替换开头的
+		Assert.assertEquals(home + "/~bar/", FileUtil.normalize("~/foo/../~bar/"));
+	}
+
 	@Test
 	public void normalizeClassPathTest() {
 		Assert.assertEquals("", FileUtil.normalize("classpath:"));

hutool-log/pom.xml

@@ -83,6 +83,12 @@
 			<version>${jboss-logging.version}</version>
 			<optional>true</optional>
 		</dependency>
+		<dependency>
+			<groupId>io.github.logtube</groupId>
+			<artifactId>logtube</artifactId>
+			<version>0.39.1</version>
+			<optional>true</optional>
+		</dependency>
 		<dependency>
 			<groupId>org.slf4j</groupId>
 			<artifactId>slf4j-simple</artifactId>

hutool-log/src/main/java/cn/hutool/log/dialect/logtube/LogTubeLog.java

@@ -0,0 +1,103 @@
+package cn.hutool.log.dialect.logtube;
+
+import cn.hutool.core.exceptions.ExceptionUtil;
+import cn.hutool.core.util.StrUtil;
+import cn.hutool.log.AbstractLog;
+import cn.hutool.log.level.Level;
+import io.github.logtube.Logtube;
+import io.github.logtube.core.IEventLogger;
+
+/**
+ * <a href="https://github.com/logtube/logtube-java">LogTube</a> log.封装<br>
+ *
+ * @author looly
+ * @since 5.6.6
+ */
+public class LogTubeLog extends AbstractLog {
+
+	private final IEventLogger logger;
+
+	// ------------------------------------------------------------------------- Constructor
+	public LogTubeLog(IEventLogger logger) {
+		this.logger = logger;
+	}
+
+	public LogTubeLog(Class<?> clazz) {
+		this((null == clazz) ? StrUtil.NULL : clazz.getName());
+	}
+
+	public LogTubeLog(String name) {
+		this(Logtube.getLogger(name));
+	}
+
+
+	@Override
+	public String getName() {
+		return logger.getName();
+	}
+
+	// ------------------------------------------------------------------------- Trace
+	@Override
+	public boolean isTraceEnabled() {
+		return logger.isTraceEnabled();
+	}
+
+	@Override
+	public void trace(String fqcn, Throwable t, String format, Object... arguments) {
+		log(fqcn, Level.TRACE, t, format, arguments);
+	}
+
+	// ------------------------------------------------------------------------- Debug
+	@Override
+	public boolean isDebugEnabled() {
+		return logger.isDebugEnabled();
+	}
+
+	@Override
+	public void debug(String fqcn, Throwable t, String format, Object... arguments) {
+		log(fqcn, Level.DEBUG, t, format, arguments);
+	}
+
+	// ------------------------------------------------------------------------- Info
+	@Override
+	public boolean isInfoEnabled() {
+		return logger.isInfoEnabled();
+	}
+
+	@Override
+	public void info(String fqcn, Throwable t, String format, Object... arguments) {
+		log(fqcn, Level.INFO, t, format, arguments);
+	}
+
+	// ------------------------------------------------------------------------- Warn
+	@Override
+	public boolean isWarnEnabled() {
+		return logger.isWarnEnabled();
+	}
+
+	@Override
+	public void warn(String fqcn, Throwable t, String format, Object... arguments) {
+		log(fqcn, Level.WARN, t, format, arguments);
+	}
+
+	// ------------------------------------------------------------------------- Error
+	@Override
+	public boolean isErrorEnabled() {
+		return logger.isErrorEnabled();
+	}
+
+	@Override
+	public void error(String fqcn, Throwable t, String format, Object... arguments) {
+		log(fqcn, Level.ERROR, t, format, arguments);
+	}
+
+	@Override
+	public void log(String fqcn, Level level, Throwable t, String format, Object... arguments) {
+		final String topic = level.name().toLowerCase();
+		logger.topic(topic)
+				.xStackTraceElement(ExceptionUtil.getStackElement(6), null)
+				.message(StrUtil.format(format, arguments))
+				.xException(t)
+				.commit();
+	}
+}

hutool-log/src/main/java/cn/hutool/log/dialect/logtube/LogTubeLogFactory.java

@@ -0,0 +1,29 @@
+package cn.hutool.log.dialect.logtube;
+
+import cn.hutool.log.Log;
+import cn.hutool.log.LogFactory;
+
+/**
+ * <a href="https://github.com/logtube/logtube-java">LogTube</a> log. 封装<br>
+ *
+ * @author Looly
+ * @since 5.6.6
+ */
+public class LogTubeLogFactory extends LogFactory {
+
+	public LogTubeLogFactory() {
+		super("LogTube");
+		checkLogExist(io.github.logtube.Logtube.class);
+	}
+
+	@Override
+	public Log createLog(String name) {
+		return new LogTubeLog(name);
+	}
+
+	@Override
+	public Log createLog(Class<?> clazz) {
+		return new LogTubeLog(clazz);
+	}
+
+}

hutool-log/src/main/java/cn/hutool/log/dialect/logtube/package-info.java

@@ -0,0 +1,7 @@
+/**
+ * LogTube的实现封装
+ *
+ * @author looly
+ *
+ */
+package cn.hutool.log.dialect.logtube;

hutool-log/src/main/resources/META-INF/services/cn.hutool.log.LogFactory

@@ -1,7 +1,8 @@
+cn.hutool.log.dialect.logtube.LogTubeLogFactory
 cn.hutool.log.dialect.slf4j.Slf4jLogFactory
 cn.hutool.log.dialect.log4j2.Log4j2LogFactory
 cn.hutool.log.dialect.log4j.Log4jLogFactory
 cn.hutool.log.dialect.commons.ApacheCommonsLogFactory
 cn.hutool.log.dialect.tinylog.TinyLogFactory
 cn.hutool.log.dialect.tinylog.TinyLog2Factory
-cn.hutool.log.dialect.jboss.JbossLogFactory
+cn.hutool.log.dialect.jboss.JbossLogFactory

hutool-log/src/test/java/cn/hutool/log/test/LogTubeTest.java

@@ -0,0 +1,17 @@
+package cn.hutool.log.test;
+
+import cn.hutool.log.Log;
+import cn.hutool.log.LogFactory;
+import cn.hutool.log.dialect.logtube.LogTubeLogFactory;
+import org.junit.Test;
+
+public class LogTubeTest {
+
+	@Test
+	public void logTest(){
+		LogFactory factory = new LogTubeLogFactory();
+		LogFactory.setCurrentLogFactory(factory);
+		Log log = LogFactory.get();
+		log.debug("LogTube debug test.");
+	}
+}

hutool-log/src/test/resources/logtube.properties

@@ -0,0 +1,90 @@
+##########################################
+#
+# 项目基本信息
+#
+##########################################
+#
+# 项目名 !!!按照实际需要修改!!! 不允许点号，使用 - 分割
+logtube.project=test-hutool
+#
+# 项目环境 !!!按照实际需要修改!!! 允许的值为 'dev', 'test', 'staging' 和 'prod'
+logtube.env=test
+#
+# 全局主题过滤器，默认设置为不包括 trace 和 debug，调试环境可以酌情打开
+logtube.topics.root=ALL,-trace
+#
+# 分包主题过滤器
+#
+# logtube.topics.com.google.gson=error
+# logtube.topics.com.google.gson=error
+#
+# 全局主题映射，trace 合并进入 debug, error 重命名为 err, warn 合并进入 info
+logtube.topic-mappings=trace=debug,error=err,warn=info
+#
+#
+##########################################
+#
+# 命令行输出
+#
+##########################################
+#
+# 是否开启命令行输出，设置为开启
+logtube.console.enabled=true
+#
+# 命令行输出设置为包括所有主题 （仍然受制于全局过滤器）
+logtube.console.topics=ALL
+#
+#
+##########################################
+#
+# 日志文件输出
+#
+##########################################
+#
+# 启动日志文件输出
+#
+logtube.file.enabled=false
+#
+# 日志文件输出包含所有主题（仍然受制于全局过滤器）
+logtube.file.topics=ALL
+#
+# 日志文件重新打开信号文件，用于 logrotate
+logtube.file.signal=/tmp/xlog.reopen.txt
+#
+# 日志文件路径
+logtube.file.dir=logs
+#
+# 日志子文件夹，除了 trace 和 debug 日志进入 others 子文件夹，剩下的全部进入 xlog 子文件夹
+# 一般情况下，xlog 子文件夹的日志文件会被收集，然后进入 xlog 系统
+logtube.file.subdir-mappings=ALL=xlog,trace=others,debug=others
+#
+#
+##########################################
+#
+# 远程输出，Redis 协议
+#
+##########################################
+#
+# 是否开启远程输出，设置为关闭
+logtube.redis.enabled=false
+#
+# 远程输出设置为包含所有主题（仍然受制于全局主题过滤器）
+logtube.redis.topics=ALL
+#
+# 远程输出目标主机，设置为为 127.0.0.1:6379，可使用逗号分隔多个主机
+logtube.redis.hosts=127.0.0.1:6379
+#
+# 远程输出 Redis 键值
+logtube.redis.key=xlog
+#
+#########################################
+#
+# 组件配置
+#
+#########################################
+#
+# 响应时间 > 100 ms 的 Redis 操作会被 LogtubeRedis 组件汇报
+logtube.filter.redis-min-duration=100
+#
+# 结果集 > 1000 bytes 的 Redis 操作会被 LogtubeRedis 组件汇报
+logtube.filter.redis-min-result-size=1000