117.info
人生若只如初见

如何使用C# Socket进行异步通信

在C#中,使用Socket进行异步通信可以提高程序的性能和响应能力

  1. 引入必要的命名空间:
using System;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
  1. 创建一个类,用于处理异步通信:
public class AsyncSocketServer
{
    private Socket _serverSocket;
    private const int BufferSize = 1024;

    public void StartListening(int port)
    {
        // 创建一个TCP/IP套接字
        _serverSocket = new Socket(AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);

        // 绑定到本地端口
        IPEndPoint localEndPoint = new IPEndPoint(IPAddress.Any, port);
        _serverSocket.Bind(localEndPoint);

        // 开始监听客户端连接
        _serverSocket.Listen(100);

        Console.WriteLine($"服务器正在监听端口 {port}...");

        // 等待客户端连接
        _serverSocket.BeginAccept(new AsyncCallback(AcceptCallback), _serverSocket);
    }

    private void AcceptCallback(IAsyncResult ar)
    {
        // 获取服务器套接字
        Socket serverSocket = (Socket)ar.AsyncState;

        // 接受客户端连接
        Socket clientSocket = serverSocket.EndAccept(ar);

        // 打印客户端信息
        Console.WriteLine($"客户端 {clientSocket.RemoteEndPoint} 已连接");

        // 准备接收数据的缓冲区
        byte[] buffer = new byte[BufferSize];

        // 开始异步接收数据
        clientSocket.BeginReceive(buffer, 0, BufferSize, SocketFlags.None, new AsyncCallback(ReceiveCallback), clientSocket);

        // 继续等待其他客户端连接
        serverSocket.BeginAccept(new AsyncCallback(AcceptCallback), serverSocket);
    }

    private void ReceiveCallback(IAsyncResult ar)
    {
        // 获取客户端套接字
        Socket clientSocket = (Socket)ar.AsyncState;

        try
        {
            // 结束异步接收操作
            int bytesRead = clientSocket.EndReceive(ar);

            if (bytesRead > 0)
            {
                // 解码接收到的数据
                string receivedData = https://www.yisu.com/ask/Encoding.ASCII.GetString(buffer, 0, bytesRead);"从客户端 {clientSocket.RemoteEndPoint} 接收到数据: {receivedData}");

                // 准备发送的数据
                byte[] sendBuffer = Encoding.ASCII.GetBytes("你好,我是服务器!");

                // 开始异步发送数据
                clientSocket.BeginSend(sendBuffer, 0, sendBuffer.Length, SocketFlags.None, new AsyncCallback(SendCallback), clientSocket);
            }
        }
        catch (Exception ex)
        {
            Console.WriteLine($"接收数据时出错: {ex.Message}");
            clientSocket.Close();
        }
    }

    private void SendCallback(IAsyncResult ar)
    {
        // 获取客户端套接字
        Socket clientSocket = (Socket)ar.AsyncState;

        try
        {
            // 结束异步发送操作
            int bytesSent = clientSocket.EndSend(ar);

            // 打印发送的数据长度
            Console.WriteLine($"向客户端 {clientSocket.RemoteEndPoint} 发送了 {bytesSent} 字节的数据");

            // 准备接收下一批数据的缓冲区
            byte[] buffer = new byte[BufferSize];

            // 开始异步接收数据
            clientSocket.BeginReceive(buffer, 0, BufferSize, SocketFlags.None, new AsyncCallback(ReceiveCallback), clientSocket);
        }
        catch (Exception ex)
        {
            Console.WriteLine($"发送数据时出错: {ex.Message}");
            clientSocket.Close();
        }
    }
}
  1. 在主程序中使用AsyncSocketServer类:
class Program
{
    static void Main(string[] args)
    {
        AsyncSocketServer server = new AsyncSocketServer();
        server.StartListening(8080);

        Console.WriteLine("按任意键退出...");
        Console.ReadKey();
    }
}

这个示例展示了如何使用C# Socket进行异步通信。当客户端连接到服务器时,服务器会异步接收客户端发送的数据,并将数据原样发送回客户端。你可以根据需要修改此示例以实现更复杂的通信功能。

未经允许不得转载 » 本文链接:https://www.117.info/ask/fef84AzsOCQFfBw.html

推荐文章

  • C#中如何合并Excel的单元格

    在C#中,可以使用Microsoft.Office.Interop.Excel库来操作Excel文件。要合并Excel单元格,需要先创建一个Excel应用程序实例,然后打开工作簿和工作表,接着选择要...

  • C#如何实现Excel文件的自动化操作

    在C#中,可以使用Microsoft Office Interop Excel库或者第三方库(如EPPlus、NPOI等)来实现Excel文件的自动化操作 使用Microsoft Office Interop Excel库: 首先...

  • 在C#中如何处理Excel的公式和函数

    在C#中处理Excel的公式和函数,可以使用Microsoft Office Interop Excel库 首先,确保已安装Microsoft Office Interop Excel库。如果没有安装,可以通过NuGet包管...

  • C#操作Excel的第三方库有哪些推荐

    在C#中操作Excel时,有多种第三方库可供选择。以下是一些推荐的库及其特点:
    推荐的C#操作Excel的第三方库 EPPlus 特点:EPPlus是一个流行的.NET库,用于处...

  • C# Socket编程中需要注意的安全问题有哪些

    在C# Socket编程中,需要注意以下安全问题: 数据加密:在传输敏感数据时,使用SSL/TLS进行加密。这可以确保数据在传输过程中不被窃取或篡改。 验证客户端身份:...

  • 如何关闭C# Socket连接

    在C#中,关闭Socket连接需要遵循以下步骤: 关闭数据的发送和接收。
    断开与远程主机的连接。
    释放Socket资源。 这里是一个简单的示例,展示了如何关闭...

  • C# Socket连接超时如何设置

    在C#中,使用Socket连接时,可以通过设置ReceiveTimeout和SendTimeout属性来控制连接超时。这两个属性分别表示接收和发送操作的超时时间,单位为毫秒。
    以下...

  • 如何实现C# Socket的多线程通信

    在C#中,使用Socket实现多线程通信可以通过创建一个服务器端和客户端并为每个连接创建单独的线程来完成。这里是一个简单的示例,展示了如何实现多线程Socket通信...