通过 c# 与 socket.io 服务器通信

Question

是否有遵循 socket.io 协议的 c# 客户端？我有一个 socket.io 服务器，它通过网站与 socket.io javascript 客户端通信，但我还需要连接一个可以发送和接收消息的 c# 片段。目前有没有一种干净的方法可以做到这一点，或者我必须编写自己的客户端。

Answer 1

codeplex 上有一个项目（NuGet 也是如此），它是 socket.io 的 C# 客户端。 （我是这个项目的作者——所以我有偏见）我无法在客户端中找到我需要的确切内容，所以我构建了它并将其重新公开发布。

示例客户端样式：

socket.On("news", (data) =>    {
Console.WriteLine(data);
});

Answer 2

使用以下库：https://github.com/sta/websocket-sharp 它可以通过 NuGet 获得：

PM> Install-Package WebSocketSharp -Pre

要连接到 Socket.IO 1.0 + 服务器，请使用以下语法：

using (var ws = new WebSocket("ws://127.0.0.1:1337/socket.io/?EIO=2&transport=websocket"))
{
    ws.OnMessage += (sender, e) =>
      Console.WriteLine("New message from controller: " + e.Data);

    ws.Connect();
    Console.ReadKey(true);
}

换句话说，将其附加到 localhost:port -“socket.io/?EIO=2&transport=websocket”。

我的完整服务器代码：https://gist.github.com/anonymous/574133a15f7faf39fdb5

Answer 3

这个包支持最新的协议。
Github - https://github.com/HavenDV/H.Socket.IO/
C# 现场示例 - https://dotnetfiddle.net/FWMpQ3/
VB.NET 现场示例 - https://dotnetfiddle.net/WzIdnG/
努吉特：

Install-Package H.Socket.IO

using System;
using System.Threading.Tasks;
using H.Socket.IO;

#nullable enable

public class ChatMessage
{
    public string? Username { get; set; }
    public string? Message { get; set; }
    public long NumUsers { get; set; }
}
    
public async Task ConnectToChatNowShTest()
{
    await using var client = new SocketIoClient();

    client.Connected += (sender, args) => Console.WriteLine($"Connected: {args.Namespace}");
    client.Disconnected += (sender, args) => Console.WriteLine($"Disconnected. Reason: {args.Reason}, Status: {args.Status:G}");
    client.EventReceived += (sender, args) => Console.WriteLine($"EventReceived: Namespace: {args.Namespace}, Value: {args.Value}, IsHandled: {args.IsHandled}");
    client.HandledEventReceived += (sender, args) => Console.WriteLine($"HandledEventReceived: Namespace: {args.Namespace}, Value: {args.Value}");
    client.UnhandledEventReceived += (sender, args) => Console.WriteLine($"UnhandledEventReceived: Namespace: {args.Namespace}, Value: {args.Value}");
    client.ErrorReceived += (sender, args) => Console.WriteLine($"ErrorReceived: Namespace: {args.Namespace}, Value: {args.Value}");
    client.ExceptionOccurred += (sender, args) => Console.WriteLine($"ExceptionOccurred: {args.Value}");
    
    client.On("login", () =>
    {
        Console.WriteLine("You are logged in.");
    });
    client.On("login", json =>
    {
        Console.WriteLine($"You are logged in. Json: \"{json}\"");
    });
    client.On<ChatMessage>("login", message =>
    {
        Console.WriteLine($"You are logged in. Total number of users: {message.NumUsers}");
    });
    client.On<ChatMessage>("user joined", message =>
    {
        Console.WriteLine($"User joined: {message.Username}. Total number of users: {message.NumUsers}");
    });
    client.On<ChatMessage>("user left", message =>
    {
        Console.WriteLine($"User left: {message.Username}. Total number of users: {message.NumUsers}");
    });
    client.On<ChatMessage>("typing", message =>
    {
        Console.WriteLine($"User typing: {message.Username}");
    });
    client.On<ChatMessage>("stop typing", message =>
    {
        Console.WriteLine($"User stop typing: {message.Username}");
    });
    client.On<ChatMessage>("new message", message =>
    {
        Console.WriteLine($"New message from user \"{message.Username}\": {message.Message}");
    });
    
    await client.ConnectAsync(new Uri("wss://socketio-chat-h9jt.herokuapp.com/"));

    await client.Emit("add user", "C# H.Socket.IO Test User");

    await Task.Delay(TimeSpan.FromMilliseconds(200));

    await client.Emit("typing");

    await Task.Delay(TimeSpan.FromMilliseconds(200));

    await client.Emit("new message", "hello");

    await Task.Delay(TimeSpan.FromMilliseconds(200));

    await client.Emit("stop typing");

    await Task.Delay(TimeSpan.FromSeconds(2));

    await client.DisconnectAsync();
}

它还支持命名空间：

// Will be sent with all messages(Unless otherwise stated).
// Also automatically connects to it.
client.DefaultNamespace = "my";

// or

// Connects to "my" namespace.
await client.ConnectAsync(new Uri(LocalCharServerUrl), cancellationToken, "my");
// Sends message to "my" namespace.
await client.Emit("message", "hello", "my", cancellationToken);

Answer 4

好吧，我找到了另一个与 socket.io 配合得很好的 .Net 库。它也是最新的。请点击以下链接，

Quobject/SocketIoClientDotNet

using Quobject.SocketIoClientDotNet.Client;

var socket = IO.Socket("http://localhost");
socket.On(Socket.EVENT_CONNECT, () =>
{
    socket.Emit("hi");
});

socket.On("hi", (data) =>
{
    Console.WriteLine(data);
    socket.Disconnect();
});
Console.ReadLine();

希望，它可以帮助某人。

Answer 5

我尝试了以上所有方法，但不知何故他们没有与我正在集成的服务交谈（也许服务被窃听，我不知道是哪个）。所以我自己写了。

https://github.com/it9gamelog/socketio-with-ws-client

简约的单文件客户端实现。由于 socket-io 是一项垂死的技术，而且规范相当复杂，因此任何一方的错误都可能永远无法修复。单个文件方法至少更容易调整、扩展和调试。

Answer 6

这取决于您的网络服务器的外观。在某些情况下，也可能适用于为常规套接字创建侦听器。
否则，您可能必须创建自己的客户端。但是，您可能只需要实现 WebSocket 传输，因此无论如何它应该相当简单。

我建议看看问题“Is there a WebSocket client implemented for .NET?”和my (fairly simple) WebSocket Socket.IO transport client implementation for Java。