using System;
using System.Windows;
using System.Net.Sockets;
using System.Threading.Tasks;
using System.IO;

namespace testEncoderRecieve
{
    public partial class MainWindow : Window
    {
        public MainWindow()
        {
            InitializeComponent();
            this.Loaded += new RoutedEventHandler(MainWindow_Loaded);
        }

        private Task ServerThread;
        private TcpListener server;
        void MainWindow_Loaded(object sender, RoutedEventArgs e)
        {
            ServerThread = new Task(startServerThreaed);
            server = new TcpListener(System.Net.IPAddress.Parse("127.0.0.1"),5555);
            //TcpListener를 생성하고, 서버 스레드가 시작되었다
            ServerThread.Start();
        }
        void startServerThreaed()
        {
            //서버를 시작시킨다.
            server.Start();

            //버퍼를 설정한다. 우선64바이트 만큼만...
            Byte[] buffer = new Byte[64];

            int testCount = 0;
            while (true)
            {
                //클라이언트를 대기한다. 클라이언트로 부터 접속신호가 있기 전까지 루프는 여기서 멈춤.
                TcpClient client = server.AcceptTcpClient();
                //클라이언트가 접속하고 스트림을 가져 온다.
                NetworkStream netStream = client.GetStream();
                //파일스트림을 생성하여 FileAccess.write로 한다.
                FileStream fs = new FileStream(@"d:\test" + testCount + ".png", FileMode.OpenOrCreate , FileAccess.Write);
                int i = 0;
                while ((i = netStream.Read(buffer, 0, buffer.Length)) > 0)
                {
                    //여기서 정수i가 0보다 클때까지, 즉 끝까지 루프를 반복하며 정해진 버퍼만큼 기록한다.
                    fs.Write(buffer, 0, i);
                }

                //루프가 끝나면 모든 스트림을 종료하고 다시 대기상태로 돌아간다.                fs.Close();
                netStream.Close();
                client.Close();
                ++testCount;
            }
        }
    }
}

package {
    import flash.events.Event;
    import flash.net.Socket;
    import flash.utils.ByteArray;
    import flash.display.Bitmap;
    import flash.display.BitmapData;
    import flash.display.Sprite;
    import flash.events.MouseEvent;
    import flash.media.Camera;
    import flash.media.Video;
    /**
     * @author superSc_PC
     */
     
    [SWF(width = "1000")]
    public class Main extends Sprite
    {
        private var cam : Camera;
        private var vid : Video;
        private var captureBitmap : Bitmap;
        
        private var socket : Socket;
        public function Main()
        {
            //필요한것들을 생성하며 캡쳐환경을 만든다.
            cam = Camera.getCamera();
            vid = new Video();
            vid.attachCamera(cam);
            captureBitmap = new Bitmap(new BitmapData(vid.width, vid.height));
            captureBitmap.x = vid.width;
            addChild(vid);
            addChild(captureBitmap);

            //화면을 클릭할때 마다 캡쳐를 한다.            stage.addEventListener(MouseEvent.CLICK    , takePic);
            //소켓을 생성하고 연결을 잡을 이벤트를 선언한다.
            socket = new Socket();
            socket.addEventListener(Event.CONNECT, connectFn);
        }
        
        //인코딩을 담을 바이트배열 변수 를 선언한다.
        private var captureByte : ByteArray;
        private function connectFn(event : Event) : void {
            //연결이 되었다. 간단한 유효성검사후 전송한다.
            if (captureByte != null && captureByte.length > 0)
            {
                socket.writeBytes(captureByte);
                socket.flush();
                socket.close();
            }
            //연결이 종료되었다.
        }

        private function takePic(event : MouseEvent) : void {
            captureBitmap.bitmapData.draw(vid);
            captureByte = PngEncoder.encode(captureBitmap.bitmapData);
            //화면이 클릭되고 캡쳐된 비트맵은 png로 인코딩된다.
            captureByte.position = 0;
            //바이트배열 포지션을 처음으로 돌려주고
            //소켓을 연결한다.
            if(socket.connected == false)
            {
                //소켓이 연결되면 위에서 선언한이벤트에 의해 connectFn이 실행된다.
                socket.connect("localhost", 5555);
            }
        }
    }
}