WebSphere Message Broker 介绍

1、1 附录二 websphere message broker介绍1.1 websphere message broker概述websphere message broker是 ibm 应用整合家族的另外一个重要组成部分，基于websphere mq开发，其产品部件如图 1。websphere message broker采用websphere mq提供的可靠消息服务（不丢失，不复传）在应用系统之间通过基于消息的异步方式集成各应用系统。针对不同系统所处理的消息格式各不相同的特点，websphere message broker 提供了专门的格式代码转换器(formatter)在不同的消息格式之间

2、按照预先定义好的转换规则进行自动的格式转换，然后将结果自动路由到目标应用系统。在消息转换的过程中websphere message broker能够识别xml，c结构，jms，soap等多种消息格式；对消息的各种操作包括消息的来源、消息的目标应用、所期望的消息格式等通过定义各种操作规则(rules)进行。图 1websphere message broker产品部件每个业务事件的核心是应当被捕捉并向您企业内的人员和应用发布的重要信息。例如，当客户访问您的网站时，您的客户关系管理（crm）系统将接收到这个人的浏览和购买习惯的信息。根据客户的动作，可能会触发您的制造系统，并通知仓库供货时间计划。会

3、计部门可能需要信用卡编号或购买订单授权，送货部门可能需要一个地址。其它的分析趋势或提供最新的执行概要的内部系统还将需要同时进行更新。websphere message broker实时地将来自多种设备和地点的信息传送给您企业内外的人员和应用。快速、高效地分发来自例行业务活动的信息的能力对于您成功运营电子商务来说至关重要。为便于提供快速、富有根据的决定以便提示合适的动作，您必须为正确的人和正确的应用在正确的时间提供正确的信息。当一个信息源被更新时，这些变化必须立即发布给所有受到影响的系统，以便您企业内的数据可以自动更新。ibm websphere message broker多平台6.0版为实施

4、集成消息和事件提供了一个灵活的基础架构。无论这些业务事件在何时、何地发生，您多可以捕捉到目标信息，并将它立即发送到需要它的应用和人员。您可以集成web交易、与贸易伙伴交换的数据、来自第三方打包应用的数据或时间极为重要的事件的现场数据，例如金融市场上发生的数据。通过扩大您的集成范围，使您可以集成您企业内的人员、应用和事件，您可以成为随需应变的企业 - 可以智能适应当前的市场环境，快速应对持续变化的商业需要，随需应变。1.2 websphere message broker的功能websphere message broker是一个数据交换平台，实现应用之间的集成，如图 2。图 2webspher

5、e message broker实现数据交换websphere message broker的功能：l 实时地向您无处不及的人员、应用、移动和无线和遥测设备提供业务事件信息l 支持多种传输协议，将您的业务范围扩展到防火墙之外l 利用一致的图形化开发环境，大幅提升整个websphere平台的效率和技能。l 简单的一次点击即可完成安装，加速部署l 将集成逻辑与应用相分离，提高业务的灵活性，帮助降低开发成本l 简化原本不能兼容的应用之间的通讯1.2.1 实时与您无处不及的企业共享信息对于很多业务事件来说，您都需要一个代理来负责在具有相同的消息结构的应用之间的消息协调工作。但是有时您还可能需要与一个使

6、用消息结构或格式与您的接收应用不同的贸易伙伴交换信息。例如，您可能需要在您的crm和供应链管理数据库之间交换应用，以便确定对于促销事件需要保存多少、哪些类型的商品。websphere message broker构建在websphere event broker 的基础之上，在基础的代理功能上，增加并丰富了传递中的消息转换功能，还增加了数据库集成功能。这样您就可以与贸易伙伴和客户实时地交换信息 - 通过事件触发的更新同步多个数据库，并为当前的业务状况提供了一份清晰的图象。带有规则和格式定制器扩展的websphere message broker增加了一个高性能的规则功能，使用预定义的标准来处理

7、具有复杂结构和多个变量的消息。因此，如果一条消息中包含多个字段 - 例如货币、金额、客户和位置 - 您可以使用new era of networks rules，根据所有这些字段来确定消息的处理。1.2.2 可靠、一致地管理业务事件带有规则和格式定制器扩展的websphere message broker增加和更新接收应用所必须的消息字段，丰富了传输中的信息，使您的业务应用无需更改。例如，您可以将运行在使用结构化数据格式（例如xml）的平台之上的一个应用与使用面向记录格式的应用集成在一起。使用代理可以帮助您：l 管理放置在分散的分部或分部的独立系统之间的信息流 - 或与您的防火墙之外的贸易伙伴

8、交换的信息。l 构建一个万能的企业集成总线 - 或一个体系结构框架 - 使您可以针对各种情况、应用和设备，可靠地在安全环境中执行业务。l 不再需要手工重新键入数据，减少了费用和错误率。l 快速一致地向正确的应用和人员发送最新的业务信息1.2.3 利用定制的信息流优化响应带有规则和格式定制器扩展的websphere message broker是建立在开放行业标准和行业领先的ibm websphere mq之上的一个灵活的消息基础设施，不管消息位于哪里，以 何种方式存储，它都帮助您有效地利用业务事件信息。它可以在众多的平台上提供可靠的一次并且唯一一次发送信息的功能，使您可以根据在各种类型的业务活

9、动中收集到的信息，优化您无所不及的企业的响应速度。并可以根据策略或业务规则来构建信息流，在人员和应用之间发布信息。您可以根据需要直接监视来自现场的遥测生产数据，在远程调整管线的流动。您可以精确地发现何时需要转移生产资源以便快速提高送货量。您还可以根据特定的需求向员工或应用发送特定的市场数据信息。通过将消息的路由逻辑与应用相分离，带有规则和格式定制器扩展的websphere message broker使您可以灵活地更改消息路由的途径，无需更改所涉及到的应用。不管从传统方式上看，信息是在您企业内部生成的，还是在外部生成的，您都可以与您的核心应用集成，让您保持竞争优势。1.2.4 集成无界限带有规

10、则和格式定制器扩展的websphere message broker提供了一种灵活的传输协议 - 包括websphere mq 产品系列中的传输协议 - 将您的企业范围延伸到您的防火墙之外。利用遥测传输，您可以配置任何传感器或控制设备与您的企业集成总线代理通讯。实际环境中发生的事件的相关信息都将被自动捕捉到，并用来推动关键的业务活动。您可以依次控制和管理您企业中实际的活动。通过集成多种消息类型，包括简单对象访问协议（soap）、电子数据交换（edi）、c、cobol和xml，您可以在贸易合作伙伴、客户和员工之间共享数据。您的顾问和服务伙伴还可以定制消息和消息流，使用java?技术或c代码创建代

11、理插件，采用特定的消息路由、分析或转换算法。您可以根据您特定的需要，根据主题或内容控制消息的发布，选择多播或单播协议来发送群组消息。要同时向多个员工或应用提供相同的消息，可以使用多播协议来发送消息。但是当您要尽量高效地向个员工或应用发送不同的信息，则需要选择单播协议。通过在您的网络中放置多个代理，进行集中控制，您可以避免单点故障，方便地管理分散系统之间的信息流。通过集中控制，您可以协调业务事件的处理，采用一致的处理方式，使您的系统更为高效地工作。1.2.5 图形化的开发环境加快部署速度使用带有规则和格式定制器扩展的websphere message broker中提供的图形化开发环境，可以直观

12、地构建消息流模型和代理拓扑。建模和可视化技术可以帮助开发人员发现设计缺陷，从而可以更快地生成更高质量的结果，加速体现价值。这个工具平台建立在ibm websphere studio workbench的基础之上，它使用开放源码的eclipse框架，其观感与其它的ibm和第三方工具插件保持一致。这个工具简化了调试和部署工作，并支持代码库，方便了团队合作。利用websphere业务集成产品系列这个完整的工具模型，可以保护您的投资，使用现有资源在众多领先的平台上部署解决方案。1.2.6 快速启动利用带有规则和格式定制器扩展的websphere message broker，您可以快速安装和部署您的解

13、决方案，其易于使用的特性帮助您快速获得价值。这些特性包括：l 一次点击即可完成安装l 在您使用的过程中随时获得帮助，提供上下文敏感的帮助l 预定义的配置和样本配置1.2.7 利用市场领先的业务集成解决方案满足要求高效灵活地组合资源使您可以优化您企业内外的业务运作。将分散的资源、数据、应用和流程捆绑在一起，您可以创建一个协作的环境来统一您整个的需求链，加速获得投资回报，快速获得价值。利用ibm的websphere业务集成解决方案，您可以连接：l 员工。通过集成业务流程，您的客户、员工、合作伙伴和供应商可以更为有效地与您的企业交互。l 流程。通过水平地管理和协调您整个的业务，您的it基础架构可以与

14、需求 - 与您的商业目标 - 保持同步。l 信息。通过实时地访问分散的信息，员工和流程可以充分利用来自多个资源库的数据和内容资源。在您向随需应变电子商务转型的过程中，您需要提高效率，简化流程，充分利用现有资源，提供及时、动态、个性化的信息，帮助构建长期的关系。websphere业务软件系列帮助您的企业更为关注核心业务。灵活。弹性。更好地应对机会 - 和崩溃 - 都将会影响您未来的发展。1.2.8 websphere message broker是一个战略性的开放框架它以早期版本为基础并对其功能进行扩展，拥有强大的功能以及为整个商业集成领域实现增值的能力，使客户能够更容易地在一个简单、开放而又可

15、扩展的框架内将不同的应用程序连接在一起。这样，供应商就有机会增强自己的产品，进一步增加为客户提供的产品的价值。在提供这一开放的框架时，ibm使客户能够在一个相对较短的时间内完成基础结构的创建。这样，客户就可以充分利用新的机会来拓展市场，同时增加对现有的应用进行连接时的效率。随着将来出现更多的可用节点，使用本产品创建的消息流能够以更快更容易的方式实现更完善的解决方案。与mq家族其他新增强的功能一道，websphere message broker的这一版本能够满足21世纪企业应用集成的需要。1.2.9 应用程序格式转换和智能路由功能作为各个应用的数据吞吐机，提供多种数据格式服务，其中包括：用户自

16、定义格式，用户可以为每一种应用定制自己的消息格式，通过这种消息格式来连接原有的旧的应用； xml格式；面向纪录的信息格式，如c的头文件，cobol records等。对于这些消息格式，提供相应的剖析器进行解析，实现它们之间的格式转换。如对于用户的bit stream的输入信息可以输出为xml的格式，反之亦然。从而无缝地连接现有的应用，并可以采用xml的新标准开发新的应用。提供检查和过滤功能，根据所传输数据的内容做动态路由。1.2.10 强大的数据处理功能作为各个应用的数据处理机，对经过bpi的数据进行各种处理操作，如计算、过滤等，使得数据在从bpi经过时便可以被进行相应地计算，从而发往目的应用

17、系统；支持数据仓库，对各应用系统所传输的数据进行集中记录，便于以后的审计和分析。1.2.11 对各种应用系统的接口功能提供强大的连接性，既提供各种与现有商业应用连接的adapter，可以将企业内部各种应用系统进行无缝连接，如sap, notes, sibel, swift, people soft, i2 等，支持各种标准数据格式或应用的接口，如xml, jdbc，对于这些应用可以不必开发新的接口，减少开发的工作量；同时提供应用程序接口，以开发客户化的连接件。1.3 websphere message broker产品特点ibm websphere message broker建立在websp

18、here mq之上，增加了一个强大的消息流程引擎，它是一个为提供关键任务商业集成工具和过程而设计的框架。由于它能够在不要求改变现有程序和数据的情况下为其增加新的功能，所以可以帮助您创建您自己的解决方案并可增强现有的解决方案。并提供以下功能特性：l 实时地向您无处不及的人员、应用、移动和无线和遥测设备提供业务事件信息l 支持多种传输协议，将您的业务范围扩展到防火墙之外l 利用一致的图形化开发环境，大幅提升整个websphere平台的效率和技能。l 简单的一次点击即可完成安装，加速部署l 将集成逻辑与应用相分离，提高业务的灵活性，帮助降低开发成本l 简化原本不能兼容的应用之间的通讯l 提供集中控制

19、，提供可配置的任意数据之间的转换和信息发布，消除繁琐的编程和软件维护l 底层基于mq的星形架构，确保消息传输的最简化连接方式l 消息流程建模：流程控制，流程特殊情况处理(反馈，失败)l 使用集线器和轮辐（spoke）模型可以使应用集成获得更高的连接效率l 对数据进行转换，同时可以确定应用之间的路由选择l 将商业逻辑和应用逻辑和数据逻辑分离开l 提供附加的商业应用功能，如发布/预订l 可以添加现有供应商和新供应商产品的集成框架，以实现进一步的增值l 与消息和关系数据库实现无缝的集成l 实现xml消息格式和其他数据格式之间的映射l 格式转换(xml, c, mrm, jms, tds分隔符, al

20、3, db，swift, iso8583 等多种格式)l eai开发支持：支持jms，支持权限管理，支持增强的pub/sub(发布/订阅)机制，内置的xml开发支持，数据库开发支持，分布事务处理，转换和路由的内嵌支持。l 可靠传输质量保证。l java 和web service 支持。1.4 websphere message broker的优势从信息交换平台的长远发展来看，要形成相互一致的业务基础信息系统和有效运行的信息层次化体系，必然需要将现在建设的和未来要扩建的各个业务应用系统平滑地整合在一起，使得各个业务系统间能够顺畅地传递信息，形成一个有机的整体，在整个系统范围内实现信息的高度共享。

21、1.4.1 产品构架优势websphere message broker的产品构架优势为：l 开放性：基于事实上的工业标准的消息中间件，能确保和其他系统的开放连接。l 扩展性：系统应该具有强大扩展伸缩能力，增加和改进应用不会对原有系统造成破坏。l 移植性：也就是尽量减少非业务的纯粹特定产品的配置。l 子系统的独立性：建立应用信息交换平台的在于连接各个子系统，而各个子系统应该尽量减少功能耦合性。应用信息交换平台和子系统的开发只针对报文，无须了解对方处理的实际过程。l 便于实现高可用性 (ha)和负载均衡管理(wlm)。l 可靠传输质量保证。l java 和web service 支持。1.4.2

22、 从网状结构到星形结构，大大简化mq的配置和管理websphere mq 消息中间件作为搭建统一的数据传输平台的核心工具，作为websphere mq 家族产品中的一员，websphere message broker和websphere mq的无缝整合不用质疑的。信息平台多套业务应用系统以及进驻各部门的应用系统只需通过本地的websphere mq与统一的数据整合系统的websphere message broker相联来完成数据的发送和接收，而数据的格式转换和智能路由的选择由websphere message broker负责，这样将来不论是增加新系统和删除旧系统都不影响到其它应用系统的配

23、置，使整个综合信息平台的规划和管理得到很好的优化。1.4.3 不同格式的数据转换websphere message broker通过消息字典来对来自不同应用系统传来的消息内容进行识别和解析，还可以根据不同的消息通过定制不同的消息流来输送到不同的应用系统。这是非常适合信息平台如何建立一个数据集中、交换，并支持系统平滑地扩展这样的基础数据交换支撑平台的需求，以后对现有系统的扩展将不会影响整个系统的架构。例如：根据输入数据的内容映射到输出数据：当输入数据.complaint.type = order时，输出数据.admin.dept=b01当输入数据.complaint.type = order时，

24、输出数据.admin.dept=c01输出数据格式=xml1.4.4 全面支持xmlxml被用于websphere message broker的核心。产品的所有配置数据都采用了xml格式。一旦一个消息以消息格式的形式被定义到mrm，那么在需要时就可以将消息的输出格式也定义为xml。因此，在消息代理程序内部可以根据非xml的消息格式生成xml消息。1.4.5 各种node组成的message flow处理节点对消息流内的消息执行不同的操作。消息流由一个输入节点发起，该节点启动一个流经消息流的消息。如下所述，websphere message broker 2.1包含了一个mqinput节点，它

25、可以从一个websphere mq队列中读取一个消息。这一节点将与其他的节点相连。尽管节点之间的连接被称为连接器，但这些构造纯粹是为了帮助将控制中心图形工具中的节点捆绑在一起。消息实际上是通过方法调用请求在节点之间传递的，这些请求中包含了一个指向在节点间被传递的消息对象的指针。可以对每一个消息流中节点的属性进行客户化处理。这将使节点能够对流经自己的消息执行特定的功能，并执行消息流要求节点执行的处理过程。1.4.6 与数据库紧密集成websphere message broker提供了与db操作相关的各种node, 如insert,update,delete等node，用户可以通过esql进行和

26、数据库的操作，如把数据存入数据库，从数据库中取数据等；信息平台可以将整个系统中产生的大量数据记录在数据中心中，以备进一步决策分析、数据挖掘，实现更深层次的数据利用。作为统一的数据整合平台，websphere message broker可以直接操作不同应用系统的数据库，实现各部门的数据高度共享。1.4.7 功能强大的发布预订系统l 基于内容和主题的过滤将发布和预订（publish and subscribe）功能添加到信息代理程序中以后，增加了该系统的功能价值。将发布/预订代理程序的优势与websphere messages broker的功能结合在一起，可以获得额外的好处。对于信息的订户，它们将不仅能够接收到自己所要求的信息，而且还可以根据自己的需要在任何级别上对信息进行过滤和格式化处理。作为一个标准的发布和预订系统，向订户提供信息的时候可以不必知道何人将会需要这些信息，因而也不必知道向何人发送这些信息。发布/预订系统的用途在于，它极大地提高了选择标准的精炼程度。每一个主题当中都包含了大量订户并不需要的信息，即使主题与订户要求的主题相匹配。因此，通过提高发送往订户的消息的选择精炼程度，以及通过基于内容的预订，将可以实现一种选择性更