'프로그래밍'에 해당되는 글 2건

[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

[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