`
我想我是海
  • 浏览: 216231 次
社区版块
存档分类
最新评论

Jencks2.0 + activeMQ4.1 使用手记

    博客分类:
  • jms
阅读更多
自打Spring2出来后一直使用其自带的MDP功能,当时使用的JMS产品是Joram,后来实在受不了Joram持久化机制和莫名其妙的不能启动服务器等,狠一狠心换成口碑日佳的ActiveMQ。ActiveMQ在使用方面竟比我想像中的简单!但这种简单来得可不简单,你需要反复翻他的文档。搞了好久后看着那简洁的配置和不用提心吊胆的Server,真有相见恨晚的感觉。
使用ActiveMQ,很难不知道有Jencks这个东西。我在之前只是简单的知道该JCA产品可以实现Message driven Pojo,但想想Spring也能做到的东西我为什么用另一套,看了Jencks的FAQ就清楚了:
www.jencks.org/How+does+Jencks+compare+to+Springs+MDPs
偶翻译能力太差,大概了解但不知道要乍讲。看官们还是自个看看吧:P。

Jencks2.0版本的配置比1.X的配置来得清爽很多。
1.X版本的可参考Springside的Wiki (XSD版):
http://www.jencks.org/How+does+Jencks+compare+to+Springs+MDPs
另外可以参考Javaeye另一位仁兄的尝试(Spring  Bean版 ):
jamsa.iteye.com/blog/post/168023
Jamsa的示例中只演示了Inboud 的情况,实际上Jencks是可以包括Inbound outbound的Message的。

我的目标是使用Jencks2.0实现MDP及对Outbound Message的管理,参考官方文档很快可以把配置做出来:
www.jencks.org/Message+Driven+POJOs
www.jencks.org/Outbound+JMS

贴一下我的配置文件全貌:
xml 代码
 
  1. xml version="1.0" encoding="UTF-8"?>  
  2.     "http://www.springframework.org/dtd/spring-beans-2.0.dtd">  
  3.   
  4. <beans>  
  5.     <!---->  
  6.     <bean id="jmsTransactionManager"  
  7.         class="org.jencks.factory.TransactionManagerFactoryBean" />  
  8.           
  9.     <!---->  
  10.     <bean id="connectionManager"  
  11.         class="org.jencks.factory.ConnectionManagerFactoryBean">  
  12.         <property name="transactionManager" ref="jmsTransactionManager" />  
  13.     <!---->bean>  
  14.   
  15.     <bean id="jmsResourceAdapter"  
  16.         class="org.apache.activemq.ra.ActiveMQResourceAdapter">  
  17.         <property name="serverUrl">  
  18.             <value>tcp://localhost:61616<!---->value>  
  19.         <!---->property>  
  20.     <!---->bean>  
  21.   
  22.     <bean id="jmsManagedConnectionFactory"  
  23.         class="org.apache.activemq.ra.ActiveMQManagedConnectionFactory">  
  24.         <property name="resourceAdapter" ref="jmsResourceAdapter" />  
  25.     <!---->bean>  
  26.   
  27.     <bean id="connectionFactory"  
  28.         class="org.jencks.factory.ConnectionFactoryFactoryBean">  
  29.         <property name="managedConnectionFactory"  
  30.             ref="jmsManagedConnectionFactory" />  
  31.         <property name="connectionManager" ref="connectionManager" />  
  32.     <!---->bean>  
  33.     <!---->  
  34.       
  35.     <!---->  
  36.     <bean id="jmsTemplate"  
  37.         class="org.springframework.jms.core.JmsTemplate">  
  38.         <property name="connectionFactory">  
  39.             <ref bean="connectionFactory" />  
  40.         <!---->property>  
  41.     <!---->bean>  
  42.   
  43.     <bean id="sender" class="net.jf.activemq.Sender">  
  44.         <property name="jmsTemplate" ref="jmsTemplate" />  
  45.         <property name="queue">  
  46.             <value>queue.text<!---->value>  
  47.         <!---->property>  
  48.     <!---->bean>  
  49.     <!---->  
  50.       
  51.     <!---->  
  52.     <bean id="receiver" class="net.jf.activemq.Receiver" /> <!---->
  53.   
  54.     <bean id="jencks" class="org.jencks.JCAContainer">  
  55.         <property name="transactionManager" ref="jmsTransactionManager" />  
  56.         <property name="threadPoolSize" value="25" />  
  57.   
  58.         <!---->  
  59.         <property name="resourceAdapter" ref="jmsResourceAdapter" />  
  60.     <!---->bean>  
  61.   
  62.     <bean id="inboundConnectorA" class="org.jencks.JCAConnector">  
  63.         <property name="jcaContainer" ref="jencks" />  
  64.         <!---->  
  65.         <property name="activationSpec">  
  66.             <bean  
  67.                 class="org.apache.activemq.ra.ActiveMQActivationSpec">  
  68.                 <property name="destination" value="queue.text" />  
  69.                 <property name="destinationType"  
  70.                     value="javax.jms.Queue" />  
  71.             <!---->bean>  
  72.         <!---->property>  
  73.         <property name="ref" value="receiver" />  
  74.     <!---->bean>  
  75.     <!---->  
  76. <!---->beans>  
注意inbound 及outboud的资源适配器使用相同的适配器。多数情况下,JMS的发送方及接收方配置分开,但注意当同时使用Jencks管理发送消息方及接收方时,要保持resourceAdepter的一致!

还一件事你一定要知道。要不你会跟我一样抓狂上好几天。就是Jencks2.0的依赖包的问题。
找遍Jencks2.0下载回来的包,其实还是差两个很重要的包。那就是geronimo-transaction和geronimo-connector包。而Jencks官网对此没有提及,很郁闷。
我在寻找这两个包的过程中下编了geronimo的几个版本都没发现,然后到这里找到他们的1.1版本。运行时发现缺少类,该类是属于Transaction包内的类,分明包内没有此类:\org\apache\geronimo\transaction\manager\XAWork。Google一下,结果奇少。我想应该是包版本问题,而Maven的仓库只有1.2Beta版本的,我下来一看也没这个类,于是没有替换掉,继续使用1.1版。
后来找到这个类是Transatction包的2.0版本才有的,我赶紧SVN了Geronimo最新的源码回来,自己Build了个快照的版本。其实是两个:
geronimo-connector-2.0-SNAPSHOT.jar
geronimo-transaction-1.2-SNAPSHOT.jar
而后来发生的问题几乎要推翻我的Java信仰。运行时报的错是NoSuchMethodError,告诉我缺少一个方法。而分明那个类,那个方法是存在的。我很确定在我的类库里,这个类只存在一个版本。我实在没有办法了,我开始怀疑2.0的成熟性。但是还没有放弃最后的希望,我又SVN了一份Jencks的最新代码回来。用Maven跑一跑,所有测试都没问题。而这时发现它只是用了Transaction及Connector的1.2的包。我决定最后一博,把这两个包替换掉2.0的包。奇迹啊,哥们,终于久违的“Hello activeMQ”打印了出来。
至今我还没想明白怎么现在又不报缺XAWork?为什么存在的方法是被报不存在?不过最后终于跑起来了,很爽。
所以不要怪我上面那一番没章法的抱怨。这样的问题让我几近崩溃。我觉得我有必要把过程写出来与大家分享。让后来的朋友能快速地解决问题。
实际上,我在看MailList的时候看到过一封类似问题的邮件,我其实只要按方法用1.2换掉1.1的Connector和Trasaction就得了。但我死活认为非要找到XAWork的包才行。而最后解决的方法却是没必要找到XAWork的包。额滴神啊。我现在还想不明白为啥。望哪位看官能指点迷津!
最后附上我的Lib(这是最重要D):
activeio-core-3.0.0-incubator.jar
activemq-console-4.1.1.jar
activemq-core-4.1.1.jar
activemq-core-4.1.1-tests.jar
activemq-jaas-4.1.1.jar
activemq-ra-4.1.1.jar
activemq-web-4.1.1.jar
backport-util-concurrent-2.1.jar
commons-logging-1.1.jar
geronimo-connector-1.2-beta.jar
geronimo-j2ee-connector_1.5_spec-1.0.1.jar
geronimo-j2ee-management_1.0_spec-1.0.jar
geronimo-jms_1.1_spec-1.0.jar
geronimo-jta_1.0.1B_spec-1.0.1.jar
geronimo-transaction-1.2-beta.jar
jencks-2.0-all.jar
jencks-amqpool-2.0.jar
log4j-1.2.12.jar
mx4j-2.1.1.jar
spring-2.0.jar
分享到:
评论

相关推荐

    水污染控制工程消毒课件实用教案.pptx

    哲克定律(Jencks' Law)在消毒中涉及的是不同类型的消毒剂对微生物的杀灭效率与剂量之间的关系。例如,氯消毒时,氯的浓度和接触时间决定了消毒效果。 二、氯消毒法 氯消毒是最常见的水处理消毒方法之一,因为氯...

    家庭的社会学习理论:分析

    Jencks,1972;Jensen,1973;Moos &amp; Insel,1974;Schulman,1970;Walberg,1971 )。 环境研究综述(例如,Bloom, 1964; Dave, 1963; Marjoribanks, 1972a; Mosychuk, 1969; Plowden, 1967; Vernon

    正常和学习障碍青少年的配对表现

    该实验的结果还表明,一些调查可能过于悲观(Jencks,1972),并且当黑人儿童获得非常早期的学前教育时,有希望的教育结果是可行的,前提是这些计划包括父母和社区资源参与和参与以及教育程序通过在丰富课程完成后与...

    移动开发_Android_基础框架_SAFApi组件开发_1742847786.zip

    移动开发_Android_基础框架_SAFApi组件开发_1742847786.zip

    《基于YOLOv8的气功动作识别系统》(包含源码、完整数据集、可视化界面、部署教程)简单部署即可运行。功能完善、操作简单,适合毕设或课程设计.zip

    资源内项目源码是来自个人的毕业设计,代码都测试ok,包含源码、数据集、可视化页面和部署说明,可产生核心指标曲线图、混淆矩阵、F1分数曲线、精确率-召回率曲线、验证集预测结果、标签分布图。都是运行成功后才上传资源,毕设答辩评审绝对信服的保底85分以上,放心下载使用,拿来就能用。包含源码、数据集、可视化页面和部署说明一站式服务,拿来就能用的绝对好资源!!! 项目备注 1、该资源内项目代码都经过测试运行成功,功能ok的情况下才上传的,请放心下载使用! 2、本项目适合计算机相关专业(如计科、人工智能、通信工程、自动化、电子信息等)的在校学生、老师或者企业员工下载学习,也适合小白学习进阶,当然也可作为毕设项目、课程设计、大作业、项目初期立项演示等。 3、如果基础还行,也可在此代码基础上进行修改,以实现其他功能,也可用于毕设、课设、作业等。 下载后请首先打开README.txt文件,仅供学习参考, 切勿用于商业用途。

    FourOnes_jquerybootstraptenine_1742855636.zip

    app开发

    MobaXterm安装包

    MobaXterm安装包

    30页-清华科技园智慧园区方案.pdf

    智慧园区,作为智慧城市的重要组成部分,正借助5G、云计算、大数据等前沿技术,实现园区的全面智慧化升级。它不仅仅是技术的堆砌,更是园区管理模式和服务理念的革新。智慧园区通过构建统一的大数据平台,实现园区内各类数据的整合与共享,让管理者能够全局掌握园区运营状态,实现人、事、物的穿透式管理。 在5G技术的加持下,智慧园区的特色应用得以更加广泛和深入地开展。从便捷通行到智慧物联,从楼宇自控到企业服务,5G智慧园区为园区内的企业和员工提供了前所未有的便捷与高效。刷脸通行、车牌识别、访客线上预约等技术的应用,不仅提升了园区的安全等级,更让通行变得简单快捷。而智慧垃圾桶、路灯等物联网设备的引入,则让园区的环境管理更加智能化、精细化。此外,5G智慧园区还通过无人机巡检、无人驾驶等创新应用,为园区的安全管理、物资配送等方面带来了全新的解决方案。 值得一提的是,智慧园区的建设并不仅仅局限于硬件设施的升级,更在于服务模式的创新。通过园区APP、在线服务平台等渠道,智慧园区实现了园区服务的线上化、便捷化,让企业和员工能够随时随地享受到园区提供的各类服务。这种以人为本的服务理念,不仅提升了园区的整体服务水平,更增强了园区的吸引力和竞争力。总之,5G智慧园区的建设为园区的可持续发展注入了新的活力,也为未来城市的发展提供了有益的借鉴和启示。

    C基础day9 思维导图

    C基础day9 思维导图

    Simulink仿真实现物体终端速度与信号处理的MATLAB代码解析(复现论文或解决问题,含详细可运行代码及解释)

    内容概要:本文档详细介绍了使用Simulink进行两个物理问题的仿真建模。第一个任务是模拟一个球体从高空落下的终端速度,通过建立重力与空气阻力的平衡模型,利用MATLAB代码构建Simulink模型,最终计算出终端速度。第二个任务是基于提供的加速度数据,通过两次积分计算物体的速度和位置,同样使用MATLAB代码实现了Simulink模型。每个任务都包含了详细的数学公式推导、参数设置以及Simulink模块的具体连接方法。仿真结果显示,终端速度约为53.6 m/s,而1秒后的速度和位置则取决于输入的加速度数据。 适合人群:对Simulink仿真工具感兴趣的工程技术人员、科研工作者以及相关专业的学生。 使用场景及目标:适用于需要进行物理系统仿真、信号处理的研究项目或教学实验。主要目标是帮助读者掌握Simulink的基本操作和应用技巧,同时加深对物理现象的理解。 其他说明:文中提供了完整的MATLAB代码,方便读者直接复制并在自己的环境中运行测试。此外,还给出了详细的中文注释,有助于初学者更好地理解各个步骤的功能和意义。

    《基于YOLOv8的隧道安全监测系统》(包含源码、完整数据集、可视化界面、部署教程)简单部署即可运行。功能完善、操作简单,适合毕设或课程设计.zip

    资源内项目源码是来自个人的毕业设计,代码都测试ok,包含源码、数据集、可视化页面和部署说明,可产生核心指标曲线图、混淆矩阵、F1分数曲线、精确率-召回率曲线、验证集预测结果、标签分布图。都是运行成功后才上传资源,毕设答辩评审绝对信服的保底85分以上,放心下载使用,拿来就能用。包含源码、数据集、可视化页面和部署说明一站式服务,拿来就能用的绝对好资源!!! 项目备注 1、该资源内项目代码都经过测试运行成功,功能ok的情况下才上传的,请放心下载使用! 2、本项目适合计算机相关专业(如计科、人工智能、通信工程、自动化、电子信息等)的在校学生、老师或者企业员工下载学习,也适合小白学习进阶,当然也可作为毕设项目、课程设计、大作业、项目初期立项演示等。 3、如果基础还行,也可在此代码基础上进行修改,以实现其他功能,也可用于毕设、课设、作业等。 下载后请首先打开README.txt文件,仅供学习参考, 切勿用于商业用途。

    音乐_安卓开发_本地音乐_播放器应用μsic_1742860435.zip

    音乐_安卓开发_本地音乐_播放器应用μsic_1742860435.zip

    Lightweight and Efficient: The backbone of the TTS Diffusion Transformer has only 0.45B param

    Lightweight and Efficient: The backbone of the TTS Diffusion Transformer has only 0.45B parameters. Ultra High-Quality Voice Cloning: See the demo video below! We also report results of recent TTS models on the Seed test sets in the following table. Bilingual Support: Supports both Chinese and English, and code-switching. Controllable: Supports accent intensity control and fine-grained pronunciation/duration adjustment (coming soon).

    博客_ionic20_移动端_应用开发模板_1742847485.zip

    博客_ionic20_移动端_应用开发模板_1742847485.zip

    《基于YOLOv8的传送带异物检测系统》(包含源码、完整数据集、可视化界面、部署教程)简单部署即可运行。功能完善、操作简单,适合毕设或课程设计.zip

    资源内项目源码是来自个人的毕业设计,代码都测试ok,包含源码、数据集、可视化页面和部署说明,可产生核心指标曲线图、混淆矩阵、F1分数曲线、精确率-召回率曲线、验证集预测结果、标签分布图。都是运行成功后才上传资源,毕设答辩评审绝对信服的保底85分以上,放心下载使用,拿来就能用。包含源码、数据集、可视化页面和部署说明一站式服务,拿来就能用的绝对好资源!!! 项目备注 1、该资源内项目代码都经过测试运行成功,功能ok的情况下才上传的,请放心下载使用! 2、本项目适合计算机相关专业(如计科、人工智能、通信工程、自动化、电子信息等)的在校学生、老师或者企业员工下载学习,也适合小白学习进阶,当然也可作为毕设项目、课程设计、大作业、项目初期立项演示等。 3、如果基础还行,也可在此代码基础上进行修改,以实现其他功能,也可用于毕设、课设、作业等。 下载后请首先打开README.txt文件,仅供学习参考, 切勿用于商业用途。

    中继增强OFDMA网络中的公平半分布式资源分配方案实现与性能评估(复现论文,含详细可运行代码及解释)

    内容概要:本文详细介绍了复现论文《Fair Semi-distributed Resource Allocation Scheme over Relay-Enhanced OFDMA Networks》的代码实现。主要内容包括系统模型构建(定义基站、中继站、移动终端及其关联关系)、资源分配算法(半分布式资源分配、改进的两阶段资源分配)和公平性调度机制(吞吐量计算、效用函数)。此外,还进行了仿真实验,对比了所提方案与集中式方案和机会主义方案在吞吐量、公平性和反馈开销方面的性能表现。最后,通过随机分布场景下的仿真进一步验证了方案的有效性和实际部署的可行性。 适合人群:通信工程专业研究人员、无线网络优化工程师、对OFDMA技术和资源分配算法感兴趣的学者和技术人员。 使用场景及目标:适用于研究和开发中继增强的OFDMA网络资源分配算法,旨在提高系统的吞吐量和公平性,降低反馈开销。目标是在大规模网络环境中实现高效、公平的资源分配。 其他说明:文中提供了详细的代码实现步骤和仿真结果,有助于读者深入理解算法原理并进行实验验证。

    2025大模型训练性能瓶颈定位流程案例.pdf

    2025大模型训练性能瓶颈定位流程案例

    蓝桥杯Python竞赛真题详解:涵盖基础与进阶算法挑战

    内容概要:本文档提供了20道蓝桥杯Python竞赛真题及其详细解答,涉及质因数分解、分数计算、特别数求和、数字三角形、约数个数、草的生长模拟、工作时长计算、互质数统计、阶乘和判定、公因数匹配、直线计算、分糖果、矩阵填充、旅行计划优化、阶乘末尾零计数、最长递增子序列、最长公共子序列、最长回文子串、最长公共前缀和最长公共后缀等多个经典算法问题。每个题目都附有完整的代码实现和解释,帮助参赛者深入理解和掌握相关知识点。 适合人群:准备参加蓝桥杯或其他编程竞赛的学生和程序员,尤其是对Python编程有一定基础并希望提高算法能力的人群。 使用场景及目标:①作为赛前复习资料,巩固基础知识;②通过实际编程练习提升算法思维和解决问题的能力;③熟悉竞赛常见题型,增强应对复杂问题的信心。 其他说明:文档不仅提供了解答思路,还包含了具体的代码实现,有助于读者更好地理解和应用所学知识。同时,这些问题覆盖了多种数据结构和算法思想,能够全面锻炼编程技能。

    word-【软考-网络工程师】学习资源

    网络工程师(中级)是软考(计算机技术与软件专业技术资格考试)的一部分,主要考察计算机网络基础、网络安全、网络管理、操作系统、数据库等内容,考试分为上午的基础知识选择题和下午的案例分析题。

Global site tag (gtag.js) - Google Analytics