[C#][Network][Thread] C#에서 쓰레드를 이용한 에코서버의 기본구조

// Thread Netwotk Server Exam

namespace threadNetworkExam

{

    public partial class Form1 : Form

    {

        // TCP 소켓통신 서버구현을 위해 TCP리스너 정의/초기화

        private TcpListener tcpListner = null;

       

        public Form1()

        {

            InitializeComponent();

        }

        // Thread Method

        // Client 접속시 스레드가 호출하여 작업할 메소드 정의

        private void AcceptClient()

        {

            while (true)

            {

                // Client 소켓통신을 위해 수신을 대기하는 TcpClient 생성

                // TcpListner를 통해 생성

                TcpClient tcpClient = tcpListner.AcceptTcpClient();

                if (tcpClient.Connected)

                {

                    // 접속한 Client IP정보를 얻어서 리스트박스에 추가

                    string str = ((IPEndPoint)tcpClient.Client.RemoteEndPoint).Address.ToString();

                    listBox1.Items.Add(str);

                }

                EchoServer echoServer = new EchoServer(tcpClient);

                Thread th = new Thread(new ThreadStart(echoServer.Process));

                th.IsBackground = true;

                th.Start();

            }

        }

        private void Form1_Load(object sender, EventArgs e)

        {

            tcpListner = new TcpListener(3000);

            tcpListner.Start();

            // 서버의 IP주소를 얻어서 텍스트박스에 넣는다.

            IPHostEntry host = Dns.GetHostEntry(Dns.GetHostName());

            for(int i = 0; i < host.AddressList.Length; i++)

            {

                if(host.AddressList[i].AddressFamily == AddressFamily.InterNetwork)

                {

                    textBox1.Text = host.AddressList[i].ToString();

                    break;

                }

            }

        }

        private void Form1_FormClosing(object sender, FormClosingEventArgs e)

        {

            tcpListner.Stop();         

           

        }

        private void button1_Click(object sender, EventArgs e)

        {

            // 서버시작 버튼클릭시 클라이언트 접속대기 및 처리를 위한 쓰레드 생성

            // Main 종료시 같이 종료되기위해 백그라운드로 설정

            Thread th = new Thread(new ThreadStart(AcceptClient));

            th.IsBackground = true;

            th.Start();

        }

    }

    public class EchoServer

    {

        TcpClient refClient;

        private BinaryReader br = null;

        private BinaryWriter bw = null;

        int intValue;

        float floatValue;

        string strValue;

        public EchoServer(TcpClient client)

        {

            refClient = client;

        }

        public void Process()

        {

            NetworkStream ns = refClient.GetStream();

            try

            {

                br = new BinaryReader(ns);

                bw = new BinaryWriter(ns);

                while(true)

                {

                    intValue = br.ReadInt32();

                    floatValue = br.ReadSingle();

                    strValue = br.ReadString();

                    bw.Write(intValue);

                    bw.Write(floatValue);

                    bw.Write(strValue);

                }

            }

            catch (SocketException se)

            {

                br.Close();

                bw.Close();

                ns.Close();

                ns = null;

                refClient.Close();

                MessageBox.Show(se.Message);

                Thread.CurrentThread.Abort();

            }

            catch (IOException ex)

            {

                // 연결이 끊어져 읽을 수 없을떄.

                br.Close();

                bw.Close();

                ns.Close();

                ns = null;

                refClient.Close();

                MessageBox.Show(ex.Message);

                Thread.CurrentThread.Abort();

            }

        }

    }

}