appender负责定义日志输出的目的地，它可以是控制台（consoleappender）、文件（fileappender）、jms服务器（jmslogappender）、以email的形式发送出去（smtpappender）等。appender是一个命名的实体，另外它还包含了对layout、errorhandler、filter等引用：
1 public interface appender {
2 void addfilter(filter newfilter);
3 public filter getfilter();
4 public void clearfilters();
5 public void close();
6 public void doappend(loggingevent event);
7 public string getname();
8 public void seterrorhandler(errorhandler errorhandler);
9 public errorhandler geterrorhandler();
10 public void setlayout(layout layout);
11 public layout getlayout();
12 public void setname(string name);
13 public boolean requireslayout();
14 }
简单的，在配置文件中，appender会注册到logger中，logger在写日志时，通过继承机制遍历所有注册到它本身和其父节点的appender（在additivity为true的情况下），调用doappend()方法，实现日志的写入。在doappend方法中，若当前appender注册了filter，则doappend还会判断当前日志时候通过了filter的过滤，通过了filter的过滤后，如果当前appender继承自skeletonappender，还会检查当前日志级别时候要比当前appender本身的日志级别阀门要打，所有这些都通过后，才会将loggingevent实例传递给layout实例以格式化成一行日志信息，最后写入相应的目的地，在这些操作中，任何出现的错误都由errorhandler字段来处理。
log4j中的appender类图结构：
在log4j core一小节中已经简单的介绍过了appenderskeleton、writerappender、consoleappender以及 filter，因小节将直接介绍具体的几个常用的appender。
fileappender继承自writerappender，它将日志写入文件。主要的日志写入逻辑已经在writerappender中处理，fileappender主要处理的逻辑主要在于将设置日志输出文件名，并通过设置的文件构建writerappender中的quitewriter字段实例。如果log文件的目录没有创建，在setfile()方法中会先创建目录，再设置日志文件。另外，所有fileappender字段在调用activateoptions()方法中生效。
1 protected boolean fileappend = true;
2 protected string filename = null;
3 protected boolean bufferedio = false;
4 protected int buffersize = 8 * 1024;
5
6 public void activateoptions() {
7 if (filename != null) {
8 try {
9 setfile(filename, fileappend, bufferedio, buffersize);
10 } catch (java.io.ioexception e) {
11 errorhandler.error("setfile(" + filename + "," + fileappend
12 + ") call failed.", e, errorcode.file_open_failure);
13 }
14 } else {
15 loglog.warn("file option not set for appender [" + name + "].");
16 loglog.warn("are you using fileappender instead of consoleappender?");
17 }
18 }
19
20 public synchronized void setfile(string filename, boolean append,
21 boolean bufferedio, int buffersize) throws ioexception {
22 loglog.debug("setfile called: " + filename + ", " + append);
23 if (bufferedio) {
24 setimmediateflush(false);
25 }
26 reset();
27 fileoutputstream ostream = null;
28 try {
29 ostream = new fileoutputstream(filename, append);
30 } catch (filenotfoundexception ex) {
31 string parentname = new file(filename).getparent();
32 if (parentname != null) {
33 file parentdir = new file(parentname);
34 if (!parentdir.exists() && parentdir.mkdirs()) {
35 ostream = new fileoutputstream(filename, append);
36 } else {
37 throw ex;
38 }
39 } else {
40 throw ex;
41 }
42 }
43 writer fw = createwriter(ostream);
44 if (bufferedio) {
45 fw = new bufferedwriter(fw, buffersize);
46 }
47 this.setqwforfiles(fw);
48 this.filename = filename;
49 this.fileappend = append;
50 this.bufferedio = bufferedio;
51 this.buffersize = buffersize;
52 writeheader();
53 loglog.debug("setfile ended");
54 }
dailyrollingfileappender继承自fileappender，不过这个名字感觉有点不靠谱，事实上，dailyrollingfileappender会在每隔一段时间可以生成一个新的日志文件，不过这个时间间隔是可以设置的，不仅仅只是每隔一天。时间间隔通过setdatepattern()方法设置，datepattern必须遵循simpledateformat中的格式。支持的时间间隔有：
1. 每天：’.’yyyy-mm-dd（默认）
2. 每星期：’.’yyyy-ww
3. 每月：’.’yyyy-mm
4. 每隔半天：’.’yyyy-mm-dd-a
5. 每小时：’.’yyyy-mm-dd-hh
6. 每分钟：’.’yyyy-mm-dd-hh-mm
dailyrollingfileappender需要设置的两个属性：datepattern和filename。其中datepattern用于确定时间间隔以及当日志文件过了一个时间间隔后用于重命名之前的日志文件；filename用于设置日志文件的初始名字。在实现过程中，datepattern用于实例化simpledateformat，记录当前时间以及计算下一个时间间隔时间。在每次写日志操作之前先判断当前时间是否已经操作计算出的下一间隔时间，若是，则将之前的日志文件重命名（向日志文件名尾添加datepattern指定的时间信息），并创新的日志文件，同时重新设置当前时间以及下一次的时间间隔。
1 public void activateoptions() {
2 super.activateoptions();
3 if (datepattern != null && filename != null) {
4 now.settime(system.currenttimemillis());
5 sdf = new simpledateformat(datepattern);
6 int type = computecheckperiod();
7 printperiodicity(type);
8 rc.settype(type);
9 file file = new file(filename);
10 scheduledfilename = filename
11 + sdf.format(new date(file.lastmodified()));
12
13 } else {
14 loglog.error("either file or datepattern options are not set for appender ["
15 + name + "].");
16 }
17 }
18 void rollover() throws ioexception {
19 if (datepattern == null) {
20 errorhandler.error("missing datepattern option in rollover().");
21 return;
22 }
23
24 string datedfilename = filename + sdf.format(now);
25 if (scheduledfilename.equals(datedfilename)) {
26 return;
27 }
28 this.closefile();
29 file target = new file(scheduledfilename);
30 if (target.exists()) {
31 target.delete();
32 }
33 file file = new file(filename);
34 boolean result = file.renameto(target);
35 if (result) {
36 loglog.debug(filename + " -> " + scheduledfilename);
37 } else {
38 loglog.error("failed to rename [" + filename + "] to ["
39 + scheduledfilename + "].");
40 }
41 try {
42 this.setfile(filename, true, this.bufferedio, this.buffersize);
43 } catch (ioexception e) {
44 errorhandler.error("setfile(" + filename + ", true) call failed.");
45 }
46 scheduledfilename = datedfilename;
47 }
48 protected void subappend(loggingevent event) {
49 long n = system.currenttimemillis();
50 if (n >= nextcheck) {
51 now.settime(n);
52 nextcheck = rc.getnextcheckmillis(now);
53 try {
54 rollover();
55 } catch (ioexception ioe) {
56 if (ioe instanceof interruptedioexception) {
57 thread.currentthread().interrupt();
58 }
59 loglog.error("rollover() failed.", ioe);
60 }
61 }
62 super.subappend(event);
63 }
按log4j文档，dailyrollingfileappender存在线程同步问题。不过本人木有找到哪里出问题了，望高人指点。
rollingfileappender继承自fileappender，不同于dailyrollingfileappender是基于时间作为阀值，rollingfileappender则是基于文件大小作为阀值。当日志文件超过指定大小，日志文件会被重命名成”日志文件名.1”，若此文件已经存在，则将此文件重命名成”日志文件名.2”，一次类推。若文件数已经超过设置的可备份日志文件最大个数，则将最旧的日志文件删除。如果要设置不删除任何日志文件，可以将maxbackupindex设置成integer最大值，如果这样，这里rollover()方法的实现会引起一些性能问题，因为它要冲最大值开始遍历查找已经备份的日志文件。
1 protected long maxfilesize = 10 * 1024 * 1024;
2 protected int maxbackupindex = 1;
3 private long nextrollover = 0;
4
5 public void rollover() {
6 file target;
7 file file;
8 if (qw != null) {
9 long size = ((countingquietwriter) qw).getcount();
10 loglog.debug("rolling over count=" + size);
11 // if operation fails, do not roll again until
12 // maxfilesize more bytes are written
13 nextrollover = size + maxfilesize;
14 }
15 loglog.debug("maxbackupindex=" + maxbackupindex);
16
17 boolean renamesucceeded = true;
18 // if maxbackups <= 0, then there is no file renaming to be done.
19 if (maxbackupindex > 0) {
20 // delete the oldest file, to keep windows happy.
21 file = new file(filename + '.' + maxbackupindex);
22 if (file.exists())
23 renamesucceeded = file.delete();
24
25 // map {(maxbackupindex - 1),
, 2, 1} to {maxbackupindex,
, 3,
26 // 2}
27 for (int i = maxbackupindex - 1; i >= 1 && renamesucceeded; i--) {
28 file = new file(filename + "." + i);
29 if (file.exists()) {
30 target = new file(filename + '.' + (i + 1));
31 loglog.debug("renaming file " + file + " to " + target);
32 renamesucceeded = file.renameto(target);
33 }
34 }
35
36 if (renamesucceeded) {
37 // rename filename to filename.1
38 target = new file(filename + "." + 1);
39 this.closefile(); // keep windows happy.
40 file = new file(filename);
41 loglog.debug("renaming file " + file + " to " + target);
42 renamesucceeded = file.renameto(target);
43 //
44 // if file rename failed, reopen file with append = true
45 //
46 if (!renamesucceeded) {
47 try {
48 this.setfile(filename, true, bufferedio, buffersize);
49 } catch (ioexception e) {
50 if (e instanceof interruptedioexception) {
51 thread.currentthread().interrupt();
52 }
53 loglog.error("setfile(" + filename
54 + ", true) call failed.", e);
55 }
56 }
57 }
58 }
59
60 //
61 // if all renames were successful, then
62 //
63 if (renamesucceeded) {
64 try {
65 this.setfile(filename, false, bufferedio, buffersize);
66 nextrollover = 0;
67 } catch (ioexception e) {
68 if (e instanceof interruptedioexception) {
69 thread.currentthread().interrupt();
70 }
71 loglog.error("setfile(" + filename + ", false) call failed.", e);
72 }
73 }
74 }
75
76 public synchronized void setfile(string filename, boolean append,
77 boolean bufferedio, int buffersize) throws ioexception {
78 super.setfile(filename, append, this.bufferedio, this.buffersize);
79 if (append) {
80 file f = new file(filename);
81 ((countingquietwriter) qw).setcount(f.length());
82 }
83 }
84 protected void setqwforfiles(writer writer) {
85 this.qw = new countingquietwriter(writer, errorhandler);
86 }
87 protected void subappend(loggingevent event) {
88 super.subappend(event);
89 if (filename != null && qw != null) {
90 long size = ((countingquietwriter) qw).getcount();
91 if (size >= maxfilesize && size >= nextrollover) {
92 rollover();
93 }
94 }
95 }
asyncappender顾名思义，就是异步的调用appender中的doappend()方法。有多种方法实现这样的功能，比如每当调用doappend()方法时，doappend()方法内部启动一个线程来处理这一次调用的逻辑，这个线程可以是新建的线程也可以是线程池，然而我们知道线程是一个比较耗资源的实体，为每一次的操作都创建一个新的线程，而这个线程在这一次调用结束后就不再使用，这种模式是非常不划算的，性能低下；而且即使在这里使用线程池，也会导致在非常多请求同时过来时引起消耗大量的线程池中的线程或者因为线程池已满而阻塞请求。因而这种直接使用线程去处理每一次的请求是不可取的。
另一种常用的方案可以使用生产者和消费中的模式来实现类似的逻辑。即每一次请求做为一个生产者，将请求放到一个queue中，而由另外一个或多个消费者读取queue中的内容以处理真正的逻辑。
在最新的java版本中，我们可以使用blockingqueue类简单的实现类似的需求，然而由于log4j的存在远早于blockingqueue的创建，因而为了实现对以前版本的兼容，它还是自己实现了这样一套生产者消费者模型。
asyncappender并不会在每一次的doappend()调用中都直接将消息输出，而是使用了buffer，即只有等到buffer中loggingevent实例到达buffersize个的时候才真正的处理这些消息，当然我们也可以讲buffersize设置成1，从而实现每一个loggingevent实例的请求都会直接执行。如果buffersize设置过大，在应用程序异常终止时可能会丢失部分日志。
1 public static final int default_buffer_size = 128;
2 private final list buffer = new arraylist();
3 private final map discardmap = new hashmap();
4 private int buffersize = default_buffer_size;
5 private final thread dispatcher;
6 private boolean locationinfo = false;
7 private boolean blocking = true;
对其他字段，discardmap用于存放当当前loggingevent请求数已经超过buffersize或当前线程被中断的情况下能继续保留这些日志信息；locationinfo用于设置是否需要保留位置信息；blocking用于设置在消费者正在处理时，是否需要生产者“暂停”下来，默认为true；而dispatcher即是消费者线程，它在构建asyncappender是启动，每次监听buffer这个list，如果发现buffer中存在loggingevent实例，则将所有buffer和discardmap中的loggingevent实例拷贝到数组中，清空buffer和discardmap，并调用asyncappender内部注册的appender实例打印日志。
1 public void run() {
2 boolean isactive = true;
3 try {
4 while (isactive) {
5 loggingevent[] events = null;
6 synchronized (buffer) {
7 int buffersize = buffer.size();
8 isactive = !parent.closed;
9
10 while ((buffersize == 0) && isactive) {
11 buffer.wait();
12 buffersize = buffer.size();
13 isactive = !parent.closed;
14 }
15 if (buffersize > 0) {
16 events = new loggingevent[buffersize
17 + discardmap.size()];
18 buffer.toarray(events);
19 int index = buffersize;
20
21 for (iterator iter = discardmap.values().iterator(); iter
22 .hasnext();) {
23 events[index++] = ((discardsummary) iter.next())
24 .createevent();
25 }
26 buffer.clear();
27 discardmap.clear();
28 buffer.notifyall();
29 }
30 }
31 if (events != null) {
32 for (int i = 0; i < events.length; i++) {
33 synchronized (appenders) {
34 appenders.appendlooponappenders(events[i]);
35 }
36 }
37 }
38 }
39 } catch (interruptedexception ex) {
40 thread.currentthread().interrupt();
41 }
42 }
这里其实有一个bug，即当程序停止时只剩下discardmap中有日志信息，而buffer中没有日志信息，由于dispatcher线程不检查discardmap中的日志信息，因而此时会导致discardmap中的日志信息丢失。即使在生成者中当buffer为空时，它也会激活buffer锁，然而即使激活后buffer本身大小还是为0，因而不会处理之后的逻辑，因而这个逻辑也处理不了该bug。
对于生产者，它首先处理当消费者线程出现异常而不活动时，此时将同步的输出日志；而后根据配置获取loggingevent中的数据；再获得buffer的对象锁，如果buffer还没满，则直接将loggingevent实例添加到buffer中，否则如果blocking设置为true，即生产者会等消费者处理完后再继续下一次接收数据。如果blocking设置为fasle或者消费者线程被打断，那么当前的loggingevent实例则会保存在discardmap中，因为此时buffer已满。
1 public void append(final loggingevent event) {
2 if ((dispatcher == null) || !dispatcher.isalive() || (buffersize <= 0)) {
3 synchronized (appenders) {
4 appenders.appendlooponappenders(event);
5 }
6 return;
7 }
8 event.getndc();
9 event.getthreadname();
10 event.getmdccopy();
11 if (locationinfo) {
12 event.getlocationinformation();
13 }
14 event.getrenderedmessage();
15 event.getthrowablestrrep();
16 synchronized (buffer) {
17 while (true) {
18 int previoussize = buffer.size();
19 if (previoussize < buffersize) {
20 buffer.add(event);
21 if (previoussize == 0) {
22 buffer.notifyall();
23 }
24 break;
25 }
26 boolean discard = true;
27 if (blocking && !thread.interrupted()
28 && thread.currentthread() != dispatcher) {
29 try {
30 buffer.wait();
31 discard = false;
32 } catch (interruptedexception e) {
33 thread.currentthread().interrupt();
34 }
35 }
36 if (discard) {
37 string loggername = event.getloggername();
38 discardsummary summary = (discardsummary) discardmap
39 .get(loggername);
40
41 if (summary == null) {
42 summary = new discardsummary(event);
43 discardmap.put(loggername, summary);
44 } else {
45 summary.add(event);
46 }
47 break;
48 }
49 }
50 }
51 }
最后，asyncappender是appender的一个容器，它实现了appenderattachable接口，改接口的实现主要将实现逻辑代理给appenderattachableimpl类。
测试代码如下：
1 @test
2 public void testasyncappender() throws exception {
3 asyncappender appender = new asyncappender();
4 appender.addappender(new consoleappender(new ttcclayout()));
5 appender.setbuffersize(1);
6 appender.setlocationinfo(true);
7 appender.activateoptions();
8 configappender(appender);
9
10 logtest();
11 }
jdbcappender将日志保存到数据库的表中，由于数据库保存操作是一个比较费时的操作，因而jdbcappender默认使用缓存机制，当然你也可以设置缓存大小为1实现实时向数据库插入日志。jdbcappender中的layout默认只支持patternlayout，用户可以通过设置自己的patternlayout，其中conversionpattern设置成插入数据库的sql语句或通过setsql()方法设置sql语句，jdbcappender内部会创建相应的patternlayout，如可以设置sql语句为：
insert into logtable(thread, class, message) values(“%t”, “%c”, “%m”)
在doappend()方法中，jdbcappender通过layout获取sql语句，将loggingevent实例插入到数据库中。
1 protected string databaseurl = "jdbc:odbc:mydb";
2 protected string databaseuser = "me";
3 protected string databasepassword = "mypassword";
4 protected connection connection = null;
5 protected string sqlstatement = "";
6 protected int buffersize = 1;
7 protected arraylist buffer;
8 protected arraylist removes;
9 private boolean locationinfo = false;
10
11 public void append(loggingevent event) {
12 event.getndc();
13 event.getthreadname();
14 event.getmdccopy();
15 if (locationinfo) {
16 event.getlocationinformation();
17 }
18 event.getrenderedmessage();
19 event.getthrowablestrrep();
20 buffer.add(event);
21 if (buffer.size() >= buffersize)
22 flushbuffer();
23 }
24 public void flushbuffer() {
25 removes.ensurecapacity(buffer.size());
26 for (iterator i = buffer.iterator(); i.hasnext();) {
27 try {
28 loggingevent logevent = (loggingevent) i.next();
29 string sql = getlogstatement(logevent);
30 execute(sql);
31 removes.add(logevent);
32 } catch (sqlexception e) {
33 errorhandler.error("failed to excute sql", e,
34 errorcode.flush_failure);
35 }
36 }
37 buffer.removeall(removes);
38 removes.clear();
39 }
40 protected string getlogstatement(loggingevent event) {
41 return getlayout().format(event);
43 protected void execute(string sql) throws sqlexception {
44 connection con = null;
45 statement stmt = null;
46 try {
47 con = getconnection();
48 stmt = con.createstatement();
49 stmt.executeupdate(sql);
50 } catch (sqlexception e) {
51 if (stmt != null)
52 stmt.close();
53 throw e;
55 stmt.close();
56 closeconnection(con);
57 }
58 protected connection getconnection() throws sqlexception {
59 if (!drivermanager.getdrivers().hasmoreelements())
60 setdriver("sun.jdbc.odbc.jdbcodbcdriver");
61 if (connection == null) {
62 connection = drivermanager.getconnection(databaseurl, databaseuser,
63 databasepassword);
64 }
65 return connection;
66 }
67 protected void closeconnection(connection con) {
68 }
用户可以编写自己的jdbcappender，继承自jdbcappender，重写getconnection()和closeconnection()，可以实现从数据库连接池中获取connection，在每次将jdbcappender缓存中的loggingevent列表插入数据库时从连接池中获取缓存，而在该操作完成后将获得的连接释放回连接池。用户也可以重写getlogstatement()以自定义插入loggingevent的sql语句。
jmsappender类将loggingevent实例序列化成objectmessage，并将其发送到jms server的一个指定topic中。它的实现比较简单，设置相应的connectionfactoryname、topicname、providerurl、username、password等jms相应的信息，在activateoptions()方法中创建相应的jms链接，在doappend()方法中将loggingevent序列化成objectmessage发送到jms server中，它也可以通过locationinfo字段是否需要计算位置信息。不过这里的实现感觉有一些bug：在序列化loggingevent实例之前没有先缓存必要的信息，如threadname，因为这些信息默认是不设置的，具体可以参考jdbcappender、asyncappender等。
1 string securityprincipalname;
2 string securitycredentials;
3 string initialcontextfactoryname;
4 string urlpkgprefixes;
5 string providerurl;
6 string topicbindingname;
7 string tcfbindingname;
8 string username;
9 string password;
10 boolean locationinfo;
11
12 topicconnection topicconnection;
13 topicsession topicsession;
14 topicpublisher topicpublisher;
15
16 public void activateoptions() {
17 topicconnectionfactory topicconnectionfactory;
18 try {
19 context jndi;
20 loglog.debug("getting initial context.");
21 if (initialcontextfactoryname != null) {
22 properties env = new properties();
23 env.put(context.initial_context_factory,
24 initialcontextfactoryname);
25 if (providerurl != null) {
26 env.put(context.provider_url, providerurl);
27 } else {
28 loglog.warn("you have set initialcontextfactoryname option but not the "
29 + "providerurl. this is likely to cause problems.");
30 }
31 if (urlpkgprefixes != null) {
32 env.put(context.url_pkg_prefixes, urlpkgprefixes);
33 }
34 if (securityprincipalname != null) {
35 env.put(context.security_principal, securityprincipalname);
36 if (securitycredentials != null) {
37 env.put(context.security_credentials,
38 securitycredentials);
39 } else {
40 loglog.warn("you have set securityprincipalname option but not the "
41 + "securitycredentials. this is likely to cause problems.");
42 }
43 }
44 jndi = new initialcontext(env);
45 } else {
46 jndi = new initialcontext();
47 }
48 loglog.debug("looking up [" + tcfbindingname + "]");
49 topicconnectionfactory = (topicconnectionfactory) lookup(jndi,
50 tcfbindingname);
51 loglog.debug("about to create topicconnection.");
52 if (username != null) {
53 topicconnection = topicconnectionfactory.createtopicconnection(
54 username, password);
55 } else {
56 topicconnection = topicconnectionfactory
57 .createtopicconnection();
58 }
59 loglog.debug("creating topicsession, non-transactional, "
60 + "in auto_acknowledge mode.");
61 topicsession = topicconnection.createtopicsession(false,
62 session.auto_acknowledge);
63 loglog.debug("looking up topic name [" + topicbindingname + "].");
64 topic topic = (topic) lookup(jndi, topicbindingname);
65 loglog.debug("creating topicpublisher.");
66 topicpublisher = topicsession.createpublisher(topic);
67 loglog.debug("starting topicconnection.");
68 topicconnection.start();
69 jndi.close();
70 } catch (jmsexception e) {
71 errorhandler.error(
72 "error while activating options for appender named ["
73 + name + "].", e, errorcode.generic_failure);
74 } catch (namingexception e) {
75 errorhandler.error(
76 "error while activating options for appender named ["
77 + name + "].", e, errorcode.generic_failure);
78 } catch (runtimeexception e) {
79 errorhandler.error(
80 "error while activating options for appender named ["
81 + name + "].", e, errorcode.generic_failure);
82 }
83 }
84
85 public void append(loggingevent event) {
86 if (!checkentryconditions()) {
87 return;
88 }
89 try {
90 objectmessage msg = topicsession.createobjectmessage();
91 if (locationinfo) {
92 event.getlocationinformation();
93 }
94 msg.setobject(event);
95 topicpublisher.publish(msg);
96 } catch (jmsexception e) {
97 errorhandler.error("could not publish message in jmsappender ["
98 + name + "].", e, errorcode.generic_failure);
99 } catch (runtimeexception e) {
100 errorhandler.error("could not publish message in jmsappender ["
101 + name + "].", e, errorcode.generic_failure);
102 }
103 }
telnetappender类将日志消息发送到指定的socket端口（默认为23），用户可以使用telnet连接以获取日志信息。这里的实现貌似没有考虑到telnet客户端如何退出的问题。另外，在windows中可能默认没有telnet支持，此时只需要到”控制面板”->”程序和功能”->”打开或关闭windows功能”中大概telnet服务即可。telnetappender使用内部类sockethandler封装发送日志消息到客户端，如果没有telnet客户端连接，则日志消息将会直接被抛弃。
1 private sockethandler sh;
2 private int port = 23;
3
4 public void activateoptions() {
5 try {
6 sh = new sockethandler(port);
7 sh.start();
8 } catch (interruptedioexception e) {
9 thread.currentthread().interrupt();
10 e.printstacktrace();
11 } catch (ioexception e) {
12 e.printstacktrace();
13 } catch (runtimeexception e) {
14 e.printstacktrace();
15 }
16 super.activateoptions();
18 protected void append(loggingevent event) {
19 if (sh != null) {
20 sh.send(layout.format(event));
21 if (layout.ignoresthrowable()) {
22 string[] s = event.getthrowablestrrep();
23 if (s != null) {
24 stringbuffer buf = new stringbuffer();
25 for (int i = 0; i < s.length; i++) {
26 buf.append(s[i]);
27 buf.append("\r\n");
28 }
29 sh.send(buf.tostring());
31 }
33 }
在sockethandler中，创建一个新的线程以监听指定的端口，如果有telnet客户端连接过来，则将其加入到connections集合中。这样在send()方法中就可以遍历connections集合，并将日志信息发送到每个连接的telnet客户端。
1 private vector writers = new vector();
2 private vector connections = new vector();
3 private serversocket serversocket;
4 private int max_connections = 20;
6 public synchronized void send(final string message) {
7 iterator ce = connections.iterator();
8 for (iterator e = writers.iterator(); e.hasnext();) {
9 ce.next();
10 printwriter writer = (printwriter) e.next();
11 writer.print(message);
12 if (writer.checkerror()) {
13 ce.remove();
14 e.remove();
15 }
18 public void run() {
19 while (!serversocket.isclosed()) {
20 try {
21 socket newclient = serversocket.accept();
22 printwriter pw = new printwriter(
23 newclient.getoutputstream());
24 if (connections.size() < max_connections) {
25 synchronized (this) {
26 connections.addelement(newclient);
27 writers.addelement(pw);
28 pw.print("telnetappender v1.0 ("
29 + connections.size()
30 + " active connections)\r\n\r\n");
31 pw.flush();
32 }
33 } else {
34 pw.print("too many connections.\r\n");
35 pw.flush();
36 newclient.close();
38
39 }
40
41 }
smtpappender将日志消息以邮件的形式发送出来，默认实现，它会先缓存日志信息，只有当遇到日志级别是error或error以上的日志消息时才通过邮件的形式发送出来，如果在遇到触发发送的日志发生之前缓存中的日志信息已满，则最早的日志信息会被覆盖。用户可以通过setevaluatorclass()方法改变触发发送日志的条件。
1 public void append(loggingevent event) {
2 if (!checkentryconditions()) {
3 return;
4 }
5 event.getthreadname();
6 event.getndc();
7 event.getmdccopy();
8 if (locationinfo) {
9 event.getlocationinformation();
10 }
11 event.getrenderedmessage();
12 event.getthrowablestrrep();
13 cb.add(event);
14 if (evaluator.istriggeringevent(event)) {
15 sendbuffer();
18 protected void sendbuffer() {
19 try {
20 string s = formatbody();
21 boolean allascii = true;
22 for (int i = 0; i < s.length() && allascii; i++) {
23 allascii = s.charat(i) <= 0x7f;
24 }
25 mimebodypart part;
26 if (allascii) {
27 part = new mimebodypart();
28 part.setcontent(s, layout.getcontenttype());
29 } else {
30 try {
31 bytearrayoutputstream os = new bytearrayoutputstream();
32 writer writer = new outputstreamwriter(mimeutility.encode(
33 os, "quoted-printable"), "utf-8");
34 writer.write(s);
35 writer.close();
36 internetheaders headers = new internetheaders();
37 headers.setheader("content-type", layout.getcontenttype()
38 + "; charset=utf-8");
39 headers.setheader("content-transfer-encoding",
40 "quoted-printable");
41 part = new mimebodypart(headers, os.tobytearray());
42 } catch (exception ex) {
43 stringbuffer sbuf = new stringbuffer(s);
44 for (int i = 0; i < sbuf.length(); i++) {
45 if (sbuf.charat(i) >= 0x80) {
46 sbuf.setcharat(i, '?');
47 }
48 }
49 part = new mimebodypart();
50 part.setcontent(sbuf.tostring(), layout.getcontenttype());
51 }
52 }
53
54 multipart mp = new mimemultipart();
55 mp.addbodypart(part);
56 msg.setcontent(mp);
57
58 msg.setsentdate(new date());
59 transport.send(msg);
60 } catch (messagingexception e) {
61 loglog.error("error occured while sending e-mail notification.", e);
62 } catch (runtimeexception e) {
63 loglog.error("error occured while sending e-mail notification.", e);
65 }
66 protected string formatbody() {
67 stringbuffer sbuf = new stringbuffer();
68 string t = layout.getheader();
69 if (t != null)
70 sbuf.append(t);
71 int len = cb.length();
72 for (int i = 0; i < len; i++) {
73 loggingevent event = cb.get();
74 sbuf.append(layout.format(event));
75 if (layout.ignoresthrowable()) {
76 string[] s = event.getthrowablestrrep();
77 if (s != null) {
78 for (int j = 0; j < s.length; j++) {
79 sbuf.append(s[j]);
80 sbuf.append(layout.line_sep);
81 }
82 }
83 }
84 }
85 t = layout.getfooter();
86 if (t != null) {
87 sbuf.append(t);
88 }
89 return sbuf.tostring();
90 }
socketappender将日志消息（loggingevent序列化实例）发送到指定host的port端口。在创建socketappender时，socketappender会根据设置的host和端口建立和远程服务器的链接，并创建objectoutputstream实例。
1 void connect(inetaddress address, int port) {
2 if (this.address == null)
4 try {
5 cleanup();
6 oos = new objectoutputstream(
7 new socket(address, port).getoutputstream());
8 } catch (ioexception e) {
9 if (e instanceof interruptedioexception) {
10 thread.currentthread().interrupt();
11 }
12 string msg = "could not connect to remote log4j server at ["
13 + address.gethostname() + "].";
14 if (reconnectiondelay > 0) {
15 msg += " we will try again later.";
16 fireconnector(); // fire the connector thread
17 } else {
18 msg += " we are not retrying.";
19 errorhandler.error(msg, e, errorcode.generic_failure);
20 }
21 loglog.error(msg);
如果创建失败，调用fireconnector()方法，创建一个connector线程，在每间隔reconnectiondelay（默认值为30000ms，若将其设置为0表示在链接出问题时不创建新的线程检测）的时间里不断重试链接。当链接重新建立后，connector线程退出并将connector实例置为null以在下一次链接出现问题时创建的connector线程检测。
1 实例置为null以在下一次链接出现问题时创建的connector线程检测。
2 void fireconnector() {
3 if (connector == null) {
4 loglog.debug("starting a new connector thread.");
5 connector = new connector();
6 connector.setdaemon(true);
7 connector.setpriority(thread.min_priority);
8 connector.start();
9 }
10 }
11
12 class connector extends thread {
13 boolean interrupted = false;
14 public void run() {
15 socket socket;
16 while (!interrupted) {
17 try {
18 sleep(reconnectiondelay);
19 loglog.debug("attempting connection to "
20 + address.gethostname());
21 socket = new socket(address, port);
22 synchronized (this) {
23 oos = new objectoutputstream(socket.getoutputstream());
24 connector = null;
25 loglog.debug("connection established. exiting connector thread.");
26 break;
27 }
28 } catch (interruptedexception e) {
29 loglog.debug("connector interrupted. leaving loop.");
30 return;
31 } catch (java.net.connectexception e) {
32 loglog.debug("remote host " + address.gethostname()
33 + " refused connection.");
34 } catch (ioexception e) {
35 if (e instanceof interruptedioexception) {
36 thread.currentthread().interrupt();
37 }
38 loglog.debug("could not connect to "
39 + address.gethostname() + ". exception is " + e);
40 }
41 }
42 }
43 }
而后，在每一次日志记录请求时只需将loggingevent实例序列化到之前创建的objectoutputstream中即可，若该操作失败，则会重新建立connector线程以隔时检测远程日志服务器可以重新链接。
2 if (event == null)
4 if (address == null) {
5 errorhandler
6 .error("no remote host is set for socketappender named \""
7 + this.name + "\".");
8 return;
10 if (oos != null) {
11 try {
12 if (locationinfo) {
13 event.getlocationinformation();
14 }
15 if (application != null) {
16 event.setproperty("application", application);
17 }
18 event.getndc();
19 event.getthreadname();
20 event.getmdccopy();
21 event.getrenderedmessage();
22 event.getthrowablestrrep();
23 oos.writeobject(event);
24 oos.flush();
25 if (++counter >= reset_frequency) {
26 counter = 0;
27 // failing to reset the object output stream every now and
28 // then creates a serious memory leak.
29 // system.err.println("doing oos.reset()");
30 oos.reset();
31 }
32 } catch (ioexception e) {
33 if (e instanceof interruptedioexception) {
34 thread.currentthread().interrupt();
36 oos = null;
37 loglog.warn("detected problem with connection: " + e);
38 if (reconnectiondelay > 0) {
39 fireconnector();
40 } else {
41 errorhandler
42 .error("detected problem with connection, not reconnecting.",
43 e, errorcode.generic_failure);
44 }
45 }
46 }
log4j为日志服务器的实现提供了socketnode类，它接收客户端的链接，并根据配置打印到相关的appender中。
1 public class socketnode implements runnable {
2 socket socket;
3 loggerrepository hierarchy;
4 objectinputstream ois;
6 public socketnode(socket socket, loggerrepository hierarchy) {
7 this.socket = socket;
8 this.hierarchy = hierarchy;
9 try {
10 ois = new objectinputstream(new bufferedinputstream(
11 socket.getinputstream()));
12 } catch (
) {
13
14 }
17 public void run() {
18 loggingevent event;
19 logger remotelogger;
21 if (ois != null) {
22 while (true) {
23 event = (loggingevent) ois.readobject();
24 remotelogger = hierarchy.getlogger(event.getloggername());
25 if (event.getlevel().isgreaterorequal(
26 remotelogger.geteffectivelevel())) {
27 remotelogger.callappenders(event);
28 }
31 } catch (
32
33 } finally {
34 if (ois != null) {
35 try {
36 ois.close();
37 } catch (exception e) {
38 logger.info("could not close connection.", e);
39 }
41 if (socket != null) {
42 try {
43 socket.close();
44 } catch (interruptedioexception e) {
45 thread.currentthread().interrupt();
46 } catch (ioexception ex) {
47 }
事实上，log4j提供了两个日志服务器的实现类：simplesocketserver和socketserver。他们都会接收客户端的连接，为每个客户端链接创建一个socketnode实例，并根据指定的配置文件打印日志消息。它们的不同在于simplesocketserver同时支持xml和properties配置文件，而socketserver只支持properties配置文件；另外，socketserver支持不同客户端使用不同的配置文件（以客户端主机名作为选择配置文件的方式），而simplesocketserver不支持。
最后，使用socketappender时，在应用程序退出时，最好显示的调用loggermanager.shutdown()方法，不然如果是通过垃圾回收器来隐式的关闭（finalize()方法）socketappender，在windows平台中可能会存在tcp管道中未传输的数据丢失的情况。另外，在网络连接不可用时，socketappender可能会阻塞应用程序，当网络可用，但是远程日志服务器不可用时，相应的日志会被丢失。如果日志传输给远程日志服务器的速度要慢于日志产生速度，此时会影响应用程序性能。这些问题在下一小节的sockethubappender中同样存在。
可以使用一下代码测试socketappender和socketnode：
2 public void testsocketappender() throws exception {
3 socketappender appender = new socketappender(
4 inetaddress.getlocalhost(), 8000);
5 appender.setlocationinfo(true);
6 appender.setapplication("appendertest");
10 logger log = logger.getlogger("levin.log4j.test.testbasic");
11 for(int i = 0;i < 100; i++) {
12 thread.sleep(10000);
13 if(i % 2 == 0) {
14 log.info("normal test
.");
15 } else {
16 log.info("exception test
", new exception());
19 }
21 @test
22 public void testsimplesocketserver() throws exception {
23 consoleappender appender = new consoleappender(new ttcclayout());
24 appender.activateoptions();
25 configappender(appender);
26
27 serversocket serversocket = new serversocket(8000);
28 while(true) {
29 socket socket = serversocket.accept();
30 new thread(new socketnode(socket,
31 logmanager.getloggerrepository()),
32 "simplesocketserver-" + 8000).start();
33 }
34 }
sockethubappender类似socketappender，它也将日志信息（序列化后的loggingevent实例）发送到指定的日志服务器，该日志服务器可以是socketnode支持的服务器。不同的是，socketappender指定日志服务器的地址和端口号，而sockethubappender并不直接指定日志服务器的地址和端口号，它自己启动一个指定端口的服务器，由日志服务器注册到到该服务器，从而产生一个连接参数，sockethubappender根据这些参数发送日志信息到注册的日志服务器，因而sockethubappender支持同时发送相同的日志信息到多个日志服务器。
另外，sockethubappender还会缓存部分loggingevent实力，从而支持在新注册一个日志服务器时，它会先将那些缓存下来的loggingevent发送给新注册服务器，然后接受新的loggingevent日志打印请求。
具体实现以及注意事项参考socketappender。最好补充一点，sockethubappender可以和chainsaw一起使用，它好像使用了zeroconf协议，和sockethubappender以及socketappender中的zeroconfsupport类相关，不怎么了解这个协议，也没有时间细看了。
将日志显示在swing窗口中。对swing不熟，没怎么看代码，不过可以使用一下测试用例简单的做一些测试，提供一些感觉。
1 @test
2 public void testlf5appender() throws exception {
3 lf5appender appender = new lf5appender();
4 appender.setlayout(new ttcclayout());
5 appender.activateoptions();
6 configappender(appender);
7
8 logtest();
9 }
externallyrolledfileappender类继承自rollingfileappender，因而它最基本的也是基于日志文件大小来备份日志文件。然而它同时还支持外界通过socket发送“rollover”给它以实现在特定情况下手动备份日志文件。log4j提供roller类来实现这样的功能，其使用方法是：
java -cp log4j-1.2.16.jar org.apache.log4j.varia.roller <hostname> <port>
但是由于任何可以和应用程序运行的服务器连接的代码都能像该服务器发送“rollover”消息，因而这种方式并不适合production环境在，在production中最好能加入一些限制信息，比如安全验证等信息。
nteventlogappender将日志打印到nt事件日志系统中（nt event log system）。顾名思义，它只能用在windows中，而且需要nteventlogappender.dll、nteventlogappender.amd64.dll、nteventlogappender.ia64.dll或nteventlogappender.x86.dll动态链接库在windows path路径中。在windows 7中可以通过控制面板->管理工具->查看事件日志中查看相应的日志信息。
nullappender作为一个null object模式存在，不会输出任何打印日志消息。