소켓을 사용하여 TCP를 통해 데이터 보내기 및 받기

소켓을 사용하여 원격 디바이스와 통신하려면 먼저 프로토콜 및 네트워크 주소 정보를 사용하여 소켓을 초기화해야 합니다. Socket 클래스에 대한 생성자에는 소켓이 연결을 만드는 데 사용하는 주소 패밀리, 소켓 형식 및 프로토콜 형식을 지정하는 매개 변수가 있습니다. 클라이언트 소켓을 서버 소켓에 연결할 때 클라이언트는 개체를 IPEndPoint 사용하여 서버의 네트워크 주소를 지정합니다.

IP 엔드포인트 만들기

System.Net.Sockets작업할 때 네트워크 엔드포인트를 개체로 IPEndPoint 나타냅니다. 는 IPEndPoint 및 해당 포트 번호로 IPAddress 생성됩니다. 를 통해 Socket대화를 시작하기 전에 앱과 원격 대상 간에 데이터 파이프를 만듭니다.

TCP/IP는 네트워크 주소와 서비스 포트 번호를 사용하여 서비스를 고유하게 식별합니다. 네트워크 주소는 특정 네트워크 대상을 식별합니다. 포트 번호는 연결할 해당 디바이스의 특정 서비스를 식별합니다. 네트워크 주소와 서비스 포트의 조합을 엔드포인트라고 합니다. 이 엔드포인트는 클래스에 의해 .NET에 EndPoint 표시됩니다. 의 EndPoint 하위 항목은 지원되는 각 주소 패밀리에 대해 정의됩니다. IP 주소 패밀리의 경우 클래스는 입니다 IPEndPoint.

클래스는 Dns TCP/IP 인터넷 서비스를 사용하는 앱에 도메인 이름 서비스를 제공합니다. 메서드는 GetHostEntryAsync DNS 서버를 쿼리하여 사용자 친화적인 도메인 이름(예: "host.contoso.com")을 숫자 인터넷 주소(예: )에 192.168.1.1매핑합니다. GetHostEntryAsyncTask<IPHostEntry> 는 awaited가 요청된 이름의 주소 및 별칭 목록을 포함하는 을 반환합니다. 대부분의 경우 AddressList 배열에 반환된 첫 번째 주소를 사용할 수 있습니다. 다음 코드는 서버host.contoso.com의 IP 주소를 포함하는 을 가져옵니다IPAddress.

IPHostEntry ipHostInfo = await Dns.GetHostEntryAsync("host.contoso.com");
IPAddress ipAddress = ipHostInfo.AddressList[0];

수동 테스트 및 디버깅을 위해 일반적으로 메서드를 사용하여 GetHostEntryAsync 값을 가져와 Dns.GetHostName() 서 localhost 이름을 IP 주소로 확인할 수 있습니다.

IANA(Internet Assigned Numbers Authority)는 일반 서비스에 대한 포트 번호를 정의합니다. 자세한 내용은 IANA: 서비스 이름 및 전송 프로토콜 포트 번호 레지스트리)를 참조하세요. 다른 서비스에는 1,024 ~ 65,535 범위의 등록된 포트 번호가 있을 수 있습니다. 다음 코드는 의 host.contoso.com IP 주소를 포트 번호와 결합하여 연결에 대한 원격 엔드포인트를 만듭니다.

IPEndPoint ipEndPoint = new(ipAddress, 11_000);

원격 디바이스의 주소를 결정하고 연결에 사용할 포트를 선택한 후 앱은 원격 디바이스와의 연결을 설정할 수 있습니다.

Socket 클라이언트 만들기

개체를 endPoint 만든 상태에서 서버에 연결할 클라이언트 소켓을 만듭니다. 소켓이 연결되면 서버 소켓 연결에서 데이터를 보내고 받을 수 있습니다.

using Socket client = new(
    ipEndPoint.AddressFamily, 
    SocketType.Stream, 
    ProtocolType.Tcp);

await client.ConnectAsync(ipEndPoint);
while (true)
{
    // Send message.
    var message = "Hi friends 👋!<|EOM|>";
    var messageBytes = Encoding.UTF8.GetBytes(message);
    _ = await client.SendAsync(messageBytes, SocketFlags.None);
    Console.WriteLine($"Socket client sent message: \"{message}\"");

    // Receive ack.
    var buffer = new byte[1_024];
    var received = await client.ReceiveAsync(buffer, SocketFlags.None);
    var response = Encoding.UTF8.GetString(buffer, 0, received);
    if (response == "<|ACK|>")
    {
        Console.WriteLine(
            $"Socket client received acknowledgment: \"{response}\"");
        break;
    }
    // Sample output:
    //     Socket client sent message: "Hi friends 👋!<|EOM|>"
    //     Socket client received acknowledgment: "<|ACK|>"
}

client.Shutdown(SocketShutdown.Both);

위의 C# 코드에서:

  • 지정된 endPoint 인스턴스 주소 패밀리, 및 ProtocolType.Tcp를 사용하여 새 Socket 개체를 SocketType.Stream인스턴스화합니다.

  • 인스턴스를 Socket.ConnectAsync 인수로 사용하여 endPoint 메서드를 호출합니다.

  • 루프에서 while :

    • 를 사용하여 Socket.SendAsync메시지를 인코딩하고 서버에 보냅니다.
    • 보낸 메시지를 콘솔에 씁니다.
    • 를 사용하여 Socket.ReceiveAsync서버에서 데이터를 수신하도록 버퍼를 초기화합니다.
    • response 승인이면 콘솔에 기록되고 루프가 종료됩니다.
  • 마지막으로 소켓은 client 지정된 SocketShutdown.Both를 호출 Socket.Shutdown 하여 송신 및 수신 작업을 모두 종료합니다.

Socket 서버 만들기

서버 소켓을 만들려면 개체가 endPoint 모든 IP 주소에서 들어오는 연결을 수신 대기할 수 있지만 포트 번호를 지정해야 합니다. 소켓이 만들어지면 서버는 들어오는 연결을 수락하고 클라이언트와 통신할 수 있습니다.

using Socket listener = new(
    ipEndPoint.AddressFamily,
    SocketType.Stream,
    ProtocolType.Tcp);

listener.Bind(ipEndPoint);
listener.Listen(100);

var handler = await listener.AcceptAsync();
while (true)
{
    // Receive message.
    var buffer = new byte[1_024];
    var received = await handler.ReceiveAsync(buffer, SocketFlags.None);
    var response = Encoding.UTF8.GetString(buffer, 0, received);
    
    var eom = "<|EOM|>";
    if (response.IndexOf(eom) > -1 /* is end of message */)
    {
        Console.WriteLine(
            $"Socket server received message: \"{response.Replace(eom, "")}\"");

        var ackMessage = "<|ACK|>";
        var echoBytes = Encoding.UTF8.GetBytes(ackMessage);
        await handler.SendAsync(echoBytes, 0);
        Console.WriteLine(
            $"Socket server sent acknowledgment: \"{ackMessage}\"");

        break;
    }
    // Sample output:
    //    Socket server received message: "Hi friends 👋!"
    //    Socket server sent acknowledgment: "<|ACK|>"
}

위의 C# 코드에서:

  • 지정된 endPoint 인스턴스 주소 패밀리, 및 ProtocolType.Tcp를 사용하여 새 Socket 개체를 SocketType.Stream인스턴스화합니다.

  • listener 메서드를 Socket.Bind 인스턴스와 endPoint 함께 인수로 호출하여 소켓을 네트워크 주소와 연결합니다.

  • Socket.Listen() 들어오는 연결을 수신 대기하기 위해 메서드가 호출됩니다.

  • listener 메서드를 Socket.AcceptAsync 호출하여 소켓에서 들어오는 연결을 수락합니다 handler .

  • 루프에서 while :

    • 클라이언트에서 데이터를 수신하기 위한 호출 Socket.ReceiveAsync 입니다.
    • 데이터가 수신되면 디코딩되어 콘솔에 기록됩니다.
    • 메시지가 로 response<|EOM|>끝나는 경우 을 사용하여 클라이언트에 승인이 Socket.SendAsync전송됩니다.

샘플 클라이언트 및 서버 실행

먼저 서버 애플리케이션을 시작한 다음 클라이언트 애플리케이션을 시작합니다.

dotnet run --project socket-server
Socket server starting...
Found: 172.23.64.1 available on port 9000.
Socket server received message: "Hi friends 👋!"
Socket server sent acknowledgment: "<|ACK|>"
Press ENTER to continue...

클라이언트 애플리케이션은 서버에 메시지를 보내고 서버는 승인으로 응답합니다.

dotnet run --project socket-client
Socket client starting...
Found: 172.23.64.1 available on port 9000.
Socket client sent message: "Hi friends 👋!<|EOM|>"
Socket client received acknowledgment: "<|ACK|>"
Press ENTER to continue...

추가 정보