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

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

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

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

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

Socket Server 의 IP & PORT 정보를 인자로 받아 맴버변수 할당

 

2. Run 함수 / Run()

Run 함수는 1회 호출 시 Server 로 메시지 Send 후 Server Recive 메시지를 수신 뒤 함수가 리턴됩니다.

 

3. GetReciveMessage 함수 public virtual void GetReciveMessage(StreamReader oStreamReader)

SocketClient 클래스를 상속 받아 GetReciveMessage 함수를 재정의 해 Server 로 부터 수신된 메시지를 처리합니다.

string str = oStreamReader.ReadToEnd();

위와 같은 코드로 Server 로부터 수신된 메시지를 받을 수 있습니다.

using System; using System.Net; using System.Net.Sockets; using System.Xml; using System.Diagnostics; using System.IO; namespace Library { public abstract class SocketClient { private string m_strIP = null; private string m_strPort = null; public SocketClient(string strIP, string strPort) { m_strIP = strIP; Trace.Assert(!string.IsNullOrEmpty(m_strIP)); m_strPort = strPort; Trace.Assert(!string.IsNullOrEmpty(m_strPort)); } public void Run(string strMsgSend) { try { int nPort; Trace.Assert(!string.IsNullOrEmpty(m_strIP)); Trace.Assert(int.TryParse(m_strPort, out nPort)); using (TcpClient oClient = new TcpClient(m_strIP, nPort)) { using (NetworkStream oStream = oClient.GetStream()) { using (StreamWriter oStreamWriter = new StreamWriter(oStream)) { oStreamWriter.WriteLine(strMsgSend); oStreamWriter.Flush(); string strClientIP = ((IPEndPoint)oClient.Client.RemoteEndPoint).Address.ToString(); using (StreamReader oStreamReader = new StreamReader(oStream)) { this.GetReciveMessage(oStreamReader); } } } } } catch (Exception ex) { throw new ApplicationException(ex.ToString()); } } public virtual void GetReciveMessage(StreamReader oStreamReader) { } } }

 

아래와 같이 SockerClient 클래스를 상속 받아 SocketClinetConsole 에서 while 문으로 Send 메시지를 입력받아

Server 로 전송하는 테스트 코드를 짜보았습니다.

 

using System; using Library; namespace SocketClinetConsole { public class SocketClientEx : SocketClient { public SocketClientEx(string strIP, string strPort) : base(strIP, strPort) { } public override void GetReciveMessage(System.IO.StreamReader oStreamReader) { Console.WriteLine("[RECV-SERVER] : " + oStreamReader.ReadToEnd()); } } class Program { static void Main(string[] args) { try { SocketClientEx oSocketClient = new SocketClientEx("127.0.0.1", "9999"); while (true) { Console.Write("[SEND-CLIENT] : "); string strMsgSend = Console.ReadLine(); oSocketClient.Run(strMsgSend); } } catch (Exception ex) { Console.WriteLine(ex.ToString()); } } } }

 

참고링크

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

http://softore.tistory.com/1