将Sun的Open Message Queue与Spring集成刘岩Email:suhuanzheng7784877163.com1. 前言基于JMS标准的消息中间件实现的产品有很多，JBossMQ、ActiveMQ、OpenMQ、OpenJMS等等，最常用的还是apache的ActiveMQ。有时也使用Sun的OpenMQ。在官网http:/mq.java.net/处可以下载。Open Message Queue是Sun Java System Message Queue的一个开源版本。Open message queue是一个企业级，可升级，非常成熟的消息服务器。它为面向消息的系统集成提供一套完整的JMS（Java Message Service ）实现。由于Open MQ源自Sun的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/imq_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/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.jarlib/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/imql10n_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:7676adminadmintrue35000RANDOM4. 消息监听器类代码如下/* * 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)