ASP.NET Core 高级(一)【.NET 的开放 Web 接口 (OWIN)】

逃离我推掉我的手 2021-06-26 16:06 604阅读 0赞

# [ASP.NET][] Core 中 .NET 的开放 Web 接口 (OWIN) #

`ASP.NET Core` 支持 .NET 的开放 Web 接口 (`OWIN`)。 `OWIN` 允许 Web 应用从 Web 服务器分离。 它定义了在管道中使用中间件来处理请求和相关响应的标准方法。 `ASP.NET Core` 应用程序和中间件可以与基于 OWIN 的应用程序、服务器和中间件进行互操作。

`OWIN` 提供了一个分离层，可一起使用具有不同对象模型的两个框架。 `Microsoft.AspNetCore.Owin` 包提供了两个适配器实现：

*  [ASP.NET][] Core 到 `OWIN`
 *  `OWIN` 到 [ASP.NET][] Core

此方法可将 [ASP.NET][] Core 托管在兼容 `OWIN` 的服务器/主机上，或在 [ASP.NET][] Core 上运行其他兼容 `OWIN` 的组件。

> 备注  
> 使用这些适配器会带来性能成本。 仅使用 [ASP.NET][] Core 组件的应用不应使用 `Microsoft.AspNetCore.Owin` 包或适配器。

## 在 [ASP.NET][] Core 管道中运行 `OWIN` 中间件 ##

[ASP.NET][] Core 的 OWIN 支持作为 `Microsoft.AspNetCore.Owin` 包的一部分进行部署。 可通过安装此包将 OWIN 支持导入到项目中。

OWIN 中间件符合 [OWIN 规范][OWIN]，该规范要求使用 `Func<IDictionary<string, object>, Task>` 接口，并设置特定的键（如 `owin.ResponseBody`）。 以下简单的 OWIN 中间件显示“Hello World”：

public Task OwinHello(IDictionary<string, object> environment)
    { 
        string responseText = "Hello World via OWIN";
        byte[] responseBytes = Encoding.UTF8.GetBytes(responseText);
    
        // OWIN Environment Keys: http://owin.org/spec/spec/owin-1.0.0.html
        var responseStream = (Stream)environment["owin.ResponseBody"];
        var responseHeaders = (IDictionary<string, string[]>)environment["owin.ResponseHeaders"];
    
        responseHeaders["Content-Length"] = new string[] {  responseBytes.Length.ToString(CultureInfo.InvariantCulture) };
        responseHeaders["Content-Type"] = new string[] {  "text/plain" };
    
        return responseStream.WriteAsync(responseBytes, 0, responseBytes.Length);
    }

示例签名返回 `Task`，并接受 OWIN 所要求的 `IDictionary<string, object>`。

以下代码显示了如何使用 `UseOwin` 扩展方法将 `OwinHello` 中间件（如上所示）添加到 `ASP.NET Core` 管道。

public void Configure(IApplicationBuilder app)
    { 
        app.UseOwin(pipeline =>
        { 
            pipeline(next => OwinHello);
        });
    }

可配置在 `OWIN` 管道中要进行的其他操作。

> 备注  
> 响应标头只能在首次写入响应流之前进行修改。

> 备注  
> 由于性能原因，不建议多次调用 `UseOwin`。 组合在一起时 `OWIN` 组件的性能最佳。

app.UseOwin(pipeline =>
    { 
        pipeline(async (next) =>
        { 
            // do something before
            await OwinHello(new OwinEnvironment(HttpContext));
            // do something after
        });
    });

## 在基于 OWIN 的服务器中使用 [ASP.NET][] Core 托管 ##

基于 OWIN 的服务器可托管 [ASP.NET][] Core 应用。 [Nowin][]（.NET OWIN Web 服务器）属于这种服务器。 本文的示例中包含了一个引用 Nowin 的项目，并使用它创建了一个自托管 [ASP.NET][] Core 的 `IServer`。

\[!code-csharp\]

`IServer` 是需要 `Features` 属性和 `Start` 方法的接口。

`Start` 负责配置和启动服务器，在此情况下，此操作通过一系列 Fluent API 调用完成，这些调用设置从 IServerAddressesFeature 分析的地址。 请注意，`_builder` 变量的 Fluent 配置指定请求将由方法中之前定义的 `appFunc` 来处理。 对于每个请求，都会调用此 `Func` 以处理传入请求。

我们还将添加一个 `IWebHostBuilder` 扩展，以便添加和配置 Nowin 服务器。

using System;
    using Microsoft.AspNetCore.Hosting.Server;
    using Microsoft.Extensions.DependencyInjection;
    using Nowin;
    using NowinSample;
    
    namespace Microsoft.AspNetCore.Hosting
    { 
        public static class NowinWebHostBuilderExtensions
        { 
            public static IWebHostBuilder UseNowin(this IWebHostBuilder builder)
            { 
                return builder.ConfigureServices(services =>
                { 
                    services.AddSingleton<IServer, NowinServer>();
                });
            }
    
            public static IWebHostBuilder UseNowin(this IWebHostBuilder builder, Action<ServerBuilder> configure)
            { 
                builder.ConfigureServices(services =>
                { 
                    services.Configure(configure);
                });
                return builder.UseNowin();
            }
        }
    }

完成此操作后，调用 Program.cs 中的扩展以使用此自定义服务器运行 [ASP.NET][] Core 应用：

using System;
    using System.Collections.Generic;
    using System.IO;
    using System.Linq;
    using System.Threading.Tasks;
    using Microsoft.AspNetCore.Hosting;
    
    namespace NowinSample
    { 
        public class Program
        { 
            public static void Main(string[] args)
            { 
                var host = new WebHostBuilder()
                    .UseNowin()
                    .UseContentRoot(Directory.GetCurrentDirectory())
                    .UseIISIntegration()
                    .UseStartup<Startup>()
                    .Build();
    
                host.Run();
            }
        }
    }

了解有关 `ASP.NET Core 服务器`的更多信息。

## 在基于 OWIN 的服务器上运行 [ASP.NET][] Core 并使用其 WebSocket 支持 ##

[ASP.NET][] Core 如何利用基于 OWIN 的服务器功能的另一个示例是访问 `WebSocket` 等功能。 前面示例中使用的 .NET OWIN Web 服务器支持内置的 Web 套接字，可由 `ASP.NET Core` 应用程序利用。 下面的示例显示了简单的 Web 应用，它支持 Web 套接字并回显通过 `WebSocket` 发送到服务器的所有内容。

public class Startup
    { 
        public void Configure(IApplicationBuilder app)
        { 
            app.Use(async (context, next) =>
            { 
                if (context.WebSockets.IsWebSocketRequest)
                { 
                    WebSocket webSocket = await context.WebSockets.AcceptWebSocketAsync();
                    await EchoWebSocket(webSocket);
                }
                else
                { 
                    await next();
                }
            });
    
            app.Run(context =>
            { 
                return context.Response.WriteAsync("Hello World");
            });
        }
    
        private async Task EchoWebSocket(WebSocket webSocket)
        { 
            byte[] buffer = new byte[1024];
            WebSocketReceiveResult received = await webSocket.ReceiveAsync(
                new ArraySegment<byte>(buffer), CancellationToken.None);
    
            while (!webSocket.CloseStatus.HasValue)
            { 
                // Echo anything we receive
                await webSocket.SendAsync(new ArraySegment<byte>(buffer, 0, received.Count), 
                    received.MessageType, received.EndOfMessage, CancellationToken.None);
    
                received = await webSocket.ReceiveAsync(new ArraySegment<byte>(buffer), 
                    CancellationToken.None);
            }
    
            await webSocket.CloseAsync(webSocket.CloseStatus.Value, 
                webSocket.CloseStatusDescription, CancellationToken.None);
        }
    }

使用与前一个相同的 `NowinServer` 来配置此[示例][Link 1] \- 唯一的区别是如何在其 `Configure` 方法中配置应用程序。 使用[简单的 websocket 客户端][websocket]的测试演示应用程序：  
![在这里插入图片描述][20190220144823992.png]

## OWIN 环境 ##

可使用 `HttpContext` 来构造 OWIN 环境。

var environment = new OwinEnvironment(HttpContext);
       var features = new OwinFeatureCollection(environment);

## OWIN 键 ##

OWIN 依赖于 `IDictionary<string,object>` 对象，以在整个 HTTP请求/响应交换中传达信息。 [ASP.NET][] Core 实现以下所列的键。 请参阅[主规范、扩展][Link 2]和 [OWIN Key Guidelines and Common Keys][]（OWIN 键指南和常用键）。

### 请求数据 (OWIN v1.0.0) ###

<table> 
 <thead> 
  <tr> 
   <th>键</th> 
   <th>值（类型）</th> 
   <th>说明</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>owin.RequestScheme</td> 
   <td><code>String</code></td> 
   <td></td> 
  </tr> 
  <tr> 
   <td>owin.RequestMethod</td> 
   <td><code>String</code></td> 
   <td></td> 
  </tr> 
  <tr> 
   <td>owin.RequestPathBase</td> 
   <td><code>String</code></td> 
   <td></td> 
  </tr> 
  <tr> 
   <td>owin.RequestPath</td> 
   <td><code>String</code></td> 
   <td></td> 
  </tr> 
  <tr> 
   <td>owin.RequestQueryString</td> 
   <td><code>String</code></td> 
   <td></td> 
  </tr> 
  <tr> 
   <td>owin.RequestProtocol</td> 
   <td><code>String</code></td> 
   <td></td> 
  </tr> 
  <tr> 
   <td>owin.RequestHeaders</td> 
   <td><code>IDictionary&lt;string,string[]&gt;</code></td> 
   <td></td> 
  </tr> 
  <tr> 
   <td>owin.RequestBody</td> 
   <td><code>Stream</code></td> 
   <td></td> 
  </tr> 
 </tbody> 
</table>

### 请求数据 (OWIN v1.1.0) ###

<table> 
 <thead> 
  <tr> 
   <th>键</th> 
   <th>值（类型）</th> 
   <th>说明</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>owin.RequestId</td> 
   <td><code>String</code></td> 
   <td>Optional</td> 
  </tr> 
 </tbody> 
</table>

### 响应数据 (OWIN v1.0.0) ###

<table> 
 <thead> 
  <tr> 
   <th>键</th> 
   <th>值（类型）</th> 
   <th>说明</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>owin.ResponseStatusCode</td> 
   <td><code>int</code></td> 
   <td>Optional</td> 
  </tr> 
  <tr> 
   <td>owin.ResponseReasonPhrase</td> 
   <td><code>String</code></td> 
   <td>Optional</td> 
  </tr> 
  <tr> 
   <td>owin.ResponseHeaders</td> 
   <td><code>IDictionary&lt;string,string[]&gt;</code></td> 
   <td></td> 
  </tr> 
  <tr> 
   <td>owin.ResponseBody</td> 
   <td><code>Stream</code></td> 
   <td></td> 
  </tr> 
 </tbody> 
</table>

### 其他数据 (OWIN v1.0.0) ###

<table> 
 <thead> 
  <tr> 
   <th>键</th> 
   <th>值（类型）</th> 
   <th>说明</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>owin.CallCancelled</td> 
   <td><code>CancellationToken</code></td> 
   <td></td> 
  </tr> 
  <tr> 
   <td>owin.Version</td> 
   <td><code>String</code></td> 
   <td></td> 
  </tr> 
 </tbody> 
</table>

### 常用键 ###

<table> 
 <thead> 
  <tr> 
   <th>键</th> 
   <th>值（类型）</th> 
   <th>说明</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>ssl.ClientCertificate</td> 
   <td><code>X509Certificate</code></td> 
   <td></td> 
  </tr> 
  <tr> 
   <td>ssl.LoadClientCertAsync</td> 
   <td><code>Func&lt;Task&gt;</code></td> 
   <td></td> 
  </tr> 
  <tr> 
   <td>server.RemoteIpAddress</td> 
   <td><code>String</code></td> 
   <td></td> 
  </tr> 
  <tr> 
   <td>server.RemotePort</td> 
   <td><code>String</code></td> 
   <td></td> 
  </tr> 
  <tr> 
   <td>server.LocalIpAddress</td> 
   <td><code>String</code></td> 
   <td></td> 
  </tr> 
  <tr> 
   <td>server.LocalPort</td> 
   <td><code>String</code></td> 
   <td></td> 
  </tr> 
  <tr> 
   <td>server.IsLocal</td> 
   <td><code>bool</code></td> 
   <td></td> 
  </tr> 
  <tr> 
   <td>server.OnSendingHeaders</td> 
   <td><code>Action&lt;Action&lt;object&gt;,object&gt;</code></td> 
   <td></td> 
  </tr> 
 </tbody> 
</table>

### SendFiles v0.3.0 ###

<table> 
 <thead> 
  <tr> 
   <th>键</th> 
   <th>值（类型）</th> 
   <th>说明</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>sendfile.SendAsync</td> 
   <td>请参阅<a href="http://owin.org/spec/extensions/owin-SendFile-Extension-v0.3.0.htm" rel="nofollow">委托签名</a></td> 
   <td>每请求</td> 
  </tr> 
 </tbody> 
</table>

### Opaque v0.3.0 ###

<table> 
 <thead> 
  <tr> 
   <th>键</th> 
   <th>值（类型）</th> 
   <th>说明</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>opaque.Version</td> 
   <td><code>String</code></td> 
   <td></td> 
  </tr> 
  <tr> 
   <td>opaque.Upgrade</td> 
   <td><code>OpaqueUpgrade</code></td> 
   <td>请参阅<a href="http://owin.org/spec/extensions/owin-SendFile-Extension-v0.3.0.htm" rel="nofollow">委托签名</a></td> 
  </tr> 
  <tr> 
   <td>opaque.Stream</td> 
   <td><code>Stream</code></td> 
   <td></td> 
  </tr> 
  <tr> 
   <td>opaque.CallCancelled</td> 
   <td><code>CancellationToken</code></td> 
   <td></td> 
  </tr> 
 </tbody> 
</table>

### WebSocket v0.3.0 ###

<table> 
 <thead> 
  <tr> 
   <th>键</th> 
   <th>值（类型）</th> 
   <th>说明</th> 
  </tr> 
 </thead> 
 <tbody> 
  <tr> 
   <td>websocket.Version</td> 
   <td><code>String</code></td> 
   <td></td> 
  </tr> 
  <tr> 
   <td>websocket.Accept</td> 
   <td><code>WebSocketAccept</code></td> 
   <td>请参阅<a href="http://owin.org/spec/extensions/owin-SendFile-Extension-v0.3.0.htm" rel="nofollow">委托签名</a></td> 
  </tr> 
  <tr> 
   <td>websocket.AcceptAlt</td> 
   <td></td> 
   <td>非规范</td> 
  </tr> 
  <tr> 
   <td>websocket.SubProtocol</td> 
   <td><code>String</code></td> 
   <td>请参阅 <a href="https://tools.ietf.org/html/rfc6455#section-4.2.2" rel="nofollow">RFC6455 4.2.2 节</a>步骤 5.5</td> 
  </tr> 
  <tr> 
   <td>websocket.SendAsync</td> 
   <td><code>WebSocketSendAsync</code></td> 
   <td>请参阅<a href="http://owin.org/spec/extensions/owin-SendFile-Extension-v0.3.0.htm" rel="nofollow">委托签名</a></td> 
  </tr> 
  <tr> 
   <td>websocket.ReceiveAsync</td> 
   <td><code>WebSocketReceiveAsync</code></td> 
   <td>请参阅<a href="http://owin.org/spec/extensions/owin-SendFile-Extension-v0.3.0.htm" rel="nofollow">委托签名</a></td> 
  </tr> 
  <tr> 
   <td>websocket.CloseAsync</td> 
   <td><code>WebSocketCloseAsync</code></td> 
   <td>请参阅<a href="http://owin.org/spec/extensions/owin-SendFile-Extension-v0.3.0.htm" rel="nofollow">委托签名</a></td> 
  </tr> 
  <tr> 
   <td>websocket.CallCancelled</td> 
   <td><code>CancellationToken</code></td> 
   <td></td> 
  </tr> 
  <tr> 
   <td>websocket.ClientCloseStatus</td> 
   <td><code>int</code></td> 
   <td>Optional</td> 
  </tr> 
  <tr> 
   <td>websocket.ClientCloseDescription</td> 
   <td><code>String</code></td> 
   <td>Optional</td> 
  </tr> 
 </tbody> 
</table>

[ASP.NET]: http://ASP.NET
[OWIN]: http://owin.org/spec/spec/owin-1.0.0.html
[Nowin]: https://github.com/Bobris/Nowin
[Link 1]: https://github.com/aspnet/Docs/tree/master/aspnetcore/fundamentals/owin/sample
[websocket]: https://chrome.google.com/webstore/detail/simple-websocket-client/pfdhoblngboilpfeibdedpjgfnlcodoo?hl=en
[20190220144823992.png]: /images/20210626/c0b667a28c6e409aae142fe4d988b601.png
[Link 2]: http://owin.org/#spec
[OWIN Key Guidelines and Common Keys]: http://owin.org/spec/spec/CommonKeys.html