C# Socket异步通讯实现详解(C# Socket异步通信实现深度解析)

原创

ithorizon 1个月前 (10-19) 阅读数 21 #后端开发

C# Socket异步通讯实现详解(C# Socket异步通信实现深度解析)

在软件开发中，网络通信是不可或缺的一部分。C# 提供了有力的 Socket 编程功能，让开发者能够方便地实现网络通信。本文将详细介绍 C# Socket 异步通信的实现方法，帮助读者深入懂得其原理和实现过程。

一、Socket 基本概念

Socket 是计算机网络通信的基本单元，它提供了进程间通信的端点。在网络编程中，Socket 可以看作是不同主机间通信的通道。C# 中的 Socket 类提供了创建和管理 Socket 的功能。

二、异步通信的优势

在传统的同步通信中，当一个操作被阻塞时，整个程序都会停下来等待操作完成。这会让程序的性能下降。异步通信可以解决这个问题，它允许程序在等待操作完成的同时继续执行其他任务。在 C# 中，通过使用 async 和 await 关键字，可以轻松实现异步通信。

三、C# Socket 异步通信实现

下面将通过一个简洁的例子来介绍 C# Socket 异步通信的实现。

3.1 创建服务器端 Socket

服务器端需要创建一个 Socket，并监听来自客户端的连接请求。


using System;
using System.Net;
using System.Net.Sockets;
using System.Threading.Tasks;
public class Server
{
    private const int BUFFER_SIZE = 1024;
    private const int PORT = 8000;
    public static async Task Main(string[] args)
    {
        var localEndPoint = new IPEndPoint(IPAddress.Any, PORT);
        var serverSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
        try
        {
            serverSocket.Bind(localEndPoint);
            serverSocket.Listen(10);
            Console.WriteLine("Waiting for a connection...");
            var clientSocket = await Task.Factory.FromAsync(serverSocket.BeginAccept, serverSocket.EndAccept, null).ConfigureAwait(false);
            Console.WriteLine("Connected with {0} at port {1}", clientSocket.RemoteEndPoint.ToString(), ((IPEndPoint)clientSocket.RemoteEndPoint).Port);
            var buffer = new byte[BUFFER_SIZE];
            int bytesRead = await clientSocket.ReceiveAsync(new ArraySegment(buffer), SocketFlags.None);
            Console.WriteLine("Received: {0}", Encoding.ASCII.GetString(buffer, 0, bytesRead));
            await clientSocket.ShutdownAsync(SocketShutdown.Both);
            clientSocket.Close();
        }
        catch (Exception e)
        {
            Console.WriteLine(e.ToString());
        }
    }
}

3.2 创建客户端 Socket

客户端需要创建一个 Socket，并连接到服务器端。


using System;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading.Tasks;
public class Client
{
    private const int BUFFER_SIZE = 1024;
    private const string SERVER_IP = "127.0.0.1";
    private const int SERVER_PORT = 8000;
    public static async Task Main(string[] args)
    {
        var remoteEndPoint = new IPEndPoint(IPAddress.Parse(SERVER_IP), SERVER_PORT);
        var clientSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
        try
        {
            await clientSocket.ConnectAsync(remoteEndPoint);
            Console.WriteLine("Socket connected to {0}", clientSocket.RemoteEndPoint.ToString());
            var message = Encoding.ASCII.GetBytes("Hello from client!");
            await clientSocket.SendAsync(new ArraySegment(message), SocketFlags.None);
            clientSocket.Shutdown(SocketShutdown.Both);
            clientSocket.Close();
        }
        catch (Exception e)
        {
            Console.WriteLine(e.ToString());
        }
    }
}