Spring 整合IBM MQ 包含多路通道_com.ibm.mq.jms.mqqueue 配置xml-程序员宅基地

技术标签: IBM MQ  Spring  

    在配置spring之前,在properties文件中配置好相应的参数信息,我都是单独存放mq的相关配置信息,便于查看,如图:

  

 

spring-mq.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:jms="http://www.springframework.org/schema/jms"
	xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
		http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.1.xsd
		http://www.springframework.org/schema/jms http://www.springframework.org/schema/jms/spring-jms.xsd">
    <description>jms</description>
    
    <bean id="sslContextFactory" class="cn.epaylinks.gc.gw.fps.connection.SSLContextFactory">
    </bean>
    <!-- mq连接工厂 -->
    <bean id="ibmJmsConnectionFactory" class="com.ibm.mq.jms.MQConnectionFactory">
        <property name="hostName" value="${ibm.mq.host}" />
        <property name="port" value="${ibm.mq.sever.port}" />
        <property name="CCSID" value="${ibm.mq.ccsid}" />
        <property name="queueManager" value="${ibm.mq.sever.manageName}" />
        <property name="channel" value="${ibm.mq.sever.channelName}" />
        <property name="SSLFipsRequired" value="${ssl.fipsRequired}"/>
	<property name="SSLPeerName" value="${ssl.server.sslPeerName}"/>
        <!-- 设置SSL双向加密通信 -->
	<property name="SSLSocketFactory">
		<bean class="org.springframework.beans.factory.config.MethodInvokingFactoryBean">
		    <!-- targetObject确定目标Bean,指定调用哪个Bean -->
		    <property name="targetObject" ref="sslContextFactory"></property>
		    <!-- targetMethod确定目标方法,指定调用目标Bean的哪个方法 -->
		    <property name="targetMethod" value="getSSLSocketFactory"></property>
		</bean>
	</property>
	<property name="SSLCipherSuite" value="${ssl.cipherSuite}"/>
    </bean>
    <!-- 创建连接 -->
    <bean id="connectionFactoryAdapter" class="org.springframework.jms.connection.UserCredentialsConnectionFactoryAdapter">
    	<property name="targetConnectionFactory" ref="ibmJmsConnectionFactory"/>
    	<property name="username" value="${ibm.mq.userName}"/>
    	<property name="password" value="${ibm.mq.password}"/>
    </bean>
    <!-- 缓存管理mq队列连接工厂 -->
    <bean id="ibmQueueConnectionFactory" class="org.springframework.jms.connection.CachingConnectionFactory">
	<property name="targetConnectionFactory" ref="connectionFactoryAdapter"/>
        <property name="sessionCacheSize" value="10"/>
        <property name="reconnectOnException" value="${ibm.reconnection}"/>      
    </bean>
    <!-- 接收消息队列-->
    <!-- 监听获取对方发起消息的输入消息队列 ibm.mq.h.req.inQueue-->
    <!-- 监听获取对方回复消息的输入消息队列 ibm.mq.h.ack.inQueue-->
    <bean id="ibmHReqReceiveQueue" class="com.ibm.mq.jms.MQQueue">
        <property name="baseQueueName" value="${ibm.mq.h.req.inQueue}" />
    </bean>
    <bean id="ibmHAckReceiveQueue" class="com.ibm.mq.jms.MQQueue">
        <property name="baseQueueName" value="${ibm.mq.h.ack.inQueue}" />
    </bean>
    
    <!-- 发送消息队列-->
    <!-- 主动发起消息给对方的输出队列 ibm.mq.h.req.outQueue-->
    <!-- 回复消息给对方的输出队列 ibm.mq.h.ack.outQueue-->
    <bean id="ibmHReqSendQueue" class="com.ibm.mq.jms.MQQueue">
        <property name="baseQueueName" value="${ibm.mq.h.req.outQueue}"/>
    </bean>
    <bean id="ibmHAckSendQueue" class="com.ibm.mq.jms.MQQueue">
        <property name="baseQueueName" value="${ibm.mq.h.ack.outQueue}"/>
    </bean>
    
    <!-- 接收消息模板 -->
    <bean id="receiveHReqJMSTemplate" class="org.springframework.jms.core.JmsTemplate">  
        <property name="connectionFactory" ref="ibmQueueConnectionFactory"/>
        <property name="defaultDestination" ref="ibmHReqReceiveQueue"/> 
        <!-- 非pub/sub模型(发布/订阅),即:队列模型 -->
        <property name="pubSubDomain" value="false"/> 
    </bean>
    <bean id="receiveHAckJMSTemplate" class="org.springframework.jms.core.JmsTemplate">  
        <property name="connectionFactory" ref="ibmQueueConnectionFactory"/>
        <property name="defaultDestination" ref="ibmHAckReceiveQueue"/> 
        <property name="pubSubDomain" value="false"/> 
    </bean>
    <!-- 发送消息模板 -->
    <bean id="sendHReqJmsTemplate" class="org.springframework.jms.core.JmsTemplate">
        <property name="connectionFactory" ref="ibmQueueConnectionFactory" />
        <property name="defaultDestination" ref="ibmHReqSendQueue" />
        <property name="pubSubDomain" value="false"/>
    </bean>
    <bean id="sendHAckJmsTemplate" class="org.springframework.jms.core.JmsTemplate">
        <property name="connectionFactory" ref="ibmQueueConnectionFactory" />
        <property name="defaultDestination" ref="ibmHAckSendQueue" />
        <property name="pubSubDomain" value="false"/>
    </bean>
    
    <!-- 消息接收程序,接收多个信道的信息 -->
    <bean id="ibmHReqJmsReceiver" class="cn.mq.transceiver.JMSHReqReceiver">  
        <property name="jmsTemplate" ref="receiveHReqJMSTemplate"/>
        <property name="receiveQueue" ref="ibmHReqReceiveQueue"/>
    </bean>
    <bean id="ibmHAckJmsReceiver" class="cn.mq.transceiver.JMSHAckReceiver">  
        <property name="jmsTemplate" ref="receiveHAckJMSTemplate"/>
        <property name="receiveQueue" ref="ibmHAckReceiveQueue"/>
    </bean>
    <!-- 消息发送程序 -->
    <bean id="ibmHReqJmsSender" class="cn.mq.transceiver.JMSHReqSender">  
        <property name="jmsTemplate" ref="sendHReqJmsTemplate"/>
        <property name="sendQueue" ref="ibmHReqSendQueue"/>
    </bean>
    <bean id="ibmHAckJmsSender" class="cn.mq.transceiver.JMSHAckSender">  
        <property name="jmsTemplate" ref="sendHAckJmsTemplate"/>
        <property name="sendQueue" ref="ibmHAckSendQueue"/>
    </bean>
    <!-- DefaultMessageListenerContainer允许指定数量的并发监听线程,可以在允许期间动态调整监听线程的数量 -->
    <bean id="queueContainer1" class="org.springframework.jms.listener.DefaultMessageListenerContainer" >
        <property name="connectionFactory" ref="ibmQueueConnectionFactory" />
        <property name="destination" ref="ibmHReqReceiveQueue"/>
        <property name="pubSubDomain" value="false" />
        <property name="messageListener" ref="ibmHReqJmsReceiver"/>
        <!-- 设置固定的线程数 -->
	    <property name="concurrentConsumers" value="${concurrentConsumers}"/>
	    <!-- 设置动态的线程数 -->  
	    <property name="concurrency" value="${concurrency}"/>
	    <!-- 设置最大的线程数 -->
	    <property name="maxConcurrentConsumers" value="${maxConcurrentConsumers}"/>
    </bean>
    <bean id="queueContainer2" class="org.springframework.jms.listener.DefaultMessageListenerContainer" >
        <property name="connectionFactory" ref="ibmQueueConnectionFactory" />
        <property name="destination" ref="ibmHAckReceiveQueue"/>
        <property name="pubSubDomain" value="false" />
        <property name="messageListener" ref="ibmHAckJmsReceiver"/>
        <!-- 设置固定的线程数 -->
	    <property name="concurrentConsumers" value="${concurrentConsumers}"/>
	    <!-- 设置动态的线程数 -->  
	    <property name="concurrency" value="${concurrency}"/>
	    <!-- 设置最大的线程数 -->
	    <property name="maxConcurrentConsumers" value="${maxConcurrentConsumers}"/>
    </bean>
</beans>

消息接收程序

public class JMSHReqReceiver implements MessageListener{

    private Logger logger = LoggerFactory.getLogger(getClass());
    @Autowired 
    CoreFpsHandler coreFpsHandler;
	/** 
	* @Fields jmsTemplate : 消息模板
	*/ 
	private JmsTemplate jmsTemplate;
	
	/** 
	* @Fields receiveQueue : 消息接收队列
	*/
	private MQQueue receiveQueue;
	

	public JmsTemplate getJmsTemplate() {
		return jmsTemplate;
	}

	public void setJmsTemplate(JmsTemplate jmsTemplate) {
		this.jmsTemplate = jmsTemplate;
	}

	public MQQueue getReceiveQueue() {
		return receiveQueue;
	}
	
	public void setReceiveQueue(MQQueue receiveQueue) {
		this.receiveQueue = receiveQueue;
	}
	
	
	/* (非 Javadoc) 
	* <p>Title: onMessage</p> 
	* <p>Description: 接收消息</p> 
	* @param message 
	* @see javax.jms.MessageListener#onMessage(javax.jms.Message) 
	*/ 
	public void onMessage(Message message) {
		try {
            TextMessage msg = (TextMessage) message;
            String msgStr = msg.getText();
            logger.info("receive message:"+msgStr);
            //调用处理器的接收报文处理方法,这里根据自己的业务逻辑进行处理
        } catch (Exception e) {
            logger.error("receive message error:"+e.getMessage(), e);
        }
	}

}

发送消息程序

public class JMSHReqSender {
	
	private Logger logger = LoggerFactory.getLogger(getClass());

	/** 
	* @Fields jmsTemplate : 消息模板
	*/ 
	private JmsTemplate jmsTemplate;
	
	/** 
	* @Fields replyTo : 发送消息队列
	*/ 
	private Destination sendQueue;
 
	public JmsTemplate getJmsTemplate() {
		return jmsTemplate;
	}
 
	public void setJmsTemplate(JmsTemplate jmsTemplate) {
		this.jmsTemplate = jmsTemplate;
	}

	public Destination getSendQueue() {
		return sendQueue;
	}

	public void setSendQueue(Destination sendQueue) {
		this.sendQueue = sendQueue;
	}

	/** 
	* @Title: sendMesage 
	* @Description: 发送消息
	* @return void 返回类型 
	* @throws 
	*/ 
	public void sendMesage(final String message) {
		// 有时候需要进行本地接口测试,不用直接连接发送
		if(!AppServletContextListener.startConnection) {
			return;
		}else {
			jmsTemplate.send(sendQueue,new MessageCreator() {
				public Message createMessage(Session session) throws JMSException {
					logger.info("send message:"+message);
					return session.createTextMessage(message);
				}
			});
		}
	}
}

   这里上了一些主要代码,至于相关的SSL加密通信的以及xml报文的加签验签,等有时间继续整理

版权声明:本文为博主原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://blog.csdn.net/qq_26182739/article/details/84346565

智能推荐

c# 调用c++ lib静态库_c#调用lib-程序员宅基地

文章浏览阅读2w次,点赞7次,收藏51次。四个步骤1.创建C++ Win32项目动态库dll 2.在Win32项目动态库中添加 外部依赖项 lib头文件和lib库3.导出C接口4.c#调用c++动态库开始你的表演...①创建一个空白的解决方案,在解决方案中添加 Visual C++ , Win32 项目空白解决方案的创建:添加Visual C++ , Win32 项目这......_c#调用lib

deepin/ubuntu安装苹方字体-程序员宅基地

文章浏览阅读4.6k次。苹方字体是苹果系统上的黑体,挺好看的。注重颜值的网站都会使用,例如知乎:font-family: -apple-system, BlinkMacSystemFont, Helvetica Neue, PingFang SC, Microsoft YaHei, Source Han Sans SC, Noto Sans CJK SC, W..._ubuntu pingfang

html表单常见操作汇总_html表单的处理程序有那些-程序员宅基地

文章浏览阅读159次。表单表单概述表单标签表单域按钮控件demo表单标签表单标签基本语法结构<form action="处理数据程序的url地址“ method=”get|post“ name="表单名称”></form><!--action,当提交表单时,向何处发送表单中的数据,地址可以是相对地址也可以是绝对地址--><!--method将表单中的数据传送给服务器处理,get方式直接显示在url地址中,数据可以被缓存,且长度有限制;而post方式数据隐藏传输,_html表单的处理程序有那些

PHP设置谷歌验证器(Google Authenticator)实现操作二步验证_php otp 验证器-程序员宅基地

文章浏览阅读1.2k次。使用说明:开启Google的登陆二步验证(即Google Authenticator服务)后用户登陆时需要输入额外由手机客户端生成的一次性密码。实现Google Authenticator功能需要服务器端和客户端的支持。服务器端负责密钥的生成、验证一次性密码是否正确。客户端记录密钥后生成一次性密码。下载谷歌验证类库文件放到项目合适位置(我这边放在项目Vender下面)https://github.com/PHPGangsta/GoogleAuthenticatorPHP代码示例://引入谷_php otp 验证器

【Python】matplotlib.plot画图横坐标混乱及间隔处理_matplotlib更改横轴间距-程序员宅基地

文章浏览阅读4.3k次,点赞5次,收藏11次。matplotlib.plot画图横坐标混乱及间隔处理_matplotlib更改横轴间距

docker — 容器存储_docker 保存容器-程序员宅基地

文章浏览阅读2.2k次。①Storage driver 处理各镜像层及容器层的处理细节,实现了多层数据的堆叠,为用户 提供了多层数据合并后的统一视图②所有 Storage driver 都使用可堆叠图像层和写时复制(CoW)策略③docker info 命令可查看当系统上的 storage driver主要用于测试目的,不建议用于生成环境。_docker 保存容器

随便推点

网络拓扑结构_网络拓扑csdn-程序员宅基地

文章浏览阅读834次,点赞27次,收藏13次。网络拓扑结构是指计算机网络中各组件(如计算机、服务器、打印机、路由器、交换机等设备)及其连接线路在物理布局或逻辑构型上的排列形式。这种布局不仅描述了设备间的实际物理连接方式,也决定了数据在网络中流动的路径和方式。不同的网络拓扑结构影响着网络的性能、可靠性、可扩展性及管理维护的难易程度。_网络拓扑csdn

JS重写Date函数,兼容IOS系统_date.prototype 将所有 ios-程序员宅基地

文章浏览阅读1.8k次,点赞5次,收藏8次。IOS系统Date的坑要创建一个指定时间的new Date对象时,通常的做法是:new Date("2020-09-21 11:11:00")这行代码在 PC 端和安卓端都是正常的,而在 iOS 端则会提示 Invalid Date 无效日期。在IOS年月日中间的横岗许换成斜杠,也就是new Date("2020/09/21 11:11:00")通常为了兼容IOS的这个坑,需要做一些额外的特殊处理,笔者在开发的时候经常会忘了兼容IOS系统。所以就想试着重写Date函数,一劳永逸,避免每次ne_date.prototype 将所有 ios

如何将EXCEL表导入plsql数据库中-程序员宅基地

文章浏览阅读5.3k次。方法一:用PLSQL Developer工具。 1 在PLSQL Developer的sql window里输入select * from test for update; 2 按F8执行 3 打开锁, 再按一下加号. 鼠标点到第一列的列头,使全列成选中状态,然后粘贴,最后commit提交即可。(前提..._excel导入pl/sql

Git常用命令速查手册-程序员宅基地

文章浏览阅读83次。Git常用命令速查手册1、初始化仓库git init2、将文件添加到仓库git add 文件名 # 将工作区的某个文件添加到暂存区 git add -u # 添加所有被tracked文件中被修改或删除的文件信息到暂存区,不处理untracked的文件git add -A # 添加所有被tracked文件中被修改或删除的文件信息到暂存区,包括untracked的文件...

分享119个ASP.NET源码总有一个是你想要的_千博二手车源码v2023 build 1120-程序员宅基地

文章浏览阅读202次。分享119个ASP.NET源码总有一个是你想要的_千博二手车源码v2023 build 1120

【C++缺省函数】 空类默认产生的6个类成员函数_空类默认产生哪些类成员函数-程序员宅基地

文章浏览阅读1.8k次。版权声明:转载请注明出处 http://blog.csdn.net/irean_lau。目录(?)[+]1、缺省构造函数。2、缺省拷贝构造函数。3、 缺省析构函数。4、缺省赋值运算符。5、缺省取址运算符。6、 缺省取址运算符 const。[cpp] view plain copy_空类默认产生哪些类成员函数

推荐文章

热门文章

相关标签