C# Socket echo server/client 예제

/*

 * http://sosal.kr/
 * made by so_Sal
 */

Server에서 Listen으로 Client의 접속을 기다립니다.

Client가 접속하면, Client가 보낸 메시지를 시간과 함께 돌려줍니다. (Echo 서버)

Stream을 이용하여 데이터 전송을 구현하였습니다. (StreamReader, StreamWriter)

인코딩은 UTF8을 사용하였습니다.

Client 소스

---

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

using System.Threading.Tasks;

using System.Windows;

 

using System.IO;

using System.Net;

using System.Net.Sockets;

 

namespace ConsoleTest

{

    class Program

    {

        static void Main(string[] args)

        {

            int PORT = 5555;

            string IP = "localhost";

 

            NetworkStream NS = null;

            StreamReader SR = null;

            StreamWriter SW = null;

            TcpClient client = null;

 

            try

            {

                client = new TcpClient(IP, PORT); //client 연결

                Console.WriteLine("{0}:{1}에 접속하였습니다.",IP,PORT);

                NS = client.GetStream(); // 소켓에서 메시지를 가져오는 스트림

                SR = new StreamReader(NS, Encoding.UTF8); // Get message

                SW = new StreamWriter(NS, Encoding.UTF8); // Send message

 

                string SendMessage = string.Empty;

                string GetMessage = string.Empty;

 

                while ((SendMessage = Console.ReadLine()) != null)

                {

                    SW.WriteLine(SendMessage); // 메시지 보내기

                    SW.Flush();

 

                    GetMessage = SR.ReadLine();

                    Console.WriteLine(GetMessage);

                }

            }

           

            catch (Exception e)

            {

                System.Console.WriteLine(e.Message);

            }

            finally

            {

                if(SW != null) SW.Close();

                if (SR != null) SR.Close();

                if (client != null) client.Close();

               

               

            }

        }

    }

}

Server 소스

---

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

using System.Threading.Tasks;

 

 

using System.IO;

using System.Net;

using System.Net.Sockets;

 

 

namespace Sock_console_server

{

    class Program

    {

        static void Main(string[] args)

        {

            TcpListener Listener = null;

            NetworkStream NS = null;

 

            StreamReader SR = null;

            StreamWriter SW = null;

            TcpClient client = null;

 

            int PORT = 5555;

           

            Console.WriteLine("서버소켓");

            try

            {

                Listener = new TcpListener(PORT);

                Listener.Start(); // Listener 동작 시작

 

                while (true)

                {

                    client = Listener.AcceptTcpClient();

 

                    NS = client.GetStream(); // 소켓에서 메시지를 가져오는 스트림

                    SR = new StreamReader(NS, Encoding.UTF8); // Get message

                    SW = new StreamWriter(NS, Encoding.UTF8); // Send message

 

                    string GetMessage = string.Empty;

 

                    while (client.Connected == true) //클라이언트 메시지받기

                    {

                        GetMessage = SR.ReadLine();

                       

                        SW.WriteLine("Server: {0} [{1}]",GetMessage,DateTime.Now); // 메시지 보내기

                        SW.Flush();

                        Console.WriteLine("Log: {0} [{1}]",GetMessage,DateTime.Now);

                    }

                }

            }

            catch (Exception e)

            {

                System.Console.WriteLine(e.Message);

            }

            finally

            {

                SW.Close();

                SR.Close();

                client.Close();

                NS.Close();

            }

        }

    }

}