第3期 杨力，等：CIAgent平台上基于MAS的企业分布式数据库集成应用研究 ·77 环境 DIAgent 过滤器 地址薄 服务线程 客户线程 消息发送函数 良线程 接收线程 接收缓冲区 发送缓冲区 发送线程 444 图2网路通信模块结构 Fig.2 Network communication module structure 接收线程：是一个常驻线程，任务是不断检查接 bean的子类)设置一个属性，当过滤器收到KQML 收缓冲区的数据，一旦有消息进入接收缓冲区就启 消息后，就存放在属性中，于是就会产生一个属性改 动一个过滤线程来接受消息进行解释和处理 变事件，对应此事件，有一个监听者，在其中实现一 过滤器：过滤器解释并处理一些简单的且仅与 系统的处理KQML消息函数（即所谓注册函数） 网络通信模块有关的一些通信原语.如查询地址或 4 者告诉地址register,unregister等.网络通信模块 结束语 的过滤器功能比较弱，大部分与DIAgent有关的消 MAS系统是一种新分布式信息集成模式的核 息还是交给DIAgent去处理，过滤器对ANSDIA- 心技术.作为分布式数据库集成的一种方案，MAS gent特别有用 其实是对传统的静态和动态集成方法的一次革命 地址簿：网络通信模块保留DIAgent的地址信 通过在中石化川西采输处的实施，把MAS技术应 息.地址薄中包含DIAgent熟人的地址，比如： 用到采输处各分队相对独立的子数据库的集成中， Query PlanDIAgent保存有PhyQueryDIAgent 证明本系统具有良好的开放性、适应性和可操作性， 地址，不需查询ANSDIAgent,当然也可查询.对于 通过引入了DIAgent对支持网络分布计算环境的 通信服务器而言，地址簿保存有系统中所有己登记 支持，使得各计算机系统中的DIAgent实现问题协 的DIAgent地址， 作处理；虽然它在企业专网上实现，但它的跨平台 消息发送函数：网络通信模块的消息发送函数 性、移动性和弱连接性决定了它同样适合Internet 首先查阅地址薄中有没有目标DIAgent的地址，如 广域网，其本身所具有的优越性和强大生命力决定 果没有，先产生一个Query_address消息（增加的语 了它的发展前景必然十分广阔 用词)，向通信服务器查询目标DIAgent的地址，然 参考文献： 后将自己挂起一段时间，直到地址薄中出现目标 DIAgent的地址.如果持续一段时间还是得不到地 [1]GU P,BALASUBRAMANIAN S,NORRIE D H.Bid- 址，则发送失败.在知道了目标DIAgent的地址后， ding based process planning and scheduling in a multi-a- 消息发送函数把消息存放在发送缓冲区.网络通信 gent system[J ]Computers Industry Engineering,1997, 32(2):477.496. 模块主要是按照上层提供的逻辑地址，将其转换为 [2]HEECHEOL J CHARL ES P,MARK R C.A Java Agent 地下（消息接收则相反），并将KQML消息线型化 infrastructure with message routing[A].Stanford Center for (或反之)，然后打包发送或解包.消息发送函数与发 Design Research (CDR)[C].Stanford,USA,1999. 送线程之间均需要访问发送缓冲区，二者是生产者 [3]张洁，高亮，李培根.多Agent技术在先进制造中的 与消费者的关系，二者需进行同步 应用[M].北京：科学出版社，2004. 消息接收实现原理：在bean类(CIAgent是 [4]CARVER Z,CVETANOVIE Z,L ESSER V.Sophisti- 1994-2008 China Academic Journal Electronic Publishing House.All rights reserved.http://www.cnki.net图 2 网络通信模块结构 Fig. 2 Network communication module structure 接收线程 :是一个常驻线程 ,任务是不断检查接 收缓冲区的数据 ,一旦有消息进入接收缓冲区就启 动一个过滤线程来接受消息进行解释和处理. 过滤器 :过滤器解释并处理一些简单的且仅与 网络通信模块有关的一些通信原语. 如查询地址或 者告诉地址 register , unregister 等. 网络通信模块 的过滤器功能比较弱 ,大部分与 DIAgent 有关的消 息还是交给 DIAgent 去处理 ,过滤器对 ANSDIA2 gent 特别有用. 地址簿 :网络通信模块保留 DIAgent 的地址信 息. 地址薄中包含 DIAgent 熟人的地址 ,比如 : QueryPlanDIAgent 保存有 PhyQueryDIAgent 地址 ,不需查询 ANSDIAgent ,当然也可查询. 对于 通信服务器而言 ,地址簿保存有系统中所有已登记 的 DIAgent 地址. 消息发送函数 :网络通信模块的消息发送函数 首先查阅地址薄中有没有目标 DIAgent 的地址 ,如 果没有 ,先产生一个 Query_address 消息 (增加的语 用词) ,向通信服务器查询目标 DIAgent 的地址 ,然 后将自己挂起一段时间 ,直到地址薄中出现目标 DIAgent 的地址. 如果持续一段时间还是得不到地 址 ,则发送失败. 在知道了目标 DIAgent 的地址后 , 消息发送函数把消息存放在发送缓冲区. 网络通信 模块主要是按照上层提供的逻辑地址 ,将其转换为 地下(消息接收则相反) ,并将 KQML 消息线型化 (或反之) ,然后打包发送或解包. 消息发送函数与发 送线程之间均需要访问发送缓冲区 ,二者是生产者 与消费者的关系 ,二者需进行同步. 消息接收实现原理 : 在 bean 类 ( CIAgent 是 bean 的子类) 设置一个属性 ,当过滤器收到 KQML 消息后 ,就存放在属性中 ,于是就会产生一个属性改 变事件 ,对应此事件 ,有一个监听者 ,在其中实现一 系统的处理 KQML 消息函数(即所谓注册函数) . 4 结束语 MAS 系统是一种新分布式信息集成模式的核 心技术. 作为分布式数据库集成的一种方案 ,MAS 其实是对传统的静态和动态集成方法的一次革命. 通过在中石化川西采输处的实施 ,把 MAS 技术应 用到采输处各分队相对独立的子数据库的集成中 , 证明本系统具有良好的开放性、适应性和可操作性 , 通过引入了 DIAgent 对支持网络分布计算环境的 支持 ,使得各计算机系统中的 DIAgent 实现问题协 作处理 ;虽然它在企业专网上实现 ,但它的跨平台 性、移动性和弱连接性决定了它同样适合 Internet 广域网 ,其本身所具有的优越性和强大生命力决定 了它的发展前景必然十分广阔. 参考文献 : [1 ] GU P , BALASUBRAMANIAN S , NORRIE D H. Bid2 ding2based process planning and scheduling in a multi2a2 gent system[J ]. Computers Industry Engineering , 1997 , 32 (2) :477 - 496. [2 ] HEECHEOL J ,CHARL ES P ,MARK R C. A Java Agent infrastructure with message routing[A]. Stanford Center for Design Research (CDR) [C]. Stanford , USA ,1999. [3 ]张 洁 ,高 亮 ,李培根. 多 Agent 技术在先进制造中的 应用[ M]. 北京 :科学出版社 ,2004. [4 ]CARV ER Z , CV ETANOVIE Z , L ESSER V. Sophisti2 第 3 期 杨 力 ,等 :CIAgent 平台上基于 MAS 的企业分布式数据库集成应用研究 · 77 ·