activemq5.5 的入门 包括安装、启动、数据库持久化

Apache ActiveMQ 5.5.0 主要是一个维护版本,修复了超过130个问题,大部分是bug和改进。

值得关注的新特性:

  • Dependency on Java 1.6 (java 1.5 is no longer supported)
  • MDC logging (SLF4J)
  • Upgrade to camel 2.7.0
  • DLQ processing per durable subscription
  • New network connector MBeans
  • IOExceptionHandler for JDBC store
  • Added support for Apache Commons Daemon

改进内容:

  • Improved support for recovery of durable subscribers with priority support
  • Improved performance for offline durable subscriptions with large message backlogs (JDBC store)
  • better support for Guest login via JAAS

下载地址:

ActiveMQ默认使用的TCP连接端口是61616, 通过查看该端口的信息可以测试ActiveMQ是否成功启动

  1. window环境运行  netstat -an|find "61616"
  2. unix环境运行netstat -an|grep 61616

启动

  1. window环境运行/activemq/bin/win32/activemq.bat
  2. unix环境运行/activemq/bin/activemq

测试

ActiveMQ默认使用的TCP连接端口是61616, 通过查看该端口的信息可以测试ActiveMQ是否成功启动

  1. window环境运行  netstat -an|find "61616"
  2. unix环境运行netstat -an|grep 61616

监控

ActiveMQ 默认启动时,启动了内置的jetty服务器,提供一个demo应用和用于监控ActiveMQ的admin应用。

admin:http://127.0.0.1:8161/admin/

demo:http://127.0.0.1:8161/demo/

配置

ActiveMQ的配置文件在/activemq/conf目录下面。主要配置文件为activemq.xml。

如何在数据库持久化

1.屏蔽硬盘读取方式 修改成jdbc数据库

<!--
        <persistenceAdapter>
            <kahaDB directory="${activemq.base}/data/kahadb"/>
        </persistenceAdapter>
        -->
	<persistenceAdapter>
		 <jdbcPersistenceAdapter dataSource="#oracle-ds"/>
	</persistenceAdapter>

 2.在</beans>的上面建立数据源信息

<bean id="oracle-ds" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
		  <property name="driverClassName" value="oracle.jdbc.driver.OracleDriver"/>
		  <property name="url" value="jdbc:oracle:thin:@127.0.0.1:oracle"/>
		  <property name="username" value="admin"/>
		  <property name="password" value="admin"/>
		  <property name="maxActive" value="200"/>
		  <property name="poolPreparedStatements" value="true"/>
	</bean>

 3.然后启动activemq.bat即可在数据库中看到几张active开头的表,一共3张。

明天抽空再写下和spring中的结合以及消息的发送和消费。

相关推荐