ActiveMQ相关背景(转)

 1 pom.xml
 2 src/main/webapp/
 3     |---- WEB-INF/
 4               |---- web.xml
 5     |---- index.jsp # 忽略
 6 src/main/resources/
 7     |---- spring-beans.xml
 8     |---- topic.properties # 集中管理修改概率比较高的属性配置
 9 src/main/java/
10     |---- cn.sinobest.asj.logserver
11               |---- LogListener.java # 接收并输出log message

 1 <project xmlns="http://maven.apache.org/POM/4.0.0"
 2     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 3     xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">
 4     <modelVersion>4.0.0</modelVersion>
 5     <groupId>cn.sinobest.asj</groupId>
 6     <artifactId>log-servler</artifactId>
 7     <packaging>war</packaging>
 8     <version>0.0.1-SNAPSHOT</version>
 9     <name>amqlog-servler Maven Webapp</name>
10     <url>http://maven.apache.org</url>
11     <description>日志服务器，从ActiveMQ订阅主题，从而获取相关的日志数据</description>
12     <dependencies>
13         <dependency>
14             <groupId>junit</groupId>
15             <artifactId>junit</artifactId>
16             <version>3.8.1</version>
17             <scope>test</scope>
18         </dependency>
19         <!-- use to import spring-webmvc framework -->
20         <dependency>
21             <groupId>org.springframework</groupId>
22             <artifactId>spring-web</artifactId>
23             <version>4.2.4.RELEASE</version>
24         </dependency>
25         <dependency>
26             <groupId>org.springframework</groupId>
27             <artifactId>spring-jms</artifactId>
28             <version>4.2.4.RELEASE</version>
29         </dependency>
30         <!-- use to subscribe topic message from ActiveMQ -->
31         <dependency>
32             <groupId>org.apache.activemq</groupId>
33             <artifactId>activemq-client</artifactId>
34             <version>5.13.2</version>
35         </dependency>
36         <!-- use to extract log content from message -->
37         <dependency>
38             <groupId>log4j</groupId>
39             <artifactId>log4j</artifactId>
40             <version>1.2.17</version>
41         </dependency>
42     </dependencies>
43     <build>
44         <finalName>amqlog-servler</finalName>
45     </build>
46 </project>

 1 <?xml version="1.0" encoding="UTF-8"?>
 2 <beans xmlns="http://www.springframework.org/schema/beans"
 3     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 4     xmlns:context="http://www.springframework.org/schema/context"
 5     xsi:schemaLocation="http://www.springframework.org/schema/beans
 6         http://www.springframework.org/schema/beans/spring-beans-4.2.xsd
 7         http://www.springframework.org/schema/context
 8         http://www.springframework.org/schema/context/spring-context-4.2.xsd">
 9     <context:property-placeholder location="classpath:topic.properties" />
10     <bean id="targetConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory">
11         <property name="brokerURL" value="${topic.brokerURL}" />
12         <!-- add trusted packages. see http://activemq.apache.org/objectmessage.html -->
13         <property name="trustedPackages">
14             <list>
15                 <value>org.apache.log4j.spi</value>
16             </list>
17         </property>
18     </bean>
19     <bean id="connectionFactory"
20         class="org.springframework.jms.connection.SingleConnectionFactory">
21         <property name="targetConnectionFactory" ref="targetConnectionFactory" />
22     </bean>
23     <bean id="destination" class="org.apache.activemq.command.ActiveMQTopic">
24         <constructor-arg name="name" value="${topic.topicName}" />
25     </bean>
26     <!-- define the message-listener to receive and dipose log data. -->
27     <bean id="messageListener" class="cn.sinobest.asj.logserver.LogListener" />
28     <bean id="jmsContainer"
29         class="org.springframework.jms.listener.DefaultMessageListenerContainer">
30         <property name="connectionFactory" ref="connectionFactory" />
31         <property name="destination" ref="destination" />
32         <property name="messageListener" ref="messageListener" />
33     </bean>
34 </beans>

 1 package cn.sinobest.asj.logserver;
 2 import javax.jms.JMSException;
 3 import javax.jms.Message;
 4 import javax.jms.MessageListener;
 5 import org.apache.activemq.command.ActiveMQObjectMessage;
 6 import org.apache.log4j.spi.LoggingEvent;
 7 public class LogListener implements MessageListener {
 8     private static final String TEMPLATE = "[%-5s] %s";
 9     public void onMessage(Message message) {
10         try {
11             // extract LoggingEvent from message
12             // you must set org.apache.log4j.spi into the trusted packages list
13             // see spring-beans.xml in classpath
14             LoggingEvent event = (LoggingEvent) ((ActiveMQObjectMessage) message)
15                     .getObject();
16             String content = String.format(TEMPLATE, event.getLevel()
17                     .toString(), event.getMessage().toString());
18             System.out.println(content);
19         } catch (JMSException e) {
20             e.printStackTrace();
21         }
22     }
23 }

1 pom.xml
2 src/main/resources/
3     |---- log4j.properties # 配置日志输出地点，及ActiveMQ的相关参数
4     |---- jndi.properties # 配置topic
5 src/main/java/
6     |---- cn.sinobest.asj.logclient
7               |---- LogProducer.java # 生成并输出日志

 1 <project xmlns="http://maven.apache.org/POM/4.0.0"
 2     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 3     xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
 4     <modelVersion>4.0.0</modelVersion>
 5     <groupId>cn.sinobest.asj</groupId>
 6     <artifactId>amqlog-client</artifactId>
 7     <version>0.0.1-SNAPSHOT</version>
 8     <name>Simple app to send log to ActiveMQ</name>
 9     <description>模拟一般的应用系统，通过log4j发送日志到ActiveMQ</description>
10     <dependencies>
11         <!-- use to write log -->
12         <dependency>
13             <groupId>log4j</groupId>
14             <artifactId>log4j</artifactId>
15             <version>1.2.17</version>
16         </dependency>
17         <dependency>
18             <groupId>commons-logging</groupId>
19             <artifactId>commons-logging</artifactId>
20             <version>1.1.1</version>
21         </dependency>
22         <!-- use to import class org.apache.activemq.jndi.ActiveMQInitialContextFactory 
23             to write log to ActiveMQ -->
24         <dependency>
25             <groupId>org.apache.activemq</groupId>
26             <artifactId>activemq-client</artifactId>
27             <version>5.13.2</version>
28         </dependency>
29     </dependencies>
30 </project>

topic.topicName=demo

 1 package cn.sinobest.asj.logclient;
 2 import org.apache.commons.logging.Log;
 3 import org.apache.commons.logging.LogFactory;
 4 public class LogProducer {
 5     private static final Log log = LogFactory.getLog(LogProducer.class);
 6     /**
 7      * @param args
 8      */
 9     public static void main(String[] args) {
10         log.debug("this is a debug message.");
11         log.info("this is a info message.");
12         log.warn("this is a warn message.");
13         log.error("this is a error message");
14         System.exit(0);
15     }
16 }