WebSocket 服务器
首先,你需要先引用这个包 SuperSocket.WebSocket.Server
让我创建这个 WebSocket 服务器,这个服务器将把收到的消息再发送回客户端:
定义命令来处理消息
class ADD : IAsyncCommand<WebSocketSession, StringPackageInfo>
{
public async ValueTask ExecuteAsync(WebSocketSession session, StringPackageInfo package)
{
.Select(p => int.Parse(p))
await session.SendAsync(result.ToString());
}
}
注册这个命令
class StringPackageConverter : IPackageMapper<WebSocketPackage, StringPackageInfo>
{
var pack = new StringPackageInfo();
var arr = package.Message.Split(' ', 3, StringSplitOptions.RemoveEmptyEntries);
pack.Key = arr[0];
pack.Parameters = arr.Skip(1).ToArray();
return pack;
}