在Tomcat中集成ActiveMQ
网上有一些介绍,但是很多都是采用JNDI的方式,麻烦,而且tomcat和activemq要分别启动,理想的方式是启动tomcat的同时启动activemq,在web工程中直接使用activemq

1,新建web工程,并导入基本jar包

2,修改web.xml
Xml代码 复制代码  收藏代码
  1. <context-param>  
  2.        <param-name>brokerURI</param-name>  
  3.        <param-value>/WEB-INF/activemq.xml</param-value>  
  4.     </context-param>  
  5.   
  6.     <listener>  
  7.     <listener-class>org.apache.activemq.web.SpringBrokerContextListener</listener-class>  
  8.     </listener>  
<context-param>
	   <param-name>brokerURI</param-name>
	   <param-value>/WEB-INF/activemq.xml</param-value>
	</context-param>

    <listener>
    <listener-class>org.apache.activemq.web.SpringBrokerContextListener</listener-class>
    </listener>

3,增加WEB-INF/activemq.xml
Xml代码 复制代码  收藏代码
  1. <beans  
  2.   xmlns="http://www.springframework.org/schema/beans"  
  3.   xmlns:amq="http://activemq.apache.org/schema/core"  
  4.   xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"  
  5.   xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd   
  6.   http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core-5.2.0.xsd      
  7.   http://activemq.apache.org/camel/schema/spring http://activemq.apache.org/camel/schema/spring/camel-spring.xsd">  
  8.   
  9.     <!-- The Oracle Datasource that will be used by the Broker -->  
  10.     <bean id="oracle-ds" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">  
  11.       <property name="driverClassName" value="oracle.jdbc.driver.OracleDriver"/>  
  12.       <property name="url" value="jdbc:oracle:thin:@localhost:1521:orcl"/>  
  13.       <property name="username" value="activemq"/>  
  14.       <property name="password" value="neusoft"/>  
  15.       <property name="maxActive" value="200"/>  
  16.       <property name="poolPreparedStatements" value="true"/>  
  17.     </bean>  
  18.   
  19.     <!-- ==================================================================== -->  
  20.     <!-- ActiveMQ Broker Configuration -->  
  21.     <!-- ==================================================================== -->  
  22.     <broker xmlns="http://activemq.apache.org/schema/core" brokerName="localhost">  
  23.          <!-- The store and forward broker networks ActiveMQ will listen to -->  
  24.         <networkConnectors>  
  25.             <!-- by default just auto discover the other brokers -->  
  26.             <networkConnector name="default-nc" uri="multicast://default"/>  
  27.             <!-- Example of a static configuration:   
  28.             <networkConnector name="host1 and host2" uri="static://(tcp://host1:61616,tcp://host2:61616)"/>  
  29.             -->  
  30.         </networkConnectors>  
  31.   
  32.         <!--   
  33.             to enable Stomp support uncomment this <connector> <serverTransport  
  34.             uri="stomp://localhost:61626"/> </connector>  
  35.         -->  
  36.             
  37.         <persistenceAdapter>  
  38.             <jdbcPersistenceAdapter dataSource="#oracle-ds"/>  
  39.             <journaledJDBC useDatabaseLock="false"></journaledJDBC>  
  40.         </persistenceAdapter>  
  41.            
  42.            
  43.         <transportConnectors>  
  44.             <transportConnector name="openwire" uri="tcp://localhost:61616" discoveryUri="multicast://default"/>  
  45.             <transportConnector name="xmpp" uri="xmpp://localhost:61222"/>  
  46.         </transportConnectors>  
  47.     </broker>  
  48.   
  49. </beans>  
<beans
  xmlns="http://www.springframework.org/schema/beans"
  xmlns:amq="http://activemq.apache.org/schema/core"
  xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd
  http://activemq.apache.org/schema/core http://activemq.apache.org/schema/core/activemq-core-5.2.0.xsd   
  http://activemq.apache.org/camel/schema/spring http://activemq.apache.org/camel/schema/spring/camel-spring.xsd">

    <!-- The Oracle Datasource that will be used by the Broker -->
	<bean   destroy-method="close">
      <property name="driverClassName" value="oracle.jdbc.driver.OracleDriver"/>
      <property name="url" value="jdbc:oracle:thin:@localhost:1521:orcl"/>
      <property name="username" value="activemq"/>
      <property name="password" value="neusoft"/>
      <property name="maxActive" value="200"/>
      <property name="poolPreparedStatements" value="true"/>
    </bean>

	<!-- ==================================================================== -->
	<!-- ActiveMQ Broker Configuration -->
	<!-- ==================================================================== -->
	<broker xmlns="http://activemq.apache.org/schema/core" brokerName="localhost">
		 <!-- The store and forward broker networks ActiveMQ will listen to -->
        <networkConnectors>
            <!-- by default just auto discover the other brokers -->
            <networkConnector name="default-nc" uri="multicast://default"/>
            <!-- Example of a static configuration:
            <networkConnector name="host1 and host2" uri="static://(tcp://host1:61616,tcp://host2:61616)"/>
            -->
        </networkConnectors>

		<!--
			to enable Stomp support uncomment this <connector> <serverTransport
			uri="stomp://localhost:61626"/> </connector>
		-->
         
		<persistenceAdapter>
            <jdbcPersistenceAdapter dataSource="#oracle-ds"/>
            <journaledJDBC useDatabaseLock="false"></journaledJDBC>
        </persistenceAdapter>
        
		
		<transportConnectors>
            <transportConnector name="openwire" uri="tcp://localhost:61616" discoveryUri="multicast://default"/>
            <transportConnector name="xmpp" uri="xmpp://localhost:61222"/>
        </transportConnectors>
	</broker>

</beans>
OK,将web工程添加进tomcat,启动tomcat,大功告成。 注意事项: 1,导入的基本jar包,只保证能够提供activemq的基本服务。 2,使用数据库来存储activemq的message,也可以不使用。 3,本文使用数据库为oracle,其他数据库的配置请参照下载zip的activemq.xml 4,如此配置activemq,启动的时候必须连接网线,否则会报错。 5,activemq.xml中的<journaledJDBC useDatabaseLock="false"></journaledJDBC>是保证更换数据库的时候activemq依然能够顺利启动

推荐文章

需要JQuery帮助选择表行数组(tr)

需要JQuery帮助选择表行数组(tr)

推荐文章

迁移rails 2.3应用程序以使用Bundler而不是config.gem

迁移rails 2.3应用程序以使用Bundler而不是config.gem

推荐文章

我想在数据库中存储公制单位-我应该使用什么数据类型?

我想在数据库中存储公制单位-我应该使用什么数据类型?

推荐文章

java打开文件和排序数据

java打开文件和排序数据

推荐文章

可扩展列表视图中的微调器?在子菜单中

可扩展列表视图中的微调器?在子菜单中

推荐文章

使用反射用枚举填充下拉列表

使用反射用枚举填充下拉列表

推荐文章

Android SensorManager.java getOrientation和getRotationMatrix算法

Android SensorManager.java getOrientation和getRotationMatrix算法

推荐文章

如何合并SSIS包文件?

如何合并SSIS包文件?

推荐文章

如何使用DirectX获取YUV流或字节数组?

如何使用DirectX获取YUV流或字节数组?

推荐文章

下课后最后一次调用Dealloc

下课后最后一次调用Dealloc

推荐文章

随机salt md5实现,包括新的注册/更改密码

随机salt md5实现,包括新的注册/更改密码

推荐文章

如何只允许“拥有”数据的用户编辑数据?

如何只允许“拥有”数据的用户编辑数据?

推荐文章

Windows服务问题:即使在安装之后,Windows服务也未显示在服务列表中

Windows服务问题:即使在安装之后,Windows服务也未显示在服务列表中

推荐文章

在OOP中,master detail对象是如何工作的?

在OOP中,master detail对象是如何工作的?

推荐文章

先进先出c++算法

先进先出c++算法

推荐文章

C语言中的三维字符数组问题

C语言中的三维字符数组问题