FlashCom 连接器

//Name:Connector.as

//Auther:Kinglong

//Email:kinglong@gmail.com

//Date:2005-06-29

//Desc:FCS连接器;

//=======================================;

importmx.events.EventDispatcher;

//=======================================;

classcom.klstudio.fcs.ConnectorextendsObject{

//======================================;

privatevardispatchEvent:Function;

publicvaraddEventListener:Function;

publicvarremoveEventListener:Function;

publicvartarget:Object;

publicvarindex:Number;

//======================================;

privatevar__connectListArray:Array;

privatevar__host_name:String;

privatevar__app_name:String;

privatevar__connected:Boolean;

privatevar__connect_list_point:Number;

privatevar__connection_num:Number;

privatevar__connection_max_num:Number;

privatevar__connection:NetConnection;

privatevar__connection_params:Object;

//=======================================;

privatevar__mar_next_connect:Number;

privatevar__mar_all_failed_connect:Number;

//=======================================;

functionConnector(host:String,app:String){

if(arguments.length>1){

this.__host_name=host;

this.__app_name=app;

}

this.initConnector();

}

//========================================;

//初始化对象;

//========================================;

privatefunctioninitConnector():Void{

//=======================================;

EventDispatcher.initialize(this);

//=======================================;

this.__connected=false;

this.__connection_num=0;

this.__connection_max_num=3;

this.__connection=null;

this.__connection_params=null;

//=======================================;

this.__connectListArray=newArray();

this.__connectListArray.push({protocol:"rtmp",port:1935});

this.__connectListArray.push({protocol:"rtmp",port:443});

this.__connectListArray.push({protocol:"rtmpt",port:80});

this.__connectListArray.push({protocol:"rtmps",port:443});

//=======================================;

}

//========================================;

//启动连接表;

//========================================;

privatefunctiondoActualConnect():Void{

this.removeAllTimeOut();

this.__connection_num++;

if(this.__connection_num>this.__connection_max_num){

this.myTrace("总共尝试"+this.__connection_max_num+"次都失败!");

this.dispatchEvent({type:"failed",data:"服务器连接失败!"});

return;

}

this.__connect_list_point=0;

vari:Number;

for(i=0;i

this["temp_nc_"+i]=newNetConnection();

this["temp_nc_"+i].index=i;

this["temp_nc_"+i].target=this;

this["temp_nc_"+i].onStatus=this.doStatus;

}

varconnection_uri:String=this.__connectListArray[this.__connect_list_point].protocol+"://"+this.__host_name+":"+this.__connectListArray[this.__connect_list_point].port+"/"+this.__app_name;

this.myTrace("[尝试"+this.__connection_num+"/"+this.__connection_max_num+"]连接到"+(this.__connect_list_point+1)+"/"+this.__connectListArray.length+":"+connection_uri);

this.dispatchEvent({type:"connect",data:this.__connectListArray[this.__connect_list_point]});

this["temp_nc_"+this.__connect_list_point].connect(connection_uri,this.__connection_params);

this.__mar_next_connect=setInterval(this,"nextConnect",3000);

}

//========================================;

//下一个连接;

//========================================;

privatefunctionnextConnect():Void{

clearInterval(this.__mar_next_connect);

this.__connect_list_point++;

if(this.__connect_list_point

varconnection_uri:String=this.__connectListArray[this.__connect_list_point].protocol+"://"+this.__host_name+":"+this.__connectListArray[this.__connect_list_point].port+"/"+this.__app_name;

this.myTrace("[尝试"+this.__connection_num+"/"+this.__connection_max_num+"]连接到"+(this.__connect_list_point+1)+"/"+this.__connectListArray.length+":"+connection_uri);

this.dispatchEvent({type:"connect",data:this.__connectListArray[this.__connect_list_point]});

this["temp_nc_"+this.__connect_list_point].connect(connection_uri,this.__connection_params);

this.__mar_next_connect=setInterval(this,"nextConnect",3000);

}

}

//=========================================;

//下一个连接;

//=========================================;

privatefunctionallFailedConnect():Void{

clearInterval(this.__mar_all_failed_connect);

this.doActualConnect();

}

//=========================================;

//取消所有线程;

//=========================================;

privatefunctionremoveAllTimeOut(ncIndex:Number):Void{

if(arguments.length==0){

ncIndex=-1;

}

clearInterval(this.__mar_next_connect);

clearInterval(this.__mar_all_failed_connect);

vari:Number;

for(i=0;i

if(i==ncIndex){

this.myTrace(this.__connectListArray[ncIndex].protocol+"://"+this.__host_name+":"+this.__connectListArray[ncIndex].port+"/"+this.__app_name+"连接尝试成功!");

}else{

this["temp_nc_"+i].close();

deletethis["temp_nc_"+i];

}

}

}

//=========================================;

privatefunctiondoStatus(ncInfo:Object):Void{

this.target.onStatus(this.index,ncInfo);

}

//=========================================;

privatefunctiononStatus(ncIndex:Number,ncInfo:Object):Void{

switch(ncInfo.code){

case"NetConnection.Connect.Success":

this.removeAllTimeOut(ncIndex);

this.__connection=this["temp_nc_"+ncIndex];

this.__connected=true;

this.dispatchEvent({type:"success"});

break;

case"NetConnection.Connect.Failed":

this.myTrace(this.__connectListArray[ncIndex].protocol+"://"+this.__host_name+":"+this.__connectListArray[ncIndex].port+"/"+this.__app_name+"连接尝试失败!");

if(ncIndex==this.__connectListArray.length-1){

this.myTrace("所有连接尝试失败!");

this.removeAllTimeOut();

this.__mar_all_failed_connect=setInterval(this,"allFailedConnect",5000);

}

break;

case"NetConnection.Connect.Closed":

case"NetConnection.Connect.AppShutdown":

this.dispatchEvent({type:"closed"});

break;

case"NetConnection.Connect.Rejected":

this.removeAllTimeOut();

this.myTrace("FlashCom服务器不接收连接尝试!");

this.dispatchEvent({type:"failed",data:ncInfo.application.message});

break;

}

}

//=========================================;

//调试;

//=========================================;

privatefunctionmyTrace(msg:Object):Void{

trace("#Connector#:"+msg);

getURL("FSCommand:log","#Connector#:"+msg);

}

//=========================================;

//设置连接参数;

//=========================================;

publicfunctionsetConnectParams(param:Object):Void{

this.__connection_params=param;

}

//=========================================;

//设置连接表;

//=========================================;

publicfunctionsetConnectListArray(arr:Array):Void{

this.__connectListArray=arr;

}

//=========================================;

//设置最大尝试连接资料;

//=========================================;

publicfunctionsetConnectMaxNum(num:Number):Void{

if(num>1&&num<11){

this.__connection_max_num=num;

}

}

//=========================================;

//连接FCS服务器;

//=========================================;

publicfunctionconnect():Void{

if(this.__connected)return;

this.__connection_num=0;

this.doActualConnect();

}

//=========================================;

//检查是否连接成功;

//=========================================;

publicfunctionisConnected():Boolean{

returnthis.__connected;

}

//=========================================;

//获取主连接NC;

//=========================================;

publicfunctiongetConnection():NetConnection{

returnthis.__connection;

}

}