Socket(Tcp) 비동기 Server

c# Socket의 비동기 서버 입니다.
비동기 부분에서 눈여겨 봐야할부분은
BeginAccept <====> EndAccept
BeginSend <====> EndSend
BeginReceive <====> EndReceive
메소드들의 짝을 이뤄야한다는점입니다.
Socket.BeginSend()의 원형을 보면(MSDN Library 참고 및 검색) public IAsyncResult BeginSend( byte[] buffer, int offset, int size, SocketFlags socketFlags, AsyncCallback callback, Object state ) AsyncCallback 대리자
Object state 상태정보를 포함한 객체(사용자정의객체도 됨)를 눈여겨봐야할것같습니다.
예외처리시 SocketException이 발생하는데요
SocketException.SocektErrorCode의 맴버들을 적절히 사용해야됩니다.
NotConnected = Socket의 연결되지 않은 상태로 응용프로그램에서 데이터를 보내고 받으...
ConnectionRefused = 원격호스트가 연결을 거부했습니다.
ConnectionReset = 원격피어가 연결을 다시 설정했습니다. 등등등.
public class StateObject { public Socket workSocket = null; public const int BUFFER_SIZE = 1024; public byte[] buffer = new byte[BUFFER_SIZE]; public StringBuilder sb = new StringBuilder(); } public class AsyncServer { /// Begin Connect ==> EndConnet 메서드를 호출하여 완료 /// private Socket hsock; private byte[] buffer; private const int MAXSIZE = 1024; private StateObject so1; private StateObject so2; private UTF8Encoding utf8; // private BackgroundWorker bw_Receiver; public AsyncServer() { // 비동기라 쓰레드를 사용하지 않아도 되는것 같습니다. // this.bw_Receiver = new BackgroundWorker(); // this.bw_Receiver.WorkerSupportsCancellation = true; // this.bw_Receiver.DoWork +=new DoWorkEventHandler(bw_Receiver_DoWork); // this.bw_Receiver.RunWorkerCompleted +=new RunWorkerCompletedEventHandler(bw_Receiver_RunWorkerCompleted); this.hsock = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp); this.buffer = new byte[MAXSIZE]; utf8 = new UTF8Encoding(); this.so2 = new StateObject(); // hsock.Connect( } public void Listen() { this.hsock.Bind(new IPEndPoint(IPAddress.Parse("127.0.0.1"), 9999)); this.hsock.Listen(2); Array.Clear(buffer, 0, MAXSIZE); // c 에서 memset(&buff, 0, buff.length) 엯할 Console.WriteLine("클라이언트 접속 대기 중입니다....."); this.hsock.BeginAccept(new AsyncCallback(OnListenCallBack), hsock); } public void Send(string message) { byte[] sendByte = utf8.GetBytes(message); Socket t_Csock = this.so2.workSocket; t_Csock.BeginSend(sendByte, 0, sendByte.Length, SocketFlags.None, new AsyncCallback(OnSendCallBack), t_Csock); } // Send CallBack private void OnSendCallBack(IAsyncResult ar) { Socket t_CientSock = (Socket)ar.AsyncState; int size = t_CientSock.EndSend(ar); // 전송이 성공적으로 되었다면 결과값으로 보낸 크기가 리턴(size) // 그렇지 않다면 에러가 나올것이다. if (size < 0) { Console.WriteLine("Sending.... 실패"); } } // Receive CallBack private void OnReceiveCallBack(IAsyncResult ar) { StateObject so = (StateObject)ar.AsyncState; Socket t_sock = so.workSocket; try { int read = t_sock.EndReceive(ar); IPEndPoint ep = (IPEndPoint)t_sock.RemoteEndPoint; Console.WriteLine("클라이언트로부터 데이터를 받았습니다.ip: {0}, port: {1}", ep.Address, ep.Port); if (read > 0) { // so.sb.Append(utf8.GetString(so.buffer, 0, read)); Console.WriteLine("===> \t {0}", utf8.GetString(so.buffer, 0, read)); t_sock.BeginReceive(so.buffer, 0, StateObject.BUFFER_SIZE, SocketFlags.None, new AsyncCallback(OnReceiveCallBack), so); } else // 데이터가 없다. { if (so.sb.Length > 1) { string strContent; strContent = so.sb.ToString(); Console.WriteLine(String.Format("Read {0} byte from socket" + "data = {1} ", strContent.Length, strContent)); } t_sock.Close(); } } catch (SocketException se) // 클라이언트가 연결이 끊겼을경우 { Console.WriteLine("Receive Catch Error {0}, {1}", se.Message, se.SocketErrorCode); if (se.SocketErrorCode == SocketError.ConnectionReset) { this.hsock.Close(); Console.WriteLine("클라이언트 연결이 끊겼습니다. "); } } } // Accept CallBack private void OnListenCallBack(IAsyncResult ar) { // 클라이언트가 접속한후에 종료하게 된다면 서버쪽에서는 에러가 남 // 새로운 클라이언트가 올떄마나 새로운 클래스 객체를 생성하고 // 클래스 객체안에서는 메세지를 주고 받을 byte형 try { Socket t_sock = (Socket)ar.AsyncState; Socket s2 = t_sock.EndAccept(ar); IPEndPoint ep = (IPEndPoint)s2.RemoteEndPoint; Console.WriteLine("클라이언트가 접속 했습니다. ip: {0}, port: {1}", ep.Address, ep.Port); this.so2.workSocket = s2; // 클라이언트 정보 s2.BeginReceive(so2.buffer, 0, MAXSIZE, SocketFlags.None, new AsyncCallback(OnReceiveCallBack), so2); } catch (SocketException se) { Console.WriteLine(se.Message + " / " + se.SocketErrorCode); } } public class AsyncServerEventArg : EventArgs { public bool ClientIsConnected; public IPEndPoint ClientEP; public string Message; public AsyncServerEventArg(bool isConnected, IPEndPoint ep) { this.ClientIsConnected = isConnected; this.ClientEP = ep; } public AsyncServerEventArg(string message) { this.Message = message; } } public delegate void ClientConnectedHandler(object sender, AsyncServerEventArg e); public event ClientConnectedHandler ClientIsConnected; }// close AsycServer CLASS }// CLOSE NameSpace