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

Update Autobahn server app with native and managed paths.

This commit is contained in:
Chris Ross 2014-10-24 15:14:07 -07:00
parent 98e9285fa8
commit 76d3043bbe
2 changed files with 35 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
test/AutobahnTestServer/Project.json
View File

@ -4,9 +4,13 @@
"dependencies": { "dependencies": {
"Microsoft.AspNet.Server.IIS": "1.0.0-beta1-*", "Microsoft.AspNet.Server.IIS": "1.0.0-beta1-*",
"Microsoft.AspNet.Server.WebListener": "1.0.0-beta1-*", "Microsoft.AspNet.Server.WebListener": "1.0.0-beta1-*",
"Microsoft.AspNet.WebSockets.Server": "1.0.0-beta1-*" "Microsoft.AspNet.WebSockets.Server": "1.0.0-beta1-*",
"Kestrel": "1.0.0-beta1-*"
},
"commands": {
"web": "Microsoft.AspNet.Hosting --server Microsoft.AspNet.Server.WebListener --server.urls http://localhost:12345",
"kestrel": "Microsoft.AspNet.Hosting --server Kestrel --server.urls http://localhost:12344"
}, },
"commands": { "web": "Microsoft.AspNet.Hosting --server Microsoft.AspNet.Server.WebListener --server.urls http://localhost:12345" },
"frameworks" : { "frameworks" : {
"aspnet50" : { }, "aspnet50" : { },
"aspnetcore50" : { } "aspnetcore50" : { }

40
test/AutobahnTestServer/Startup.cs
View File

@ -15,22 +15,40 @@ namespace AutobahnTestServer
{ {
public void Configure(IApplicationBuilder app) public void Configure(IApplicationBuilder app)
{ {
// Comment this out to test native server implementations app.Map("/Managed", managedWebSocketsApp =>
app.UseWebSockets(new WebSocketOptions()
{ {
ReplaceFeature = true, // Comment this out to test native server implementations
managedWebSocketsApp.UseWebSockets(new WebSocketOptions()
{
ReplaceFeature = true,
});
managedWebSocketsApp.Use(async (context, next) =>
{
if (context.IsWebSocketRequest)
{
Console.WriteLine("Echo: " + context.Request.Path);
var webSocket = await context.AcceptWebSocketAsync();
await Echo(webSocket);
return;
}
await next();
});
}); });
app.Use(async (context, next) => app.Map("/Native", nativeWebSocketsApp =>
{ {
if (context.IsWebSocketRequest) nativeWebSocketsApp.Use(async (context, next) =>
{ {
Console.WriteLine("Echo: " + context.Request.Path); if (context.IsWebSocketRequest)
var webSocket = await context.AcceptWebSocketAsync(); {
await Echo(webSocket); Console.WriteLine("Echo: " + context.Request.Path);
return; var webSocket = await context.AcceptWebSocketAsync();
} await Echo(webSocket);
await next(); return;
}
await next();
});
}); });
app.Run(context => app.Run(context =>