欧美三区_成人在线免费观看视频_欧美极品少妇xxxxⅹ免费视频_a级毛片免费播放_鲁一鲁中文字幕久久_亚洲一级特黄

ActiveMQ 基本配置

系統(tǒng) 2176 0

簡介

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

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

配置

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代碼? 復(fù)制代碼
  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結(jié)合使用?--> ??
  9. ?? <!--?dataDirectory默認的存儲持久化數(shù)據(jù)的目錄?--> ??
  10. ?? <!--?brokerName?設(shè)置broker的name，在注意在網(wǎng)絡(luò)上必須是唯一的--> ??
  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. ???????? <!--??恢復(fù)策略--> ??
  27. ???????????? < subscriptionRecoveryPolicy > ??
  28. ?????????? <!--?只恢復(fù)最后一個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結(jié)合使用?--> ??
  9. ?? <!--?dataDirectory默認的存儲持久化數(shù)據(jù)的目錄?--> ??
  10. ?? <!--?brokerName?設(shè)置broker的name，在注意在網(wǎng)絡(luò)上必須是唯一的--> ??
  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. ???????? <!--??恢復(fù)策略--> ??
  27. ???????????? < subscriptionRecoveryPolicy > ??
  28. ?????????? <!--?只恢復(fù)最后一個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 > ??

注釋

關(guān)于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種恢復(fù)策略，可以自行選擇使用不同的策略

  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 ?講解了關(guān)于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 基本配置


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

微信掃碼或搜索：z360901061

微信掃一掃加我為好友

QQ號聯(lián)系： 360901061

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

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

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

發(fā)表我的評論
最新評論 總共0條評論
主站蜘蛛池模板： 韩漫重考生漫画画免费读漫画下拉式土豪漫 | 久草视频在线资源 | 欧美日韩在线看 | 欧美综合自拍亚洲综合百度 | 欧美激情午夜 | 日本香蕉一区二区三区 | 谍影特工在线观看完整版 | 欧美 日韩 中文字幕 | 看黄色毛片 | 国产婷婷| 久久草视频这里只精品99 | 中文字幕在线精品 | 欧美zzzz| 日韩手机在线观看 | 日本不卡不码高清免费 | 久久免费看少妇高潮A片麻豆 | 女人一级毛片免费视频观看 | 国产小视频在线观看免费 | 日韩电影免费在线观看中文字幕 | 欧美九九| 无码激情做A爰片毛片A片小说 | 青娱乐手机免费视频 | 欧美国产精品一区二区免费 | 日韩中文字幕一区 | 久久精品国产视频 | 中文字幕二区 | 天天草天天干 | 婷婷久久综合九色综合九七 | 成人午夜大片免费看爽爽爽 | 无遮挡又黄又刺激的视频 | 亚洲精品在线视频观看 | 午夜视频国语 | 91免费版成人 | www.久| 亚洲综合精品香蕉久久网97 | 色人阁在线 | 奇米第四色网站 | 亚洲精品久久久一区二区三区 | 国产成人理在线观看视频 | 欧美6一10sex性hd | 久草在线手机 |