- 浏览: 147217 次
- 性别:
- 来自: 北京
文章分类
最新评论
-
陈碧滔:
java获取工程目录路径 -
stevenjohn:
楼主能上传一下源代码吗?
ActiveMQ5.0实战三:使用Spring发送,消费topic和queue消息 -
指挥家:
讲的很好!
Foxmail6收发Web mail邮箱邮件实现原理 -
azhqiang:
谢谢你啊。呵呵
flex最全的表单验证
简介
上一篇http://www.iteye.com/topic/15317介绍了ActiveMQ5.0的安装,这一篇将介绍的配置。ActiveMQ包含了很多features(详见http://activemq.apache.org/features.html ),
不同的需求,不同的环境,需要不同的features,当然需要不同的配置。在这里我只写了最基本的配置,算是抛砖了,希望引出更多关于ActiveMQ的高级配置。
假设已经正确安装ActiveMQ5.0,同时及其IP地址为192.168.1.148,具体使用时可以改为自己的IP。下面讲解的配置实现的features如下:
- 客户端可以通过tcp://192.168.1.148连接ActiveMQ。
- 消息持久化保存,重启服务器不会丢失消息。
- 可以通过http://192.168.1.148:8161/admin监控ActiveMQ服务器
配置
ActiveMQ默认使用的是XML格式配置,从4.0版本开始用MBean的方式实现XML配置,配置文件在${activemq.home}/conf目录下,文件名为activemq.xml。最新的默认配置见
http://svn.apache.org/repos/asf/activemq/trunk/assembly/src/release/conf/activemq.xml 。下面为本篇文章使用的配置,及重要部分的解释。
- <beans
- xmlns="http://www.springframework.org/schema/beans"
- xmlns:amq="http://activemq.org/config/1.0"
- 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.org/config/1.0 http://activemq.apache.org/schema/activemq-core.xsd
- http://activemq.apache.org/camel/schema/spring>
- <!-- persistent="true"表示要持久化存储消息,和子元素persistenceAdapter结合使用 -->
- <!-- dataDirectory默认的存储持久化数据的目录 -->
- <!-- brokerName 设置broker的name,在注意在网络上必须是唯一的-->
- <!-- 更多参考http://activemq.apache.org/xbean-xml-reference-50.html#XBeanXMLReference5.0-brokerelement -->
- <broker xmlns="http://activemq.org/config/1.0" brokerName="192.168.1.148" persistent ="true" dataDirectory="${activemq.base}/data" useShutdownHook="false">
- <!-- Destination specific policies using destination names or wildcards -->
- <!-- wildcards意义见http://activemq.apache.org/wildcards.html -->
- <destinationPolicy>
- <policyMap>
- <policyEntries>
- <!-- 这里使用了wildcards,表示所有以EUCITA开头的topic -->
- <policyEntry topic="EUCITA.>" producerFlowControl="false" memoryLimit="10mb">
- <!-- 分发策略 -->
- <dispatchPolicy>
- <!-- 按顺序分发 -->
- <strictOrderDispatchPolicy/>
- </dispatchPolicy>
- <!-- 恢复策略-->
- <subscriptionRecoveryPolicy>
- <!-- 只恢复最后一个message -->
- <lastImageSubscriptionRecoveryPolicy/>
- </subscriptionRecoveryPolicy>
- </policyEntry>
- </policyEntries>
- </policyMap>
- </destinationPolicy>
- <!-- The transport connectors ActiveMQ will listen to -->
- <transportConnectors>
- <transportConnector name="openwire" uri="tcp://192.168.1.148:61616" discoveryUri="multicast://default"/>
- <transportConnector name="ssl" uri="ssl://192.168.1.148:61617"/>
- <transportConnector name="stomp" uri="stomp://192.168.1.148:61613"/>
- <transportConnector name="xmpp" uri="xmpp://192.168.1.148:61222"/>
- </transportConnectors>
- <!-- 消息持久化方式 -->
- <persistenceAdapter>
- <amqPersistenceAdapter directory="${activemq.base}/data"/>
- </persistenceAdapter>
- </broker>
- <!-- lets create a command agent to respond to message based admin commands on the ActiveMQ.Agent topic -->
- <commandAgent xmlns="http://activemq.org/config/1.0"/>
- <!-- An embedded servlet engine for serving up the Admin console -->
- <jetty xmlns="http://mortbay.com/schemas/jetty/1.0">
- <connectors>
- <nioConnector port="8161" />
- </connectors>
- <handlers>
- <webAppContext contextPath="/admin" resourceBase="${activemq.base}/webapps/admin" logUrlOnStart="true" />
- <webAppContext contextPath="/demo" resourceBase="${activemq.base}/webapps/demo" logUrlOnStart="true" />
- </handlers>
- </jetty>
- </beans>
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:amq="http://activemq.org/config/1.0" 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.org/config/1.0 http://activemq.apache.org/schema/activemq-core.xsd http://activemq.apache.org/camel/schema/spring> <!-- persistent="true"表示要持久化存储消息,和子元素persistenceAdapter结合使用 --> <!-- dataDirectory默认的存储持久化数据的目录 --> <!-- brokerName 设置broker的name,在注意在网络上必须是唯一的--> <!-- 更多参考http://activemq.apache.org/xbean-xml-reference-50.html#XBeanXMLReference5.0-brokerelement --> <broker xmlns="http://activemq.org/config/1.0" brokerName="192.168.1.148" persistent ="true" dataDirectory="${activemq.base}/data" useShutdownHook="false"> <!-- Destination specific policies using destination names or wildcards --> <!-- wildcards意义见http://activemq.apache.org/wildcards.html --> <destinationPolicy> <policyMap> <policyEntries> <!-- 这里使用了wildcards,表示所有以EUCITA开头的topic --> <policyEntry topic="EUCITA.>" producerFlowControl="false" memoryLimit="10mb"> <!-- 分发策略 --> <dispatchPolicy> <!-- 按顺序分发 --> <strictOrderDispatchPolicy/> </dispatchPolicy> <!-- 恢复策略--> <subscriptionRecoveryPolicy> <!-- 只恢复最后一个message --> <lastImageSubscriptionRecoveryPolicy/> </subscriptionRecoveryPolicy> </policyEntry> </policyEntries> </policyMap> </destinationPolicy> <!-- The transport connectors ActiveMQ will listen to --> <transportConnectors> <transportConnector name="openwire" uri="tcp://192.168.1.148:61616" discoveryUri="multicast://default"/> <transportConnector name="ssl" uri="ssl://192.168.1.148:61617"/> <transportConnector name="stomp" uri="stomp://192.168.1.148:61613"/> <transportConnector name="xmpp" uri="xmpp://192.168.1.148:61222"/> </transportConnectors> <!-- 消息持久化方式 --> <persistenceAdapter> <amqPersistenceAdapter directory="${activemq.base}/data"/> </persistenceAdapter> </broker> <!-- lets create a command agent to respond to message based admin commands on the ActiveMQ.Agent topic --> <commandAgent xmlns="http://activemq.org/config/1.0"/> <!-- An embedded servlet engine for serving up the Admin console --> <jetty xmlns="http://mortbay.com/schemas/jetty/1.0"> <connectors> <nioConnector port="8161" /> </connectors> <handlers> <webAppContext contextPath="/admin" resourceBase="${activemq.base}/webapps/admin" logUrlOnStart="true" /> <webAppContext contextPath="/demo" resourceBase="${activemq.base}/webapps/demo" logUrlOnStart="true" /> </handlers> </jetty> </beans>
注释
关于XML配置中元素的具体信息可以参考http://activemq.apache.org/xbean-xml-reference-50.html 下面介绍本篇配置使用的一些重要元素。
DispathPolicy
ActiveMQ支持3中不同的分发策略(避免翻译了以后误解,这里用原文):
- <roundRobinDispatchPolicy>:Simple dispatch policy that sends a message to every subscription that matches the message.
- <simpleDispatchPolicy>:Simple dispatch policy that sends a message to every subscription that matches the message.
- <strictOrderDispatchPolicy>:Dispatch policy that causes every subscription to see messages in the same order.
SubscriptionRecoveryPolicy
ActiveMQ支持6种恢复策略,可以自行选择使用不同的策略
- <fixedCountSubscriptionRecoveryPolicy>: keep a fixed count of last messages.
- <fixedSizedSubscriptionRecoveryPolicy>: keep a fixed amount of memory available in RAM for message history which is evicted in time order.
- <lastImageSubscriptionRecoveryPolicy>:only keep the last message.
- <noSubscriptionRecoveryPolicy>:disable recovery of messages.
- <queryBasedSubscriptionRecoveryPolicy>:perform a user specific query mechanism to load any messages they may have missed.
- <timedSubscriptionRecoveryPolicy>:keep a timed buffer of messages around in memory and use that to recover new subscriptions.
PersistenceAdapter
http://activemq.apache.org/persistence 讲解了关于persistence的信息。ActiveMQ5.0使用AMQ Message Store 持久化消息,这种方式提供了很好的性能(The AMQ Message Store is an embeddable transactional message storage solution that is extremely fast and reliable.) 默认使用该存储方式即可,如果想使用JDBC来存储,可以查找文档配置。
Summary
本篇文章只提供了基本配置信息。如果需要更多的文章,可以查看ActiveMQ的文档。
讲了安装和简单的配置,下一篇将介绍和Sping的整合,以及多个queue,多个topic,多个producer,多个consumer的配置,使用。
发表评论
-
Weblogic下创建JMS消息服务
2010-11-08 14:29 1841转载:http://yunzhongxia.iteye.com ... -
Spring整合Blazeds实现Weblogic JMS消息服务
2010-11-08 14:27 1486转载:http://yunzhongxia.iteye.com ... -
Spring整合Blazeds实现ActiveMQ JMS消息服务
2010-11-08 14:18 1780转载:http://yunzhongxia.iteye.com ... -
Blazeds+JMS(ActiveMQ)+Spring实现消息
2010-11-08 14:16 1843转载:http://yunzhongxia.iteye.com ... -
Jms之ActiveMQ学习笔记
2010-11-08 10:48 2727ActiveMQ 是一个完全支持JMS1.1和J2EE 1.4 ... -
ActiveMQ5.0实战一: 安装配置ActiveMQ5.0
2010-11-02 09:59 987简介 ActiveMQ 是开源的JMS实现,Geroni ... -
ActiveMQ文档学习
2010-11-01 13:59 2156研究ActiveMQ 的文档1. 背景当前,CORBA、DCO ... -
主题:JMS的两种消息模型(Point-to-Point(P2P)和Publish/Subscribe(Pub/Sub))应用举例
2010-11-01 13:57 15171、P2P模型 在P2P模型中,有下列概念:消息队列(Queu ...
相关推荐
activemq实战
最新的activemq版本,刚开始写jms,希望大家都能用到
博文链接:https://cddcdd.iteye.com/blog/170685
ActiveMQ集群实战教程
n 二: ActiveMQ安装和基本使用 包括:通过源码安装、基本的配置示例、启动、测试运行、关闭等 n 三:理解和掌握JMS 包括:基本概念、消息结构、可靠性机制、PTP、Pub/Sub、API结构、JMS应用开 发的基本步骤、持久和...
springboot+activemq, 用代码讲解了activemq的2中处理模式:PTP与PUB/SUB, 具体讲解已经在文章中介绍过了
ActiveMQ 实战。本手册介绍了JMS以及ActiveMQ的常用操作以及配置。可以作为ActiveMQ应用开发人员的参考手册。
activemq实战
ActiveMQ实战(英文版) ActiveMQ实战(英文版) ActiveMQ实战(英文版)
该资源是spring与activemq的基础整合,适合消息中间件的初学者
含如下内容:JMS API;Apache-activeMQ;ActiveMQ实战pdf
ActiveMQ 入门实战(3)--SpringBoot 整合 ActiveMQ(csdn)————程序
activeMQ-5.15版本,里面更改了activeMQ配置,新增了mysql的连接内容。lib里添加了durid和mysql连接的jar文件
ActiveMQ5.0 的二进制发布包中bin目录中包含一个名为activemq的脚本,直接运行这个脚本就可以启动一个broker。
ActiveMQ_使用failover模式进行连接切换时,线程断开 ,ActiveMQ_使用failover模式进行连接切换时,线程断开
activemq-all-5.8.0.jar 下载 activemq-all-5.8.0.jar 下载 activemq-all-5.8.0.jar 下载 activemq-all-5.8.0.jar 下载 activemq-all-5.8.0.jar 下载
linux下activemq安装包和配置文档
NULL 博文链接:https://baobeituping.iteye.com/blog/407104