本文还有配套的精品资源，点击获取 menu-r.4af5f7ec.gif

简介：WebSocket 协议使得客户端与服务器间能建立持久的双向通信连接，尤其适合实时应用开发。C# 是 Windows 平台下广泛使用的编程语言，与 IIS 结合可实现 WebSocket 服务。本文将介绍如何在 IIS 中配置和使用 C# 来建立 WebSocket 服务，包括理解 WebSocket API，配置服务器和应用程序池，以及创建客户端和服务器端的 WebSocket 连接代码。案例中将展示具体的服务器端 HTTP 模块和客户端实现，帮助开发者掌握实时通信应用的开发技巧。
webSocket

1. WebSocket 协议基础与实时应用价值

1.1 WebSocket 协议简介

WebSocket 是一种在单个 TCP 连接上进行全双工通信的协议，它为 web 应用程序提供了一种与服务器进行持久连接的解决方案。与传统的轮询或长轮询技术相比，WebSocket 能够显著减少不必要的数据传输，实现近乎实时的双向通信。

1.2 WebSocket 协议的优势

WebSocket 之所以在实时应用中受到青睐，是因为它具备了几个显著优势：首先，它通过单一连接实现了高效的数据传输；其次，能够支持服务器向客户端主动推送消息，增强了应用的实时交互能力；最后，它的使用大大简化了实时应用的网络层面的复杂度，开发者可以更加专注于业务逻辑的开发。

1.3 WebSocket 的实时应用价值

在诸如即时通讯、在线游戏、实时监控、股票交易和各种实时数据共享平台等场景中，WebSocket 显示出了巨大的应用价值。它不仅提高了数据传输的效率，还极大地优化了用户体验。通过 WebSocket，开发者能够构建出响应更快速、交互更丰富的实时应用。

2. C# 语言和 IIS 服务器介绍

C#（发音为 “See Sharp”）是一种现代的、面向对象的编程语言，最初由微软公司为.NET框架开发。其设计目标是结合Visual Basic的易用性和C++的强大功能。C# 语言从一开始就是随着.NET平台的发展而成长起来的，随着技术的演进和语言的更新，C# 已经成为众多开发者首选的语言之一。

2.1 C# 语言概述

2.1.1 C# 的起源和发展

C# 语言的历史可以追溯到20世纪末，微软公司的Anders Hejlsberg（同时也是Turbo Pascal和Delphi的主要开发人员）在1999年被微软招揽，开始主导一个名为Cool的新语言开发项目。到了2000年，这个项目正式发布其第一个公共版本，并命名为C#。

C# 的版本与.NET框架版本紧密相关，随着.NET的每个新版本的发布，C# 也会更新以增加新特性，提高性能和安全性，并改进开发者的生产力。

C# 语言的最新版本是C# 9，它包含了许多特性，比如记录类型、目标类型的新变量声明、模式匹配的增强等。

2.1.2 C# 的主要特点和优势

C# 的主要特点和优势包括：

  • 类型安全 ：C# 在编译时检查类型，防止类型相关的错误。
  • 面向对象编程（OOP） ：支持封装、继承、多态等OOP概念。
  • 统一的语言规范 ：C# 是一个单一的语言，可以在.NET平台上的多种设备上运行。
  • 垃圾回收 ：自动内存管理减少了内存泄漏和空指针异常的风险。
  • 丰富的类库 ：.NET框架提供了大量的预构建类库，让开发者快速构建各种应用程序。
  • 跨平台 ：通过.NET Core和.NET 5/6等更新，C# 现在可以跨平台运行，支持Windows、macOS和Linux。
  • 异步编程模型 ：C# 支持异步编程，使开发高性能和响应式应用程序变得简单。

C# 的跨平台能力、面向对象的特性以及丰富的开发工具和库，使得它在企业级应用、游戏开发（Unity引擎使用C#作为主要编程语言），以及云服务等多个领域都有广泛的应用。

2.2 IIS 服务器概述

IIS（Internet Information Services）是微软公司推出的一个用于Windows平台的Web服务器产品。IIS支持各种Web服务和协议，比如HTTP、HTTPS、FTP、SMTP等，被广泛用于Windows Server系统上。它提供了丰富的功能和管理工具，为网站部署、虚拟主机管理、Web应用程序托管提供了全面的支持。

2.2.1 IIS 的基本功能和特点

IIS 的基本功能和特点包括：

  • Web服务器功能 ：作为HTTP服务器，能够处理HTML页面的请求和响应。
  • 应用程序池 ：允许不同应用程序之间隔离执行环境，提高应用程序稳定性和安全性。
  • SSL支持 ：支持安全套接层(SSL)和传输层安全性(TLS)，确保数据传输的安全性。
  • 负载均衡 ：可以配置多个服务器实例来处理请求，实现请求的负载均衡。
  • 扩展性和可伸缩性 ：支持Web园，可以扩展到多台服务器来处理更多的用户请求。
  • 管理工具 ：通过图形用户界面（GUI）或命令行工具进行管理，方便管理大型部署。

2.2.2 IIS 在 WebSocket 技术中的作用

IIS 在 WebSocket 技术中扮演着重要角色，尤其是作为C# WebSocket 通信的托管环境。IIS 可以配置为支持WebSocket协议，使得Web应用程序能够实现低延迟的全双工通信。这对于实时应用程序，比如聊天应用、游戏、实时仪表盘、协作工具等，都是至关重要的。

IIS 通过内置的WebSocket模块，使得开发者可以在熟悉的IIS环境中部署WebSocket服务。此外，开发者还能利用IIS的安全性、性能优化和管理工具等特性，来确保WebSocket服务的高可用性和安全性。

IIS 对WebSocket的支持包括自动升级到WebSocket协议的能力，以及对WebSockets通信的管理。这意味着开发者可以在IIS中配置SSL/TLS来加密WebSocket通道，确保数据传输安全，并通过IIS的管理工具对WebSocket服务进行监控和故障排查。

IIS 与WebSocket的集成，为使用C#开发的Web应用程序带来了新的维度。开发者可以利用IIS的成熟和稳定特性，构建性能优异、易于维护和扩展的实时应用程序。

3. C# WebSocket API 基础知识

3.1 WebSocket 协议的 C# 实现概述

3.1.1 C# 中 WebSocket 相关类和接口

在C#中，WebSocket协议的实现主要依靠了.NET Framework提供的System.Net.WebSockets命名空间。这个命名空间中包含了用于处理WebSocket通信的主要类和接口，如 WebSocket 类、 WebSocketCloseStatus 枚举和 WebSocketReceiveResult 结构体。

WebSocket 类是一个抽象类，提供了基本的WebSocket操作，包括打开、关闭、接收和发送消息。而 WebSocketCloseStatus 枚举则定义了WebSocket会话可能的状态码，例如 NormalClosure （正常关闭）、 EndpointUnavailable （端点不可用）等。

WebSocketReceiveResult 是一个重要的结构体，用于表示 ReceiveAsync 方法的返回结果。它包含一些属性，比如 Count （返回的数据量）、 EndOfMessage （是否接收到完整的消息）、 MessageType （消息类型）、 Status （接收状态）。

WebSocket ws = ...; // WebSocket 连接实例

// 异步接收数据
private async Task<WebSocketReceiveResult> ReceiveDataAsync(WebSocket ws)
{
    var buffer = new byte[1024 * 4]; // 数据缓冲区
    var result = await ws.ReceiveAsync(new ArraySegment<byte>(buffer), CancellationToken.None);
    return result;
}

3.1.2 C# WebSocket 通信机制

C#中的WebSocket通信机制相对直观易懂。首先创建WebSocket连接，然后根据需要异步接收或发送数据，最终关闭连接。这一过程中，开发者需要处理多种状态和错误情况，以确保通信的稳定性。

一个基本的WebSocket通信流程如下：

  1. 创建WebSocket实例并打开连接。
  2. 接收或发送消息，直到收到关闭消息。
  3. 发送关闭消息，并等待对方确认关闭。
  4. 关闭WebSocket连接。

在整个通信过程中，需要特别注意异步操作和异常处理，确保通信不会因为某个环节的失败而中断。同时，开发者也应该处理好网络问题导致的断线重连等逻辑，保证通信的可靠性。

try
{
    await ws.CloseAsync(WebSocketCloseStatus.NormalClosure, "Goodbye", CancellationToken.None);
}
catch (Exception ex)
{
    // 处理异常，比如网络异常导致的关闭失败
}

3.2 C# WebSocket API 的使用方法

3.2.1 创建 WebSocket 服务端

要创建一个WebSocket服务端，首先需要了解.NET中WebSocket相关的类和接口。以下是创建WebSocket服务端的简单步骤：

  1. 使用 HttpListener 或 WebSocketListener 来监听客户端的连接请求。
  2. 当监听到连接请求时，调用 AcceptWebSocketAsync 方法来接受WebSocket连接。
  3. 使用 WebSocket 对象来处理接收消息和发送消息的逻辑。

下面是一个使用 HttpListener 和 WebSocket 类创建简单WebSocket服务端的代码示例：

using System;
using System.Net;
using System.Net.WebSockets;
using System.Text;
using System.Threading;
using System.Threading.Tasks;

public class SimpleWebSocketServer
{
    public static async Task StartServerAsync(string url)
    {
        var listener = new HttpListener();
        listener.Prefixes.Add(url);
        listener.Start();

        Console.WriteLine("Server started at: " + url);

        while (true)
        {
            var context = await listener.GetContextAsync();
            var request = context.Request;
            var response = context.Response;

            if (request.IsWebSocketRequest)
            {
                WebSocket webSocket = await request.AcceptWebSocketAsync(subProtocol: null);

                while (webSocket.State == WebSocketState.Open)
                {
                    var buffer = new byte[1024 * 4];
                    var result = await webSocket.ReceiveAsync(new ArraySegment<byte>(buffer), CancellationToken.None);

                    if (result.MessageType == WebSocketMessageType.Close)
                    {
                        await webSocket.CloseAsync(WebSocketCloseStatus.NormalClosure, string.Empty, CancellationToken.None);
                        break;
                    }

                    var receivedText = Encoding.UTF8.GetString(buffer, 0, result.Count);
                    Console.WriteLine("Received text: " + receivedText);
                    await webSocket.SendAsync(new ArraySegment<byte>(Encoding.UTF8.GetBytes(receivedText)), 
                                                WebSocketMessageType.Text, 
                                                endOfMessage: true, 
                                                CancellationToken.None);
                }
            }
            else
            {
                response.StatusCode = 400;
                response.Close();
            }
        }
    }
}

3.2.2 客户端连接和消息处理

客户端连接WebSocket服务端相对简单。以下是客户端连接服务端并处理消息的基本步骤：

  1. 创建 ClientWebSocket 实例。
  2. 调用 ConnectAsync 方法连接到WebSocket服务端。
  3. 使用 ReceiveAsync 和 SendAsync 方法来接收和发送消息。
  4. 确保在适当的时候关闭WebSocket连接。

以下是一个客户端连接WebSocket服务端并接收和发送消息的简单示例：

using System;
using System.Net.WebSockets;
using System.Text;
using System.Threading;
using System.Threading.Tasks;

public class SimpleWebSocketClient
{
    private readonly Uri _serverUri;

    public SimpleWebSocketClient(string uri)
    {
        _serverUri = new Uri(uri);
    }

    public async Task ConnectAndCommunicateAsync()
    {
        using (var client = new ClientWebSocket())
        {
            await client.ConnectAsync(_serverUri, CancellationToken.None);
            Console.WriteLine("Connected to WebSocket server.");

            var buffer = new byte[1024 * 4];
            while (client.State == WebSocketState.Open)
            {
                var result = await client.ReceiveAsync(new ArraySegment<byte>(buffer), CancellationToken.None);

                if (result.MessageType == WebSocketMessageType.Close)
                {
                    await client.CloseAsync(WebSocketCloseStatus.NormalClosure, string.Empty, CancellationToken.None);
                    break;
                }

                var receivedText = Encoding.UTF8.GetString(buffer, 0, result.Count);
                Console.WriteLine("Received text: " + receivedText);

                await client.SendAsync(new ArraySegment<byte>(Encoding.UTF8.GetBytes(receivedText)), 
                                       WebSocketMessageType.Text, 
                                       endOfMessage: true, 
                                       CancellationToken.None);
            }
        }
    }
}

在这个客户端示例中，我们使用了 ClientWebSocket 类来处理WebSocket通信。我们创建了一个新的实例，并连接到服务器。在循环中，我们接收来自服务器的消息，并发送回服务器。当接收到关闭消息时，我们关闭连接。需要注意的是，通信过程中可能会遇到错误，因此，异常处理是不可或缺的一部分。

4. IIS 中 WebSocket 服务的配置

IIS（Internet Information Services）作为微软出品的Web服务器管理工具，与WebSocket协议的结合，可以让开发者利用.NET环境快速构建可扩展的实时Web应用。本章深入探讨如何在IIS中配置和优化WebSocket服务，以提高实时通信性能和安全性。

4.1 IIS WebSocket 模块的安装和配置

4.1.1 安装 WebSocket 模块

IIS默认并不自带WebSocket支持，需要额外安装和配置WebSocket模块才能使IIS服务器支持WebSocket协议。以下是安装步骤的详细介绍：

  1. 确保服务器操作系统满足安装要求。通常，WebSocket模块与.NET Framework配合使用，因此确保系统安装了相应的.NET Framework版本。

  2. 下载并安装IIS WebSocket模块。可以通过“控制面板”->“程序和功能”->“启用或关闭Windows功能”来添加WebSocket功能。

  3. 安装完成后，需要重启IIS服务以使新添加的功能生效。

# PowerShell命令安装IIS WebSocket模块
Enable-WindowsOptionalFeature -Online -FeatureName IIS-WebSockets

4.1.2 配置 WebSocket 服务端口和协议

安装完WebSocket模块后，接下来是配置服务端口和协议，以支持WebSocket通信：

  1. 打开IIS管理器，定位到你的网站属性。

  2. 在“编辑站点”对话框中，切换到“高级设置”标签页。

  3. 在“高级设置”中找到“WebSocket协议”，勾选启用选项。

  4. 指定用于WebSocket通信的端口，这可以是标准的WebSocket端口80（HTTP）和443（HTTPS），也可以是自定义端口。

<system.webServer>
    <webSocket enabled="true" />
</system.webServer>

4.2 IIS WebSocket 服务的高级配置

4.2.1 安全设置和权限管理

安全性是配置WebSocket服务时不可忽视的环节。下面介绍如何设置安全属性和权限管理：

  1. 确保传输层安全（TLS）或传输层加密（SSL）已经启用，以保证通信的加密性。

  2. 配置IIS进行IP和域名限制，防止未授权的访问。

  3. 利用Windows授权规则进行角色或用户级别的权限管理，确保只有授权用户可以建立WebSocket连接。

4.2.2 性能优化和故障排查

优化WebSocket服务性能可以提高用户体验和服务器效率。下面是一些常用的优化和故障排查方法：

  1. 利用IIS的性能计数器监控WebSocket连接状态和服务器负载。

  2. 调整连接超时和心跳间隔，减少不必要的资源消耗。

  3. 使用IIS日志和.NET应用的日志来跟踪和诊断问题。

graph LR
A[IIS WebSocket配置] -->|1.安装模块| B[WebSocket模块安装]
B -->|2.配置端口和协议| C[服务端口和协议配置]
C -->|3.安全设置| D[安全性和权限管理]
D -->|4.性能优化| E[性能监控与故障排查]

此流程图清晰地展示了配置IIS中WebSocket服务的步骤，每一个节点都对应本节内容的具体操作。

4.2.3 高级配置示例代码块

以下是一个配置WebSocket服务端口和协议的示例代码块：

<system.webServer>
    <urlCompression doStaticCompression="true" doDynamicCompression="true"/>
    <webSocket enabled="true" maxPendingConnections="1000" />
    <windowsAuthentication enabled="true" />
    <security>
        <requestFiltering>
            <hiddenSegments>
                <remove segment="bin" />
            </hiddenSegments>
        </requestFiltering>
    </security>
</system.webServer>

在配置中， enabled="true" 启用WebSocket服务， maxPendingConnections="1000" 设置了最大等待连接数， <windowsAuthentication enabled="true" /> 启用Windows认证，提供额外的安全层级。

4.2.4 性能优化和故障排查示例代码块

配置WebSocket服务后，监控其性能和状态是持续优化的关键，以下是使用PowerShell脚本进行性能监控的示例：

# PowerShell脚本监控WebSocket连接数
Get-Counter -Counter "\Web Service(WebSocket)\Current Connections" -ComputerName "YourServerName"

这段代码使用了 Get-Counter 命令来获取指定服务器上WebSocket的当前连接数，这对于实时监控和故障排查非常有用。

以上是IIS中WebSocket服务配置的详细介绍，这些配置不仅包括了基本的安装和启用过程，还涵盖了高级的安全和性能优化设置，以及相应的示例代码。通过这些详细配置，开发者可以更好地掌握如何在IIS中搭建和管理WebSocket服务。

5. 应用程序池.NET Framework 版本要求

5.1 .NET Framework 版本对 WebSocket 的支持

5.1.1 不同版本 .NET Framework 的特性

.NET Framework 自推出以来，版本不断迭代，每一次升级都伴随着新的特性和改进。随着技术的进步，WebSocket 协议也得到了不同版本 .NET Framework 的支持。从.NET Framework 4.5 开始，就加入了对 WebSocket 协议的原生支持，使得在 C# 中使用 WebSocket 成为了可能。这一特性允许开发者创建全双工的通信通道，广泛用于实时数据传输和通知服务。

.NET Framework 4.6 又引入了更多优化和改进，提高了 WebSocket 通信的性能和稳定性。而随着 ASP.NET Core 的推出，WebSocket 的支持得到了进一步增强。ASP.NET Core 2.1 甚至提供了更灵活的 WebSocket 中间件配置选项，允许开发者更精细地控制 WebSocket 连接的生命周期和行为。

5.1.2 选择合适的 .NET Framework 版本

选择合适的 .NET Framework 版本对于开发高效稳定的应用程序至关重要。在涉及 WebSocket 技术时，开发者需要根据项目需求和目标服务器环境来选择合适的框架版本。对于较老的服务器或系统，可能只能支持到.NET Framework 4.5，而在较新的项目中，推荐使用.NET Framework 4.6 或更高版本，以利用 WebSocket 的最佳实践和性能改进。

开发者应当评估现有代码库的兼容性、库和框架的依赖关系，以及目标用户基础的环境。如果可以自由选择，通常建议采用最新稳定版本，以保证得到最佳的性能和最新的功能。

5.2 应用程序池的配置和管理

5.2.1 应用程序池的作用和重要性

应用程序池是 IIS 中的一个重要概念，它为在服务器上运行的应用程序提供了隔离的环境。通过应用程序池，可以为每个应用程序配置独立的进程模型、运行时环境和资源使用限制。这对于性能优化、提高安全性以及管理多个应用程序的运行是极其有益的。

应用程序池的作用不仅限于隔离，它还支持应用程序的平滑回收，允许管理员无须中断服务即可进行更新和维护。此外，它还为监控和故障排查提供了便利，通过将应用程序分组到应用程序池中，可以单独跟踪资源使用情况，从而实现更精细的性能分析和故障诊断。

5.2.2 配置应用程序池以支持 WebSocket

为了使应用程序池支持 WebSocket 连接，需要进行特定的配置调整。首先，应用程序池的.NET CLR 版本必须设置为支持 WebSocket 的框架版本。例如，如果选择使用 .NET Framework 4.5 或更高版本，则必须确保.NET CLR 版本至少设置为 v4.0。

其次，要配置应用程序池允许 WebSocket 连接，需要修改应用程序池的高级设置，确保“WebSocket”协议已经启用。以下是一个配置应用程序池以支持 WebSocket 的示例代码块：

<configuration>
  <system.webServer>
    <applicationPools>
      <add name="MyWebSocketAppPool"CLRVersion="v4.0">
        <processModel identityType="ApplicationPoolIdentity"/>
      </add>
    </applicationPools>
    <webSocket enabled="true"/>
  </system.webServer>
</configuration>

在上述配置中， CLRVersion 属性设置为 “v4.0”，以支持使用 .NET Framework 4.5 或更高版本。 <webSocket enabled="true"/> 确保 WebSocket 功能已启用。这种配置允许 Web 应用程序响应 WebSocket 请求并进行双工通信。

接下来，需要确保应用程序池中的 Web 应用程序代码能够处理 WebSocket 连接。这通常涉及到监听特定的端点、接受连接、发送和接收消息等。在 .NET Framework 中，可以通过 System.Net.WebSockets 命名空间下的类来实现这些功能。

5.2.3 性能优化和故障排查

对于在 IIS 中托管的使用 WebSocket 技术的应用程序，性能优化和故障排查也是至关重要的环节。要优化应用程序池中的 WebSocket 应用程序性能，开发者可以调整应用程序池的以下设置：

  • CPU 使用限制 ：设置 CPU 时间的使用上限，以防止应用程序消耗过多的服务器资源。
  • 内存使用限制 ：配置内存使用上限，避免内存溢出导致的应用程序崩溃。
  • 回收时间设置 ：配置应用程序池的回收时间，定期重启进程以避免内存泄漏。

在故障排查方面，应密切监控应用程序池的日志，查找任何可能表明问题的错误信息或警告。另外，使用 netstat 和 telnet 等工具可以帮助检查 WebSocket 端点是否正常工作。例如，可以使用以下命令测试特定端口上的 WebSocket 连接：

telnet <服务器地址> <端口号>

如果端口是开放的，并且服务器已正确配置 WebSocket，你应该能够看到服务器的响应，表明 WebSocket 服务运行正常。

在应用程序池中托管 WebSocket 应用程序时，开发者还需要了解如何进行问题诊断和性能监控，以便在出现问题时快速响应。利用 IIS 提供的性能计数器和相关的诊断工具，可以详细了解应用程序的运行状况。例如，通过查看请求处理时间、工作进程数量以及请求队列长度等指标，可以评估应用程序的健康状况和性能瓶颈。

6. C# 中 WebSocket 服务器和客户端实现方法

6.1 C# WebSocket 服务器端实现

6.1.1 设计服务器端架构

WebSocket服务器端架构设计需要考虑如何处理来自客户端的连接请求、如何管理这些连接以及如何高效地传输数据。一个典型的服务器端架构包括一个监听端口，用来接收客户端的连接请求；一个连接管理器，用来维护和管理所有的WebSocket连接；以及消息处理器，用来处理发送和接收的数据。

6.1.2 实现服务器端代码

在C#中，可以通过 System.Net.WebSockets 命名空间下的 WebSocket 类来实现WebSocket服务端。以下是一个简单的服务器端示例代码，展示了如何创建一个监听在特定端口的WebSocket服务端，并对客户端的连接请求进行响应。

using System;
using System.Net;
using System.Net.WebSockets;
using System.Threading;
using System.Threading.Tasks;

public class WebSocketServer
{
    private readonly int _port;
    private readonly CancellationTokenSource _cts = new CancellationTokenSource();

    public WebSocketServer(int port)
    {
        _port = port;
    }

    public async Task Run()
    {
        var server = new HttpListener();
        server.Prefixes.Add($"http://localhost:{_port}/ws/");
        server.Start();

        Console.WriteLine("Server started...");

        while (!_cts.IsCancellationRequested)
        {
            var context = await server.GetContextAsync();
            if (context.Request.IsWebSocketRequest)
            {
                var webSocketContext = await context.AcceptWebSocketAsync(subProtocol: null);
                var webSocket = webSocketContext.WebSocket;

                await Echo(webSocket, _cts.Token);
            }
            else
            {
                context.Response.StatusCode = 400;
                context.Response.Close();
            }
        }
    }

    private async Task Echo(WebSocket webSocket, CancellationToken ct)
    {
        var buffer = new byte[1024 * 4];
        while (webSocket.State == WebSocketState.Open)
        {
            var result = await webSocket.ReceiveAsync(new ArraySegment<byte>(buffer), ct);
            if (result.MessageType == WebSocketMessageType.Text || result.MessageType == WebSocketMessageType.Binary)
            {
                await webSocket.SendAsync(new ArraySegment<byte>(buffer, 0, result.Count), result.MessageType, result.EndOfMessage, ct);
            }
            else if (result.MessageType == WebSocketMessageType.Close)
            {
                await webSocket.CloseAsync(WebSocketCloseStatus.NormalClosure, string.Empty, ct);
                break;
            }
        }
    }

    public void Stop()
    {
        _cts.Cancel();
    }
}

// To run this server, instantiate WebSocketServer and call the Run method.

在这个例子中，服务器端通过监听HTTP请求来响应WebSocket连接，并使用 Echo 方法来简单地将接收到的消息回发给客户端。服务器会在一个无限循环中等待客户端连接，当接收到关闭消息时，服务器会关闭WebSocket连接。

6.2 C# WebSocket 客户端实现

6.2.1 设计客户端架构

WebSocket客户端需要有连接服务器的能力、发送消息到服务器的功能以及接收服务器消息的逻辑。在设计客户端架构时，通常需要处理连接的建立和关闭、消息的异步发送和接收、以及错误处理等问题。

6.2.2 实现客户端代码

使用C#，我们同样可以利用 System.Net.WebSockets 命名空间来创建WebSocket客户端。以下是一个客户端连接到服务器并发送接收消息的示例代码。

using System;
using System.Net.WebSockets;
using System.Text;
using System.Threading;
using System.Threading.Tasks;

public class WebSocketClient
{
    private readonly Uri _uri;
    private ClientWebSocket _clientWebSocket;

    public WebSocketClient(string uri)
    {
        _uri = new Uri(uri);
        _clientWebSocket = new ClientWebSocket();
    }

    public async Task Connect()
    {
        await _clientWebSocket.ConnectAsync(_uri, CancellationToken.None);
    }

    public async Task SendReceive()
    {
        const int ReceiveChunkSize = 1024;
        var buffer = new byte[ReceiveChunkSize];
        while (_clientWebSocket.State == WebSocketState.Open)
        {
            var result = await _clientWebSocket.ReceiveAsync(new ArraySegment<byte>(buffer), CancellationToken.None);

            if (result.MessageType == WebSocketMessageType.Text || result.MessageType == WebSocketMessageType.Binary)
            {
                string receivedText = Encoding.UTF8.GetString(buffer, 0, result.Count);
                Console.WriteLine($"Received message: {receivedText}");

                // Echo the received message back to the server.
                await _clientWebSocket.SendAsync(new ArraySegment<byte>(buffer, 0, result.Count),
                                                  result.MessageType, result.EndOfMessage,
                                                  CancellationToken.None);
            }
            else if (result.MessageType == WebSocketMessageType.Close)
            {
                await _clientWebSocket.CloseAsync(WebSocketCloseStatus.NormalClosure, string.Empty, CancellationToken.None);
                break;
            }
        }
    }

    public void Close()
    {
        _clientWebSocket.CloseAsync(WebSocketCloseStatus.NormalClosure, string.Empty, CancellationToken.None);
    }
}

// To run this client, instantiate WebSocketClient with server URL and call Connect method.
// After connection, call SendReceive method to start sending/receiving messages.

在这个例子中，客户端首先通过 Connect 方法建立连接，随后调用 SendReceive 方法来接收并发送消息。客户端会一直监听服务器发送的消息，并在接收到关闭请求后结束连接。

6.3 服务器和客户端的交互实例

6.3.1 实例演示服务器和客户端的通信过程

为了展示服务器和客户端的通信过程，我们可以通过以下步骤来进行一个简单的测试。

  1. 在服务器上运行 WebSocketServer 类的 Run 方法。
  2. 在客户端上运行 WebSocketClient 类的 Connect 方法，建立连接。
  3. 在客户端上运行 SendReceive 方法，并发送一条消息。
  4. 观察服务器控制台输出接收到的消息，并将相同的响应消息发送回客户端。
  5. 观察客户端控制台输出从服务器接收到的消息。

6.3.2 分析实例中遇到的问题及解决方案

在实际开发中，可能会遇到各种问题，比如网络问题导致连接失败、数据发送接收异常、协议不匹配等。解决这些问题需要在网络层面上进行调试，或者利用客户端和服务器的异常处理逻辑来进行恢复。例如，在 WebSocketServer 类和 WebSocketClient 类中，我们使用 try-catch 块来捕获并处理可能出现的异常。

此外，还可以在客户端和服务器之间实现更复杂的交互逻辑，如消息类型检测、消息压缩、心跳机制等，来保证通信的稳定性和效率。在遇到问题时，根据错误日志逐步排查并解决具体的问题，是保证WebSocket通信顺利进行的关键。

本文还有配套的精品资源，点击获取 menu-r.4af5f7ec.gif

简介：WebSocket 协议使得客户端与服务器间能建立持久的双向通信连接，尤其适合实时应用开发。C# 是 Windows 平台下广泛使用的编程语言，与 IIS 结合可实现 WebSocket 服务。本文将介绍如何在 IIS 中配置和使用 C# 来建立 WebSocket 服务，包括理解 WebSocket API，配置服务器和应用程序池，以及创建客户端和服务器端的 WebSocket 连接代码。案例中将展示具体的服务器端 HTTP 模块和客户端实现，帮助开发者掌握实时通信应用的开发技巧。


本文还有配套的精品资源，点击获取
menu-r.4af5f7ec.gif

Logo
https://edu.csdn.net/learn/39067/627173?utm_source=2019755004

汇聚全球AI编程工具，助力开发者即刻编程。

更多推荐

cover

一个 API 入口调用多个大模型：AiiOnly客户端 + CC Switch 打通 Codex AI编程流程

avatar AI编程社区
cover

VSCode Claude Code + MiMo 中转免登录完整配置教程（解决原生登录弹窗 + 模型报错）

avatar AI编程社区
cover

从零开始做一个属于自己的 Skill（保姆级教程）

avatar AI编程社区