PB环境下分布式应用程序的开发
请选择段落导航
1.PB环境下分布式应用程序的开发(1)
2.PB环境下分布式应用程序的开发(2)
PB环境下分布式应用程序的开发(1)
一、分布式应用程序概述 分布式系统的出现源于传统的C/S结构的若干弊病,如效率低,安全性差等,结合到数据库方面来说,全球的DNS(域名解析系统)系统是一个很典型的例子,试想如果把全世界所有的域名都集中到一台服务器中来进行管理,那服务器肯定会因负载过重而无法正常工作,整个互联网也就瘫痪了。 在编写C/S结构的数据库应用系统时,同样也会遇到这类问题,那就是如果客户数量很多,数据量又都很大的情况下,服务器的负载就会很重,而且重复性工作很多,因为很多客户发出的查询可能完全相同而服务器却需要一一进行查询;同时查询算法存储于客户端,这可能不适合一些商业环境,因为算法本身可能是需要保密的。如果能够在传统的服务器和客户机之间再加一个服务器用于存储查询算法和临时查询结果,则以上问题均得到了解决。这正是分布式系统的工作原理。 二、在PB环境下如何进行分布式应用程序的开发 下图是分布式系统的工作原理图: 图(一) 首先,分布式服务器必须建立与数据库服务器的连接,可以通过ODBC&&接口来实现,本文不在叙述,下面要讲述客户端如何通过分布式服务器来访问数据。 在PB环境下要实现分布式的编程,首先在DTS端,需要用到两个对象,一个TransPort对象和一个不可视的用户对象(Classà Custom,Nonvisible Object,以下简称NVO),其中TransPort对象用于响应客户端的连接请求,NVO对象用于和客户端进行实际的数据传输。在客户端也需要用到两个对象,分别是Connection对象和代理对象(NVO-Proxy),其中Connection对象用于建立到DTS的连接,NVO-Proxy实际上是与NVO一一对应的,它只是NVO的一个代理,在客户端通过此代理对象来调用NVO的&&函数来实现相关功能。 以下是TransPort对象和Connection对象的常用&&属性及方法: 1、TransPort对象 &&属性: Driver:可选的值有四个,分别是WinSock、NamedPipes、OpenClientServer和Local,由于Winsock的通用性,一般情况下都选择Winsock。 Application:对于Winsock而言指的是端口号,用户可以任意指定,但必须大于4096。 方法: Listen():其调用方法是transport.Listen(),即开始监听,如果调用成功则返回0。 StopListening():其调用方法是transport.StopListening(),即结束监听,如果调用成功则返回0。 2、Connection对象 &&属性: Driver:与Transport对象相同 Application:与Transport对象相同,但要注意两者必须一致。 Location:DTS的IP地址 方法: ConnectToServer():其调用方法是connection.ConnectToServer(),即连接DTS,如果调用成功则返回0,显然在调用该&&函数之前,DTS必须处于监听状态。 DisconnectServer():其调用方法是connection.DisconnectServer ( ),即断开与DTS的连接。 CreateInstance():其调用方法是connection.CreateInstance(variable),即建立一个NVO的代理以便调用NVO的相关&&函数。注意在调用该&&函数之前,必须保证客户端已经与DTS建立了连接。 对于NVO和NVO-Proxy对象,在DTS中建好NVO后,为了在客户端设置其代理,可以先在DTS中设置本地代理,然后将此代理输出到客户端。具体设置方法如下:在PB的用户对象画板中,在用户对象上点击鼠标右健,选择"Set Proxy Name",输入代理对象的名称并存盘,打开PB的Library画板,找到刚才保存的代理对象,点击鼠标右健并选择"Export…"将此代理对象保存成文件,最后在客户端将此文件导入即可。导入以后,在客户端就可以通过此代理对象来调用NVO的&&函数了。
三、实例 先看如下两个图,图二表示DTS端,图三表示Client端。其中DTS已经建立了与数据库服务器的连接,数据窗口中显示的是所有的数据;Client并没有数据库&&接口,而是通过DTS间接的访问数据,在数据窗口中显示的是所有男性职工。 图(二) 图(三) 该程序的大部分源代码如下: DTS端: 1、首先定义一个全局变量:Transport mytrans; 2、在"开始监听"按钮中输入如下代码: long ll mytrans=create transport mytrans.driver="winsock" mytrans.application="5000" //端口号 mytrans.location="." //本地服务器 ll=mytrans.listen() //开始监听 if ll<>0 then messagebox(string(mytrans.errcode),mytrans.errtext) return end if server.settranspool(12,16,10) //设置连接缓冲,注意"server"为应用的名称 this.text="正在监听中..." this.enabled=false 3、在"结束监听"按钮中输入如下代码: mytrans.stoplistening() //结束监听 destroy mytrans cb_1.text="开始监听" cb_1.enabled=true 4、建立一个NVO: 利用PB的User Objects画板建立一个classàcustom的用户对象,建立用户对象&&函数nvoretrieve(ref blob buffer,string filter) returns long,&&函数体如下: long ll SQLCA.DBMS = "ODBC" SQLCA.AutoCommit = False SQLCA.DBParm = "Connectstring='DSN=person'" connect; //建立与数据库的连接 datastore datastore_buffer datastore_buffer=create datastore datastore_buffer.dataobject="dw_person" //dw_person是一个数据窗口 datastore_buffer.settransobject(sqlca) datastore_buffer.retrieve() datastore_buffer.setfilter(filter) datastore_buffer.filter() ll=datastore_buffer.getfullstate(buffer) //&&函数getfullstate()和setfullstate()常用于分布式应用程序。 disconnect; return ll 5、建立NVO的代理对象 在用户对象上点鼠标右健,选择"Set Proxy Name",输入"NVO_dw",保存用户对象。 打开Library画板,将"NVO_dw"输出为文件,以便在客户端导入该代理。 Client端: 1、打开Library画板,将刚才输出的文件导入 2、定义两个全局变量: connection myconn nvo_dw proxy_dw 3、在"连接"按钮中输入如下代码: long ll myconn=create connection myconn.driver="winsock" myconn.application="5000" //必须和DTS端的端口号一致 myconn.location="192.168.6.1" //DTS的IP地址 ll=myconn.connecttoserver() //建立连接 if ll<>0 then messagebox(string(myconn.errcode),myconn.errtext) return end if this.text="正在连接中..." this.enabled=false cb_2.enabled=true cb_3.enabled=true 3、在"断开"按钮中输入如下代码: myconn.disconnectserver() //断开连接 destroy myconn cb_1.enabled=true cb_1.text="连接" cb_3.enabled=false this.enabled=false
来源:十度教育 作者: 关键字:开发 发表日期:2006-5-29 11:57:03
网页显示有限 阅读全文请下载本文完整版WORD文档
上一篇:PB/Sybase系统开发中的数据库转移 下一篇:PowerBuilder实用技巧八则
共2页 9 7 [1 ] [2 ] 8 : >
2008-8-30 10:22:30