WebSocket 服务器

    首先,你需要先引用这个包 SuperSocket.WebSocket.Server

    让我创建这个 WebSocket 服务器,这个服务器将把收到的消息再发送回客户端:

    定义命令来处理消息

    1. class ADD : IAsyncCommand<WebSocketSession, StringPackageInfo>
    2. {
    3. public async ValueTask ExecuteAsync(WebSocketSession session, StringPackageInfo package)
    4. {
    5. .Select(p => int.Parse(p))
    6. await session.SendAsync(result.ToString());
    7. }
    8. }

    注册这个命令

    1. class StringPackageConverter : IPackageMapper<WebSocketPackage, StringPackageInfo>
    2. {
    3. var pack = new StringPackageInfo();
    4. var arr = package.Message.Split(' ', 3, StringSplitOptions.RemoveEmptyEntries);
    5. pack.Key = arr[0];
    6. pack.Parameters = arr.Skip(1).ToArray();
    7. return pack;
    8. }