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

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),并且当黑人儿童获得非常早期的学前教育时,有希望的教育结果是可行的,前提是这些计划包括父母和社区资源参与和参与以及教育程序通过在丰富课程完成后与...

    【优化流量】基于matlab遗传算法GA求解OD流量优化问题【含Matlab源码 9159期】.mp4

    Matlab领域上传的视频均有对应的完整代码,皆可运行,亲测可用,适合小白; 1、代码压缩包内容 主函数:main.m; 调用函数:其他m文件;无需运行 运行结果效果图; 2、代码运行版本 Matlab 2019b;若运行有误,根据提示修改;若不会,私信博主; 3、运行操作步骤 步骤一:将所有文件放到Matlab的当前文件夹中; 步骤二:双击打开main.m文件; 步骤三:点击运行,等程序运行完得到结果; 4、仿真咨询 如需其他服务,可私信博主; 4.1 博客或资源的完整代码提供 4.2 期刊或参考文献复现 4.3 Matlab程序定制 4.4 科研合作

    基于深度学习YOLOv9实现道路红绿灯行人车辆(8类)识别检测系统python源码+详细教程+模型+数据集+评估指标曲线.zip

    【使用教程】 一、环境配置 1、建议下载anaconda和pycharm 在anaconda中配置好环境,然后直接导入到pycharm中,在pycharm中运行项目 anaconda和pycharm安装及环境配置参考网上博客,有很多博主介绍 2、在anacodna中安装requirements.txt中的软件包 命令为:pip install -r requirements.txt 或者改成清华源后再执行以上命令,这样安装要快一些 软件包都安装成功后才算成功 3、安装好软件包后,把anaconda中对应的python导入到pycharm中即可(不难,参考网上博客) 二、环境配置好后,开始训练(也可以训练自己数据集) 1、数据集准备 需要准备yolo格式的目标检测数据集,如果不清楚yolo数据集格式,或者有其他数据训练需求,请看博主yolo格式各种数据集集合链接:https://blog.csdn.net/DeepLearning_/article/details/127276492 更多详情介绍,见资源内的项目说明

    (源码)基于SpringBoot和Vue的学生作业互评系统.zip

    # 基于Spring Boot和Vue的学生作业互评系统 ## 项目简介 本项目是一个基于Spring Boot和Vue框架开发的学生作业互评系统。系统主要功能包括学生作业的提交、教师作业的布置、作业的批改与评分、以及学生之间的作业互评。通过该系统,教师可以方便地管理课程和作业,学生可以在线提交作业并参与互评,从而提高作业质量和学习效果。 ## 项目的主要特性和功能 1. 用户管理 支持学生、教师和管理员三种角色的用户管理。 提供用户注册、登录、密码修改等功能。 2. 课程管理 教师可以创建和管理课程,学生可以选课。 支持课程信息的查看和编辑。 3. 作业管理 教师可以布置作业,设置作业的截止日期和评分标准。 学生可以在线提交作业,查看作业提交状态。 4. 作业批改与评分 教师可以对学生提交的作业进行批改和评分。 学生可以查看自己的作业评分和教师的评语。

    PHP学生成绩查询(源代码+论文).rar

    PHP学生成绩查询(源代码+论文)

    c语言学生信息系统.rar

    c语言学生信息系统

    Android的多媒体框架OpenCore介绍.zip

    Android的多媒体框架OpenCore介绍

    AutocompleteTest.zip

    AutocompleteTest

    2023-04-06-项目笔记 - 第三百一十八阶段 - 4.4.2.316全局变量的作用域-316 -2025.11.15

    2023-04-06-项目笔记-第三百一十八阶段-课前小分享_小分享1.坚持提交gitee 小分享2.作业中提交代码 小分享3.写代码注意代码风格 4.3.1变量的使用 4.4变量的作用域与生命周期 4.4.1局部变量的作用域 4.4.2全局变量的作用域 4.4.2.1全局变量的作用域_1 4.4.2.316局变量的作用域_316- 2024-11-15

    可以识别视频语音自动生成字幕SRT文件的开源 Windows-GUI 软件工具.zip

    可以识别视频语音自动生成字幕SRT文件的开源 Windows-GUI 软件工具

    c语言情人节的红玫瑰.rar

    c语言情人节的红玫瑰

    c语言24点游戏源码.rar

    c语言24点游戏源码

    c语言实现的汉诺塔演示程序.rar

    c语言实现的汉诺塔演示程序

    android_jni操作指南.zip

    android_jni操作指南

    网上绝无仅有的Log分析教程及例子.zip

    网上绝无仅有的Log分析教程及例子

    python编写开源的跳板机(堡垒机)系统Jumpserver-v3.10.7.zip

    Jumpserver 是一款由python编写开源的跳板机(堡垒机)系统,实现了跳板机应有的功能。基于ssh协议来管理,客户端无需安装agent。 Jumpserver 3.0 架构上和 2.0 变化较大,建议全新安装一套环境来体验。如需升级,请务必升级前进行备份。 支持常见系统: 1、redhat centos 2、debian 3、suse ubuntu 4、freebsd 5、其他ssh协议硬件设备 特点: 完全开源,GPL授权 Python编写,容易再次开发 实现了跳板机基本功能,认证、授权、审计 集成了Ansible,批量命令等 支持WebTerminal Bootstrap编写,界面美观 自动收集硬件信息 录像回放 命令搜索 实时监控 批量上传下载

Global site tag (gtag.js) - Google Analytics