基于IBM WebSphere MQ的商业银行数据推送技术的应用

文/杜丛强　曾庆妍

1　引言

IBM WebSphere MQ是一款基于消息传送或消息队列的商业通讯中间件，WebSphere MQ 技术可以广泛的实施在IBM平台和非IBM平台上。WebSphere MQ主要功能是在孤立的应用程序之间传送消息，消息可以在不同的应用软件、计算机系统和不同的网络协议之间进行传递。WebSphere MQ 提供了面向业务的信息技术框架，用户可以简单方便的基于该框架开发出高效、可靠的分布式应用程序系统。基于WebSphere MQ的应用程序更容易开发和维护，可以对商业问题进行有效的模拟。

2　IBM WebSphere MQ体系架构

2.1　客户机和服务器

WebSphere MQ支持在应用程序的客户机和服务器两端对其进行配置，客户端通过MQI通道与服务器进行通讯。客户机组件允许操作系统上运行的应用程序通过MQI调用另一个操作系统上的队列管理器。WebSphere MQ服务器是为客户提供排队服务的队列管理器，在服务器与客户机之间有专用的通信链路。当客户机连接到服务器时，客户机的应用程序发出与本地应用程序相同的MQI调用。当客户机发出MQ连接请求MQCONN调用时，会连接到指定的队列管理器，队列管理器处理从连接请求返回的其他MQI调用。

2.2　触发机制

队列管理器可以设置特定的触发条件，如果队列的触发条件被触发并且该队列被设置成触发队列，则队列管理器会将触发消息发送到启动队列中。本地或远程的应用程序A向应用队列中PUT一条消息，当队列为空时将会形成触发事件，同时产生一条对应的触发消息，触发消息包含进程定义的具体信息。队列管理器创建触发消息，并把它PUT到启动队列中，触发监控器从启动队列中GET出触发信息对其进行处理，发出启动应用程序B的命令，应用程序处理应用队列中的消息。

图1：商业银行核心系统数据推送功能示意图

3　IBM WebSphere MQ在银行核心系统中的应用

3.1　数据推送功能描述

商业银行核心系统要求数据推送具有很高的准确性和实时性。当核心业务系统某些信息发生变动时，需要及时通知其他系统，以便各系统以此信息为依据开展业务或进行风险管理。目前大多数商业银行是采用ESB系统轮询发起联机交易到核心系统查询消息档，发现需要推送的消息时，获取待推送信息并发送给短信通知平台。这种方式存在的问题是不能保证数据推送的时效性，同时也加重了ESB系统和核心系统的负担。

本文的目标是实现数据的主动推送机制。该机制的优点在于，只有当核心系统信息发生变动时，才触发推送；减少了各系统之间的通讯量，最大限度的降低了资源的占用；对于主机推送的重要信息，系统会在推送失败之后进行补救，确保信息不丢失，有效的保证了数据推送的可靠性和安全性。

3.2　数据推送功能设计与实现

应用程序负责组织推送消息并将消息保存到数据库的消息推送档中，核心系统程序在交易完成时将待发送消息写入本地的消息队列，再由监控程序写入MQ Client中的队列，ESB总线系统根据定义的报文格式将FORM解析成XML格式后，根据消息类型以及订阅系统的订阅方式进行消息发布。消息推送的具体流程如图1。

（1）核心系统应用程序需要消息推送时，调用平台的消息登记程序，将待推送的消息登记到消息推送档中。

（2）核心系统在交易正常完成结束后，对于需要实时推送的消息，通过消息推送程序将推送信息写入本地消息队列中，消息队列监控程序获取到推送消息后将其写入MQ Client中的队列。

（3）对于异步推送的消息，将由核心的轮询进程定时扫描消息推送档，一旦读取到待推送的消息记录时，将待推送消息记录写入到MQ Client中的队列。

（4）MQ Client 将队列中的推送消息发送到ESB总线系统的 MQ Server中的队列。

（5）ESB总线系统通过MQ Server将推送消息发送请求上送到信息交互平台或者其他订阅应用系统。

4　总结

本文首先介绍了IBM WebSphere MQ的体系框架，然后提出了一种商业银行核心系统数据推送方案，该方案能够有效的保证数据推送的可靠性和时效性。由于采用了IBM WebSphere MQ消息中间件技术，降低了整个核心系统和ESB系统的负载压力，使得整个核心系统和外围系统之间具备良好的兼容性和可扩展性，可以灵活的应对系统功能或性能方面新的变化。