亚洲免费在线-亚洲免费在线播放-亚洲免费在线观看-亚洲免费在线观看视频-亚洲免费在线看-亚洲免费在线视频

ActiveMQ 基本配置

系統(tǒng) 2319 0

簡介

上一篇http://www.javaeye.com/topic/15317介紹了ActiveMQ5.0的安裝，這一篇將介紹的配置。ActiveMQ包含了很多features（詳見 http://activemq.apache.org/features.html ?），???
不同的需求，不同的環(huán)境，需要不同的features，當然需要不同的配置。在這里我只寫了最基本的配置，算是拋磚了，希望引出更多關于ActiveMQ的高級配置。
假設已經(jīng)正確安裝ActiveMQ5.0，同時及其IP地址為192.168.1.148，具體使用時可以改為自己的IP。下面講解的配置實現(xiàn)的features如下：

  1. 客戶端可以通過tcp://192.168.1.148連接ActiveMQ。
  2. 消息持久化保存，重啟服務器不會丟失消息。
  3. 可以通過http://192.168.1.148:8161/admin監(jiān)控ActiveMQ服務器

配置

ActiveMQ默認使用的是XML格式配置，從4.0版本開始用MBean的方式實現(xiàn)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/beans?http://www.springframework.org/schema/beans/spring-beans-2.0.xsd??
  5. ??http://activemq.org/config/1.0?http://activemq.apache.org/schema/activemq-core.xsd??
  6. ??http://activemq.apache.org/camel/schema/spring > ??
  7. ???
  8. ?? <!--?persistent="true"表示要持久化存儲消息，和子元素persistenceAdapter結合使用?--> ??
  9. ?? <!--?dataDirectory默認的存儲持久化數(shù)據(jù)的目錄?--> ??
  10. ?? <!--?brokerName?設置broker的name，在注意在網(wǎng)絡上必須是唯一的--> ??
  11. ?? <!--?更多參考http://activemq.apache.org/xbean-xml-reference-50.html#XBeanXMLReference5.0-brokerelement?--> ??
  12. ?? < broker ? xmlns = "http://activemq.org/config/1.0" ? brokerName = "192.168.1.148" ? persistent ?= "true" ? dataDirectory = "${activemq.base}/data" ? useShutdownHook = "false" > ??
  13. ???
  14. ???? <!--?Destination?specific?policies?using?destination?names?or?wildcards?--> ??
  15. ???? <!--?wildcards意義見http://activemq.apache.org/wildcards.html?--> ??
  16. ???? < destinationPolicy > ??
  17. ?????? < policyMap > ??
  18. ???????? < policyEntries > ??
  19. ??????? <!--?這里使用了wildcards，表示所有以EUCITA開頭的topic?--> ??
  20. ?????????? < policyEntry ? topic = "EUCITA.>" ? producerFlowControl = "false" ? memoryLimit = "10mb" > ??
  21. ???????????? <!--?分發(fā)策略?--> ??
  22. ???????? < dispatchPolicy > ??
  23. ?????????? <!--?按順序分發(fā)?--> ??
  24. ?????????????? < strictOrderDispatchPolicy /> ??
  25. ???????????? </ dispatchPolicy > ??
  26. ???????? <!--??恢復策略--> ??
  27. ???????????? < subscriptionRecoveryPolicy > ??
  28. ?????????? <!--?只恢復最后一個message?--> ??
  29. ?????????????? < lastImageSubscriptionRecoveryPolicy /> ??
  30. ???????????? </ subscriptionRecoveryPolicy > ??
  31. ?????????? </ policyEntry > ??
  32. ???????? </ policyEntries > ??
  33. ?????? </ policyMap > ??
  34. ???? </ destinationPolicy > ??
  35. ??
  36. ???? <!--?The?transport?connectors?ActiveMQ?will?listen?to?--> ??
  37. ???? < transportConnectors > ??
  38. ??????? < transportConnector ? name = "openwire" ? uri = "tcp://192.168.1.148:61616" ? discoveryUri = "multicast://default" /> ??
  39. ??????? < transportConnector ? name = "ssl" ????? uri = "ssl://192.168.1.148:61617" /> ??
  40. ??????? < transportConnector ? name = "stomp" ??? uri = "stomp://192.168.1.148:61613" /> ??
  41. ??????? < transportConnector ? name = "xmpp" ???? uri = "xmpp://192.168.1.148:61222" /> ??
  42. ???? </ transportConnectors > ??
  43. ?????
  44. ???? <!--?消息持久化方式?--> ??
  45. ???? < persistenceAdapter > ??
  46. ?????? < amqPersistenceAdapter ? directory = "${activemq.base}/data" /> ??
  47. ???? </ persistenceAdapter > ??
  48. </ broker > ??
  49. ??
  50. ?? <!--?lets?create?a?command?agent?to?respond?to?message?based?admin?commands?on?the?ActiveMQ.Agent?topic?--> ??
  51. ???? < commandAgent ? xmlns = "http://activemq.org/config/1.0" /> ??
  52. ????
  53. ?? <!--?An?embedded?servlet?engine?for?serving?up?the?Admin?console?--> ??
  54. ?? < jetty ? xmlns = "http://mortbay.com/schemas/jetty/1.0" > ??
  55. ???? < connectors > ??
  56. ?????? < nioConnector ? port = "8161" ? /> ??
  57. ???? </ connectors > ??
  58. ??
  59. ???? < handlers > ??
  60. ?????? < webAppContext ? contextPath = "/admin" ? resourceBase = "${activemq.base}/webapps/admin" ? logUrlOnStart = "true" ? /> ???????
  61. ?????? < webAppContext ? contextPath = "/demo" ? resourceBase = "${activemq.base}/webapps/demo" ? logUrlOnStart = "true" ? /> ?????????
  62. ???? </ handlers > ??
  63. ?? </ jetty > ???
  64. </ beans > ??
[xml] ? view plain copy
?
  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/beans?http://www.springframework.org/schema/beans/spring-beans-2.0.xsd??
  5. ??http://activemq.org/config/1.0?http://activemq.apache.org/schema/activemq-core.xsd??
  6. ??http://activemq.apache.org/camel/schema/spring > ??
  7. ???
  8. ?? <!--?persistent="true"表示要持久化存儲消息，和子元素persistenceAdapter結合使用?--> ??
  9. ?? <!--?dataDirectory默認的存儲持久化數(shù)據(jù)的目錄?--> ??
  10. ?? <!--?brokerName?設置broker的name，在注意在網(wǎng)絡上必須是唯一的--> ??
  11. ?? <!--?更多參考http://activemq.apache.org/xbean-xml-reference-50.html#XBeanXMLReference5.0-brokerelement?--> ??
  12. ?? < broker ? xmlns = "http://activemq.org/config/1.0" ? brokerName = "192.168.1.148" ? persistent ?= "true" ? dataDirectory = "${activemq.base}/data" ? useShutdownHook = "false" > ??
  13. ???
  14. ???? <!--?Destination?specific?policies?using?destination?names?or?wildcards?--> ??
  15. ???? <!--?wildcards意義見http://activemq.apache.org/wildcards.html?--> ??
  16. ???? < destinationPolicy > ??
  17. ?????? < policyMap > ??
  18. ???????? < policyEntries > ??
  19. ??????? <!--?這里使用了wildcards，表示所有以EUCITA開頭的topic?--> ??
  20. ?????????? < policyEntry ? topic = "EUCITA.>" ? producerFlowControl = "false" ? memoryLimit = "10mb" > ??
  21. ???????????? <!--?分發(fā)策略?--> ??
  22. ???????? < dispatchPolicy > ??
  23. ?????????? <!--?按順序分發(fā)?--> ??
  24. ?????????????? < strictOrderDispatchPolicy /> ??
  25. ???????????? </ dispatchPolicy > ??
  26. ???????? <!--??恢復策略--> ??
  27. ???????????? < subscriptionRecoveryPolicy > ??
  28. ?????????? <!--?只恢復最后一個message?--> ??
  29. ?????????????? < lastImageSubscriptionRecoveryPolicy /> ??
  30. ???????????? </ subscriptionRecoveryPolicy > ??
  31. ?????????? </ policyEntry > ??
  32. ???????? </ policyEntries > ??
  33. ?????? </ policyMap > ??
  34. ???? </ destinationPolicy > ??
  35. ??
  36. ???? <!--?The?transport?connectors?ActiveMQ?will?listen?to?--> ??
  37. ???? < transportConnectors > ??
  38. ??????? < transportConnector ? name = "openwire" ? uri = "tcp://192.168.1.148:61616" ? discoveryUri = "multicast://default" /> ??
  39. ??????? < transportConnector ? name = "ssl" ????? uri = "ssl://192.168.1.148:61617" /> ??
  40. ??????? < transportConnector ? name = "stomp" ??? uri = "stomp://192.168.1.148:61613" /> ??
  41. ??????? < transportConnector ? name = "xmpp" ???? uri = "xmpp://192.168.1.148:61222" /> ??
  42. ???? </ transportConnectors > ??
  43. ?????
  44. ???? <!--?消息持久化方式?--> ??
  45. ???? < persistenceAdapter > ??
  46. ?????? < amqPersistenceAdapter ? directory = "${activemq.base}/data" /> ??
  47. ???? </ persistenceAdapter > ??
  48. </ broker > ??
  49. ??
  50. ?? <!--?lets?create?a?command?agent?to?respond?to?message?based?admin?commands?on?the?ActiveMQ.Agent?topic?--> ??
  51. ???? < commandAgent ? xmlns = "http://activemq.org/config/1.0" /> ??
  52. ????
  53. ?? <!--?An?embedded?servlet?engine?for?serving?up?the?Admin?console?--> ??
  54. ?? < jetty ? xmlns = "http://mortbay.com/schemas/jetty/1.0" > ??
  55. ???? < connectors > ??
  56. ?????? < nioConnector ? port = "8161" ? /> ??
  57. ???? </ connectors > ??
  58. ??
  59. ???? < handlers > ??
  60. ?????? < webAppContext ? contextPath = "/admin" ? resourceBase = "${activemq.base}/webapps/admin" ? logUrlOnStart = "true" ? /> ???????
  61. ?????? < webAppContext ? contextPath = "/demo" ? resourceBase = "${activemq.base}/webapps/demo" ? logUrlOnStart = "true" ? /> ?????????
  62. ???? </ handlers > ??
  63. ?? </ jetty > ???
  64. </ beans > ??

注釋

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

DispathPolicy

ActiveMQ支持3中不同的分發(fā)策略（避免翻譯了以后誤解，這里用原文）：

  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的配置，使用。

?

?

ActiveMQ 基本配置


更多文章、技術交流、商務合作、聯(lián)系博主

微信掃碼或搜索：z360901061

微信掃一掃加我為好友

QQ號聯(lián)系： 360901061

您的支持是博主寫作最大的動力，如果您喜歡我的文章，感覺我的文章對您有幫助，請用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧，狠狠點擊下面給點支持吧，站長非常感激您！手機微信長按不能支付解決辦法：請將微信支付二維碼保存到相冊，切換到微信，然后點擊微信右上角掃一掃功能，選擇支付二維碼完成支付。

【本文對您有幫助就好】元

您的支持是博主寫作最大的動力，如果您喜歡我的文章，感覺我的文章對您有幫助，請用微信掃描上面二維碼支持博主2元、5元、10元、自定義金額等您想捐的金額吧，站長會非常 感謝您的哦！！！

發(fā)表我的評論
最新評論 總共0條評論
主站蜘蛛池模板： 亚州激情视频在线播放 | 亚洲免费国产 | 欧美成人激情在线 | 91视频社区 | 国产日产精品_国产精品毛片 | 国产精品一区二区综合 | 亚洲图欧美色综合图 | 国产成人精品高清在线观看99 | 亚洲综合精品香蕉久久网 | 九九热这里有精品 | 九九精品在线观看 | 911国产在线观看精品 | 久久精品国产精品亚洲人人 | 久久99精品久久久久久牛牛影视 | 久久精品视频免费在线观看 | 国产成人精品久久亚洲高清不卡 | a免费国产一级特黄aa大 | 欧美毛片在线 | 亚洲综合在线观看视频 | 久久国产精品国产精品 | 欧美精品另类 | 国产成人亚洲影视在线 | 欧美精品在线一区 | 手机在线国产精品 | 天天干天天添 | 亚洲欧美日韩一区二区 | 爱爱视频免费网站 | 国产午夜亚洲精品久久999 | 精品国产91 | 国语性猛交xxxx乱大交 | 亚色在线视频 | 男人的网站在线观看 | 深夜免费视频 | 国产精品亚洲欧美日韩一区在线 | 欧美日韩亚洲在线观看 | 夜夜夜网站 | 视频在线一区二区 | 鲁啊鲁在线视频 | 精品国产午夜久久久久九九 | 久久国产乱子伦精品免费一 | 午夜国产福利在线观看 |