[C#] TCP Socket Server 라이브러리 만들기

[C#] TCP Socket Server 라이브러리 만들기

TCP 통신을 하기위해서는 Server 와 Client 가 필요합니다.

TCP Socket Server 코드는 아래 코드를 참고합니다.

1. 생성자 / public SocketServer(string strIP, string strPort)

TcpListener 초기화에 필요한 IP & PORT 정보를 인자로 받아 맴버변수 할당

2. Start 함수 / Start()

TcpListener 객체 생성 및 Start

3. Stop 함수 / Stop()

TcpListener Stop

4. Run 함수 / Run()

Run 함수는 1회 호출 시 Client 로 부터 수신된 메시지를 처리 후 함수가 리턴됩니다.

따라서, 외부에서 선언한 Thread, Timer, while 등의 코드에서 지속적으로 Run 함수를 호출해야합니다.

5. GetSendMessage 함수 GetSendMessage(string strMsgRecive)

아래의 SocketServer 클래스를 그대로 사용하신다면 본 함수의 내부를 수정하여 사용하면됩니다.

기본적으로 SocketServer 클래스를 상속을 받아 GetSendMessage 함수를 재정의 후 사용하도록 설계된 클래스입니다.

※ 본 코드는 아직 테스트가 완료되지 않은 코드이기 떄문에 버그가 발생할 수 있습니다.

 

using System; using System.Net; using System.Net.Sockets; using System.Xml; using System.Diagnostics; using System.IO; namespace Library { public abstract class SocketServer { private TcpListener m_oListener = null; private string m_strIP = null; private string m_strPort = null; public SocketServer(string strIP, string strPort) { m_strIP = strIP; Trace.Assert(!string.IsNullOrEmpty(m_strIP)); m_strPort = strPort; Trace.Assert(!string.IsNullOrEmpty(m_strPort)); } public void Start() { try { int nPort; Trace.Assert(!string.IsNullOrEmpty(m_strIP)); Trace.Assert(int.TryParse(m_strPort, out nPort)); IPAddress oIPAddress = IPAddress.Parse(m_strIP); m_oListener = new TcpListener(oIPAddress, nPort); m_oListener.Start(); } catch { throw new ApplicationException("Socket Start Error!"); } } public void Stop() { try { m_oListener.Stop(); } catch { throw new ApplicationException("Socket Stop Error!"); } } public void Run() { try { using (TcpClient oClient = m_oListener.AcceptTcpClient()) { using (NetworkStream oStream = oClient.GetStream()) { string strClientIP = ((IPEndPoint)oClient.Client.RemoteEndPoint).Address.ToString(); string strMsgRecive = null; string strMsgSend = null; using (StreamReader oStreamReader = new StreamReader(oStream)) { strMsgRecive = oStreamReader.ReadLine(); using (StreamWriter oStreamWriter = new StreamWriter(oStream)) { strMsgSend = this.GetSendMessage(strClientIP, strMsgRecive); oStreamWriter.WriteLine(strMsgSend); } } } } } catch (Exception ex) { throw new ApplicationException(ex.ToString()); } } public virtual string GetSendMessage(string strClientIP, string strMsgRecive) { return null; } } }

 

아래와 같이 SockerServer 클래스를 상속 받아 TestConsole 에서 while 문으로 호출하는 테스트 코드를 짜보았습니다.

"Waiting for Client Message..." 가 Write 된 후 대기하는 모습이 보입니다.

Client 에서 Recive Message 가 오기전까지 Run() 함수에서 대기하는 모습을 볼 수 있습니다.

 

using System; using Library; namespace SocketServerConsole { public class SocketServerEx : SocketServer { public SocketServerEx(string strIP, string strPort) : base(strIP, strPort) { } public override string GetSendMessage(string strClientIP, string strClientMsg) { // RECV Console.WriteLine(string.Format("[RECV-CLIENT] : IP={0} MSG={1}", strClientIP, strClientMsg)); // SEND string strServerMsg = string.Format("HELLO CLIENT!"); Console.WriteLine("[SEND-SERVER] : " + strServerMsg); return strServerMsg; } } class Program { static void Main(string[] args) { try { SocketServerEx oSocketServer = new SocketServerEx("127.0.0.1", "9999"); oSocketServer.Start(); while (true) { Console.WriteLine("Waiting for Client Message..."); oSocketServer.Run(); } } catch (Exception ex) { Console.WriteLine(ex.ToString()); } } } }

 

 

참고링크

[C#] TCP Socket Client 라이브러리 만들기
http://softore.tistory.com/2