我在服务器上有一个线程,用于处理通过 WebSocket 连接从客户端接收到的数据:
public HttpResponseMessage Get()
{
if (HttpContext.Current.IsWebSocketRequest)
{
HttpContext.Current.AcceptWebSocketRequest(ProcessWebSocket);
}
return new HttpResponseMessage(HttpStatusCode.SwitchingProtocols);
}
private async Task ProcessWebSocket(AspNetWebSocketContext context)
{
WebSocket webSocket = context.WebSocket; //Gets the current WebSocket object.
const int maxMessageSize = 1024;
byte[] receivedDataBuffer = new byte[maxMessageSize];
logger.Debug("WSC-New WebSocket connection");
while (webSocket.State == WebSocketState.Open)
{
var timeOut = new CancellationTokenSource(70000).Token;
WebSocketReceiveResult webSocketReceiveResult = await webSocket.ReceiveAsync(new ArraySegment<byte>(receivedDataBuffer), timeOut);
//If input frame is cancelation frame, send close command.
if (webSocketReceiveResult.MessageType == WebSocketMessageType.Close)
{
await webSocket.CloseAsync(WebSocketCloseStatus.NormalClosure, String.Empty, CancellationToken.None);
logger.Debug("WSC-Close …
Run Code Online (Sandbox Code Playgroud)