ActionScript vedioDisplay rmtp

公司要用flash实现实况转播,好不容易把实验品搞定.总结下~~~

在flash页面上放置一个按钮,点击按钮就将本地的摄像头和麦克风捕获的信息发送到服务器.


连接到服务器步骤.


1. 添加监听,连接服务器.


　　　　　　 nc = new NetConnection();
            nc.client = new Client();
            nc.addEventListener(NetStatusEvent.NET_STATUS, netStatusHandler);
            nc.connect(strServer);

2. 发布视频


　　　　     ns = new NetStream(nc);
            ns.addEventListener(NetStatusEvent.NET_STATUS, netStatusHandler);
            ns.client = new CustomClient();
            camera = Camera.getCamera();
            micophone = Microphone.getMicrophone();

            if (camera != null && micophone != null) {
                   camera.addEventListener(ActivityEvent.ACTIVITY, activityHandler);
                   micophone.addEventListener(ActivityEvent.ACTIVITY, activityHandler);
                   ns.attachCamera( camera );
                   ns.attachAudio( micophone );             
                   ns.publish(strName,"record");
                } else {
                trace("Please check your camera and microphone");
              }


得到本地的摄像头和麦克风之后,就可以通过netstream的publish方法直接发送.




代码:


package{
    import flash.net.NetConnection;
    import flash.net.NetStream;
    import flash.events.NetStatusEvent;

    import flash.events.MouseEvent;
    import flash.events.ActivityEvent;
    import flash.display.MovieClip;
    import flash.media.Camera;
    import flash.media.Microphone;
    import fl.controls.Button;
    import fl.controls.TextInput;
   
    public class ServerStream extends MovieClip{
       
        var nc:NetConnection;
        var stream:NetStream;       
        var ns:NetStream;
        //var video:Video;


        private var camera:Camera;            //摄像头变量
        private var micophone:Microphone;    //麦克风变量
       
        private var strName:String;
        private var strServer:String;
        private var strStream:String;
       
        //构造函数
        public function ServerStream(){
           
            strName = "livestream";
            strServer = "rtmp://localhost/live";
            strStream = "live";
           
            startBtn.addEventListener(MouseEvent.CLICK,StartBtnHandle);
        }
       
        public function StartBtnHandle(evt:MouseEvent):void{
            startBtn.enabled = false;
            trace("StartBtnHandle");
            ListenAndConnection();
        }
       
        //添加监听,然后连接到服务器.
        public function ListenAndConnection(){
            nc = new NetConnection();
            nc.client = new Client();
            nc.addEventListener(NetStatusEvent.NET_STATUS, netStatusHandler);
            nc.connect(strServer);
        }
       
        //发布视频
        private function publishLiveStream():void {
            ns = new NetStream(nc);
            ns.addEventListener(NetStatusEvent.NET_STATUS, netStatusHandler);
            ns.client = new CustomClient();
            camera = Camera.getCamera();
            micophone = Microphone.getMicrophone();

            if (camera != null && micophone != null) {
                   camera.addEventListener(ActivityEvent.ACTIVITY, activityHandler);
                   micophone.addEventListener(ActivityEvent.ACTIVITY, activityHandler);
                ns.attachCamera( camera );
                    ns.attachAudio( micophone );
                // start publishing
              // triggers NetStream.Publish.Start
             trace(strName+strStream);
                   ns.publish(strName,"record");
                } else {
                trace("Please check your camera and microphone");
              }
        }
       
        public function Refreash():void{           
            if (camera != null){               
                //camera.addEventListener(ActivityEvent.ACTIVITY, activityHandler);               
                ns.attachCamera(camera);
            }
           
            if (micophone != null) {               
                //micphone.addEventListener(ActivityEvent.ACTIVITY, activityHandler);                               
                ns.attachAudio(micophone);
            }           
        }
       
        //处理ActivityEvent发出的事件
        private function activityHandler(event:ActivityEvent):void {
           trace("activityHandler: " + event);
           trace("activating: " + event.activating);
        }
       
        //处理NetConnection和NetStreme发出的事件
        private function netStatusHandler(event:NetStatusEvent):void{
            trace("connected is: " + nc.connected );
            trace("event.info.level: " + event.info.level);
            trace("event.info.code: " + event.info.code);
           
            switch (event.info.code){
                case "NetConnection.Connect.Success":
                     trace("Congratulations! you're connected");
                     publishLiveStream();
                    // createPlayList(nc);
                     // instead you can also call createPlayList() here
                     break;
               
                case "NetConnection.Connect.Failed":
                case "NetConnection.Connect.Rejected":
                     trace ("Oops! the connection was rejected");
                     break;
                
                case "NetStream.Play.Stop":
                     trace("The stream has finished playing");
                     break;
                
                case "NetStream.Play.StreamNotFound":
                     trace("The server could not find the stream you specified");
                     break;
                
                case "NetStream.Publish.BadName":
                     trace("The stream name is already used");
                     break;
                case "NetStream.Publish.Start":
                     trace("Adding metadata to the stream");
                     // when publishing starts, send the metadata
                     //var metaData:Object = new Object();
                     //metaData.title = "liveDJconcert";
                     //metaData.width = 400;
                     //metaData.height = 200;
                     //stream.send("@setDataFrame", "onMetaData", metaData);
                     break;

            }
        }
    }
}

class Client{       
         public function onBWCheck( rest):Number{
            return 0;
        }
       
        public function onBWDone( rest):void{
               var p_bw:Number;
            if (rest.length > 0)
                p_bw = rest[0];
            trace("bandwidth = " + p_bw);
        }
}
   
class CustomClient{
        public function onMetaData(info:Object):void{
            trace("width: " + info.width);
            trace("height: " + info.height);
            }

}