TCP üzerinden veri göndermek ve almak için Soketleri kullan

Uzak cihazlarla iletişim kurmak için yuva kullanabilmeniz için önce yuvanın protokol ve ağ adresi bilgileriyle başlatılması gerekir. Socket sınıfının oluşturucusu, bağlantı oluştururken yuvanın kullandığı adres ailesini, yuva türünü ve protokol türünü belirleyen parametrelere sahiptir. İstemci yuvasını bir sunucu yuvasına bağlarken, istemci sunucunun ağ adresini belirtmek için bir IPEndPoint nesne kullanır.

IP uç noktası oluşturma

ile System.Net.Socketsçalışırken bir ağ uç noktasını nesne olarak IPEndPoint temsil edebilirsiniz. IPEndPoint, IPAddress ile buna karşılık gelen bağlantı noktası numarasıyla oluşturulur. aracılığıyla Socketbir konuşma başlatabilmeniz için önce uygulamanızla uzak hedef arasında bir veri kanalı oluşturursunuz.

TCP/IP, bir hizmeti benzersiz olarak tanımlamak için bir ağ adresi ve hizmet bağlantı noktası numarası kullanır. Ağ adresi belirli bir ağ hedefini tanımlar; bağlantı noktası numarası, o cihazdaki bağlanacak hizmeti tanımlar. Ağ adresi ve hizmet bağlantı noktası birleşimi, sınıfı tarafından EndPoint .NET'te temsil edilen uç nokta olarak adlandırılır. Desteklenen her adres ailesi için bir alt öğe olarak EndPoint tanımlanır; IP adresi ailesi için ise sınıf IPEndPoint olur.

sınıfı, Dns TCP/IP internet hizmetlerini kullanan uygulamalara etki alanı adı hizmetleri sağlar. yöntemi, GetHostEntryAsync kullanıcı dostu bir etki alanı adını ("host.contoso.com") sayısal bir İnternet adresiyle (örneğin 192.168.1.1) eşlemek için bir DNS sunucusunu sorgular. GetHostEntryAsync beklediğinizde, istenen ad için adreslerin ve diğer adların listesini içeren bir Task<IPHostEntry> döndürür. Çoğu durumda, dizide AddressList döndürülen ilk adresi kullanabilirsiniz. Aşağıdaki kod, sunucu için IP adresini içeren bir IPAddress alır host.contoso.com.

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

Tavsiye

Manuel test ve hata ayıklama amacıyla, GetHostEntryAsync değerinden elde edilen ana bilgisayar adını kullanarak, localhost adını bir IP adresine çözümlemek için genellikle Dns.GetHostName() yöntemini kullanabilirsiniz. Aşağıdaki kod parçacığını göz önünde bulundurun:

var hostName = Dns.GetHostName();
IPHostEntry localhost = await Dns.GetHostEntryAsync(hostName);
// This is the IP address of the local machine
IPAddress localIpAddress = localhost.AddressList[0];

İnternet Atanan Numaralar Yetkilisi (IANA), ortak hizmetler için bağlantı noktası numaralarını tanımlar. Daha fazla bilgi için bkz . IANA: Hizmet Adı ve Aktarım Protokolü Bağlantı Noktası Numarası Kayıt Defteri). Diğer hizmetler 1.024 ile 65.535 arasında kayıtlı bağlantı noktası numaralarına sahip olabilir. Aşağıdaki kod, bağlantı için uzak uç nokta oluşturmak üzere host.contoso.com ip adresini bir bağlantı noktası numarasıyla birleştirir.

IPEndPoint ipEndPoint = new(ipAddress, 11_000);

Uzak cihazın adresini belirledikten ve bağlantı için kullanılacak bağlantı noktasını seçtikten sonra uygulama uzak cihazla bağlantı kurabilir.

Socket İstemci oluştur

endPoint nesnesi oluşturulduktan sonra sunucuya bağlanmak için bir istemci yuvası oluşturun. Yuva bağlandıktan sonra, sunucu yuva bağlantısından veri gönderip alabilir.

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);

Yukarıdaki C# kodu:

• Verilen Socket örneğindeki adres ailesi, endPoint ve SocketType.Stream ile yeni bir ProtocolType.Tcp nesnesi oluşturur.

• Socket.ConnectAsync yöntemini endPoint örneğiyle bir bağımsız değişken olarak çağırır.

• Döngüde while :

  • kullanarak Socket.SendAsyncsunucuya bir ileti kodlar ve gönderir.
  • Gönderilen iletiyi konsola yazar.
  • Sunucudan veri almak için Socket.ReceiveAsync kullanarak bir arabellek başlatır.
  • response bir onay olduğunda, konsola yazılır ve ardından döngüden çıkılır.

• Nihayet, client soket, verilen Socket.Shutdown'yi çağırdığında, SocketShutdown.Both hem gönderme hem de alma işlemlerini kapatır.

Sunucu oluştur Socket

Sunucu yuvasını oluşturmak için, endPoint nesne herhangi bir IP adresinde gelen bağlantıları dinleyebilir, ancak bağlantı noktası numarası belirtilmelidir. Yuva oluşturulduktan sonra, sunucu gelen bağlantıları kabul edebilir ve istemcilerle iletişim kurabilir.

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|>"
}

Yukarıdaki C# kodu:

• Verilen Socket örneğindeki adres ailesi, endPoint ve SocketType.Stream ile yeni bir ProtocolType.Tcp nesnesi oluşturur.

• listener, yuvayı ağ adresiyle ilişkilendirmek için Socket.Bind örneğini bir bağımsız değişken olarak kullanarak endPoint yöntemini çağırır.

• yöntemi Socket.Listen() , gelen bağlantıları dinlemek için çağrılır.

• listener Socket.AcceptAsync yuvasında gelen bir bağlantıyı kabul etmek için handler yöntemini çağırır.

• Döngüde while :

  • Veriyi istemciden almak için Socket.ReceiveAsync çağrılır.
  • Veriler alındığında kodu çözülerek konsola yazılır.
  • response mesajı <|EOM|> ile biterse, Socket.SendAsync kullanılarak istemciye bir onay gönderilir.

Örnek istemciyi ve sunucuyu çalıştırma

Önce sunucu uygulamasını başlatın ve ardından istemci uygulamasını başlatın.

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...

İstemci uygulaması sunucuya bir ileti gönderir ve sunucu bir bildirimle yanıt verir.

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...

Ayrıca bakınız

• .NET 'de Soketler
• .NET'te ağ oluşturma
• System.Net.Sockets
• Socket