Log4j 2.0在开发中的高级使用详解—SocketAppender的远程输出(五)

本文涉及的产品
日志服务 SLS,月写入数据量 50GB 1个月
简介: Log4j2的Appenders充分考虑了日志事件的输出、包装以及过滤转发的可能,包括最基本的输出到本地文件、输出到远程主机,<br> 对文件进行封装、注入,并且还能按照日志文件的时间点、文件大小等条件进行自动封存。<br> 例如,想要将几个不同源的日志汇集到一起,可以用FlumeAppender;想要在LogEvent中注入信息,<br> 可以用RewriteAppender;想要
Log4j2的Appenders充分考虑了日志事件的输出、包装以及过滤转发的可能,包括最基本的输出到本地文件、输出到远程主机,
对文件进行封装、注入,并且还能按照日志文件的时间点、文件大小等条件进行自动封存。
例如,想要将几个不同源的日志汇集到一起,可以用FlumeAppender;想要在LogEvent中注入信息,
可以用RewriteAppender;想要让系统按照设定的时间间隔自动封存日志信息,可以用RollingFileAppender
(每隔一定时间自动保存一份新增的日志文件,并按照时间戳等指定格式命名);当产生安全级别达ERROR或FATAL的LogEvent时,
给维护人员发送邮件可用SMTPAppender;希望将日志信息写到远程主机的,可用SocketAppender;希望能够按照RFC5424格式向远程主机发送日志信息,

可用SyslogAppender等等。

SocketAppender
将log event输出到一个远程服务器上(需指定服务器名和端口号),数据可以以任意指定的格式经由TCP或UDP协议发送。
SocketAppender中比较重要的参数有:
⑴ host,String,指定服务器的主机名。(必需)
⑵ immediateFlush,boolean,是否立即flush,还是等待缓存到一定大小后在flush。
⑶ layout,Layout,log event输出的格式。
⑷ port,integer,远程服务器坚挺log event的应用的端口号。
⑸ protocol,String,发送log event所使用的协议,"TCP" 或"UDP"。
⑹ reconnectionDelay,integer,当连接断开时,延迟等待的ms数。
⑺ name,String ,Appender的名称。
⑻ protocol,String,通讯协议 默认TCP。可选值 "TCP" (default), "SSL" or "UDP".
⑼ SSL,SslConfiguration,包含密钥存储库和信任存储库的配置.
⑽ filter,Filter,一个过滤器来确定事件应该由这个Appender。 不止一个过滤器 可以通过使用一个CompositeFilter。
⑾ immediateFail,boolean,设置为true时,日志事件不会等待尝试重新连接,将立即如果失败 套接字是不可用的。
⑿ immediateFlush,boolean, 当该值设置成真时,默认情况下,每个写将冲洗。 这将保证写的数据 到磁盘,但可能会影响性能。
⒀ layout,Layout,LogEvent ,布局使用格式。 缺省值是SerializedLayout。
⒁ reconnectionDelay,integer ,如果设置为值大于0,一个错误后SocketManager将尝试重新连接 在指定的毫秒数后的服务器。 如果连接失败 将抛出一个异常(可以被应用程序如果ignoreExceptions是 设置为假)。
⒂ ignoreExceptions,boolean,默认值是真正的添加事件时,遇到了引起异常 内部记录,然后忽略。 当设置为假将传播到异常 调用者。 你必须设置这个假当包装这个AppenderFailoverAppender。

日志服务器代码(main方法):

package com.herman.log4j2.server;

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;

public class TestServer {
    public static void main(String[] args) throws IOException {
    	ServerSocket socket = new ServerSocket(5000);
        while (true) {
	        Socket client = socket.accept();
	        Thread t = new Thread(new LogRunner(client));
	        t.start();
        }
	}
}
日志服务器代码(Runnable线程):

package com.herman.log4j2.server;

import java.io.IOException;
import java.io.InterruptedIOException;
import java.io.ObjectInputStream;
import java.net.Socket;

public class LogRunner implements Runnable{
	 private ObjectInputStream ois;

     public LogRunner(Socket client) {
         try {
              this.ois = new ObjectInputStream(client.getInputStream());
         } catch (Exception e) {
        	 e.printStackTrace();
         }
     }

	 public void run() {
	     try {
	         while (true) {
	        	 Object obj= ois.readObject();
	             System.out.println(obj.toString());
	         }
	     } catch(java.io.EOFException e) {
	         //读取的时候到达尾端抛出的异常,屏蔽掉
	     } catch(java.net.SocketException e) {
	     } catch(InterruptedIOException e) {
	    	 Thread.currentThread().interrupt();
	     } catch(IOException e) {
	     } 	catch (Exception e) {
	    	 e.printStackTrace();
	     } finally {
	     }
	 }
}
客户端xml配置(log4j2.xml):
<?xml version="1.0" encoding="UTF-8"?>
<Configuration>
  <!-- Appenders 输出目的地 -->
  <Appenders>
  	<!-- 配置日志输出文件名字     追加读写     host地址  端口    -->
    <Socket name="A1" host="localHost" port="5000">
    	<!-- 输出格式  序列布局-->
      <SerializedLayout/>
    </Socket>
    <!-- 控制台输出 -->
    <Console name="STDOUT" target="SYSTEM_OUT">
    	<!-- 输出格式  布局-->
      <PatternLayout pattern="%d %-5p [%t] %C{2} (%F:%L) - %m%n"/>
    </Console>
  </Appenders>
  <Loggers>
  	<!-- debug级别 -->
    <Root level="debug">
      <AppenderRef ref="A1"/>
      <AppenderRef ref="STDOUT"/>
    </Root>
  </Loggers>
</Configuration>
客户端测试代码:

package com.herman.log4j2.test;

import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;

/**
 * @see log4j 2.0 简单的配置使用一个文件Appender
 * @author Herman.Xiong
 * @date 2014年7月21日 14:32:55
 */
public class Test2 {
	/**
	 * 配置日志级别为debug,输出位置为控制台和文件
	 */
	private static Logger log = LogManager.getLogger(Test2.class);
	public static void main(String[] args) {
		log.trace("trace");
		log.debug("debug");
		log.info("info");
		log.warn("warn");
		log.error("error");
		log.fatal("fatal");
		
		
		log.trace("trace");
		log.debug("debug");
		log.info("info");
		log.warn("warn");
		log.error("error");
		log.fatal("fatal");
		log.exit();
	}
}
输出效果:

Logger=com.herman.log4j2.test.Test2 Level=DEBUG Message=debug
Logger=com.herman.log4j2.test.Test2 Level=INFO Message=info
Logger=com.herman.log4j2.test.Test2 Level=WARN Message=warn
Logger=com.herman.log4j2.test.Test2 Level=ERROR Message=error
Logger=com.herman.log4j2.test.Test2 Level=FATAL Message=fatal
Logger=com.herman.log4j2.test.Test2 Level=DEBUG Message=debug
Logger=com.herman.log4j2.test.Test2 Level=INFO Message=info
Logger=com.herman.log4j2.test.Test2 Level=WARN Message=warn
Logger=com.herman.log4j2.test.Test2 Level=ERROR Message=error
Logger=com.herman.log4j2.test.Test2 Level=FATAL Message=fatal
欢迎大家关注我的个人博客!!!!

如有不懂,疑问或者欠妥的地方,请加QQ群:135430763   进行反馈,共同学习!





相关实践学习
日志服务之使用Nginx模式采集日志
本文介绍如何通过日志服务控制台创建Nginx模式的Logtail配置快速采集Nginx日志并进行多维度分析。
目录
相关文章
|
6月前
|
存储 监控 数据库
Django 后端架构开发:高效日志规范与实践
Django 后端架构开发:高效日志规范与实践
130 1
|
8月前
|
存储 数据采集 JavaScript
深入理解数仓开发(一)数据技术篇之日志采集
深入理解数仓开发(一)数据技术篇之日志采集
|
9月前
|
小程序 前端开发 API
微信小程序全栈开发中的异常处理与日志记录
【4月更文挑战第12天】本文探讨了微信小程序全栈开发中的异常处理和日志记录,强调其对确保应用稳定性和用户体验的重要性。异常处理涵盖前端(网络、页面跳转、用户输入、逻辑异常)和后端(数据库、API、业务逻辑)方面;日志记录则关注关键操作和异常情况的追踪。实践中,前端可利用try-catch处理异常,后端借助日志框架记录异常,同时采用集中式日志管理工具提升分析效率。开发者应注意安全性、性能和团队协作,以优化异常处理与日志记录流程。
230 0
|
9月前
|
调度
kettle开发篇-写日志
kettle开发篇-写日志
555 0
|
4月前
|
Rust 前端开发 JavaScript
Tauri 开发实践 — Tauri 日志记录功能开发
本文介绍了如何为 Tauri 应用配置日志记录。Tauri 是一个利用 Web 技术构建桌面应用的框架。文章详细说明了如何在 Rust 和 JavaScript 代码中设置和集成日志记录,并控制日志输出。通过添加 `log` crate 和 Tauri 日志插件,可以轻松实现多平台日志记录,包括控制台输出、Webview 控制台和日志文件。文章还展示了如何调整日志级别以优化输出内容。配置完成后,日志记录功能将显著提升开发体验和程序稳定性。
197 1
Tauri 开发实践 — Tauri 日志记录功能开发
|
6月前
|
SQL 关系型数据库 MySQL
【MySQL】根据binlog日志获取回滚sql的一个开发思路
【MySQL】根据binlog日志获取回滚sql的一个开发思路
|
3月前
|
监控 开发者
鸿蒙5.0版开发:使用HiLog打印日志(ArkTS)
在HarmonyOS 5.0中,HiLog是系统提供的日志系统,支持DEBUG、INFO、WARN、ERROR、FATAL五种日志级别。本文介绍如何在ArkTS中使用HiLog打印日志,并提供示例代码。通过合理使用HiLog,开发者可以更好地调试和监控应用。
307 16
|
4月前
|
开发工具 git
git显示开发日志+WinSW——将.exe文件注册为服务的一个工具+图床PicGo+kubeconfig 多个集群配置 如何切换
git显示开发日志+WinSW——将.exe文件注册为服务的一个工具+图床PicGo+kubeconfig 多个集群配置 如何切换
60 1
|
4月前
|
开发框架 缓存 安全
开发日志:IIS安全配置
开发日志:IIS安全配置
开发日志:IIS安全配置
|
6月前
|
JSON 中间件 Go
go语言后端开发学习(四) —— 在go项目中使用Zap日志库
本文详细介绍了如何在Go项目中集成并配置Zap日志库。首先通过`go get -u go.uber.org/zap`命令安装Zap,接着展示了`Logger`与`Sugared Logger`两种日志记录器的基本用法。随后深入探讨了Zap的高级配置,包括如何将日志输出至文件、调整时间格式、记录调用者信息以及日志分割等。最后,文章演示了如何在gin框架中集成Zap,通过自定义中间件实现了日志记录和异常恢复功能。通过这些步骤,读者可以掌握Zap在实际项目中的应用与定制方法
228 1
go语言后端开发学习(四) —— 在go项目中使用Zap日志库