Spring整合JMS、IBM MQ發送和接收消息

最近才接觸到MQ，由於之前完全不知道是幹嘛用的，還是很花了一點時間研究的~先來簡單解釋一下名詞啦

一、名詞解釋

1. MQ

   MQ（message queue）指消息隊列，是應用程序對應用程序的通信方法。可以利用消息隊列暫存數據報文。
   MQ的原理其實就是生產者-消費者模式。有關生產者-消費者模式的詳細解釋可以看這篇博文http://blog.csdn.net/yolanda_nuonuo/article/details/62038122
   MQ是一種異步通訊。
   生產者，發送消息到MQ服務器
   消費者，到MQ服務器，獲取生產者發送的消息(根據MQ的不同配置，可以是MQ推送消息給消費者，或者是消費者主動從MQ獲取消息)

2. JMS

   JMS即
   JAVA消息服務（Java Message Service），是一個Java平臺中關於面向消息中間件（MOM）的API，用於在兩個應用程序之間，或分布式系統中發送消息，進行異步通信。

使用JMS 的應用程序被稱為JMS 客戶端，處理消息路由與傳遞的消息系統被稱為JMS Provider，而JMS 應用則是由多個JMS 客戶端和一個JMS Provider 構成的業務系統。
發送消息的JMS 客戶端被稱為生產者（producer），而接收消息的JMS 客戶端則被稱為消費者(consumer)。同一JMS 客戶端既可以是生產者也可以是消費者。

所以MQ跟JMS的關系就是，我們可以通過JMS來跟MQ進行通信。

二、具體實現

1.首先是發送數據，新建application-send.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xmlns:context="http://www.springframework.org/schema/context"
    xmlns:aop="http://www.springframework.org/schema/aop"
    xmlns:jpa="http://www.springframework.org/schema/data/jpa"
    xmlns:tx="http://www.springframework.org/schema/tx"
    xmlns:cache="http://www.springframework.org/schema/cache"
    xmlns:p="http://www.springframework.org/schema/p"
    xsi:schemaLocation="http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.1.xsd
        http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.1.xsd
        http://www.springframework.org/schema/data/jpa http://www.springframework.org/schema/data/jpa/spring-jpa-1.3.xsd
        http://www.springframework.org/schema/cache http://www.springframework.org/schema/cache/spring-cache-3.1.xsd
        http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.1.xsd
        http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.1.xsd">

    <context:property-placeholder ignore-unresolvable="false" location="classpath:application.properties" />

    <context:annotation-config />
    <!-- <context:component-scan base-package="com.*" /> -->

    <bean id="ibmJmsConnectionFactory" class="com.ibm.mq.jms.MQQueueConnectionFactory">
        <property name="hostName" value="${ibm.mqHostUrl}" />
        <property name="port" value="${ibm.mqPort}" />
        <property name="CCSID" value="0000" />
        <property name="queueManager" value="${ibm.mqManager}" />
        <property name="channel" value="${ibm.mqChannel}" />
        <property name="transportType" value="1" />
    </bean>
    <bean id="ibmQueueConnectionFactory" class="org.springframework.jms.connection.CachingConnectionFactory">
        <property name="targetConnectionFactory" ref="ibmJmsConnectionFactory"/>
        <property name="sessionCacheSize" value="10"/>
    </bean>

    <bean id="ibmQueue" class="com.ibm.mq.jms.MQQueue">
        <property name="baseQueueName" value="${ibm.mqName}" />
    </bean>

    <bean id="ibmJmsTemplate" class="org.springframework.jms.core.JmsTemplate">
        <property name="connectionFactory" ref="ibmQueueConnectionFactory" />
        <property name="defaultDestination" ref="ibmQueue" />
        <property name="pubSubDomain" value="false" />
    </bean>  

    <bean id="ibmMessageSender" class="com.yolanda.sender.MessageSenderImpl">
    </bean>

</beans>
 

2.發送數據的代碼
先寫一個接口

public interface MessageSender {

    public void sendMessage(String message);

}

再寫實現類

import java.io.UnsupportedEncodingException;
import javax.annotation.Resource;
import javax.jms.BytesMessage;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.Session;

import org.springframework.beans.factory.annotation.Value;
import org.springframework.jms.core.JmsTemplate;
import org.springframework.jms.core.MessageCreator;
import org.springframework.stereotype.Component;

@Component("ibmMessageSender")
public class MessageSenderImpl implements MessageSender {

    @Resource(name="ibmJmsTemplate")
    private JmsTemplate jmsTemplate;

    /**
     * 這裏為什麽要用final呢？是下面那個createTextMessage方法要求的...
     */
    public void sendMessage(final String message) {
        this.jmsTemplate.send(new MessageCreator() {
            public Message createMessage(Session session) throws JMSException {
                    return session.createTextMessage(message);
            }
        });
    }

}

3.接下來就是收數據辣，新建application-recv.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xmlns:context="http://www.springframework.org/schema/context"
    xmlns:aop="http://www.springframework.org/schema/aop"
    xmlns:jpa="http://www.springframework.org/schema/data/jpa"
    xmlns:tx="http://www.springframework.org/schema/tx"
    xmlns:cache="http://www.springframework.org/schema/cache"
    xmlns:p="http://www.springframework.org/schema/p"
    xsi:schemaLocation="http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.1.xsd
        http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.1.xsd
        http://www.springframework.org/schema/data/jpa http://www.springframework.org/schema/data/jpa/spring-jpa-1.3.xsd
        http://www.springframework.org/schema/cache http://www.springframework.org/schema/cache/spring-cache-3.1.xsd
        http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.1.xsd
        http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.1.xsd">

    <bean id="ibmJmsConnectionFactory" class="com.ibm.mq.jms.MQQueueConnectionFactory">
        <property name="hostName" value="${ibm.mqHostUrl}" />
        <property name="port" value="${ibm.mqPort}" />
        <property name="CCSID" value="1381" />
        <property name="queueManager" value="${ibm.mqManager}" />
        <property name="channel" value="${ibm.mqChannel}" />
        <property name="transportType" value="1" />
    </bean>
    <bean id="ibmQueueConnectionFactory" class="org.springframework.jms.connection.CachingConnectionFactory">
        <property name="targetConnectionFactory" ref="ibmJmsConnectionFactory"/>
        <property name="sessionCacheSize" value="10"/>
    </bean>

    <bean id="ibmQueue" class="com.ibm.mq.jms.MQQueue">
        <property name="baseQueueName" value="MQTEST" />
    </bean>

    <bean id="queueContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
        <property name="connectionFactory" ref="ibmQueueConnectionFactory" />
        <property name="destination" ref="ibmQueue" />
        <property name="pubSubDomain" value="false" />
        <property name="concurrentConsumers" value="20" />
        <property name="messageListener" ref="ibmTextMessageListener" />
    </bean>


    <!-- 異步接收消息處理類 -->
    <bean id="ibmextMessageListener" class="com.yolanda.receive.TextMessageListener" />
</beans>

4.由於整合了Spring，又是用JMS，所以代碼還是灰常簡單的，這裏我們只需要實現MessageListener的onMessage（），監聽一下就可以啦

package com.yolanda.receiver;

import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.TextMessage;

import org.springframework.beans.factory.annotation.Autowired;

public class TextMessageListener implements MessageListener {
    @Autowired
    public void onMessage(Message message) {
        try {
            TextMessage msg = (TextMessage) message;
            String msgStr = msg.getText();
            System.out.println("Receive message:" + msgStr);
        } catch (Exception e) {
            e
.printStackTrace();
        }
    }

好啦，圓滿結束啦，不用spring整合的話，代碼還是比較繁瑣的，果然還是用比較好呢！

Spring整合JMS、IBM MQ發送和接收消息