C# Rookiss Part4 게임서버 : Listener

21-12-02

🙇‍♀️Listener

문지기를 따로 빼자!

Accept, Receive, Send 등 모든 입출력 함수들은 비동기 방식으로 해야 됨
일단 예약을 해놓고 손님이 들어오면 작동하게 끔 만들기 (이벤트 방식)
낚시 예시
- 처음에는 낚시대를 직접 던지기
- 입질이 바로 오면 바로 할일하기
- 입질이 안오면 올때까지 기다리다가 오면 할일하기
- 할일이 끝났으면 다시 낚시대 던지기

ServerCore는 라이브러리로 바뀜

args.Completed += new EventHandler<SocketAsyncEventArgs>(OnAccepteCompleted); 잘 모르는 부분 => 그냥 이렇게 쓰는건갑다 해야됨

게임에는 비동기함수를 써야한다 - Accept => AcceptAsync

Async계열의 함수들은 그 행동을 했든 안했든 일단 리턴을 함 -> 일을 안했을 땐 일단 빠져나갔으니까 다시 알려줘야함 ( 이벤트 방식) 일을 요청하는 부분과 실제 일을 하는 부분으로 나뉜다 - RegisterAccept, OnAcceptCompleted

pending = 미결정의 pending == false 실행과 거의 동시에 클라에서 접속이 온 경우

args.Completed 는 EventHandler방식으로 이벤트 방식으로 콜벡으로 전달하는 방식

Action _onAcceptHandler를 만든 이유 - Accept를 한 이유의 행동들을 이벤트 형식으로 받아서 소켓이 그 일을 하게 만들기 위하여, _onAcceptHandler.Invoke(args.AcceptSocket);이 되는 것!, args.AcceptSocket은 args가 AcceptAsync를 했기 때문에 가진 Socket이라고 생각하면 될듯

Async계열의 함수들은 당장은 값을 뽑아올 수가 없기 때문에 SocketAsyncEventArgs가 이런저런 정보들을 가져와서 전달해주는 느낌

프로그램에서 Socket을 인자로 받는 함수를 만들어서 Init(IPEndPoint, Action)에 맞춰준다

🪐Listener분석

class Listener
{
    Socket _listenSocket; // 리스너 소켓 생성
    Action<Socket> _onAcceptHandler; // 이벤트 방식으로 전달

    public void Init(IPEndPoint endPoint, Action<Socket> onAcceptHandler) // 이닛할때 이벤트 연결까지 해줌
    {
        // 문지기
        _listenSocket = new Socket(endPoint.AddressFamily, SocketType.Stream, ProtocolType.Tcp); // 리스너 소켓 연결
        _onAcceptHandler += onAcceptHandler; // 이벤트 구독 신청

        // 문지기 교육
        _listenSocket.Bind(endPoint); // 바인드 결합

        // 영업 시작
        // BackLog : 최대 대기수
        _listenSocket.Listen(10); // 일꾼 수 설정

        SocketAsyncEventArgs args = new SocketAsyncEventArgs(); // 이벤트 형식 요정 생성
        args.Completed += new EventHandler<SocketAsyncEventArgs>(OnAcceptCompleted); // 컴플릿 구독 신청
        RegisterAccept(args); // 첫 낚시대 던지기
    }

    void RegisterAccept(SocketAsyncEventArgs args) // 어셉 등록하기 함수, 이벤트핸들러 때매 SocketAsyncEventArgs args 인자가 필요
    {
        args.AcceptSocket = null; // 두번째 턴부터 남아있는 값으로 에러나기 때문에 초기화 시켜주기

        bool pending = _listenSocket.AcceptAsync(args); // 비동기 함수로 팬딩 유무확인
        if (pending == false) // 팬딩이 없다는 건 낚시대를 넣자마자 물고기가 낚이는 것
            OnAcceptCompleted(null, args);
    }

    void OnAcceptCompleted(object sender, SocketAsyncEventArgs args) // 이벤트핸들러 때매 object sender, SocketAsyncEventArgs args 인자가 필요
    {
        if (args.SocketError == SocketError.Success) // 에러가 없이 잘 성공했을 때
        {
            _onAcceptHandler.Invoke(args.AcceptSocket); // 서버코어에 있는 일 시키기 (이벤트 발송)
        }
        else
            Console.WriteLine(args.SocketError.ToString()); // 무슨 에러인지 확인하기

        RegisterAccept(args); // 다끝났으면 다시 낚시대 던지기
    }
}

args.Completed += new EventHandler<SocketAsyncEventArgs>(OnAcceptCompleted); // 어싱크를 만들고 어싱크아규먼츠를 넣어준경우 콜백함수는 별도의 쓰레드가 생성

void OnAcceptCompleted(object sender, SocketAsyncEventArgs args) // 레드존, 쓰레드나 테스크를 만들지 않았지만 자동적으로 풀에서 생성해서 사용함

🪐Listner, DummyClient, ServerCore 전체 코드

Listner

namespace ServerCore
{
  class Listener
  {
      Socket _listenSocket;
      Action<Socket> _onAcceptHandler;

      public void Init(IPEndPoint endPoint, Action<Socket> onAcceptHandler)
      {
          // 문지기
          _listenSocket = new Socket(endPoint.AddressFamily, SocketType.Stream, ProtocolType.Tcp);
          _onAcceptHandler += onAcceptHandler;

          // 문지기 교육
          _listenSocket.Bind(endPoint);

          // 영업 시작
          // BackLog : 최대 대기수
          _listenSocket.Listen(10);

          SocketAsyncEventArgs args = new SocketAsyncEventArgs();
          args.Completed += new EventHandler<SocketAsyncEventArgs>(OnAcceptCompleted);
          RegisterAccept(args);
      }

      void RegisterAccept(SocketAsyncEventArgs args)
      {
          args.AcceptSocket = null;

          bool pending = _listenSocket.AcceptAsync(args);
          if (pending == false)
              OnAcceptCompleted(null, args);
      }

      void OnAcceptCompleted(object sender, SocketAsyncEventArgs args)
      {
          if (args.SocketError == SocketError.Success)
          {
              _onAcceptHandler.Invoke(args.AcceptSocket);
          }
          else
              Console.WriteLine(args.SocketError.ToString());

          RegisterAccept(args);
      }

      public Socket Accept()
      {
            
          return _listenSocket.Accept();
      }
  }
}

DummyClient

namespace DummyClient
{
  class Program
  {
      static void Main(string[] args)
      {
          while (true)
          {
              // DNS (Domain Name System)
              string host = Dns.GetHostName();
              IPHostEntry ipHost = Dns.GetHostEntry(host);
              IPAddress ipAddr = ipHost.AddressList[0];
              IPEndPoint endPoint = new IPEndPoint(ipAddr, 7777);

              // 휴대폰 설정
              Socket socket = new Socket(endPoint.AddressFamily, SocketType.Stream, ProtocolType.Tcp);

              try
              {
                  // 문지기한테 입장 문의
                  socket.Connect(endPoint);
                  Console.WriteLine($"Connected to {socket.RemoteEndPoint.ToString()}");

                  // 보낸다
                  byte[] sendBuff = Encoding.UTF8.GetBytes("Hello World!");
                  int sendBytes = socket.Send(sendBuff);

                  // 받는다
                  byte[] recvBuff = new byte[1024];
                  int recvBytes = socket.Receive(recvBuff);
                  string recvData = Encoding.UTF8.GetString(recvBuff, 0, recvBytes);
                  Console.WriteLine($"[From Server] {recvData}");

                  // 나간다
                  socket.Shutdown(SocketShutdown.Both);
                  socket.Close();
              }
              catch (Exception e)
              {
                  Console.WriteLine(e.ToString());
              }

              Thread.Sleep(500);
          }
      }
  }
}

ServerCore

namespace ServerCore
{
  class Program
  {
      static Listener _listener = new Listener();

      static void OnAcceptHandler(Socket clientSocket)
      {
          try
          {
              // 받는다
              byte[] recvBuff = new byte[1024];
              int recvBytes = clientSocket.Receive(recvBuff);
              string recvData = Encoding.UTF8.GetString(recvBuff, 0, recvBytes);
              Console.WriteLine($"[From Client] {recvData}");

              // 보낸다
              byte[] sendBuff = Encoding.UTF8.GetBytes("Welcome to MMORPG Server!");
              clientSocket.Send(sendBuff);

              // 쫓아낸다
              clientSocket.Shutdown(SocketShutdown.Both);
              clientSocket.Close();
          }
          catch (Exception e)
          {
              Console.WriteLine(e.ToString());
          }
      }

      static void Main(string[] args)
      {
          // DNS (Domain Name System)
          string host = Dns.GetHostName();
          IPHostEntry ipHost = Dns.GetHostEntry(host);
          IPAddress ipAddr = ipHost.AddressList[0];
          IPEndPoint endPoint = new IPEndPoint(ipAddr, 7777);

          _listener.Init(endPoint, OnAcceptHandler);

          Console.WriteLine("Listening...");
          while (true)
          {
              ;
          }

      }
  }
}

Twitter Facebook LinkedIn

C# Rookiss Part4 게임서버 : Listener

🙇‍♀️Listener

🪐Listener분석

🪐Listner, DummyClient, ServerCore 전체 코드

공유하기

참고

BOJ 1436. 영화감독 숌

배열 회전

Split 구현

최대공약수 최소공배수