视频技术

FFmpeg red5 nginx Html5 rtsp rtmp

·您当前的位置：首页 > 技术教程 > Rtmp技术 >

[AS3]adobe fms下p2p之实现图片分享功能源代码(2)

时间:2014-05-08 08:46yjmyzz
3、P2PFileShare.as 用于处理P2P文件分享(即从一个peer端发送另一个peer端) packagep2p { importflash.events.Event; importflash.events.EventDispatcher; importflash.events.NetStatusEvent; importflash.events

3、P2PFileShare.as 用于处理P2P文件分享(即从一个peer端发送另一个peer端)

  1. package p2p 
  2. { 
  3.     import flash.events.Event; 
  4.     import flash.events.EventDispatcher; 
  5.     import flash.events.NetStatusEvent; 
  6.     import flash.events.StatusEvent; 
  7.     import flash.net.GroupSpecifier; 
  8.     import flash.net.NetConnection; 
  9.     import flash.net.NetGroup; 
  10.     import flash.net.NetGroupReplicationStrategy; 
  11.     import flash.utils.ByteArray;   
  12.       
  13.     public class P2PFileShare extends EventDispatcher 
  14.     {   
  15.           
  16.         public var connected:Boolean = false; 
  17.           
  18.         public var netConnection:NetConnection; 
  19.           
  20.           
  21.         public var netGroup:NetGroup; 
  22.           
  23.         private const SERVER:String = "rtmfp://localhost/"; 
  24.         private const DEVKEY:String = "HelloServer"; 
  25.           
  26.         public var p2pSharedObject:P2PSharedObject; 
  27.           
  28.         public function P2PFileShare() 
  29.         { 
  30.         } 
  31.           
  32.         public function connect():void{ 
  33.             netConnection = new NetConnection(); 
  34.             netConnection.addEventListener(NetStatusEvent.NET_STATUS,netStatus);                
  35.             netConnection.connect(SERVER+DEVKEY); 
  36.         } 
  37.           
  38.         public function startSharing(p2pSharedObject:P2PSharedObject):void{ 
  39.             triggerEvent("startSharing - chunks shared: "+p2pSharedObject.packetLenght);            
  40.             this.p2pSharedObject = p2pSharedObject;         
  41.             netGroup.addHaveObjects(0,p2pSharedObject.packetLenght); 
  42.         } 
  43.           
  44.         public function startReceiving():void{ 
  45.             triggerEvent("startReceiving");         
  46.             p2pSharedObject = new P2PSharedObject(); 
  47.             p2pSharedObject.chunks = new Object();          
  48.             receiveObject(0); 
  49.         } 
  50.           
  51.           
  52.         protected function onGroupConnected():void{ 
  53.             netGroup.replicationStrategy = NetGroupReplicationStrategy.LOWEST_FIRST; 
  54.               
  55.         } 
  56.           
  57.         protected function netStatus(event:NetStatusEvent):void{ 
  58.             triggerEvent(event.info.code); 
  59.               
  60.             switch(event.info.code){ 
  61.                 case "NetConnection.Connect.Success": 
  62.                     setupGroup(); 
  63.                     break; 
  64.                   
  65.                 case "NetGroup.Connect.Success": 
  66.                     connected = true; 
  67.                       
  68.                     onGroupConnected(); 
  69.                       
  70.                     break; 
  71.                   
  72.                 case "NetGroup.Replication.Fetch.SendNotify": // e.info.index 
  73.                     triggerEvent("____ index: "+event.info.index); 
  74.                       
  75.                     break; 
  76.                   
  77.                 case "NetGroup.Replication.Fetch.Failed": // e.info.index 
  78.                     triggerEvent("____ index: "+event.info.index); 
  79.                       
  80.                     break; 
  81.                   
  82.                 case "NetGroup.Replication.Fetch.Result": // e.info.index, e.info.object 
  83.                     //triggerEvent("____ index: "+event.info.index+" | object: "+event.info.object); 
  84.                       
  85.                     netGroup.addHaveObjects(event.info.index,event.info.index); 
  86.                       
  87.                     p2pSharedObject.chunks[event.info.index] = event.info.object; 
  88.                       
  89.                     if(event.info.index == 0){ 
  90.                         p2pSharedObject.packetLenght = Number(event.info.object); 
  91.                         triggerEvent("p2pSharedObject.packetLenght: "+p2pSharedObject.packetLenght); 
  92.                           
  93.                         receiveObject(1); 
  94.                           
  95.                     }else{ 
  96.                         if(event.info.index+1<p2pSharedObject.packetLenght){ 
  97.                             receiveObject(event.info.index+1); 
  98.                         }else{ 
  99.                             triggerEvent("Receiving DONE"); 
  100.                             triggerEvent("p2pSharedObject.packetLenght: "+p2pSharedObject.packetLenght); 
  101.                               
  102.                             p2pSharedObject.data = new ByteArray(); 
  103.                             for(var i:int = 1;i<p2pSharedObject.packetLenght;i++){ 
  104.                                 p2pSharedObject.data.writeBytes(p2pSharedObject.chunks[i]); 
  105.                             } 
  106.                               
  107.                             triggerEvent("p2pSharedObject.data.bytesAvailable: "+p2pSharedObject.data.bytesAvailable); 
  108.                             triggerEvent("p2pSharedObject.data.length: "+p2pSharedObject.data.length); 
  109.                               
  110.                             dispatchEvent(new Event(Event.COMPLETE)); 
  111.                         } 
  112.                     } 
  113.                       
  114.                       
  115.                     break; 
  116.                   
  117.                 case "NetGroup.Replication.Request": // e.info.index, e.info.requestID 
  118.                     netGroup.writeRequestedObject(event.info.requestID,p2pSharedObject.chunks[event.info.index]) 
  119.                     // 
  120.                       
  121.                     triggerEvent("____ ID: "+event.info.requestID+", index: "+event.info.index); 
  122.                     break; 
  123.                   
  124.                 default: 
  125.                     break; 
  126.             } 
  127.         } 
  128.           
  129.         protected function setupGroup():void{ 
  130.             triggerEvent("setupGroup");         
  131.             var spec:GroupSpecifier = new GroupSpecifier("myGroup"); 
  132.             spec.serverChannelEnabled = true; 
  133.             spec.objectReplicationEnabled = true;       
  134.             netGroup = new NetGroup(netConnection,spec.groupspecWithAuthorizations()); 
  135.             netGroup.addEventListener(NetStatusEvent.NET_STATUS,netStatus);         
  136.         } 
  137.           
  138.           
  139.         protected function receiveObject(index:Number):void{ 
  140.             netGroup.addWantObjects(index,index); 
  141.             p2pSharedObject.actualFetchIndex = index; 
  142.         } 
  143.           
  144.         protected function triggerEvent(str:String):void { 
  145.             trace("P2pFilShare.triggerEvent CuPlayer.com被调用:str->", str); 
  146.             var e:StatusEvent = new StatusEvent(StatusEvent.STATUS,false,false,"status",str); 
  147.               
  148.             dispatchEvent(e); 
  149.         } 
  150.           
  151.           
  152.           
  153.     } 
  154. } 

最后的flash peer端：

运行截图

  1. package { 
  2.   
  3.     import fl.controls.Button; 
  4.     import fl.controls.TextArea; 
  5.     import fl.controls.TextInput; 
  6.     import flash.display.StageAlign; 
  7.     import flash.display.StageScaleMode; 
  8.     import flash.events.Event; 
  9.     import flash.events.StatusEvent; 
  10.     import flash.display.Loader; 
  11.     import flash.display.MovieClip; 
  12.     import flash.events.MouseEvent; 
  13.     import flash.net.NetGroupInfo; 
  14.     import p2p.LocalFileLoader; 
  15.     import p2p.P2PFileShare; 
  16.     import p2p.P2PSharedObject; 
  17.   
  18.   
  19.     public class p2p_FileShare extends MovieClip { 
  20.   
  21.         private var _btnBrowse:Button; 
  22.         private var _btnShare:Button; 
  23.         private var _btnReceive:Button; 
  24.         private var _txtOutput:TextArea; 
  25.         private var _txtReceive:TextInput; 
  26.         private var _txtSend:TextInput; 
  27.   
  28.         private var _localFileLoader:LocalFileLoader; 
  29.         private var _loader:Loader; 
  30.         private var _fileShare:P2PFileShare; 
  31.   
  32.         public function p2p_FileShare(){ 
  33.             // constructor code         
  34.             init(); 
  35.         } 
  36.   
  37.         private function init():void { 
  38.             this.stage.align = StageAlign.TOP_LEFT; 
  39.             this.stage.scaleMode = StageScaleMode.NO_SCALE; 
  40.   
  41.             this._localFileLoader = new LocalFileLoader(); 
  42.             this._localFileLoader.addEventListener(StatusEvent.STATUS, onStatus); 
  43.             this._localFileLoader.addEventListener(Event.COMPLETE, fileLoaderComplete); 
  44.   
  45.             _fileShare = new P2PFileShare(); 
  46.             _fileShare.addEventListener(StatusEvent.STATUS, onStatus); 
  47.             _fileShare.addEventListener(Event.COMPLETE, fileShareComplete); 
  48.               
  49.   
  50.             this._fileShare.connect(); 
  51.             this._loader = new Loader(); 
  52.             addChild(_loader); 
  53.             _loader.x = 218; 
  54.             _loader.y = 43.35; 
  55.   
  56.             this._btnBrowse = btnBrowse; 
  57.             this._btnShare = btnStartShare; 
  58.             this._btnReceive = btnReceive; 
  59.             this._txtOutput = txtOutput; 
  60.             this._txtReceive = txtReceive; 
  61.             this._txtSend = txtSend; 
  62.   
  63.             this._btnBrowse.addEventListener(MouseEvent.CLICK, _btnBrowse_Click); 
  64.             this._btnReceive.addEventListener(MouseEvent.CLICK, _btnReceive_Click); 
  65.             this._btnShare.addEventListener(MouseEvent.CLICK, _btnShare_Click); 
  66.         } 
  67.   
  68.         private function onStatus(event:StatusEvent):void { 
  69.             writeText(event.level); 
  70.             if (event.level == "NetGroup.Connect.Success"){ 
  71.                 _btnShare.enabled = false; 
  72.                 _btnReceive.enabled = true; 
  73.             } 
  74.             try { 
  75.                 refreshInfo(); 
  76.             } catch (e:Error){ 
  77.   
  78.             } 
  79.         } 
  80.   
  81.         private function fileLoaderComplete(event:Event):void { 
  82.             writeText("fileLoaderComplete"); 
  83.             _loader.unload(); 
  84.             _loader.loadBytes(_localFileLoader.p2pSharedObject.data); 
  85.             this._fileShare.startSharing(this._localFileLoader.p2pSharedObject); 
  86.             this._btnShare.enabled = true; 
  87.             this._btnReceive.enabled = false; 
  88.             this._btnBrowse.enabled = false; 
  89.         } 
  90.   
  91.         private function fileShareComplete(event:Event):void { 
  92.             writeText("fileShareComplete"); 
  93.             _loader.unload(); 
  94.             _loader.loadBytes(_fileShare.p2pSharedObject.data); 
  95.         } 
  96.   
  97.         private function writeText(txt:String):void { 
  98.             trace("p2p_FileShare.writeText 被调用:txt->", txt); 
  99.             this._txtOutput.appendText(txt + "\n"); 
  100.         } 
  101.   
  102.         private function _btnBrowse_Click(e:MouseEvent):void { 
  103.             this._localFileLoader.browseFileSystem(); 
  104.         } 
  105.           
  106.         private function _btnShare_Click(e:MouseEvent):void { 
  107.             this._fileShare.startSharing(this._localFileLoader.p2pSharedObject); 
  108.             this._btnShare.enabled = false; 
  109.         } 
  110.           
  111.           
  112.         private function _btnReceive_Click(e:MouseEvent):void { 
  113.             this._fileShare.startReceiving(); 
  114.         } 
  115.   
  116.   
  117.         protected function refreshInfo():void { 
  118.             var obj:NetGroupInfo = this._fileShare.netGroup.info; 
  119.             _txtReceive.text = obj.objectReplicationReceiveBytesPerSecond + ""; 
  120.             _txtSend.text = obj.objectReplicationSendBytesPerSecond + ""; 
  121.         } 
  122.     } 
  123.   
  124. } 

 

热门文章推荐

请稍候...

保利威视云平台-轻松实现点播直播视频应用

酷播云数据统计分析跨平台播放器