《将Sun的Open_Message_Queue与Spring集成.doc》由会员分享，可在线阅读，更多相关《将Sun的Open_Message_Queue与Spring集成.doc（7页珍藏版）》请在金锄头文库上搜索。
1、将Sun的Open Message Queue与Spring集成刘岩Email:1. 前言基于JMS标准的消息中间件实现的产品有很多，JBossMQ、ActiveMQ、OpenMQ、OpenJMS等等，最常用的还是apache的ActiveMQ。有时也使用Sun的OpenMQ。在官网http:/ Message Queue是Sun Java System Message Queue的一个开源版本。Open message queue是一个企业级，可升级，非常成熟的消息服务器。它为面向消息的系统集成提供一套完整的JMS（Java Message Service ）实现。由于Open MQ源自Su
2、n的Java Message Queue，所以其具有Java System Message Queue拥有的所有特性，功能和性能。2. 环境配置下载后将相关的jar拷贝到项目的classpath下面。笔者在此为了安全起见，引入了很多jar包，将语言包都引入了。各位读者可以因地制宜。以下是引入jar包的列表lib/openmqjar/common-message.jarlib/openmqjar/fscontext.jarlib/openmqjar/grizzly.jarlib/openmqjar/imq_de.jarlib/openmqjar/imq_es.jarlib/openmqjar/i
3、mq_fr.jarlib/openmqjar/imq_it.jarlib/openmqjar/imq_ja.jarlib/openmqjar/imq_ko.jarlib/openmqjar/imq_pt_BR.jarlib/openmqjar/imq_zh_CN.jarlib/openmqjar/imq_zh_TW.jarlib/openmqjar/imq.jarlib/openmqjar/imqadmin.jarlib/openmqjar/imqbridgemgr.jarlib/openmqjar/imqbroker.jarlib/openmqjar/imqjmsbridge.jarlib/
4、openmqjar/imqjmsra.rarlib/openmqjar/imqjmx_de.jarlib/openmqjar/imqjmx_es.jarlib/openmqjar/imqjmx_fr.jarlib/openmqjar/imqjmx_it.jarlib/openmqjar/imqjmx_ja.jarlib/openmqjar/imqjmx_ko.jarlib/openmqjar/imqjmx_pt_BR.jarlib/openmqjar/imqjmx_zh_CN.jarlib/openmqjar/imqjmx_zh_TW.jarlib/openmqjar/imqjmx.jarli
5、b/openmqjar/imql10n_server_de.jarlib/openmqjar/imql10n_server_es.jarlib/openmqjar/imql10n_server_fr.jarlib/openmqjar/imql10n_server_it.jarlib/openmqjar/imql10n_server_ja.jarlib/openmqjar/imql10n_server_ko.jarlib/openmqjar/imql10n_server_pt_BR.jarlib/openmqjar/imql10n_server_zh_CN.jarlib/openmqjar/im
6、ql10n_server_zh_TW.jarlib/openmqjar/imqservlet.jarlib/openmqjar/imqstomp.jarlib/openmqjar/imqutil.jarlib/openmqjar/imqxm.jarlib/openmqjar/jaxm-api.jarlib/openmqjar/jhall.jarlib/openmqjar/jms.jarlib/openmqjar/jta.jarlib/openmqjar/protobuf-2.3.0.jar3. 之后项目加入Spring的相关jar包。增加Spring配置文件内容如下：127.0.0.1:767
7、6adminadmintrue35000RANDOM4. 消息监听器类代码如下/* * JMS消息消费者。 * 接收JMS消息后获得router想要的消息后，调用router接口更新本地缓存 * author liuyan * */public class JMSMessageListener implements MessageListener private Logger log = Logger.getLogger(JMSMessageListener.class.getName();/* * 接收JMS消息后的业务处理 */public void onMessage(Message message) log.info(接收消息);byte byteMessage = JMSByteConverterUtil.ConverterMessageToBttes(message);try log.info(将转型成实体对象);/ catch (InvalidProtocolBufferException e)
