业务数据集成VIP免费

1.1.1.功能概述业务数据集成是指MDMServer与外围系统之间的数据交换时需要中间处理的模块应用层。如图所示，外围系统主要通过三种模式与MDMServer交互(这里不考虑ETL)：直接的webservice访问–主要通过http协议联机访问，一般不通过业务集成层而直接访问数据服务层近实时的消息通知–主要通过MQ消息访问，需要在业务集成层进行必要的处理批量处理–主要通过文件进行数据传递，需要在业务集成层进行处理业务集成服务层的主要内容包括：近实时的消息通知数据标准代码的转换交易xml的拆分其他规则ExtPackageMDMinfrastructure数据服务层近实时处理业务集成层MDMDBModuleMQ个险BaseServicesHttp电商网上销售批量加载FTP(file)批量处理团险养老金银保电商自助服务架构服务层业务总控批量处理标准代码的转换入库方式判断处理，判断是否是新增还是更改交易拆分其他规则1.1.2.联机数据集成（基于MQ/XML）联机数据集成主要处理近实时消息通知，处理模式如下图所示。MQ组件是所有的客户信息更新消息的载体，MsgReceiver组件负责接收MQ的消息，通过MsgParser组件进行xml格式解析，MsgReceiver转交到IntegrateFW组件，IntegrateFW组件是转发框架，负责业务集成层的基本控制，根据报文的类型调用必要的规则处理进行数据转换或者信息拆分，然后交由具体逻辑处理实现模块IntegrateImpl完成业务集成逻辑，并最终通过ServiceInvocation模块调用MDM的服务，完成交易。数据服务层主要包括扩展服务和组合服务。如上图，根据业务需求，一般性的顺序如下详述：1ejbCreate–MQ中的信息通知WAS容器，根据MsgReceiver组件的MDB情况，创建一个实例进入池态；2onMessage–WAS容器调用MDB的onMessage方法，并把消息作为参数传递到该方法；2.1deliver–onMessage方法中调用IntegrateFW组件的deliver方法，并传递消息；2.1.1parse–IntegrateFW组件调用MsgParser组件解析传入的消息体；2.1.1.1Constructor–MsgParser组件根据消息体解析，生成一个IBObj对象；2.1.2parse–parse方法返回生成的IBObj对象；2.1.3getTCRMTxType–获取IBObj对象的服务类型；2.1.4getTCRMTxType–返回字符串结果；2.1.5getRequestName–获取IBObj的请求者；2.1.6getRequestName–返回；2.1.7Constructor–IntegrateFW根据服务对象和请求者，实例化一个IntegrateImpl组件中集成服务实例；2.1.8execute–调用具体实例的业务逻辑，并把IBObj作为参数传递；2.1.8.1callRule–调用标准代码转换规则，进行必要规则处理；2.1.8.2callRule–返回规则处理后的IBObj对象；2.1.8.3matchRule–调用客户识别规则，进行识别2.1.8.4matchRule–调用返回2.1.8.5constructIBObj–在具体的业务逻辑处理中，根据具体需要调用MsgParser创建需要的IBObj对象；2.1.8.5.1Constructor–MsgParser构建新的IBObj实例；2.1.8.6constructIBObj–返回具体的IBObj实例；2.1.8.7setAttribute–处理具体的IBObj实例内容；2.1.8.8setAttribute–处理内容返回；2.1.8.9toServiceXml–处理完所有的IBObj实例内容后，调用方法转换为xml标准服务格式；2.1.8.10toServiceXml–返回xml字节流；2.1.8.11invoke–调用MDM服务；2.1.8.12invoke–返回；2.1.9execute–完成具体业务集成逻辑实例的执行；2.2deliver–完成整个业务集成逻辑的执行；注：2.1.8到2.1.9之间可能有多次的callRule和invoke调用；2.1.8到2.1.9execute的调用需要包括在事务处理中；批量处理的业务集成层设计参见《批量型》章节。1.1.2.1.MsgReceiver组件MsgReceiver组件主要由IntegrateMDB组成，IntegrateMDB是一个MessageDriverBean，通过onMessage(Message)方法接收MQ的消息通知。信息接收组件主要负责从MQ接收消息，参数Message使用BytesMessage类型，消息格式为XML形式，其具体的接口定义参见《服务接口定义》中的相关通过MQ接口部分。接口主要包括：个险–增加客户(addPerson/CSCMQ)个险–保全修改客户(updatePerson/CSCMQ)电商网上销售–增加客户(addPerson/TOLMQ)电商网上销售–修改客户基本信息(updatePersonBase/TOLMQ)电商网上销售–保全修改客户(updatePerson/TOLMQ)注：以上括号中的...