微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

FLEX4 用RemoteObject同时调用多个服务端函数,且指定每个调用的回调处理函数(附下载地址)

  在用到FLEX的AMF信道进行远程通讯过程中,很多人都碰到一个问题:实例化一个RemoteObject对象,调用多个服务端函数和指定resultHandler()来作不同的处理。

    而且我们希望远程函数调用与本地的函数调用区别开来,新手进来也不容易困惑~!

   

    下面我们来讲讲以上的问题怎么解决

   

//1、派生一个RemoteObject来实现我们想要的功能
public class HtRemoteObject extends mx.rpc.remoting.mxml.RemoteObject

                  //指定认的失败回调函数,成功的回调在创建远程调用时指定,不需要认的,这样在我们使用时只要指定成功的回调就行了,失败的就用认的,这样省去每次都要指定两个回调的麻烦。
                  public var onResult:Function=null;
		
                  public var onFault:Function = HtRemoteObject.onFaultDefault;
                  // 用户自定义对象,在返回的事件中 e.token.ids 中可获取到,要扩展远程调用就是简单的事情了,哈哈。
		public var ids:Object=null;

		/**
		 * 构造函数
		 * @param destination    网关的终点
		 * @param source    远端函数的命名空间和类名,也就是远端函数所处的位置
		 * @param debug    是否连接调试服务器(调试模式)
		 * @param showBusyCursor    是否显示鼠标忙指针
		 *
		 */
		public function HtRemoteObject(destination:String=null,source:String=null,debug:Boolean=false,showBusyCursor:Boolean=false)
		{
			if(destination==null)
				destination=HtRemoteObject.DESTINATION;
			if(source==null)
				source=HtRemoteObject.SysInfoInterface;
				
			super(destination);
			super.source=source;
			super.showBusyCursor=showBusyCursor; //鼠标指针忙
			
			if (debug || fdgModel.config.isDebug)
			{
			//fdgModel为我的数据模型,大家可以自行构造自己的数据模型。
				super.endpoint=fdgModel.config.serverUrl + "/Gateway.aspx";//指定服务器端点调试时使用
			}
		}

                  /**
		 * 远程通讯,认的失败处理函数
		 * @param e 事件
		 *
		 */
		static public function onFaultDefault(e:FaultEvent):void
		{
			CursorManager.removeBusyCursor();	
			try {
				throw new HtError("远程服务器错误:" + mx.utils.ObjectUtil.toString(e),e.fault.faultCode as int);
			}
			catch (err:Error)
			{
				ht.errors.HtError.showError(err);
			}
		}

		/**
		 * 远程调用 Server 中的函数 
		 * @foo 函数名
		 * @args 参数列表
		 */
		public function call(foo:String,...args):void
		{
			if(foo.length==0)
				throw new Error("foo can not be empty!");
				
			//创建一个远程调用函数	
			var operation:AbstractOperation=this.getoperation(foo);
			//Token
			var call:AsyncToken = operation.send.apply(null,args);
			
			// ids 中承载了处理函数用户自定义ids,在 onDSResultParser onFaultParser 中解析和处理
			var idsWapper : Object = new Object;
			//使用自定的错误回调函数由onFaultParser调度,使用前要设定this.onFault
			idsWapper.onFaultCB = this.onFault;
			//使用自定的正确回调函数由onResultParser调度,使用时要设定this.onResult
			idsWapper.onResultCB = this.onResult;
			idsWapper.ids = this.ids;
			//如果要显示进程
			idsWapper.progress = progress;
			call.ids = idsWapper;
			//设定回调处理器
			call.addResponder(new mx.rpc.Responder(HtRemoteObject.onResultParser,HtRemoteObject.onFaultParser) as IResponder);			
		}

		/**
		 * 处理服务器返回的数据,如果正确,则调用'数据返回回调',错误调用'错误处理回调'
		 * @param evt 成功事件
		 * 
		 */		
		static protected function onResultParser(e:ResultEvent):void
		{
			try
			{
				var idsWapper : Object = e.token.ids;
				
				// 删除进度条对象
				if (null != idsWapper.progress)
				{
					var progress : UIComponent = idsWapper.progress as UIComponent;
					idsWapper.progress = null;
					if (null != progress && null != progress.parent && progress.parent.contains(progress))
						progress.parent.removeChild(progress);
				}
				
				CursorManager.removeBusyCursor();
				var onResult : Function = idsWapper.onResultCB as Function;
				e.token.ids = idsWapper.ids;
				if (null != onResult)
					onResult (e);
			}
			catch(err:Error)
			{
				ht.errors.HtError.showError(err);
			}
		}

		static protected function onFaultParser(e:FaultEvent):void
		{
			try
			{
				var idsWapper : Object = e.token.ids;
				
				// 删除进度条对象
				if (null != idsWapper.progress)
				{
					var progress : UIComponent = idsWapper.progress as UIComponent;
					idsWapper.progress = null;
					if (null != progress && null != progress.parent && progress.parent.contains(progress))
						progress.parent.removeChild(progress);
				}
				
				CursorManager.removeBusyCursor();
				
				var onFault : Function = idsWapper.onFaultCB as Function;
				e.token.ids = idsWapper.ids;
				if (null == onFault)
					onFault = HtRemoteObject.onFaultDefault;
				onFault(e);
			}
			catch(err:Error)
			{
				ht.errors.HtError.showError(err);
			}
		}

以下为升级版的补充说明:Flex远程调用批量打包通讯库

批量远程通讯接口类
  建议所有请求都使用本类
  数据缓冲池对象(FXGlobalModel)的rpc是本类的实例
     
使用的方法
1、基于数据缓冲池访问WS:设置onFault; onResult; addCaller; 即可
2、远程调用:如需要全部请求返回后进行回调处理,则设置 onAllResult; onAllFault; 这时,调用 commit 后才会提交addDSCaller、addCaller的请求
3、请用WSRemoteObject 此类,不要直接用HtRemoteObject 
4、返回的格式为:{ code: 0,ret: Object },错误时为:{ code: numErrorCode,what: strErrorMsg }
5、最佳使用方式:在某个单例对象中实例化WSRemoteObject :public var rpc:WSRemoteObject; 调用时可以 XXX.rpc....这样操作,如:
  XXX.currModel.rpc.onFault = onQueryFault;
  XXX.currModel.rpc.onResult = onQueryResult;
  XXX.currModel.rpc.addCaller(NetHandler.DATA_ACCESS_INTERFACE,"QueryOBD",queryInfo);
  //此行可以不用,不用时请在系统的某处判断rpc.callNumber>0时再commit(),也可以设定某个时间间隔来定时做此判断,比如3s或10s也可以1s,就看大家的需要了
  XXX.currModel.rpc.commit();

设置:
1、请在工程的编译参数加入-services引用此标准的RO设置(./WEB-INF/flex/services-config.xml)
2、以上文件包含此项endpoint(动态取URL值):<endpoint uri="http://{server.name}:{server.port}/{context.root}/[page.PHP|aspx|jsp]" class="flex.messaging.endpoints.AMFEndpoint"/>(请参考官方讲解)
3、debug开启时,可用FXConfig.SERVER_URL指定通讯地址
4、destination可通过FXConfig.CURR_DESTINATION 指定,但建议用-services的指定,如asp.net的为 fluorine ,PHP的为zend 或 amfPHP 等等,具体看用哪种服务端
补:使用时请详细查看API参考里的 FXConfig 类与 WSRemoteObject 类,再有就是 WSRemoteObject 支持的事件:RpcEvent.RPC_ERROR 此事件会在返回值code > 0 时发出,可以这样处理:
private function rpcErrorHandler(e:RpcEvent):void
{
  if (e.errorObject is Error)
    //LogError(e.errorObject as Error);
  else if (e.errorObject is FaultEvent)
    //LogErrorEvent(e.errorObject as FaultEvent);
}

附下载地址:http://code.google.com/p/flex-rpc/

请看完这个: http://code.google.com/p/flex-rpc/wiki/FlexRPC_Help

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。

相关推荐