wangli/im-center
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

hotfix: xxl日志文件不存在的问题

Browse Source
This commit is contained in:
yanglin 2025-03-10 09:50:41 +08:00
parent 389047223d
commit 0d8d2734f8
1 changed files with 10 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
im-center-server/src/main/java/cn/axzo/im/utils/XxlAppender.java
View File

@ -1,12 +1,16 @@
package cn.axzo.im.utils; package cn.axzo.im.utils;
import java.io.File;
import java.util.concurrent.locks.ReentrantLock;
import org.apache.commons.lang3.StringUtils;
import com.xxl.job.core.log.XxlJobFileAppender;
import ch.qos.logback.core.Layout; import ch.qos.logback.core.Layout;
import ch.qos.logback.core.UnsynchronizedAppenderBase; import ch.qos.logback.core.UnsynchronizedAppenderBase;
import ch.qos.logback.core.encoder.Encoder; import ch.qos.logback.core.encoder.Encoder;
import ch.qos.logback.core.encoder.LayoutWrappingEncoder; import ch.qos.logback.core.encoder.LayoutWrappingEncoder;
import com.xxl.job.core.log.XxlJobFileAppender;
import java.util.concurrent.locks.ReentrantLock;
/** /**
* @author yanglin * @author yanglin
@ -27,7 +31,9 @@ public class XxlAppender<E> extends UnsynchronizedAppenderBase<E> {
@Override @Override
protected void append(E event) { protected void append(E event) {
String logFileName = XxlJobFileAppender.contextHolder.get(); String logFileName = XxlJobFileAppender.contextHolder.get();
if (logFileName == null) return; if (StringUtils.isBlank(logFileName)) return;
File file = new File(logFileName);
if (!file.exists()) return;
if (encoder == null) return; if (encoder == null) return;
byte[] bytes = encoder.encode(event); byte[] bytes = encoder.encode(event);
String message = new String(bytes); String message = new String(bytes);