随着项目的逐渐扩大,日志的增加也变得更快。log4j是常用的日志记录工具,在有些时候,我们可能需要将log4j的日志发送到专门用于记录日志的远程服务器,特别是对于稍微大一点的应用。这么做的优点有:
远程打印日志的原理:项目a需要打印日志,而a调用log4j来打印日志,log4j的jmsappender又给配置的地址(activemq地址)发送一条jms消息,此时绑定在queue上的项目b的监听器发现有消息到来,于是立即唤醒监听器的方法开始输出日志。
本文将使用两个java项目product和logging,其中product项目就是模拟线上的项目,而logging项目模拟运行在专用的日志服务器上的项目。说明:本文的例子是在windows平台下。
解压后不需要任何配置,进入到bin下对应的系统架构文件夹

双击activemq.bat启动,如果看到类似下面的页面,就代表activemq启动好了:
可以点击manage activemq broker进入queue的查看界面。
我用maven来管理项目,方便维护各种依赖的jar包。先看下项目结构:
项目不复杂,主要是4个文件:pom.xml,main.java,log4j.properties和jndi.properties
pom.xml中主要是声明项目的依赖包,其余没有什么东西了:
main.java:
说明:然后是log4j.properties:
其实按理说只需要这么三个文件就可以了,但是这时候执行会报错:
为什么会报错呢?来看看jmsappender的javadoc文档,它是这么描述的:
大意是说,jmsappender需要一个jndi配置来初始化一个jndi上下文(context)。因为有了这个上下文才能管理jms topic和topic的连接。于是为项目配置一个叫jndi.properties的文件,其内容为:
然后再运行就不会报错了。我们先来看看activemq(注意切换到topic标签页下):
可以看到,主题为logtopic的消息,有3条进queue,这3条也出queue了。而出queue的消息,已经被我们的监听器收到并打印出来了:
需要注意的是,本例只是一个很简单的例子,目的是阐明远程打印日志的原理。实际项目中,一般日志服务器上运行着的,不是项目,而是专用的日志记录器。下面,我们就把这个项目拆分成两个项目,并用spring来管理这些用到的bean
修改后的product的项目结构并没有改变,改变的只是main类:
这个main类和普通的logger调用一样,仅仅负责打印日志。有没有觉得太简单了呢?
来看看项目结构图:
为了让监听器一直活着,我把logging写成了一个web项目,跑在tomcat上。index.jsp就是个hello world字符串而已,用来验证logging活着。注意,在logging项目中,已没有product项目中的log4j.properties和jndi.properties两个文件。
来看看另外几个文件:
pom.xml(每个包的目的都写在注释里了):
web.xml
spring.xml
logmessagelistener指向我们自己实现的日志消息处理逻辑类,topicdestination则关注topic为“logtopic”的消息,而jmscontainer把这两个对象绑在一起,这样就能接收并处理消息了。
最后就是伟大的监听器了logmessagelistener了:
哈哈,说伟大,其实太简单了。但是可以看到,监听器里面就是之前product项目中main类里面移除的实现了messagelistener接口中的代码。
在执行测试前,删掉activemq中所有的queue,确保测试效果。
先运行logging项目,开始queue的监听。再运行product的main类的main函数,可以先看到main类打印到控制台的日志:
接下来去看看queue中的情况:
可以看到有个叫logtopic的主题的消息,进了3条,出了3条。不用想,出queue的3条日志已经被logging项目的listener接收并打印出来了,现在去看看tomcat的控制台:
还要注意queue中的logtopic的consumer数量为1而不是0,这与开始的截图不同。我们都知道这个consumer是logging项目中的logmessagelistener对象,它一直活着,是因为tomcat一直活着;之前的consumer数量为0,是因为在main函数执行完后,queue的监听器(也是写日志的对象)就退出了。
通过把product和logging项目分别放在不同的机器上执行,在第三台机器上部署activemq(当然你可以把activemq搭建在任意可以访问的地方),再配置一下product项目的log4j.properties文件和logging项目的spring.xml文件就能用于生产环境啦。
jmsappender类将loggingevent实例序列化成objectmessage,并将其发送到jms server的一个指定topic中,因此,使用此种将日志发送到远程的方式只支持topic方式发送,不支持queue方式发送。我们再log4j.properties中配置了这一句:
这一句指定了使用的appender,打开这个appender,在里面可以看到很多setter,比如:
这些setter不是巧合,而正是对应了我们在log4j.properties中设置的其他几个选项:
来看看jmsappender的activeoptions方法,这个方法是用于使我们在log4j.properties中的配置生效的:
上面初始化了一个topicconnection,一个topicsession,一个topicpublisher。咱们再来看看这个appender的append方法:
这里使用topicpublisher.publish()方法,把序列化的消息发布出去。可见这也证明了jmsappender只支持以topic方式发送消息。
样例下载:百度网盘
参考:
<a href="http://activemq.apache.org/how-do-i-use-log4j-jms-appender-with-activemq.html">http://activemq.apache.org/how-do-i-use-log4j-jms-appender-with-activemq.html</a>