nanoframework.System.Net.Sockets.TcpClient 1.1.83

欢迎访问 .NET nanoFramework System.Net.Sockets.TcpClient

此 API 实现了与官方 .NET 相似的 TcpListener 和 TcpClient 类模式。 System.NET.Sockets.TcpClient.

这些是用于 TCP 连接的 Socket 的包装类。nanoframework 实现的 TcpClient 不包括异步方法和 Connected 属性。

构建状态

组件	构建状态	NuGet 包
nanoFramework.System.Net.Sockets.TcpClient

使用方法

重要： 显然这需要一个正常工作的网络连接。请检查有关如何连接到网络的示例，例如参阅 Networking 示例包

TcpListener 类提供了创建监听套接字以接受传入的 TCP 连接的简单方法，而 TcpClient 则提供了连接和进行 TCP 连接通信的方法。

示例

TcpListener 和 TcpClient 的示例可以在 nanoFramework 示例仓库中找到。

监听传入连接

以下代码展示如何设置监听套接字并在 1234 端口上作为 TcpClient 接受连接。

TcpListener listener = new TcpListener(IPAddress.Any, 1234);

// Start listening for incoming connections
listener.Start();
while (true)
{
    try
    {
        // Wait for incoming connections
        TcpClient client = listener.AcceptTcpClient();

        NetworkStream stream = client.GetStream();

        Byte[] bytes = new Byte[256];        
        int i;

        // Wait for incoming data and echo back
        while((i = stream.Read(bytes, 0, bytes.Length))!=0)
        {
            // Do something with data ?

            stream.Write(bytes, 0, i);
        }

        // Shutdown connection
        client.Close();
    }
    catch(Exception ex)
    {
        Debug.WriteLine($"Exception:-{ex.Message}");
    }
}

如果您想处理一个以上的同时连接，则可以启动一个单独的工作线程。

TcpListener listener = new TcpListener(IPAddress.Any, 1234);

// Start listening for incoming connections with backlog
listener.Start(2);

while (true)
{
    try
    {
        // Wait for incoming connections
        TcpClient client = listener.AcceptTcpClient();

        // Start thread to handle connection
        Thread worker = new Thread(() => WorkerThread(client));
        worker.Start();
    }
    catch(Exception ex)
    {
        Debug.WriteLine($"Exception:-{ex.Message}");
    }
}

TcpListener 示例中用于处理TcpClient连接的工作线程。

private static void WorkerThread(TcpClient client)
{
    try
    {
        NetworkStream stream = client.GetStream();

        Byte[] bytes = new Byte[256];        
        int i;

        // Loop reading data until connection closed
        while((i = stream.Read(bytes, 0, bytes.Length))!=0)
        {
            // Do something with data ?

            // Write back received data bytes to stream
            stream.Write(bytes, 0, i);
        }
    }
    catch(Exception ex)
    {
        Debug.WriteLine($"Exception:-{ex.Message}");
    }
    finally
    {
        // Shutdown connection
        client.Close();
    } 
}

TcpClient

TcpClient 还可以使用主机名/端口或 IPEndPoint 来发起连接。例如连接到另一个监听连接的 nanoFramework 设备。

TcpClient client = new TcpClient()

try
{
    client.Connect(hostname, port)

    NetworkStream stream = client.GetStream();

    // Write / Read data on stream

    // for example Write 'ABC' and wait for response
    byte[] writeData = new byte[] { 0x41, 0x42, 0x43 };  
    stream.Write(writeData, 0, writeData.Length);

    // Read reply and close
    byte[] buffer = new byte[1024];
    int bytesRead = stream.Read(buffer, 0, buffer.Length);

    // Process read data ?
}
catch(SocketException sx)
{
    Console.WriteLine($"Socket error:{sx.ErrorCode} exception:{sx.Message}");
}
finally
{
    client.Close();
}

对于安全连接，可以使用 SslStream。

client.Connect(HostName, 443);

// Create SSlStream from underlying SOcket
SslStream stream = new SslStream(client.Client);

// Don't verify Server certificate for this sample code
stream.SslVerification = SslVerification.NoVerification;
stream.AuthenticateAsClient(HostName, SslProtocols.Tls12);

// stream.Write() or stream.Read()

反馈和文档

有关文档、提供反馈、问题以及了解如何贡献，请参阅 主页仓库。

加入我们的 Discord 社区 这里。

鸣谢

此项目的贡献者列表可在 CONTRIBUTORS 中找到。

许可协议

nanoframework 类库采用 MIT 许可协议。

行为准则

本项目采纳了贡献者公约定义的行为准则，以明确我们社区中预期的行为。有关更多信息，请参阅 .NET Foundation 行为准则。

.NET Foundation

此项目由 .NET Foundation 支持。