Example 3服务器+ Example1 客户端

示例3

此源代码片段包含了如何使用<code>WebSocketSharp库来创建一个HTTP服务器，并提供WebSocket服务。 分析整个代码，我们可以归纳出以下关键信息：

导入了一系列重要的命名空间，包括系统配置、加密库、文本、WebSocket等。

定义了Example3名称空间和包含Main方法的Program类，作为HTTP服务器和WebSocket服务的入口点。

HTTP服务器使用4649端口实例化，同时注释掉的代码展示了其他可能的方式来实例化HTTP服务器（包括带安全连接的https，以及监听不同网络地址和端口的服务器实例）。

当服务器运行在DEBUG模式下，可以设置日志级别、响应等待时间以及清理策略。

注释掉的代码示例说明了如何设置服务器的SSL配置，以及如何设置基本或摘要型的HTTP身份验证。

服务器利用HttpServer.DocumentRootPath设置了文档根目录路径。

通过OnGet事件处理程序来处理HTTP GET请求，可以读取文件并根据文件内容类型设置响应头和正文。

服务器添加了Echo和Chat两个WebSocket服务。

注释掉的代码中包括了WebSocket服务的详细初始化示例，例如设置协议、校验器和对服务器发送的Cookie进行校验等。

服务器启动并开始监听，在控制台上显示一些运行信息。

最后，通过读取输入来停止HTTP服务器

综上所述，本段代码提供了使用WebSocketSharp库创建符合个人需要的HTTP服务器与WebSocket服务的多种示例和配置方法。通过此代码，可以开启一个支持WebSocket通信的服务器，并可通过相关配置来实现安全连接、HTTP认证和基于文档根路径的内容服务能力。

App.config文件

下面代码初始化一个基于WebSocketSharp库的WebSocket服务器，它允许客户端通过WebSocket协议连接进行通信，并提供HTTP服务，可以响应基于HTTP的GET请求。提供静态文件服务和WebSocket回显(Echo)/聊天(Chat)服务。支持通过不同方式指定服务的地址和端口，包含了调试模式下的日志等级设置，以及生产模式下的SSL/TLS证书配置和HTTP认证机制的配置，但这些功能默认是被注释掉的。服务器通过控制台命令启动和停止，并能在控制台输出当前服务的状态信息。

<code>using System; // 引入System命名空间

using System.Configuration; // 引入System.Configuration命名空间，用于访问配置文件

using System.Security.Cryptography.X509Certificates; // 引入System.Security.Cryptography.X509Certificates命名空间，用于处理证书

using System.Text; // 引入System.Text命名空间，包含编码和字符集的功能

using WebSocketSharp; // 引入WebSocketSharp命名空间，一个实现WebSocket协议的C#库

using WebSocketSharp.Net; // 引入WebSocketSharp.Net命名空间，提供网络相关的功能

using WebSocketSharp.Server; // 引入WebSocketSharp.Server命名空间，用于创建和管理WebSocket服务器

// 定义了一个名为Example3的命名空间

namespace Example3

{

// 定义了一个Program类

public class Program

{

// 主函数

public static void Main (string[] args)

{

// 创建HttpServer类的新实例。

//

// 如果需要提供安全连接（即HTTPS），应使用带有'secure'参数设置为true

// 或者带有https协议的HTTP URL来创建新实例。

var httpsv = new HttpServer (4649); // 在4649端口上实例化HttpServer

// var httpsv = new HttpServer (5963, true); // 使用SSL在5963端口上实例化HttpServer（代码暂时被注释）

// 下面的被注释的代码块展示了其他创建HttpServer实例的方式。

// 例如绑定到所有IP地址、绑定到IPv6地址、通过具体IP实例化等等。

/*注释掉的代码展示了多种不同的方法来创建HttpServer的实例，包括监听不同的网络接口（所有网络、IPv4回环地址、IPv6回环地址）、监听不同的端口（常规端口、安全端口）、以及支持安全连接（SSL/TLS）。代码被注释意味着虽然是可用的选项，但当前不是活动状态。这些代码为开发者提供了灵活性，在不同场景下快速调整服务器监听的网络接口和端口。*/

// 使用SSL，在5963端口上创建一个支持安全连接的HttpServer实例（代码被注释）

// var httpsv = new HttpServer (5963, true);

// 在所有网络接口的4649端口上创建HttpServer实例（代码被注释）

// var httpsv = new HttpServer (System.Net.IPAddress.Any, 4649);

// 在所有网络接口的5963端口上创建支持SSL的HttpServer实例（代码被注释）

// var httpsv = new HttpServer (System.Net.IPAddress.Any, 5963, true);

// 在所有IPv6地址的4649端口上创建HttpServer实例（代码被注释）

// var httpsv = new HttpServer (System.Net.IPAddress.IPv6Any, 4649);

// 在所有IPv6地址的5963端口上创建支持SSL的HttpServer实例（代码被注释）

// var httpsv = new HttpServer (System.Net.IPAddress.IPv6Any, 5963, true);

// 通过HTTP协议，在所有网络接口的4649端口上创建HttpServer实例（代码被注释）

// var httpsv = new HttpServer ("http://0.0.0.0:4649");

// 通过HTTPS协议，在所有网络接口的5963端口上创建HttpServer实例（代码被注释）

// var httpsv = new HttpServer ("https://0.0.0.0:5963");

// 通过HTTP协议，在所有IPv6地址的4649端口上创建HttpServer实例（代码被注释）

// var httpsv = new HttpServer ("http://[::0]:4649");

// 通过HTTPS协议，在所有IPv6地址的5963端口上创建HttpServer实例（代码被注释）

// var httpsv = new HttpServer ("https://[::0]:5963");

// 在回环接口（localhost）的4649端口上创建HttpServer实例（代码被注释）

// var httpsv = new HttpServer (System.Net.IPAddress.Loopback, 4649);

// 在回环接口（localhost）的5963端口上创建支持SSL的HttpServer实例（代码被注释）

// var httpsv = new HttpServer (System.Net.IPAddress.Loopback, 5963, true);

// 在IPv6回环接口（localhost）的4649端口上创建HttpServer实例（代码被注释）

// var httpsv = new HttpServer (System.Net.IPAddress.IPv6Loopback, 4649);

// 在IPv6回环接口（localhost）的5963端口上创建支持SSL的HttpServer实例（代码被注释）

// var httpsv = new HttpServer (System.Net.IPAddress.IPv6Loopback, 5963, true);

// 通过HTTP协议，在localhost的4649端口上创建HttpServer实例（代码被注释）

// var httpsv = new HttpServer ("http://localhost:4649");

// 通过HTTPS协议，在localhost的5963端口上创建HttpServer实例（代码被注释）

// var httpsv = new HttpServer ("https://localhost:5963");

// 通过HTTP协议，在127.0.0.1（IPv4回环地址）的4649端口上创建HttpServer实例（代码被注释）

// var httpsv = new HttpServer ("http://127.0.0.1:4649");

// 通过HTTPS协议，在127.0.0.1（IPv4回环地址）的5963端口上创建HttpServer实例（代码被注释）

// var httpsv = new HttpServer ("https://127.0.0.1:5963");

// 通过HTTP协议，在[::1]（IPv6回环地址）的4649端口上创建HttpServer实例（代码被注释）

// var httpsv = new HttpServer ("http://[::1]:4649");

// 通过HTTPS协议，在[::1]（IPv6回环地址）的5963端口上创建HttpServer实例（代码被注释）

// var httpsv = new HttpServer ("https://[::1]:5963");

#if DEBUG

// 若是处于DEBUG模式，以下参数会被设置。

httpsv.Log.Level = LogLevel.Trace; // 日志级别被设置为Trace

// 以下是在DEBUG模式下可能会设置的其他参数。

// 更改响应WebSocket Ping或Close的等待时间为2秒（代码被注释）

// httpsv.WaitTime = TimeSpan.FromSeconds (2);

// httpsv.KeepClean = false; // 不定期移除不活跃的WebSocket会话（代码被注释）

#endif

/*被注释掉的代码展示了如何对HttpServer实例进行配置，包括配置安全连接（设置服务器证书）、提供HTTP认证（设置认证方案，用户凭证查找函数）以及解决等待处于TIME_WAIT状态的套接字的问题。被注释意味着这些配置在当前不被应用，这些代码为开发者提供了灵活性，在不同场景下快速调整服务器的配置。*/

// 若要启用具有安全性的连接（SSL/TLS），需要取消以下部分的注释，

// 并指定服务器证书的路径与密码。

// 提供安全连接

/*

var cert = ConfigurationManager.AppSettings["ServerCertFile"]; // 获取服务器证书文件路径

var passwd = ConfigurationManager.AppSettings["CertFilePassword"]; // 获取服务器证书文件密码

httpsv.SslConfiguration.ServerCertificate = new X509Certificate2 (cert, passwd); // 创建X509证书实例并设置为服务器证书（代码段被注释）

*/

// 提供HTTP认证（基础认证/摘要认证）

/*

httpsv.AuthenticationSchemes = AuthenticationSchemes.Basic; // 设置认证方案为基础认证

httpsv.Realm = "WebSocket Test"; // 设置领域/域名为"WebSocket Test"

httpsv.UserCredentialsFinder = id => {

var name = id.Name; // 获取用户名

// 返回用户名、密码以及角色

return name == "nobita"

? new NetworkCredential (name, "password", "gunfighter")

: null; // 如果找不到用户的凭证，则返回null（代码段被注释）

};

*/

// 解决等待处于TIME_WAIT状态的套接字问题

// httpsv.ReuseAddress = true; // 设置可重用地址（代码被注释）

// 设置文档根路径。

httpsv.DocumentRootPath = ConfigurationManager.AppSettings["DocumentRootPath"];

// 设置HTTP GET请求处理事件。

httpsv.OnGet += (sender, e) => { // 为httpsv实例的OnGet事件绑定一个事件处理程序

var req = e.Request; // 获取请求对象

var res = e.Response; // 获取响应对象

var path = req.RawUrl; // 获取请求的RawUrl属性，即原始请求路径

if (path == "/") // 如果请求路径是根目录

path += "index.html"; // 则将路径改为"index.html"

byte[] contents; // 定义一个字节数组来存放文件内容

if (!e.TryReadFile (path, out contents)) { // 尝试读取指定路径的文件内容到contents数组中

res.StatusCode = (int) HttpStatusCode.NotFound; // 如果文件不存在，设置响应状态码为404（未找到）

return; // 结束事件处理

}

// 以下根据请求文件的类型设置Content-Type响应头

if (path.EndsWith(".html")) { // 如果文件是HTML文件

res.ContentType = "text/html"; // 设置响应内容类型为text/html

res.ContentEncoding = Encoding.UTF8; // 设置响应内容的编码为UTF-8

}

else if (path.EndsWith(".js")) { // 如果文件是JavaScript文件

res.ContentType = "application/javascript"; // 设置响应内容类型为application/javascript

res.ContentEncoding = Encoding.UTF8; // 同样设置编码为UTF-8

}

res.ContentLength64 = contents.LongLength; // 设置响应内容的长度

res.Close(contents, true); // 将内容发送给客户端并关闭响应

};

// 添加WebSocket服务。

httpsv.AddWebSocketService<Echo> ("/Echo"); // 添加Echo服务

httpsv.AddWebSocketService<Chat> ("/Chat"); // 添加Chat服务

// WebSocket服务的初始化（如果需要初始化参数）。下面的多个注释代码块用于配置服务。

httpsv.Start(); // 启动HttpServer

// 如果服务器已经开始监听，则输出一些基本的服务信息。

if (httpsv.IsListening) {

Console.WriteLine ("Listening on port {0}, and providing WebSocket services:", httpsv.Port);

foreach (var path in httpsv.WebSocketServices.Paths)

Console.WriteLine ("- {0}", path); // 输出提供服务的路径

}

Console.WriteLine ("\nPress Enter key to stop the server..."); // 提示按下回车停止服务器

Console.ReadLine (); // 等待用户输入

httpsv.Stop (); // 停止HttpServer

}

}

}

启动服务：

Listening on port 4649, and providing WebSocket services:

- /Echo

- /Chat

Press Enter key to stop the server...

下面代码定义了一个名为Chat的类，该类继承自WebSocketBehavior类，用于处理WebSocket服务器的一个聊天服务。在新的WebSocket连接建立时获取用户名，并向所有已连上的会话广播该用户已上线的消息。当收到消息时，将该用户的用户名和消息内容进行拼装，并广播给所有已连上的会话。当WebSocket连接断开时，广播该用户已下线的消息。整个Chat类就是一个简单的聊天室服务的实现。

using System; // 引用System命名空间

using System.Threading; // 引用System.Threading命名空间，提供多线程相关的功能

using WebSocketSharp; // 引用WebSocketSharp命名空间，一个实现WebSocket协议的C#库

using WebSocketSharp.Server; // 引用WebSocketSharp.Server命名空间，用于创建和管理WebSocket服务器

// 定义Example3名字空间

namespace Example3

{

// 定义公共类Chat，继承自WebSocketBehavior

public class Chat : WebSocketBehavior

{

private string _name; // 私有字符串变量，表示聊天的用户名

private static int _number = 0; // 私有静态整型变量，与用户名关联

private string _prefix; // 私有字符串变量，表示用户名前缀

// 构造函数

public Chat ()

{

_prefix = "anon#"; // 默认的用户名前缀是“anon#”

}

// Prefix 属性的get和set方法

public string Prefix {

get {

return _prefix;

}

set {

_prefix = !value.IsNullOrEmpty () ? value : "anon#";

}

}

// 获取用户名的私有方法

private string getName ()

{

var name = Context.QueryString["name"]; // 获取QueryString中的"name"字段的值作为用户名

return !name.IsNullOrEmpty () ? name : _prefix + getNumber (); // 如果"name"字段非空，则用户名为其值，否则，用户名为前缀+_number

}

// 获取_number的私有方法，并使用Interlocked增量操作该变量，保证线程安全

private static int getNumber ()

{

return Interlocked.Increment(ref _number);

}

// 覆盖基类的OnClose方法，该方法在WebSocket连接关闭时被调用

protected override void OnClose (CloseEventArgs e)

{

if (_name == null)

return;

var fmt = "{0} got logged off..."; // 定义消息格式

var msg = String.Format (fmt, _name); // 格式化消息字符串

Sessions.Broadcast (msg); // 向所有连接的会话广播消息

}

// 覆盖基类的OnMessage方法，该方法在收到WebSocket消息时被调用

protected override void OnMessage (MessageEventArgs e)

{

var fmt = "{0}: {1}"; // 定义消息格式

var msg = String.Format (fmt, _name, e.Data); // 格式化消息字符串

Sessions.Broadcast (msg); // 向所有连接的会话广播消息

}

// 覆盖基类的OnOpen方法，该方法在建立新的WebSocket连接后立即被调用

protected override void OnOpen ()

{

_name = getName (); // 获取用户名

var fmt = "{0} has logged in!"; // 定义消息格式

var msg = String.Format (fmt, _name); // 格式化消息字符串

Sessions.Broadcast (msg); // 向所有连接的会话广播消息

}

}

}

下面代码定义了名为Echo的类，该类继承自WebSocketBehavior，用于处理WebSocket服务器上的回声服务。当Echo服务的WebSocket连接收到客户端送来的消息时，它简单地将相同的消息数据直接返回给客户端。这个类通常用于测试客户端与服务器的连接是否正常，检查消息的去程和回程延迟。

using System; // 引入System命名空间

using WebSocketSharp; // 引入WebSocketSharp命名空间，一个实现WebSocket协议的C#库

using WebSocketSharp.Server; // 引入WebSocketSharp.Server命名空间，用于创建和管理WebSocket服务器

// 定义Example3名字空间

namespace Example3

{

// 定义公共类Echo，继承自WebSocketBehavior

public class Echo : WebSocketBehavior

{

// 覆盖基类的OnMessage方法，该方法在收到WebSocket消息时被调用

protected override void OnMessage(MessageEventArgs e)

{

Send(e.Data); // 将收到的消息数据发送回客户端，实现回声（echo）功能

}

}

}

示例1

这段代码展示了如何使用<code>WebSocketSharp库创建一个WebSocket客户端，连接到WebSocket服务器，并发送和接收消息。它提供了处理打开连接、接收消息、发生错误以及关闭连接的事件处理程序。代码还包括了调试相关的设置，以及一些被注释的代码块来展示如何配置WebSocket客户端（例如SSL证书验证、发送凭证、处理cookies等），但这些部分目前并未启用。用户通过控制台可以输入消息发送到服务器，输入"exit"来关闭程序。

using System; // 引入System命名空间，它是最基础的命名空间

using System.Threading; // 引入多线程相关的命名空间

using WebSocketSharp; // 引入WebSocketSharp库，它提供了WebSocket协议的实现

using WebSocketSharp.Net; // 引入网络相关的命名空间

namespace Example // 定义一个名为Example的命名空间

{

public class Program // 定义一个公共类Program

{

public static void Main (string[] args) // 主函数，程序入口点

{

// 创建 WebSocket 类的新实例。

//

// WebSocket类继承了System.IDisposable接口，因此可以

// 使用using 语句。 WebSocket 连接将被关闭

// 当控件离开 using 块时关闭状态 1001（离开）。

//

// 如果您想通过安全连接连接到服务器，

// 您应该使用 wss 方案 WebSocket URL 创建一个新实例。

using (var ws = new WebSocket ("ws://localhost:4649/Echo")) // 创建一个WebSocket实例连接到指定的服务端地址和端口

//using (var ws = new WebSocket ("wss://localhost:5963/Echo"))

//using (var ws = new WebSocket ("ws://localhost:4649/Chat"))

//using (var ws = new WebSocket ("wss://localhost:5963/Chat"))

//using (var ws = new WebSocket ("ws://localhost:4649/Chat?name=nobita"))

//using (var ws = new WebSocket ("wss://localhost:5963/Chat?name=nobita"))

{

// 设置WebSocket事件

ws.OnOpen += (sender, e) => ws.Send ("Hi, there!"); // 当WebSocket连接建立时，发送一条消息"Hi, there!"

ws.OnMessage += (sender, e) => { // 当从服务端接收到消息时，执行该事件

var fmt = "[WebSocket Message] {0}"; // 定义一个格式字符串

var body = !e.IsPing ? e.Data : "A ping was received."; // 如果接收到的不是Ping消息，则输出数据，否则输出"A ping was received."

Console.WriteLine (fmt, body); // 将消息输出到控制台

};

ws.OnError += (sender, e) => { // 当发生错误时，执行该事件

var fmt = "[WebSocket Error] {0}"; // 定义一个格式字符串

Console.WriteLine (fmt, e.Message); // 将错误信息输出到控制台

};

ws.OnClose += (sender, e) => { // 当WebSocket连接关闭时，执行该事件

var fmt = "[WebSocket Close ({0})] {1}"; // 定义一个格式字符串

Console.WriteLine (fmt, e.Code, e.Reason); // 将关闭信息输出到控制台

};

#if DEBUG

// 调试时设置的额外选项

ws.Log.Level = LogLevel.Trace; // 设置日志级别

// 设置等待Ping或Close的响应时间为10秒（代码被注释）

// ws.WaitTime = TimeSpan.FromSeconds (10);

// 当接收到ping时触发WebSocket.OnMessage事件（代码被注释）

// ws.EmitOnPing = true;

#endif

// 开启消息压缩功能

// ws.Compression = CompressionMethod.Deflate; //（代码被注释）

// 验证服务器证书（代码段被注释）

/*

ws.SslConfiguration.ServerCertificateValidationCallback =

(sender, certificate, chain, sslPolicyErrors) => {

// 省略了输出证书信息的代码

return true; // 如果服务器证书有效

};

*/

// 发送HTTP认证信息（基础认证或摘要认证）（代码被注释）

// ws.SetCredentials ("nobita", "password", false);

// 发送来源页首部（代码被注释）

// ws.Origin = "http://localhost:4649";

// 发送cookies（代码被注释）

// ws.SetCookie (new Cookie ("name", "nobita"));

// ws.SetCookie (new Cookie ("roles", "\"idiot, gunfighter\""));

// 通过HTTP代理服务器连接（代码被注释）

// ws.SetProxy ("http://localhost:3128", "nobita", "password");

// 开启重定向（代码被注释）

// ws.EnableRedirection = true;

ws.Connect (); // 连接到服务器

// 异步连接到服务器（代码被注释）

// ws.ConnectAsync ();

Console.WriteLine ("\nType 'exit' to exit.\n"); // 输出提示信息

while (true) { // 开始一个循环，持续监听输入

Thread.Sleep (1000); // 线程休眠1秒

Console.Write ("> "); // 控制台输出"> "

var msg = Console.ReadLine (); // 读取用户输入

if (msg == "exit") // 如果输入的是"exit"

break; // 跳出循环

ws.Send (msg); // 将输入的消息发送到WebSocket服务器

}

}

}

}

}

示例2

这段代码演示了如何使用<code>WebSocketSharp库创建一个WebSocket服务器，并监听特定的端口（例如4649）。服务器被配置为提供两种WebSocket服务：Echo和Chat。服务器的日志级别在调试模式下被设置为Trace，以便记录详细信息，方便开发者调试。此外，代码还包含了一些注释掉的部分，展示了如何进行更多高级配置，例如配置SSL/TLS安全连接，启用HTTP基础或摘要认证，设置地址重用，定制WebSocket服务的初始化参数等。其中大多数配置目前都被注释了，所以不会生效。服务器启动后，会打印正在监听的端口和提供的WebSocket服务路径。代码的最后部分等待用户按回车键来停止服务器。

using System; // 使用System命名空间，包含基本的类定义和类型。

using System.Configuration; // 引用配置管理相关的类，如读取配置文件等。

using System.Security.Cryptography.X509Certificates; // 引用安全性和加密相关的类，特别是处理X509证书。

using WebSocketSharp; // 引用WebSocketSharp库，它提供实现WebSocket协议的类。

using WebSocketSharp.Net; // 引用网络相关的类。

using WebSocketSharp.Server; // 引用WebSocket服务器相关的类。

namespace Example2 // 定义一个名为Example2的命名空间。

{

public class Program // 定义一个公共类Program。

{

public static void Main (string[] args) // 主函数，程序的入口点。

{

// 创建一个新的WebSocketServer实例。

var wssv = new WebSocketServer (4649); // 初始化一个监听端口为4649的WebSocket服务器实例。

//var wssv = new WebSocketServer (5963, true); // （被注释）同时指出此服务器为安全连接（wss）。

//var wssv = new WebSocketServer (System.Net.IPAddress.Any, 4649); // 使用任意IPv4地址。

//var wssv = new WebSocketServer (System.Net.IPAddress.Any, 5963, true); // 使用任意IPv4地址和提供安全连接。

//var wssv = new WebSocketServer (System.Net.IPAddress.IPv6Any, 4649); // 使用任意IPv6地址。

//var wssv = new WebSocketServer (System.Net.IPAddress.IPv6Any, 5963, true); // 使用任意IPv6地址和提供安全连接。

//var wssv = new WebSocketServer ("ws://0.0.0.0:4649"); // 使用IPv4通配地址。

//var wssv = new WebSocketServer ("wss://0.0.0.0:5963"); // 使用IPv4通配地址和提供安全连接。

//var wssv = new WebSocketServer ("ws://[::0]:4649"); // 使用IPv6通配地址。

//var wssv = new WebSocketServer ("wss://[::0]:5963"); // 使用IPv6通配地址和提供安全连接。

//var wssv = new WebSocketServer (System.Net.IPAddress.Loopback, 4649); // 使用本机回环地址IPv4。

//var wssv = new WebSocketServer (System.Net.IPAddress.Loopback, 5963, true); // 使用本机回环地址IPv4和提供安全连接。

//var wssv = new WebSocketServer (System.Net.IPAddress.IPv6Loopback, 4649); // 使用本机回环地址IPv6。

//var wssv = new WebSocketServer (System.Net.IPAddress.IPv6Loopback, 5963, true); // 使用本机回环地址IPv6和提供安全连接。

//var wssv = new WebSocketServer ("ws://localhost:4649"); // 使用localhost和端口4649。

//var wssv = new WebSocketServer ("wss://localhost:5963"); // 使用localhost和端口5963提供安全连接。

//var wssv = new WebSocketServer ("ws://127.0.0.1:4649"); // 使用IPv4的本机回环地址和端口4649。

//var wssv = new WebSocketServer ("wss://127.0.0.1:5963"); // 使用IPv4的本机回环地址和端口5963提供安全连接。

//var wssv = new WebSocketServer ("ws://[::1]:4649"); // 使用IPv6的本机回环地址和端口4649。

//var wssv = new WebSocketServer ("wss://[::1]:5963"); // 使用IPv6的本机回环地址和端口5963提供安全连接。

#if DEBUG

// 更改日志级别（只有在调试模式下起作用）。

wssv.Log.Level = LogLevel.Trace; // 设置日志级别为Trace（追踪），目的是显示尽可能多的调试信息。

// 更改WebSocket Ping或Close回应的等待时间（代码被注释）。

// wssv.WaitTime = TimeSpan.FromSeconds (2);

// 不定期移除非活动会话（代码被注释）。

// wssv.KeepClean = false;

#endif

// 提供安全连接（代码段被注释）。

/*

var cert = ConfigurationManager.AppSettings["ServerCertFile"]; // 从配置文件获取证书文件路径。

var passwd = ConfigurationManager.AppSettings["CertFilePassword"]; // 从配置文件获取证书密码。

wssv.SslConfiguration.ServerCertificate = new X509Certificate2 (cert, passwd); // 创建证书实例并应用于服务器的SSL配置。

*/

// 提供HTTP认证（基础/摘要）（代码段被注释）。

/*

wssv.AuthenticationSchemes = AuthenticationSchemes.Basic; // 设置认证方案为Basic（基础认证）。

wssv.Realm = "WebSocket Test"; // 设置认证域为"WebSocket Test"。

wssv.UserCredentialsFinder = id => { // 设置用户凭据查找函数。

var name = id.Name; // 获取用户名。

// 返回用户名、密码和角色。

return name == "nobita" // 如果用户名为"nobita"，则返回凭据。

? new NetworkCredential (name, "password", "gunfighter")

: null; // 如果用户凭据未找到，返回null。

};

*/

// 解决等待处于TIME_WAIT状态的套接字（代码被注释）。

// wssv.ReuseAddress = true;

// 添加WebSocket服务。

wssv.AddWebSocketService<Echo> ("/Echo"); // 添加名为"/Echo"的WebSocket回音服务。

wssv.AddWebSocketService<Chat> ("/Chat"); // 添加名为"/Chat"的WebSocket聊天服务。

// 添加WebSocket服务并进行初始化（代码段被注释）。

// 用初始化方案添加WebSocket服务（以下代码被注释，并没有在实际程序中运行）。

/*

wssv.AddWebSocketService<Chat> (

"/Chat",

s => {

s.Prefix = "Anon#"; // 设置聊天服务的前缀。

// 发送包含子协议名称的Sec-WebSocket-Protocol头。

s.Protocol = "chat"; // 为聊天服务设置子协议。

// 忽略Sec-WebSocket-Extensions头。

s.IgnoreExtensions = true; // 忽略WebSocket扩展。

// 在接收到ping时发出WebSocket.OnMessage事件。

s.EmitOnPing = true; // 允许ping消息触发OnMessage事件。

// 验证Origin头。

s.OriginValidator = val => {

// 检查Origin头的值，如果有效则返回true。

Uri origin;

return !val.IsNullOrEmpty()

&& Uri.TryCreate(val, UriKind.Absolute, out origin)

&& origin.Host == "localhost"; // 如果来源是localhost，则认为是有效的。

};

// 验证cookies。

s.CookiesValidator = (req, res) => {

// 检查请求中的cookies，并在必要时设置要发送给客户端的cookies。

foreach (var cookie in req) {

cookie.Expired = true; // 将请求中的所有cookie设置为过期。

res.Add(cookie); // 将过期的cookie添加到响应中。

}

return true; // 如果验证有效则返回true。

};

}

);

*/

wssv.Start (); // 启动WebSocket服务器。

// 如果WebSocket服务器正在监听，则输出信息。

if (wssv.IsListening) {

Console.WriteLine ("Listening on port {0}, and providing WebSocket services:", wssv.Port); // 打印监听端口及服务信息。

// 循环通过WebSocket服务器提供的服务路径，并打印出来。

foreach (var path in wssv.WebSocketServices.Paths)

Console.WriteLine ("- {0}", path); // 打印服务路径。

}

Console.WriteLine ("\nPress Enter key to stop the server..."); // 提示按回车键停止服务器。

Console.ReadLine (); // 等待用户输入回车键。

wssv.Stop (); // 停止WebSocket服务器。

}

}

}

笔记