基于消息中间件的异构数据集成实现.docVIP

基于消息中间件的异构数据集成实现 王峰，刘娟，鞠登峰，鲁丽萍，邹丹平 （中国电力科学研究院， 北京市 100192） Realization of Heterogeneous Data Integration Based on Message-oriented Middleware Wang Feng, Liu Juan,Ju Deng-feng, Lu Li-ping,Zou Dan-ping （China Electric Power Research Institute，Bei jing， 100192） ABSTRACT: This paper introduces the basic principles and features of message-oriented middleware,and puts forward the realization of heterogeneous data integration based on message-oriented middleware for the actual situation of the power company’s information systems. KEY WORD: message-oriented middleware;message queue; data integration; heterogeneous data 摘要：本文介绍了消息中间件的基本原理、特点，并针对供电公司信息系统的实际情况，提出一种基于消息中间件的异构数据集成实现方案。 关键词：消息中间件(MOM)；消息队列；数据集成；异构数据 1 引言 分层管理模式是在在国家政府机关和大型企业中普遍采用的一种管理模式，例如政府机关包括中央、省、市、县等若干级，大型企业一般又分为总公司、公司和生产厂等层次，为了加强上级机关/企业对下级的管理和各级机关/企业之间互通信息的需求，各级机构之间需要及时、可靠地交换大量的数据信息。由于这些数据，可能是不同的系统产生的，如财务系统、人事系统等，这些系统通常都是自治的，并且数据可能是异构的，但又是需要彼此交互的，因此这些机关和企业迫切需要在本机构内，建立一个数据传输和集成的平台。本文就是介绍一种基于消息中间件的数据集成实现方案。 2 消息中间件（MOM） 2.1 定义 消息中间件[2]是一种由消息传送机制或消息队列模式组成的中间件技术，利用高效可靠的消息传递机制进行平台无关的数据交流，并基于数据通信来进行分布式系统的集成。与其它中间件技术不同(例如ORB和RPC)，一般来说，消息中间件并不要求系统具备一个可靠的底部传输层，而是通过以消息的形式收发应用程序数据来连接运行于不同系统上的应用程序。信息可以同步传送，也支持异步传送。在异步方式下，应用程序并不需要消息即时即刻传送到对方，只是由MOM 确保把信息以消息的方式传送到适当的目的地，并且只传一次[1]。 2.2 通信模式 消息中间件主要有3种工作模式：点对点模式，发布/订阅模式以及消息队列模式。通常将点对点模式和发布/订阅模式统称为消息传递模式。 （1）点对点模式 点对点模式是一种程序到程序的直接通信模式。应用请求通过消息的形式直接从一个程序发送至另一个程序。双方的程序采用面向连接的形式相互通信，程序之间必须维持一条逻辑链路连接，所以点对点模式并不适合松耦合、时间独立应用程序采用。需要强调的是，这种直接的链路连接通常支持大多数的通信协议。 （2）订阅/发布模式 订阅/发布模式从现实的贸易应用演化而来。虽然这个模式目前来说仅仅被少数的产品所采用，但是这种技术已经到达了一定程序的成熟。它在由信息生产者事件驱动的商务系统的开发方面有很大的潜力[10]。 图1 订阅/发布模式 Fig.1 subscribe/publish model 如图1所示，在订阅/发布模式中，没有传统意义上的客户端和服务器，而是网络中进行信息发布的应用程序和接收某个特定主题信息的应用程序。发布消息的应用程序只需要简单地将消息以主题方式发送出去，由消息代理来负责将消息传递给所有订购该主题的订阅消息的应用程序。发布/订阅模式由于更加智能有效，事实上已成为消息中间件的非正式标准。 （3）消息队列模式 消息队列模式是一种程序之间的非直接的通信模式，它允许程序通过消息队列进行通信。消息队列模式通常意味着无连接模式，并不强制要求对方程序一定可用。如图2所示，消息放入队列（通常基于内存或者硬盘）直接或者按顺序传送。这种方式允许程序按照不同的速度独立运行，而不需要在双方之间建立一条逻辑连接。 图2 消息队列模式 Fig.2 message queue model 采用消息队列模式的中间件对企业分布式应用系统的开发具