標準出力に差し替え可能なプリントストリームを作成し、System.outをログに転送する実装例

CreateLogStream.java

	public static void redirectLogs() {
		// 標準出力・標準エラー出力のログへの転送
		Logger stdoutLog = LoggerFactory.getLogger("console.out");
		Logger stderrLog = LoggerFactory.getLogger("console.err");
		System.setOut(createLogStream(stdoutLog::info));
		System.setErr(createLogStream(stderrLog::info));
	}

	/**
	 * 標準出力に差し替え可能なプリントストリームを作成します.<br>
	 * プリントストリームへの出力は文字列として引数のコンシューマに渡されます.<br>
	 * スレッドごとに独立したバッファをもっています.
	 * @return プリントストリーム
	 */
	public static PrintStream createLogStream(Consumer<String> logReceiver) {
		return new PrintStream(new OutputStream() {

			private ThreadLocal<ByteArrayOutputStream> bosTls = new ThreadLocal<ByteArrayOutputStream>() {
				@Override
				protected ByteArrayOutputStream initialValue() {
					return new ByteArrayOutputStream();
				}
			};

			@Override
			public void write(int b) throws IOException {
				if (b == 0x0a || b == 0x0d) {
					flush();
				} else {
					bosTls.get().write(b);
				}
			}

			@Override
			public void write(byte[] b, int off, int len) throws IOException {
				ByteArrayOutputStream bos = bosTls.get();
				for (int idx = 0; idx < len; idx++) {
					byte c = b[off + idx];
					if (c == 0x0a || c == 0x0d) {
						flush();
					} else {
						bos.write(c);
					}
				}
			}

			@Override
			public void close() throws IOException {
				flush();
			}

			@Override
			public void flush() throws IOException {
				ByteArrayOutputStream bos = bosTls.get();
				if (bos.size() > 0) {
					String msg = new String(bos.toByteArray());
					bos.reset();

					logReceiver.accept(msg);
				}
			}
		});
	}