pending이 true일 때는, 아까 말한 거꾸로 메시지를 알려주도록 하는 작업을 해보자.
초기화 함수에 넣어주어 처음 시작 때 무조건 한번 실행되도록 할 것이다.
public void Init(IPEndPoint endPoint)
{
...//(위 코드 참고)SocketAsyncEventArgs args = new SocketAsyncEventArgs();
args.Completed+= new EventHandler<SocketAsyncEventArgs>(OnAcceptCompleted);
RegisterAccept(args);
}
EventHandler를 사용하기 위해 콜백 함수인 OnAcceptCompleted를 넣어주고,
classProgram
{
static Listener _listener = new Listener();
staticvoidOnAcceptHandler(Socket clientSocket)
{
try
{
//받는다byte[] recvBuff = newbyte[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());
}
}
staticvoidMain(string[] args)
{
//DNS (Domain Name System)//도메인 등록 후 -> IP주소 찾게끔 만들면 유지보수가 용이함 string host = Dns.GetHostName(); //PC의 호스트명을 받는다 (호스트명은 IP 주소 대신 사용할 수 있는 식별 이름)
IPHostEntry ipHost = Dns.GetHostEntry(host); //해당 호스트의 IP 관련 주소들을 받는다.
IPAddress ipAddr = ipHost.AddressList[0]; //여러개의 주소를 담고있는 리스트를 반환하며 이중 첫번째 값을 할당한다(여러개의 주소를 뱉어주는 경우도 있음)
IPEndPoint endPoint = new IPEndPoint(ipAddr, 7777); //7777은 포트 번호 , IP 주소와 포트 번호를 할당한다.
_listener.Init(endPoint,OnAcceptHandler);
Console.WriteLine("Listening...");
while (true)
{
;
}
}
}
//DNS (Domain Name System)//도메인 등록 후 -> IP주소 찾게끔 만들면 유지보수가 용이함//PC의 호스트명을 받는다 (호스트명은 IP 주소 대신 사용할 수 있는 식별 이름) string host = Dns.GetHostName();
IPHostEntry ipHost = Dns.GetHostEntry(host); //해당 호스트의 IP 관련 주소들을 받는다.
IPAddress ipAddr = ipHost.AddressList[0]; //여러개의 주소를 담고있는 리스트를 반환하며 이중 첫번째 값을 할당한다(여러개의 주소를 뱉어주는 경우도 있음)
IPEndPoint endPoint = new IPEndPoint(ipAddr, 7777); //7777은 포트 번호 , IP 주소와 포트 번호를 할당한다.
IPHostEntry :DNS 클래스의 GetHostEntry의 반환 값을 담는 컨테이너 클래스. 호스트 관련 정보와 IP관련 정보를 받는다.
IPAddress :하나의 인터페이스에 대한 주소를 포함하는 클래스. 첫번 째 인덱스에 담긴 IP 주소를 할당한다.
IPEndPoint :IP 주소와 포트를 바인딩하여 소켓과 원격 주소를 연결한다.
⭐ 서버 코드
//문지기
Socket listenSocket = new Socket(endPoint.AddressFamily, SocketType.Stream, ProtocolType.Tcp);
try{
//문지기 교육
listenSocket.Bind(endPoint);
// 영업 시작// backlog : 최대 대기수
listenSocket.Listen(10);
while (true)
{
Console.WriteLine("Listening....");
// 손님을 입장시킨다
Socket clientSocket = listenSocket.Accept();
// 받는다 byte[] recvBuff = newbyte[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.Write(e.ToString());
}
문지기를 만든다 -> 서버 소켓을 만든다 (IP관련 정보와 소켓 타입, 연결 방법(프로토콜 설정)을 결정한다.
endPoint를 바인드 한다 (* endPoint :IP주소와 포트 번호의 조합)
클라이언트를 입장 시키고, 클라이언트가 전달하려는 내용을 받는다. (문자열을 전달하는 간단 예제)
클라이언트에게 서버 응답을 전달한다
후 연결을 종료한다 (* shut down : 현재 연결된 프로세스의 개수에 상관없이 연결을 종료한다. close:연결된 개수가 0이 되어야지만 연결이 종료된다. 소켓을 메모리 상에서 완전 해제하려면 shutdown 후에 close를 해 줘야 한다)
⭐ 클라이언트 코드
//클라이언트 소켓 설정
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("Connected Client !");
int sendBytes = socket.Send(sendBuff);
// 받는다byte[] recvBuff = newbyte[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.Write(e.ToString);
}
