FlashCom 连接器

本连接器代码是可支持Flashcom多端口(1935,443,80),多协议(rtmp,rtmps,rtmpt)扫描.

以下是Connector.as代码片段：

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

// Name:Connector.as

// Auther:Kinglong

// Email:kinglong@gmail.com

// Date:2005-06-29

// Desc:FCS连接器;

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

import mx.events.EventDispatcher;

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

class com.klstudio.fcs.Connector extends Object{

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

private var dispatchEvent:Function;

public var addEventListener:Function;

public var removeEventListener:Function;

public var target:Object;

public var index:Number;

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

private var __connectListArray:Array;

private var __host_name:String;

private var __app_name:String;

private var __connected:Boolean;

private var __connect_list_point:Number;

private var __connection_num:Number;

private var __connection_max_num:Number;

private var __connection:NetConnection;

private var __connection_params:Object;

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

private var __mar_next_connect:Number;

private var __mar_all_failed_connect:Number;

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

function Connector(host:String,app:String){

if(arguments.length>1){

this.__host_name = host;

this.__app_name = app;

}

this.initConnector();

}

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

// 初始化对象;

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

private function initConnector():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 = new Array();

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});

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

}

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

// 启动连接表;

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

private function doActualConnect():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;

var i:Number;

for(i=0;i<this.__connectListArray.length;i++){

this["temp_nc_"+i] = new NetConnection();

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

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

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

}

var connection_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);

}

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

// 下一个连接;

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

private function nextConnect():Void{

clearInterval(this.__mar_next_connect);

this.__connect_list_point ++;

if(this.__connect_list_point<this.__connectListArray.length){

var connection_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);

}

}

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

// 下一个连接;

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

private function allFailedConnect():Void{

clearInterval(this.__mar_all_failed_connect);

this.doActualConnect();

}

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

// 取消所有线程;

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

private function removeAllTimeOut(ncIndex:Number):Void{

if(arguments.length == 0){

ncIndex = -1;

}

clearInterval(this.__mar_next_connect);

clearInterval(this.__mar_all_failed_connect);

var i:Number;

for(i=0;i<this.__connectListArray.length;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();

delete this["temp_nc_"+i];&nb

[1] [2] 下一页