1、使用MDC的方式结合logback记录日志

黄浪
1 parent e3df6564
Showing 5 changed files with 89 additions and 2 deletions Show diff stats
src/main/java/com/example/mina/Application.java
src/main/java/com/example/mina/client/box/qrb3000/Qrb3000ProtocolFactory.java
src/main/java/com/example/mina/processor/LogBeanPostProcessor.java
src/main/java/com/example/mina/processor/VbLogUtils.java
src/main/resources/logback-spring.xml
@@ -64,11 +64,11 @@ public class Application {
         MatrixClient client = clientManager.getOrCreateClient(connectConfig);
-//        client.setAttenuation(1,2,3, null);
+        client.setAttenuation(1,2,3, null);
 //        LockSupport.parkNanos(1000_000_000);
 //        client.setOffset(1, 2);
-        client.getOffset(2);
+//        client.getOffset(2);
         LockSupport.parkNanos(1000_000_000);
 //        client.setOffset(1,2);
@@ -3,6 +3,7 @@ package com.example.mina.client.box.qrb3000;
 import com.example.mina.client.base.MatrixCommand;
 import com.example.mina.client.base.MatrixConstants;
 import com.example.mina.client.base.MatrixResponse;
+import com.example.mina.processor.VbLogUtils;
 import com.example.mina.server.util.CommandHelper;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.mina.core.buffer.IoBuffer;
@@ -52,6 +53,7 @@ public class Qrb3000ProtocolFactory implements ProtocolCodecFactory {
                     mc.getType()
             );
             int cmd = mc.getCommand();
+            VbLogUtils.infoLog(log, "", mc.getMatrixId(),msg);
             IoBuffer buffer = IoBuffer.allocate(100, false).setAutoExpand(true);
@@ -0,0 +1,30 @@
+package com.example.mina.processor;
+
+import lombok.extern.slf4j.Slf4j;
+import org.slf4j.MDC;
+import org.slf4j.Marker;
+import org.slf4j.MarkerFactory;
+import org.springframework.beans.BeansException;
+import org.springframework.beans.factory.config.BeanPostProcessor;
+import org.springframework.stereotype.Component;
+
+@Slf4j
+@Component
+public class LogBeanPostProcessor implements BeanPostProcessor {
+
+    @Override
+    public Object postProcessBeforeInitialization(Object bean, String beanName) throws BeansException {
+//        log.info("postProcessBeforeInitialization: {}", beanName);
+        return bean;
+    }
+
+    @Override
+    public Object postProcessAfterInitialization(Object bean, String beanName) throws BeansException {
+//        Marker marker = MarkerFactory.getMarker("postProcessAfterInitialization");
+//        MDC.put("taskId", "QRB3000/100_20210402");
+//        log.info(marker, "postProcessAfterInitialization: {}", beanName);
+//        MDC.clear();
+        return bean;
+    }
+
+}
@@ -0,0 +1,30 @@
+package com.example.mina.processor;
+
+import org.slf4j.Logger;
+import org.slf4j.MDC;
+import org.slf4j.Marker;
+import org.slf4j.MarkerFactory;
+
+import java.time.LocalDate;
+import java.time.format.DateTimeFormatter;
+
+/**
+ * @ProjectName: demo
+ * @Package: com.example.mina.processor
+ * @ClassName: VbLogUtils
+ * @Author: HuangLang
+ * @Description: 用于记录设备日志
+ * @Date: 2021-04-01 下午 8:46
+ */
+public class VbLogUtils {
+    public static void infoLog(Logger log, String matrixType, String matrixId, Object msg){
+        Marker marker = MarkerFactory.getMarker("postProcessAfterInitialization");
+        matrixType = "QRB1234";
+        matrixId = "100";
+        MDC.put("taskId",
+                matrixType + "/" + matrixId + "_" + LocalDate.now().format(DateTimeFormatter.ofPattern("yyyyMMdd")));
+        log.info("info msg, msg is: {}", msg);
+        MDC.clear();
+    }
+
+}
@@ -0,0 +1,25 @@
+<configuration>
+
+    <appender name="SIFT" class="ch.qos.logback.classic.sift.SiftingAppender">
+        <!-- in the absence of the class attribute, it is assumed that the
+             desired discriminator type is
+             ch.qos.logback.classic.sift.MDCBasedDiscriminator -->
+        <discriminator>
+            <key>taskId</key>
+            <defaultValue>log</defaultValue>
+        </discriminator>
+        <sift>
+            <appender name="FILE-${taskId}" class="ch.qos.logback.core.FileAppender">
+                <file>log/${taskId}.log</file>
+                <append>false</append>
+                <layout class="ch.qos.logback.classic.PatternLayout">
+                    <pattern>%d %marker [%thread] %level %mdc %logger{35} - %msg%n</pattern>
+                </layout>
+            </appender>
+        </sift>
+    </appender>
+
+    <root level="DEBUG">
+        <appender-ref ref="SIFT" />
+    </root>
+</configuration>
 \ No newline at end of file
	@@ -64,11 +64,11 @@ public class Application {		@@ -64,11 +64,11 @@ public class Application {
64	MatrixClient client = clientManager.getOrCreateClient(connectConfig);	64	MatrixClient client = clientManager.getOrCreateClient(connectConfig);
65		65
66		66
67	-// client.setAttenuation(1,2,3, null);	67	+ client.setAttenuation(1,2,3, null);
68	// LockSupport.parkNanos(1000_000_000);	68	// LockSupport.parkNanos(1000_000_000);
69		69
70	// client.setOffset(1, 2);	70	// client.setOffset(1, 2);
71	- client.getOffset(2);	71	+// client.getOffset(2);
72	LockSupport.parkNanos(1000_000_000);	72	LockSupport.parkNanos(1000_000_000);
73		73
74	// client.setOffset(1,2);	74	// client.setOffset(1,2);
@@ -0,0 +1,30 @@		@@ -0,0 +1,30 @@
	1	+package com.example.mina.processor;
	2	+
	3	+import lombok.extern.slf4j.Slf4j;
	4	+import org.slf4j.MDC;
	5	+import org.slf4j.Marker;
	6	+import org.slf4j.MarkerFactory;
	7	+import org.springframework.beans.BeansException;
	8	+import org.springframework.beans.factory.config.BeanPostProcessor;
	9	+import org.springframework.stereotype.Component;
	10	+
	11	+@Slf4j
	12	+@Component
	13	+public class LogBeanPostProcessor implements BeanPostProcessor {
	14	+
	15	+ @Override
	16	+ public Object postProcessBeforeInitialization(Object bean, String beanName) throws BeansException {
	17	+// log.info("postProcessBeforeInitialization: {}", beanName);
	18	+ return bean;
	19	+ }
	20	+
	21	+ @Override
	22	+ public Object postProcessAfterInitialization(Object bean, String beanName) throws BeansException {
	23	+// Marker marker = MarkerFactory.getMarker("postProcessAfterInitialization");
	24	+// MDC.put("taskId", "QRB3000/100_20210402");
	25	+// log.info(marker, "postProcessAfterInitialization: {}", beanName);
	26	+// MDC.clear();
	27	+ return bean;
	28	+ }
	29	+
	30	+}
	@@ -0,0 +1,25 @@		@@ -0,0 +1,25 @@
		1	+<configuration>
		2	+
		3	+ <appender name="SIFT" class="ch.qos.logback.classic.sift.SiftingAppender">
		4	+ <!-- in the absence of the class attribute, it is assumed that the
		5	+ desired discriminator type is
		6	+ ch.qos.logback.classic.sift.MDCBasedDiscriminator -->
		7	+ <discriminator>
		8	+ <key>taskId</key>
		9	+ <defaultValue>log</defaultValue>
		10	+ </discriminator>
		11	+ <sift>
		12	+ <appender name="FILE-${taskId}" class="ch.qos.logback.core.FileAppender">
		13	+ <file>log/${taskId}.log</file>
		14	+ <append>false</append>
		15	+ <layout class="ch.qos.logback.classic.PatternLayout">
		16	+ <pattern>%d %marker [%thread] %level %mdc %logger{35} - %msg%n</pattern>
		17	+ </layout>
		18	+ </appender>
		19	+ </sift>
		20	+ </appender>
		21	+
		22	+ <root level="DEBUG">
		23	+ <appender-ref ref="SIFT" />
		24	+ </root>
		25	+</configuration>
0	\ No newline at end of file	26	\ No newline at end of file