关于IBM WebSphere MQ的使用

喜欢ヅ旅行 2022-07-16 00:25 251阅读 0赞

# 1.IBM WebSphere MQ工具的使用 #

## 1.下载并安装 ##

http://www.ibm.com/developerworks/downloads/ws/wmq/

## 2.新建队列管理器QM\_TEST ##

![这里写图片描述][format_png]

## 3.新建通道channel5（***注：类型选择为服务器连接***） ##

![这里写图片描述][format_png 1]

## 4.新建队列Q1 ##

![这里写图片描述][format_png 2]

# 关于在JAVA工程中使用MQ #

## 1.配置监听器工厂等其他信息 ##

### xml文件 ###

<beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:tx="http://www.springframework.org/schema/tx" xmlns:context="http://www.springframework.org/schema/context" xmlns:aop="http://www.springframework.org/schema/aop" xsi:schemaLocation=" http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.0.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.0.xsd" default-lazy-init="false" >
     
        
        <bean id="mqConnectionFactory" class="com.ibm.mq.jms.MQQueueConnectionFactory">
            <property name="hostName">
                <value>${blvc.mq.hostName}</value>
            </property>
            <property name="port">
                <value>${blvc.mq.port}</value>
            </property>
            <property name="queueManager">
                <value>${blvc.mq.queueManager}</value>
            </property>
            <property name="channel">
                <value>${blvc.mq.channel}</value>
            </property>
            <property name="CCSID" value="1381"/>
            <property name="transportType" value="1" />
        </bean>
     
     
        
        <bean id="jmsQueueConnectionFactory" class="org.springframework.jms.connection.CachingConnectionFactory">
            <property name="targetConnectionFactory" ref="mqConnectionFactory" />
            <property name="sessionCacheSize">
                <value>${blvc.jms.sessionCacheSize}</value>
            </property>
        </bean>
     
        
        <bean id="jmsDestinationResolver" class="org.springframework.jms.support.destination.DynamicDestinationResolver" />
     
        
        <bean id="jmsTemplateSend" class="org.springframework.jms.core.JmsTemplate">
            <property name="connectionFactory" ref="jmsQueueConnectionFactory" />
            <property name="destinationResolver" ref="jmsDestinationResolver" />
            <property name="defaultDestinationName">
           	 	<value>${S130.send.destinationName}</value>
            </property>
            <property name="pubSubDomain" value="false" />
        </bean>
        
    	    
        <bean id="jmsListenerTaskExecutor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
            <property name="corePoolSize">
                <value>${blvc.jms.corePoolSize}</value>
            </property>
            <property name="maxPoolSize">
                <value>${blvc.jms.maxPoolSize}</value>
            </property>
            <property name="keepAliveSeconds">
                <value>${blvc.jms.keepAliveSeconds}</value>
            </property>
            <property name="queueCapacity">
                <value>${blvc.jms.queueCapacity}</value>
            </property>
            <property name="threadNamePrefix" value="jmsListenerTaskExecutor" />
        </bean>
     
     	
        <bean id="jmsListener" class="com.bl.man.busi.listener.MQReceiveListener"></bean>
        
        <bean id="jmsContainer" class="org.springframework.jms.listener.DefaultMessageListenerContainer">
            <property name="connectionFactory" ref="jmsQueueConnectionFactory" />
            <property name="destinationResolver" ref="jmsDestinationResolver" />
            <property name="messageListener" ref="jmsListener" />
            <property name="cacheLevelName" value="CACHE_CONSUMER" />
            <property name="taskExecutor" ref="jmsListenerTaskExecutor" />
            <property name="concurrentConsumers">
                <value>${thk.recv.concurrentConsumers}</value>
            </property>
            <property name="maxConcurrentConsumers">
                <value>${thk.recv.maxConcurrentConsumers}</value>
            </property>
            <property name="destinationName">
                <value>${thk.recv.destinationName}</value>
            </property>
        </bean>
    </beans>

### 1.properties文件 ###

#MQ Server
    #TEST
    blvc.mq.hostName=127.0.0.1
    blvc.mq.port=1414
    blvc.mq.queueManager=QM_TEST//队列管理器名称
    blvc.mq.channel=channel5//通道名称（类型：服务器连接通道）
    
    
    #jms session pool
    blvc.jms.sessionCacheSize=5
    blvc.jms.corePoolSize=5
    blvc.jms.maxPoolSize=5
    blvc.jms.keepAliveSeconds=10
    blvc.jms.queueCapacity=10
    
    #jms listerner (add here)
    thk.recv.concurrentConsumers=1
    thk.recv.maxConcurrentConsumers=1
    thk.recv.destinationName=Q1

## 2.在srping中加载这些文件 ##

<import resource="applicationContext-MQ.xml"/>
    <bean class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
    	<property name="systemPropertiesModeName" value="SYSTEM_PROPERTIES_MODE_OVERRIDE" />
    	<property name="searchSystemEnvironment" value="true" /> 
    	<property name="ignoreResourceNotFound" value="false" />
    	<property name="locations">
    		<list>
    			<value>classpath:config/*.properties</value>
    		</list>
    	</property>
    </bean>

## 3.写监听器MQReceiveListener ##

package com.bl.man.busi.listener;
    
    import javax.jms.Message;
    import javax.jms.MessageListener;
    import javax.jms.TextMessage;
    
    /**
     * 
     * MQ监听器
     *
     */
    public class MQReceiveListener implements MessageListener {
    
    	@Override
    	public void onMessage(Message msg) {
    		TextMessage tm = (TextMessage)msg;
    		try {
    			System.out.println("++----------"+tm.getText());
    		} catch (Exception e) {
    			e.printStackTrace();
    		}
    	}
    }

## 4.往MQ中放置信息 ##

@Autowired
    private JmsTemplate jmsTemplateSend;
    jmsTemplateSend.setDefaultDestinationName("Q1");//队列名称
    jmsTemplateSend.send(createTxtMsg("123456"));//放入的消息
    
    public MessageCreator createTxtMsg(final String msg) { 
    	return new MessageCreator() { 
    		public Message createMessage(Session session) throws JMSException { 
    			TextMessage textMessage = session.createTextMessage();
    			textMessage.setText(msg);
    			return textMessage;
    		}
    	};
    }

[format_png]: /images/20220716/df0db685bb7f486f8e1c61b60b8bce95.png
[format_png 1]: /images/20220716/e911c92b568e473e93fd9cf06bba64ae.png
[format_png 2]: /images/20220716/46bf40a407e348a3b0115bf1ee28114c.png