将Logback日志输出到websocket

package com.websocket.logback.ws; import ch.qos.logback.classic.Logger; import ch.qos.logback.classic.encoder.PatternLayoutEncoder; import ch.qos.logback.classic.spi.ILoggingEvent; import ch.qos.logback.core.Appender; import ch.qos.logback.core.OutputStreamAppender; import ch.qos.logback.core.util.OptionHelper; import javax.websocket.Session; import java.io.*; import java.nio.charset.StandardCharsets; public class LogbackWebsocketContext { private final Logger logger; private final Session session; private static final String logPattern = "%d{${LOG_DATEFORMAT_PATTERN:-yyyy-MM-dd HH:mm:ss.SSS}} ${LOG_LEVEL_PATTERN:-%5p} ${PID:- } --- [%15.15t] %-40.40logger{39} : %m%n${LOG_EXCEPTION_CONVERSION_WORD:-%wEx}"; public LogbackWebsocketContext(Logger logger, Session session) { this.logger = logger; this.session = session; } private PipedInputStream pipedInputStream; private PipedOutputStream pipedOutputStream; private Appender<ILoggingEvent> appender; public void start() throws IOException { pipedInputStream = new PipedInputStream(); pipedOutputStream = new PipedOutputStream(pipedInputStream); appender = createAppender(logger, pipedOutputStream); logger.addAppender(appender); Thread thread = createWriteThread(session, pipedInputStream); thread.start(); } public void close() throws IOException { appender.stop(); logger.detachAppender(appender); pipedInputStream.close(); pipedOutputStream.close(); } private Appender<ILoggingEvent> createAppender(ch.qos.logback.classic.Logger log, PipedOutputStream pipedOutputStream) { OutputStreamAppender<ILoggingEvent> outputStreamAppender = new OutputStreamAppender<>(); outputStreamAppender.setContext(log.getLoggerContext()); PatternLayoutEncoder encoder = new PatternLayoutEncoder(); encoder.setPattern(OptionHelper.substVars(logPattern, log.getLoggerContext())); encoder.setContext(log.getLoggerContext()); encoder.start(); encoder.setCharset(StandardCharsets.UTF_8); outputStreamAppender.setEncoder(encoder); outputStreamAppender.setOutputStream(pipedOutputStream); outputStreamAppender.start(); return outputStreamAppender; } private Thread createWriteThread(Session session, PipedInputStream pipedInputStream) { return new Thread(() -> { InputStreamReader inputStreamReader = new InputStreamReader(pipedInputStream, StandardCharsets.UTF_8); BufferedReader bufferedReader = new BufferedReader(inputStreamReader); String s; try { while ((s = bufferedReader.readLine()) != null) { session.getBasicRemote().sendText(s); } } catch (IOException e) { throw new RuntimeException(e); } }); } }