我在websocket领域很新。
我可以使用以下JavaScript代码连接到websocket服务器：
var webSocket = new WebSocket(url);
但是对于我的应用程序，我需要使用C#连接到同一台服务器。我正在使用的代码是：
ClientWebSocket webSocket = null;
webSocket = new ClientWebSocket();
await webSocket.ConnectAsync(new Uri(url), CancellationToken.None);
代码的第三行出现以下错误：
"当期望状态码101时，服务器返回状态码200"
经过一番调查后，我发现在连接过程中服务器无法将HTTP协议切换为WebSocket协议。
我的C#代码有问题还是服务器出现了故障？因为我使用的URL是第三方提供的，所以无法访问服务器。
你能否就此问题给我任何建议？
ReceiveAsync()循环接收消息，直到接收到Close帧或CancellationToken被取消。发送消息很简单，只需使用SendAsync()即可。不要在使用CloseOutputAsync()之前使用CloseAsync()，因为您需要先停止接收循环。否则，CloseAsync()将挂起，或者如果您使用CancellationToken退出ReceiveAsync()，CloseAsync()将抛出异常。ReceiveAsync()，当接收到特殊的Close帧时结束循环。因此，当您想要断开连接时，必须告诉服务器您使用CloseOutputAsync关闭，以便它会回复一个类似的Close帧到您的客户端，以便能够结束接收。Guid类。SendRequest()方法等待匹配响应到达，或者...连接已关闭。非常方便，可以使代码比事件驱动的方法更易读。当然，您仍然可以在接收到消息时调用事件，只需确保它们没有与需要响应的任何请求匹配即可。async方法中等待，我使用SemaphoreSlim。每个请求将其自己的信号量放入特殊字典中，当我获得响应时，我通过响应令牌找到条目，释放信号量，处理它，从字典中删除。看起来很复杂，但实际上非常简单。using System;
using System.Collections.Generic;
using System.IO;
using System.Linq;
using System.Net.WebSockets;
using System.Threading;
using System.Threading.Tasks;
namespace Example {
public class WsClient : IDisposable {
public int ReceiveBufferSize { get; set; } = 8192;
public async Task ConnectAsync(string url) {
if (WS != null) {
if (WS.State == WebSocketState.Open) return;
else WS.Dispose();
}
WS = new ClientWebSocket();
if (CTS != null) CTS.Dispose();
CTS = new CancellationTokenSource();
await WS.ConnectAsync(new Uri(url), CTS.Token);
await Task.Factory.StartNew(ReceiveLoop, CTS.Token, TaskCreationOptions.LongRunning, TaskScheduler.Default);
}
public async Task DisconnectAsync() {
if (WS is null) return;
// TODO: requests cleanup code, sub-protocol dependent.
if (WS.State == WebSocketState.Open) {
CTS.CancelAfter(TimeSpan.FromSeconds(2));
await WS.CloseOutputAsync(WebSocketCloseStatus.Empty, "", CancellationToken.None);
await WS.CloseAsync(WebSocketCloseStatus.NormalClosure, "", CancellationToken.None);
}
WS.Dispose();
WS = null;
CTS.Dispose();
CTS = null;
}
private async Task ReceiveLoop() {
var loopToken = CTS.Token;
MemoryStream outputStream = null;
WebSocketReceiveResult receiveResult = null;
var buffer = new byte[ReceiveBufferSize];
try {
while (!loopToken.IsCancellationRequested) {
outputStream = new MemoryStream(ReceiveBufferSize);
do {
receiveResult = await WS.ReceiveAsync(buffer, CTS.Token);
if (receiveResult.MessageType != WebSocketMessageType.Close)
outputStream.Write(buffer, 0, receiveResult.Count);
}
while (!receiveResult.EndOfMessage);
if (receiveResult.MessageType == WebSocketMessageType.Close) break;
outputStream.Position = 0;
ResponseReceived(outputStream);
}
}
catch (TaskCanceledException) { }
finally {
outputStream?.Dispose();
}
}
private async Task<ResponseType> SendMessageAsync<RequestType>(RequestType message) {
// TODO: handle serializing requests and deserializing responses, handle matching responses to the requests.
}
private void ResponseReceived(Stream inputStream) {
// TODO: handle deserializing responses and matching them to the requests.
// IMPORTANT: DON'T FORGET TO DISPOSE THE inputStream!
}
public void Dispose() => DisconnectAsync().Wait();
private ClientWebSocket WS;
private CancellationTokenSource CTS;
}
}
顺便问一下，为什么要使用除了.NET内置库之外的其他库？我找不到任何理由，除非是Microsoft类的文档可能不太好。也许 - 如果出于某种非常奇怪的原因，您想要在古老的.NET Framework中使用现代WebSocket传输 ;)
哦，我还没有测试过这个例子。它来自已经测试过的代码，但所有内部协议部分都被删除，只剩下传输部分。
由于WebsocketSharp不支持.NET Core，我建议使用websocket-client替代。
这是一些示例代码
static async Task Main(string[] args)
{
var url = new Uri("wss://echo.websocket.org");
var exitEvent = new ManualResetEvent(false);
using (var client = new WebsocketClient(url))
{
client.MessageReceived.Subscribe(msg => Console.WriteLine($"Message: {msg}"));
await client.Start();
await client.Send("Echo");
exitEvent.WaitOne();
}
Console.ReadLine();
}
一定要使用ManualResetEvent，否则它不起作用。
不太确定WebSocketSharp NuGet包发生了什么，但我注意到现在WebSocket#已经成为NuGet存储库中最相关的结果。 我花了一些时间才意识到Connect()现在返回Task，希望这个示例能对某人有用：
using System;
using System.Threading.Tasks;
using WebSocketSharp;
namespace Example
{
class Program
{
private static void Main(string[] args)
{
using (var ws = new WebSocket(url: "ws://localhost:1337", onMessage: OnMessage, onError: OnError))
{
ws.Connect().Wait();
ws.Send("Hey, Server!").Wait();
Console.ReadKey(true);
}
}
private static Task OnError(ErrorEventArgs errorEventArgs)
{
Console.Write("Error: {0}, Exception: {1}", errorEventArgs.Message, errorEventArgs.Exception);
return Task.FromResult(0);
}
private static Task OnMessage(MessageEventArgs messageEventArgs)
{
Console.Write("Message received: {0}", messageEventArgs.Text.ReadToEnd());
return Task.FromResult(0);
}
}
}
Console.ReadKey不允许代码离开using块，因此在按下键之前不会执行任何清理操作。 - mBardosWebsocket的URL应该以ws://或wss://开头，后者是安全的websocket。
public async Task SendMessageAsync(string message) { ArraySegment bytesToSend = new ArraySegment(Encoding.UTF8.GetBytes(message));
await WS.SendAsync(bytesToSend, WebSocketMessageType.Text, true, CancellationToken.None);
} - Sean Griffin