huahaofeng
/
aspnetcore
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Remove redundant websocket sample code.

This commit is contained in:
Chris Ross 2015-04-24 09:50:36 -07:00
parent 01a13bfa1d
commit 59e40904ad
1 changed files with 5 additions and 42 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

47
samples/SampleApp/Startup.cs
View File

@ -1,9 +1,6 @@
using Microsoft.AspNet.Builder; using System;
using Microsoft.AspNet.Builder;
using Microsoft.AspNet.Http; using Microsoft.AspNet.Http;
using System;
using System.Net.WebSockets;
using System.Threading;
using System.Threading.Tasks;
namespace SampleApp namespace SampleApp
{ {
@ -19,44 +16,10 @@ namespace SampleApp
context.Request.Path, context.Request.Path,
context.Request.QueryString); context.Request.QueryString);
if (context.IsWebSocketRequest) context.Response.ContentLength = 11;
{ context.Response.ContentType = "text/plain";
var webSocket = await context.AcceptWebSocketAsync(); await context.Response.WriteAsync("Hello world");
await EchoAsync(webSocket);
}
else
{
context.Response.ContentLength = 11;
context.Response.ContentType = "text/plain";
await context.Response.WriteAsync("Hello world");
}
}); });
} }
public async Task EchoAsync(WebSocket webSocket)
{
var buffer = new ArraySegment<byte>(new byte[8192]);
for (; ;)
{
var result = await webSocket.ReceiveAsync(
buffer,
CancellationToken.None);
if (result.MessageType == WebSocketMessageType.Close)
{
return;
}
else if (result.MessageType == WebSocketMessageType.Text)
{
Console.WriteLine("{0}", System.Text.Encoding.UTF8.GetString(buffer.Array, 0, result.Count));
}
await webSocket.SendAsync(
new ArraySegment<byte>(buffer.Array, 0, result.Count),
result.MessageType,
result.EndOfMessage,
CancellationToken.None);
}
}
} }
} }