利用Flex实现P2P文件传送

<mx:Application xmlns:mx="http://www.adobe.com/2006/mxml" layout="absolute" addedToStage="init()">
?<mx:Script source="test/filesend.as"> </mx:Script>
?<mx:TextInput x="9" y="41" width="301" id="txtNearID"/>
?<mx:TextInput x="9" y="72" width="301" id="txtFarID"/>
?<mx:Label x="319" y="72" text="Target address"/>
?<mx:Label x="319" y="42" text="Your address"/>
?<mx:Button x="237" y="102" label="Validate" click="receive(event)"/>
?<mx:VBox??x="8" y="165" width="302" height="242" id="fileField" horizontalAlign="right">
??<mx:HBox width="100%" height="28">
???<mx:TextInput width="227" id="txtFile"/>
???<mx:Button label="Browse" click="browseHandler()"/>
??</mx:HBox>
??<mx:List width="302" height="143" id="fileList" ></mx:List>
??<mx:Button id="btnSend" label="Send" enabled="false" click="onFileSend(event)"/>
?</mx:VBox>
</mx:Application>

?

as代码：

//Importing the necessary classes
import mx.events.ItemClickEvent;
import mx.events.ListEvent;
import mx.controls.Alert;
//import mx.automation.events.ListItemSelectEvent;
import mx.collections.ArrayCollection;

// Creating constants for the stratus serveraddress and your developer key
private const SERVER_ADDRESS:String = "rtmfp://stratus.adobe.com/";
private const DEVELOPER_KEY:String = "d1206cd8a9de7cd4b0b960e3-73bf82f0a3dd";

//Creating variable for handling the incomming and outgoing data
private var netConnection:NetConnection;
private var sendStream:NetStream;
private var recievedStream:NetStream;

// Create a variabele for handling the files
private var file:FileReference;

// A Dataprovider for the listitem (to display downloads)
private var dp:ArrayCollection = new ArrayCollection;

private function init():void
{
?// Creating a new connection to the Stratus server
?netConnection = new NetConnection();
?netConnection.addEventListener(NetStatusEvent.NET_STATUS,netConnectionHandler);
?netConnection.connect(SERVER_ADDRESS+DEVELOPER_KEY);
}

public function netConnectionHandler(e:NetStatusEvent):void
{?
?// If there was a connection was made with the Stratusserver
?if(e.info.code == "NetConnection.Connect.Success")
?{
??// Adding your id to the NearID textfield
??txtNearID.text = netConnection.nearID;
??// Creating a new netstream that handles the outgoing data
??sendStream = new NetStream(netConnection,NetStream.DIRECT_CONNECTIONS);
??sendStream.addEventListener(NetStatusEvent.NET_STATUS,netStreamHandler);
??// Giving the stream a idName
??sendStream.publish("file");
?}
}

public function netStreamHandler(e:NetStatusEvent):void
{
?Alert.show(e.info.code);
}

private function receive(e:Event):void
{?
?// This functions handles the incomming data
?// Connection between you and the target
?recievedStream = new NetStream(netConnection,txtFarID.text);
?recievedStream.client = this;
?recievedStream.addEventListener(NetStatusEvent.NET_STATUS,incomingStreamHandler);
?// Using the "file" stream identification
?recievedStream.play("file");
}

public function incomingStreamHandler(e:NetStatusEvent):void
{
?
?// If there was a connection between you and the target
?if(e.info.code == "NetStream.Play.Start")
?{
??Alert.show(e.info.code);
??// set the textBackgroundcolor to green
??txtFarID.setStyle("backgroundColor","#00ff00");
??// show the fileBrowse/Send view
??fileField.visible = true;
?}
}

private function browseHandler():void
{
?// Creating a new FileReference to start choosing your file
?file = new FileReference;
?// Adding eventListeners
?file.addEventListener(Event.SELECT,selectHandler);
?file.addEventListener(IOErrorEvent.IO_ERROR,ioErrorHandler);
?file.addEventListener(ProgressEvent.PROGRESS,progressHandler);
?file.addEventListener(Event.COMPLETE,completeHandler);
?// Open the browse-file dialogue
?file.browse();
}

private function selectHandler(event:Event):void
{
?// If you selected a file to send
?file =??FileReference(event.target);
?// load the file
?file.load();
?// Set the source textfield to the filename
?txtFile.text = file.name;
}
private function completeHandler(event:Event):void
{
?// The file was loaded succesfully
?//Alert.show("completeHandler: " + event);
?//trace("completeHandler: " + event);
?// The send button will be enabled
?btnSend.enabled= true;
}

private function ioErrorHandler(event:IOErrorEvent):void
{
?trace("ioErrorHandler: " + event);
?//Alert.show("出错了: " + event);
}

private function progressHandler(event:ProgressEvent):void
{
?// Process??loading the file
?var file:FileReference = FileReference(event.target);
?//trace("progressHandler: name=" + file.name + " bytesLoaded=" + event.bytesLoaded + " bytesTotal=" + event.bytesTotal);
?//Alert.show("progressHandle提交: name=" + file.name + " bytesLoaded=" + event.bytesLoaded + " bytesTotal=" + event.bytesTotal);
?//Alert.show("chengong");
?
}

public function onFileSend(e:Event):void
{
?Alert.show("send: " + e);
?// Creating an object
?var fileData:Object = new Object();
?// Giving the object a property that container the file data as a ByteArray
?fileData.file = file.data
?// Property of the name of the file
?fileData.name = file.name;
?// Sending the file to the target and it will be received
?// by the 'onFileReceived' function
?sendStream.send("onFileReceived",fileData);
}

public function onFileReceived(info:Object):void
{
?Alert.show("888");
?// This functions handles the incomming data
?// We add the object to a dataprovider
?// For displayin the files in a list
?// Giving the name and file data as properties
?dp.addItem({label:info.name,file:info.file});
?// If an item of the list was clicked
?fileList.addEventListener(ListEvent.ITEM_CLICK,itemDownloadHandler);
?// Setting the dataprovider of the listcomponent
?fileList.dataProvider = dp;
}
private function itemDownloadHandler(event:ListEvent):void
{
?Alert.show("999999999");
?// creating new FileReference
?file= new FileReference();
?// saving the clicked item to your computer
?// brings out a savedialogue
?file.save(event.itemRenderer.data.file,event.itemRenderer.data.label);
}

说明：

FP10里，AS3提供了一个新的API用于支持RTMFP协义。连接到Stratus服务并创建点到点的流媒体就像是在FMS上工作一般。需要使用的的开发工具是Flash CS4或更高版本和Flash Builder4，运行环境需要在FP10以上或AIR1.5上。