`
virusfu
  • 浏览: 182081 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

ActiveMQ5.0实战二: 基本配置

 
阅读更多
/**
*作者:andyao,email:andyaoy@gmail.com
*http://andyao.iteye.com/blog/154092
*/
ActiveMQ5.0实战一: 安装配置ActiveMQ5.0
ActiveMQ5.0实战三:使用Spring发送,消费topic和queue消息

简介

上一篇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如下:

  1. 客户端可以通过tcp://192.168.1.148连接ActiveMQ。
  2. 消息持久化保存,重启服务器不会丢失消息。
  3. 可以通过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。下面为本篇文章使用的配置,及重要部分的解释。

Xml代码收藏代码
  1. <beans
  2. xmlns="http://www.springframework.org/schema/beans"
  3. xmlns:amq="http://activemq.org/config/1.0"
  4. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://www.springframework.org/schema/beanshttp://www.springframework.org/schema/beans/spring-beans-2.0.xsd
  5. http://activemq.org/config/1.0http://activemq.apache.org/schema/activemq-core.xsd
  6. http://activemq.apache.org/camel/schema/spring>
  7. <!--persistent="true"表示要持久化存储消息,和子元素persistenceAdapter结合使用-->
  8. <!--dataDirectory默认的存储持久化数据的目录-->
  9. <!--brokerName设置broker的name,在注意在网络上必须是唯一的-->
  10. <!--更多参考http://activemq.apache.org/xbean-xml-reference-50.html#XBeanXMLReference5.0-brokerelement-->
  11. <brokerxmlns="http://activemq.org/config/1.0"brokerName="192.168.1.148"persistent="true"dataDirectory="${activemq.base}/data"useShutdownHook="false">
  12. <!--Destinationspecificpoliciesusingdestinationnamesorwildcards-->
  13. <!--wildcards意义见http://activemq.apache.org/wildcards.html-->
  14. <destinationPolicy>
  15. <policyMap>
  16. <policyEntries>
  17. <!--这里使用了wildcards,表示所有以EUCITA开头的topic-->
  18. <policyEntrytopic="EUCITA.>"producerFlowControl="false"memoryLimit="10mb">
  19. <!--分发策略-->
  20. <dispatchPolicy>
  21. <!--按顺序分发-->
  22. <strictOrderDispatchPolicy/>
  23. </dispatchPolicy>
  24. <!--恢复策略-->
  25. <subscriptionRecoveryPolicy>
  26. <!--只恢复最后一个message-->
  27. <lastImageSubscriptionRecoveryPolicy/>
  28. </subscriptionRecoveryPolicy>
  29. </policyEntry>
  30. </policyEntries>
  31. </policyMap>
  32. </destinationPolicy>
  33. <!--ThetransportconnectorsActiveMQwilllistento-->
  34. <transportConnectors>
  35. <transportConnectorname="openwire"uri="tcp://192.168.1.148:61616"discoveryUri="multicast://default"/>
  36. <transportConnectorname="ssl"uri="ssl://192.168.1.148:61617"/>
  37. <transportConnectorname="stomp"uri="stomp://192.168.1.148:61613"/>
  38. <transportConnectorname="xmpp"uri="xmpp://192.168.1.148:61222"/>
  39. </transportConnectors>
  40. <!--消息持久化方式-->
  41. <persistenceAdapter>
  42. <amqPersistenceAdapterdirectory="${activemq.base}/data"/>
  43. </persistenceAdapter>
  44. </broker>
  45. <!--letscreateacommandagenttorespondtomessagebasedadmincommandsontheActiveMQ.Agenttopic-->
  46. <commandAgentxmlns="http://activemq.org/config/1.0"/>
  47. <!--AnembeddedservletengineforservinguptheAdminconsole-->
  48. <jettyxmlns="http://mortbay.com/schemas/jetty/1.0">
  49. <connectors>
  50. <nioConnectorport="8161"/>
  51. </connectors>
  52. <handlers>
  53. <webAppContextcontextPath="/admin"resourceBase="${activemq.base}/webapps/admin"logUrlOnStart="true"/>
  54. <webAppContextcontextPath="/demo"resourceBase="${activemq.base}/webapps/demo"logUrlOnStart="true"/>
  55. </handlers>
  56. </jetty>
  57. </beans>

注释

关于XML配置中元素的具体信息可以参考http://activemq.apache.org/xbean-xml-reference-50.html下面介绍本篇配置使用的一些重要元素。

DispathPolicy

ActiveMQ支持3中不同的分发策略(避免翻译了以后误解,这里用原文):

  1. <roundRobinDispatchPolicy>:Simple dispatch policy that sends a message to every subscription that matches the message.
  2. <simpleDispatchPolicy>:Simple dispatch policy that sends a message to every subscription that matches the message.
  3. <strictOrderDispatchPolicy>:Dispatch policy that causes every subscription to see messages in the same order.

SubscriptionRecoveryPolicy

ActiveMQ支持6种恢复策略,可以自行选择使用不同的策略

  1. <fixedCountSubscriptionRecoveryPolicy>: keep a fixed count of last messages.
  2. <fixedSizedSubscriptionRecoveryPolicy>: keep a fixed amount of memory available in RAM for message history which is evicted in time order.
  3. <lastImageSubscriptionRecoveryPolicy>:only keep the last message.
  4. <noSubscriptionRecoveryPolicy>:disable recovery of messages.
  5. <queryBasedSubscriptionRecoveryPolicy>:perform a user specific query mechanism to load any messages they may have missed.
  6. <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的配置,使用。

分享到:
评论

相关推荐

    activeMq5.0

    在学习和使用ActiveMQ 5.0时,你可能需要了解如何创建和配置消息代理、如何编写生产者和消费者代码、如何设置安全策略、如何使用管理工具监控系统状态等。通过实践这些基本操作,你可以深入理解消息中间件的工作原理...

    ActiveMQ5.0 监视的JSP支持中文

    **标题:“ActiveMQ5.0 监视的JSP支持中文”** ActiveMQ是Apache软件基金会的一个开源项目,它是一个功能强大的消息中间件,广泛应用于分布式系统中的异步通信。在ActiveMQ 5.0版本中,对于中文支持的改进是一项...

    消息队列:ActiveMQ:ActiveMQ的高级特性:虚拟目的地与代理.docx

    消息队列:ActiveMQ:ActiveMQ的高级特性:虚拟目的地与代理.docx

    activeMq 实战

    ### ActiveMQ 实战 #### JMS 基本构件概览 **ActiveMQ** 是一个高性能、功能丰富的开源消息中间件,它实现了 **Java Message Service (JMS)** 规范。JMS 规范定义了一组接口,这些接口提供了一个标准的方式来进行...

    ActiveMQ集群实战视频教程

    ActiveMQ集群实战教程

    消息队列:ActiveMQ:ActiveMQ消息类型:点对点与发布订阅.docx

    消息队列:ActiveMQ:ActiveMQ消息类型:点对点与发布订阅.docx

    ActiveMQ路由配置方式

    ActiveMQ路由配置方式 ActiveMQ路由配置是Apache ActiveMQ项目中的一种重要配置方式,它依赖另一个Apache项目Camel。ActiveMQ集成了Camel,启动时同时会启动Camel。通过Camel Web Console可以进行Routing配置。 ...

    activemq与spring整合源代码

    2. 配置ActiveMQ服务器:在服务器端配置ActiveMQ,启动服务器,并创建需要的队列或主题。 3. Spring配置:在Spring的配置文件中,定义JMS相关的bean,包括ConnectionFactory、Destination(队列或主题)、Message...

    activemq-service-5.0.0.jar

    标签:activemq-service-5.0.0.jar,activemq,service,5.0.0,jar包下载,依赖包

    ActiveMQ.rar

    n 二: ActiveMQ安装和基本使用 包括:通过源码安装、基本的配置示例、启动、测试运行、关闭等 n 三:理解和掌握JMS 包括:基本概念、消息结构、可靠性机制、PTP、Pub/Sub、API结构、JMS应用开 发的基本步骤、持久和...

    ActiveMQ的处理模式:PTP与PUB/SUB

    在SpringBoot中配置和使用ActiveMQ的PTP模式,通常需要创建一个Queue bean,并通过配置JMS模板来发送和接收消息。 其次,发布/订阅(PUB/SUB)模式则是基于主题(Topic)的通信方式。与队列不同,主题可以让多个...

    ActiveMQ 配置文件详解

    **ActiveMQ配置文件详解** Apache ActiveMQ 是一个开源的消息中间件,它实现了多种消息协议,如JMS(Java Message Service)和AMQP(Advanced Message Queuing Protocol),并且广泛应用于分布式系统中,提供可靠的...

    ActiveMQ的activemq.xml详细配置讲解

    对于初学者,理解这些基本元素是掌握ActiveMQ配置的关键。配合提供的文档,如《activeMQ in Action.doc》和《ActiveMQ测试报告.pdf》,可以更深入地学习ActiveMQ的工作原理和最佳实践。对于与数据库的集成,如`...

    activeMQ集群的使用与配置[收集].pdf

    需要注意的是,在ActiveMQ 5.0版本中存在一个bug:采用AMQ Message Store,运行一个producer,两个consumer,并采用特定的配置文件时,可能会报出错误。这个bug已经被修正,预定在5.1.0版本上体现。 Broker ...

    ActiveMQ实战(英文版)

    通过阅读《ActiveMQ实战(英文版)》,读者将能够学习到如何配置、部署和管理ActiveMQ,以及如何在实际项目中利用其特性解决复杂的消息传递问题。此外,书中可能还会涵盖故障排查、性能调优和最佳实践等内容,帮助...

    ActiveMQ 实战

    ActiveMQ实战手册以介绍JMS和ActiveMQ的操作及配置为主,JMS(Java Message Service)是Java平台中对于面向消息中间件(MOM)的一种标准的API,用于在两个应用程序之间,或分布式系统中发送消息,进行异步通信。...

    activemq-5.15+mysqljdbc配置.zip

    首先,让我们详细了解一下ActiveMQ的基本概念。ActiveMQ作为消息代理,它负责接收、存储并转发消息。它支持多种协议,如OpenWire、STOMP、AMQP、MQTT等,可以与各种客户端和应用程序进行通信。在5.15版本中,...

    activemq实战

    ### ActiveMQ 实战知识点解析 #### 一、ActiveMQ简介与背景 - **Apache ActiveMQ** 是一个开源的消息中间件,支持多种消息传递协议(如AMQP、STOMP等),并提供高性能、高可用性的消息服务。 - **背景**:在分布式...

Global site tag (gtag.js) - Google Analytics