微服务架构如何设计API代理网关和OAuth2授权认证框架（微服务api权限控制）

1，授权认证与微服务架构1.1，由不同团队合作引发的授权认证问题去年的时候，公司开发一款新产品，但人手不够，将B/S系统的Web开发外包，外包团队使用Vue.js框架，调用我们的WebAPI，但是这些WebAPI并不在一台服务器上，甚至可能是第三方提供的WebAPI。

同时处于系统安全的架构设计，后端WebAPI是不能直接暴露在外面的；另一方面，我们这个新产品还有一个C/S系统，C端登录的时候，要求统一到B/S端登录，可以从C端无障碍的访问任意B/S端的页面，也可以调用B/S系统的一些API，所以又增加了一个API网关代理。

整个系统的架构示意图如下：

注：上图还有一个iMSF，这是一个实时消息服务框架，这里用来做文件服务，参见《消息服务框架使用案例之--大文件上传（断点续传）功能》在Web端会读取这些上传的文件1.2，微服务--分布式“最彻底”的分1.2.1，为什么需要分布式

大部分情况下，如果你的系统不是很复杂，API和授权认证服务，文件服务都可以放到一台服务器：Web Port 服务器上，但要把它们分开部署到不同的站点，或者不同的服务器，主要是出于以下考虑：1，职责单一：每一个服务都只做一类工作，比如某某业务WebAPI，授权服务，用户身份认证服务，文件服务等；职责单一使得开发、部署和维护变得容易，比如很容易知道当前是授权服务的问题，而不是业务API问题。

2，系统安全：采用内外网隔离的方案，一些功能需要直接暴露在公网，这需要付出额外的成本，比如带宽租用和安全设施；另外一些功能部署在内网，这样能够提供更大的安全保证3，易于维护：每一个服务职责都比较单一，所以每一个服务都足够小，那么开发维护就更容易，比如要更新一个功能，只需要更新一个服务而不用所有服务器都暂停；另一方面也更加容易监控服务器的负载，如果发现某一个服务器负载太大可以增加服务器来分散负载。

4，第三方接入：现在系统越来越复杂，内部的系统很可能需要跟第三方的系统对接，一起协同工作；或者整个系统一部分是 .NET开发的，一部分又是Java平台开发的，两个平台部署的环境有很大差异，没法部署在一起；或者虽然同是ASP.NET MVC，但是一个是MVC３，一个是MVC５，所以需要分别独立部署。

以上就是各个服务需要分开部署的原因，而这样做的结果就是我们常说的分布式计算了，这是自然需求的结果，不是为了分而拆分1.2.2，依赖于中间层而不直接依赖于服务客户端直接访问后端服务，对后端的服务会形成比较强的依赖。

有架构经验的朋友都知道，解决依赖的常见手段就是添加一个中间层，客户端依赖于这个中间层而不是直接依赖于服务层这样做有几个很大的好处：当服务负载过大的时候可以在中间层做负载均衡；或者后端某个服务出现问题可以切换主备服务;

或者替换后端某个服务的版本做灰度发布另一方面，当后端服务部署为多个独立的进程/服务器后，客户端直接访问这些服务，将是一个更加较复杂的问题,负载均衡，主备切换，灰度发布等运维功能更难操作，除此之外，还有下面两个比较重要的问题：。

客户端直接访问后端多个服务，将暴露过多的后端服务器地址，从而增加安全隐患；后端服务太多，需要在客户端维护这些服务访问关系，增加开发调试的复杂性；B/S页面的AJax跨域问题，WebAPI地址跟主站地址不一样，要解决跨域问题比较复杂并且也会增加安全隐患。

所以，为了解决客户端对后端服务层的依赖，并且解决后端服务太多以后引起的问题，我们需要在客户端和后端服务层之间添加一个中间层，这个中间层就是我们的服务代理层，也就是我们后面说的服务网关代理（WebAPI Gateway Proxy），它作为我们所有Web访问的入口站点，这就是上图所示的 Web Port。

有了网关代理，后台所有的WebAPI都可以通过这个统一的入口提供对外服务的功能，而对于后端不同服务地址的路由，由网关代理的路由功能来实现，所以这个代理功能很像Nginx这样的反向代理，只不过，这里仅仅代理WebAPI，而不是其它Web资源。

现在，网关已经成为很多分布式系统的标配，比如TX的这个架构：

注：上图来源于网络，侵删！另外，这个读写分离代理，如果使用SOD框架，可以在AdoHelper对象直接设置读写不同的连接字符串简单达到效果1.2.3，微服务架构经过上面的设计，我们发现这个架构有几个特点：。

每个服务足够小，职责单一；每个服务运行在自己的进程或者独立的服务器中，独立发布部署和开发维护；服务对外提供访问或者服务之间进行通信，都是使用轻量级的HTTP API;每个服务有自己独立的存储，彼此之间进行数据交互都通过接口进行；

有一个API代理网关统一提供服务的对外访问这些特点是非常符合现在流行的微服务思想的，比如在《什么是微服务》这篇文章中，像下面说的这样：微服务最早由Martin Fowler与James Lewis于2014年共同提出，微服务架构风格是一种使用一套小服务来开发单个应用的方式途径，每个服务运行在自己的进程中，" g6 B8 \4 j$ w, u5 H+ R8 w 并使用轻量级机制通信，通常是HTTP API，这些服务基于业务能力构建，并能够通过自动化部署机制来独立部署，这些服务使用不同的编程语言实现，以及不同数据存储技术， - I8 O( |0 i( w3 w0 E0 u2 | 并保持最低限度的集中式管理。

所以我们这个架构是基本符合微服务思想的，它的诞生背景也是要解决其它传统单体软件项目现在遇到的问题一样的，是在比较复杂的实际需求环境下自然而然的一种需求，不过好在它没有过多的“技术债务”，所以设计实施起来比较容易。

下面我们来详细看看这个架构是如何落地的2，“授权\认证\资源”独立服务的OAuth2.0架构2.1，为什么需要OAuth2.0 ?OAuth 2.0已经是一个“用户验证和授权”的工业级标准OAuth（开放授权）是一个开放标准，1.0版本于2006年创立，它允许用户让第三方应用访问该用户在某一网站上存储的私密的资源（如照片，视频，联系人列表），而无需将用户名和密码提供给第三方应用。

OAuth 2.0关注客户端开发者的简易性，同时为Web应用，桌面应用和手机，和起居室设备提供专门的认证流程2012年10月，OAuth 2.0协议正式发布为RFC 6749以上内容详见OAuth 2.0官网。

现在百度开放平台，腾讯开放平台等大部分的开放平台都是使用的OAuth 2.0协议作为支撑，国内越来越多的企业都开始支持OAuth2.0协议现在，我们的产品设计目标是要能够和第三方系统对接，那么在对接过程中的授权问题就是无法回避的问题。

在我们原来的产品中，有用户授权验证的模块，但并没有拆分出独立的服务，用它与第三方系统对接会导致比较大的耦合性；另一方面，与第三方系统对接合作不一定每次都是以我们为主导，也有可能要用第三方的授权认证系统这就出现了选择哪一方的授权认证方案的问题。

之前我曾经经历过一个项目，因为其中的授权认证问题导致系统迟迟不能集成所以，选择一个开放标准的授权认证方案，才是最佳的解决方案，而OAuth 2.0正是这样的方案2.2，OAuth的名词解释和规范（1）Third-party application：第三方应用程序，本文中又称”客户端”（client），即上一节例子中的“Web Port”或者C/S客户端应用程序。

（2）HTTP service：HTTP服务提供商，即上一节例子中提供软件产品的我们公司或者第三方公司（3）Resource Owner：资源所有者，本文中又称“用户”（user）（4）User Agent：用户代理，本文中就是指浏览器或者C/S客户端应用程序。

（5）Authorization server：授权服务器，即服务提供商专门用来处理认证的服务器（6）Resource server：资源服务器，即服务提供商存放用户生成的资源的服务器，即上一节例子中的内部API服务器、第三方外部API服务器和文件服务器等。

它与认证服务器，可以是同一台服务器，也可以是不同的服务器以上名词是OAuth规范内必须理解的一些名词，然后我们才能方便的讨论OAuth2.0是如何授权的有关OAuth的思路、运行流程和详细的四种授权模式，请参考阮一峰老师的《理解OAuth 2.0》。

2.3，OAuth2.0的授权模式为了表述方便，先简单说说这4种授权模式：授权码模式（authorization code）--是功能最完整、流程最严密的授权模式它的特点就是通过客户端的后台服务器，与"服务提供商"的认证服务器进行互动。

简化模式（implicit）--不通过第三方应用程序的服务器，直接在浏览器中向认证服务器申请令牌，跳过了"授权码"这个步骤，因此得名所有步骤在浏览器中完成，令牌对访问者是可见的，且客户端不需要认证密码模式（resource owner password credentials）--用户向客户端提供自己的用户名和密码。

客户端使用这些信息，向"服务商提供商"索要授权在这种模式中，用户必须把自己的密码给客户端，但是客户端不得储存密码客户端模式（client credentials）--指客户端以自己的名义，而不是以用户的名义，向"服务提供商"进行认证。

严格地说，客户端模式并不属于OAuth框架所要解决的问题在这种模式中，用户直接向客户端注册，客户端以自己的名义要求"服务提供商"提供服务，其实不存在授权问题在我们的需求中，用户不仅仅通过B/S系统的浏览器进行操作，还会通过C/S程序的客户端进行操作，B/S，C/S系统主要都是我们提供和集成的，客户购买了我们这个产品要使用它就意味着客户信任我们的产品。

授权码模式虽然是最完整的授权模式，但是授权码模式授权完成后需要浏览器的跳转，显然浏览器无法直接跳转到我们的C/S客户端，虽然从技术上可以模拟，但实现起来成本还是比较高；简化模式也有这个问题所以我们最终决定采用OAuth2.0的密码模式。

2.4，OAuth2.0密码模式授权流程 简单来说，密码模式的步骤如下： 用户向客户端提供用户名和密码客户端将用户名和密码发给认证服务器，向后者请求令牌认证服务器确认无误后，向客户端提供访问令牌 上面这个步骤只是说明了令牌的获取过程，也就是我们常说用户登陆成功的过程。

当用户登陆成功之后，客户端得到了一个访问令牌，然后再使用这个令牌去访问资源服务器，具体说来还有如下后续过程：4，客户端携带此访问令牌，访问资源服务器；5，资源服务器去授权服务器验证客户端的访问令牌是否有效；

6，如果访问令牌有效，授权服务器给资源服务器发送用户标识信息；7，资源服务器根据用户标识信息，处理业务请求，最后发送响应结果给客户端。下面是流程图：

注意：这个流程适用于资源服务器、授权服务器相分离的情况，否则，流程中的第5，6步不是必须的，甚至第4，7步都是显而易见的事情而不必说明现在大部分有关OAuth2.0的介绍文章都没有4，5，6，7步骤的说明，可能为了表述方便，默认都是将授权服务器跟资源服务器合在一起部署的。

2.5，授权、认证与资源服务的分离什么情况下授权服务器跟资源服务器必须分开呢？如果一个系统有多个资源服务器并且这些资源服务器的框架版本不兼容，运行环境有差异，代码平台不同（比如一个是.NET，一个是Java），或者一个是内部系统，一个是外部的第三方系统，必须分开部署。

在这些情况下，授权服务器跟任意一个资源服务器部署在一起都不利于另一些资源服务器的使用，导致系统集成成本增加这个时候，授权服务器必须跟资源服务器分开部署，我们在具体实现OAuth2.0系统的时候，需要做更多的事情。

什么情况下授权服务器跟认证服务器必须分开呢？ 授权（authorization）和认证（authentication）有相似之处，但也是两个不同的概念：授权（authorization）：授权，批准;批准（或授权）的证书；

认证（authentication）：认证;身份验证;证明，鉴定;密押仅仅从这两个词的名词定义可能不太容易分辨，我们用实际的例子来说明他们的区别：有一个管理系统，包括成熟的人员管理，角色管理，权限管理，系统登录的时候，用户输入的用户名和密码到系统的人员信息表中查询，通过后取得该用户的角色权限。

在这个场景中，用户登录系统实际上分为了3个步骤：用户在登录界面，输入用户名和密码，提交登录请求；【认证】系统校验用户输入的用户名和密码是否在人员信息表中；【授权】给当前用户授予相应的角色权限现在，该管理系统需要和第三方系统对接，根据前面的分析，这种情况下最好将授权功能独立出来，采用OAuth这种开放授权方案，而认证问题，原有管理系统坚持用户信息是敏感信息，不能随意泄露给第三方，要求在原来管理系统完成认证。

这样一来，授权和认证，只好分别作为两个服务，独立部署实现了本文的重点就是讲述如何在授权服务器和资源服务器相分离，甚至授权和认证服务器相分离的情况下，如何设计实现OAuth2.0的问题3，PWMIS OAuth2.0 方案。

PWMIS OAuth2.0 方案就是一个符合上面要求的授权与认证相分离，授权与资源服务相分离的架构设计方案，该方案已经成功支撑了我们产品的应用下面分别来说说该方案是如何设计和落地的3.1，使用Owin中间件搭建OAuth2.0认证授权服务器。

这里主要总结下本人在这个产品中搭建OAuth2.0服务器工作的经验至于为何需要OAuth2.0、为何是Owin、什么是Owin等问题，不再赘述我假定读者是使用Asp.Net,并需要搭建OAuth2.0服务器,对于涉及的Asp.Net Identity(Claims Based Authentication)、Owin、OAuth2.0等知识点已有基本了解。

若不了解，请先参考以下文章：MVC5 - ASP.NET Identity登录原理 - Claims-based认证和OWIN下一代Asp.net开发规范OWIN（1）—— OWIN产生的背景以及简单介绍

OWIN OAuth 2.0 Authorization Server我们的工作，可以从研究《OWIN OAuth 2.0 Authorization Server》这个DEMO开始，不过为了更好的结合本文的主题，实现授权与认证相分离的微服务架构，推荐大家直接从我的DEMO开始：https://github.com/bluedoctor/PWMIS.OAuth2.0

PS：大家觉得好，先点个赞支持下，谢谢！克隆我这个DEMO到本地，下面开始我们OAuth2.0如何落地的正式讲解3.2，PWMIS.OAuth2.0解决方案介绍首先看到解决方案视图，先逐个做下简单说明：。

3.2.1，运行解决方案将解决方案的项目，除了PWMIS.OAuth2.Tools，全部设置为启动项目，启动之后，在 http://localhost:62424/ 站点，输入下面的地址：http://localhost:62424/Home

然后就可以看到下面的界面：

点击登录页面，为了方便演示，不真正验证用户名和密码，所以随意输入，提交后结果如下图：

点击确定，进入了业务操作页面，如下图：

如果能够看到这个页面，我们的OAuth2.0演示程序就成功了。还可以运行解决方案里面的WinForm测试程序，先登录，然后运行性能测试，如下图：

更多信息，请参考下文的【3.8集成C/S客户端访问】下面我们来看看各个程序集项目的构建过程3.3，项目 PWMIS.OAuth2.AuthorizationCenter首先添加一个MVC5项目PWMIS.OAuth2.AuthorizationCenter，然后添加如下包引用：。

Microsoft.AspNet.MvcMicrosoft.Owin.Host.SystemWebMicrosoft.Owin.Security.OAuthMicrosoft.Owin.Security

.Cookies然后在项目根目录下添加一个OWin的启动类 Startup：using Microsoft.Owin;0 S' R, g- z" S7 G. F using Microsoft.Owin.Security; $ x7 `% n! |" O, G" } using Microsoft.Owin.Security.OAuth; 5 Q3 z- f5 D8 C ^

using Owin; 4 ?7 \ m3 C+ _ using System; ' V* G' b: F1 L# @1 j& _ using System.Collections.Generic; 3 }0 N8 }5 j# _' Q using System.Diagnostics;6 }9 b3 k. P/ Y2 ]8 D, b using System.Web.Http; * B( A5 x! N" B% k: a, y- \! @$ s9 h* Z

namespacePWMIS.OAuth2.AuthorizationCenter ; x4 |# `3 b7 |8 p4 l/ e& o- g {1 Q" t. y( Q4 J( p publicpartialclassStartup7 f5 v3 I2 P5 t d9 J3 o$ q { 8 R. R1 }, G% S. [1 _ [0 ^0 f9 w- T publicvoidConfigureAuth

(IAppBuilder app)+ U8 M% ]: w9 Y; l3 } {- t) |* R0 W/ }3 K var OAuthOptions = new OAuthAuthorizationServerOptions; r9 D! O3 j% ^0 d" V" d {( e/ }7 I; O& @2 |0 F n AllowInsecureHttp =

true,6 @: e4 o8 S/ x& R* W% X f AuthenticationMode = AuthenticationMode.Active,' U" g3 d7 \& ~ TokenEndpointPath =

new PathString("/api/token"), //获取 access_token 授权服务请求地址 # M8 h( @ N# k1 ?$ p AuthorizeEndpointPath = new PathString(

"/authorize"), //获取 authorization_code 授权服务请求地址 6 T3 q! P0 f1 m4 N AccessTokenExpireTimeSpan = TimeSpan.FromSeconds(

60), //access_token 过期时间，默认10秒太短 & B( P8 K, g: V/ p9 @3 e 4 x9 \' n, ]6 ~4 X6 } Provider = new OpenAuthorizationServerProvider(), //access_token 相关授权服务

1 h7 Z- h/ i5 @# V5 a5 o AuthorizationCodeProvider = new OpenAuthorizationCodeProvider(), //authorization_code 授权服务

' P/ r) O3 w. G RefreshTokenProvider = new OpenRefreshTokenProvider() //refresh_token 授权服务; _" H2 m* g. W& |1 t }; 0 R7 I1 B4 S1 g& @' p6 }7 C app.UseOAuthBearerTokens(OAuthOptions);

//表示 token_type 使用 bearer 方式 + S3 F I1 B/ J' `: r* G }% |: E- i5 Y4 k# P' {9 q7 g* m 2 g6 q, D9 T. U4 O8 y5 X; | W9 i publicvoidConfiguration(IAppBuilder app) J; s6 F, `5 `/ I- Y* _/ @& Z {# {6 R( T% q8 Q2 s

// For more information on how to configure your application, visit http://go.microsoft.com/fwlink/?LinkID=316888

: m( @( j. E/ ^; \* g ConfigureAuth(app); ( W! q6 E# C% r" i; ?/ r! i + y' q6 |$ N' ], x var configuration = new HttpConfiguration(); 5 |7 n& F% C1 `( B7 T+ o3 H WebApiConfig.Register(configuration);& g9 |5 ]" m3 t) Z' K! \ app.UseWebApi(configuration); $ Z8 r4 U" d1 a " {% Q7 g4 L2 n1 L' q) Z9 q' q }. u8 ?, t* t8 B* D$ { # ?' _$ f1 i! H' b1 O# V }7 u$ M- Q3 i- S3 ^ }

上面的代码中，定义了access_token 授权服务请求地址和access_token 过期时间，这里设置60秒后过期由于本篇着重讲述OAuth2.0的密码授权模式，我们直接看到类 OpenAuthorizationServerProvider的定义：。

OpenAuthorizationServerProvider token过期时间不宜太长，比如一天，这样不安全，但也不能太短，比如10秒，这样当API访问量比较大的时候会增大刷新token的负担，所以这里设置成60秒。

3.3.1，验证客户端信息在本类的第一个方法 ValidateClientAuthentication 验证客户端的信息，这里的客户端可能是C/S程序的客户端，也可能是访问授权服务器的网关代理服务器，OAuth2.0会验证需要生成访问令牌的客户端，只有合法的客户端才可以提供后续的生成令牌服务。

客户端信息有2个部分，一个是clientId，一个是clientSecret，前者是客户端的唯一标识，后者是授权服务器颁发给客户端的秘钥，这个秘钥可以设定有效期或者设定授权范围为简便起见，我们的演示程序仅仅到数据库去检查下传递的这两个参数是否有对应的数据记录，使用下面一行代码:。

var identityRepository = IdentityRepositoryFactory.CreateInstance();这里会用到一个验证客户端的接口，包括验证用户名和密码的方法一起定义了：

////// 身份认证持久化接口///publicinterfaceIIdentityRepository/ O: P9 x; s4 O, |: V+ K" p' a {7 q2 c. W) x$ N; j4 G+ I //////

客户ID是否存在/////////Task ExistsClientId

(string clientId); ! L% w c) j; A5 q ////// 校验客户标识//////客户ID///

客户秘钥///Task ValidateClient(string clientId,

string clientSecret);0 `+ J: j2 e! s8 {% c4 i/ J6 v% t ////// 校验用户名密码/////////

///Task ValidatedUserPassword(string userName,

string password);+ s9 \' c/ Y+ y( v& i }这样我们就可以通过反射或者简单 IOC框架将客户端验证的具体实现类注入到程序中，本例实现了一个简单的客户端和用户认证类，采用的是SOD框架访问数据库：namespace

PWMIS.OAuth2.AuthorizationCenter.Repository% B: c4 Z1 V- { n* E% K {! X4 C- i' V+ `! R publicclass SimpleIdentityRepository : IIdentityRepository , E/ [9 i: n8 o. A+ [ { - o& @# P. V- ^, u/ ~

privatestatic System.Collections.Concurrent.ConcurrentDictionary dictClient = new System.Collections.Concurrent.ConcurrentDictionary<

string, string>();) a: o% G5 [9 [$ ~) i$ ` publicasync Task ExistsClientId(string clientId)5 N- g* L( E5 T$ Z { " q6 T7 \( w; b7 x

returnawait Task.Run(() => 1 o/ }5 [7 ]0 ^8 G" A2 V3 y {' P1 S* l) A) C7 M AuthClientInfoEntity entity = new AuthClientInfoEntity();- P0 R3 k; @4 Y$ \9 a, C. f entity.ClientId = clientId;0 j- @8 i) k# w+ w , \6 D% v2 u4 y4 y OQL q = OQL.From(

entity) 1 v7 j5 |! o9 n9 I+ N .Select(entity.ClientId)* z2 @& h, _/ |8 J1 V .Where(entity.ClientId) ( z9 {4 P4 i9 y2 Y2 l O( H .END; ( a2 F& r4 B6 K" F% T AuthDbContext context =

new AuthDbContext(); * R* ]/ u+ o; B6 |4 M0 p3 A AuthClientInfoEntity dbEntity = context.QueryObject(

q);" g4 Q/ H7 B% H# F* k% D; S d8 o2 m return dbEntity != null;! F/ M7 ]3 \2 ^9 V }); + x5 c8 x# y% G% e }- ` Z5 S; Y3 |3 L' ` 6 {$ x: P% p5 p9 I publicasyncTask

ValidateClient(string clientId, string clientSecret) 7 S0 U* w9 [7 F" o5 n/ v% N {* u6 x! C( x. B, T) T* m stringdict_clientSecret;9 ?9 L+ y' M- s5 H5 j

if (dictClient.TryGetValue(clientId, out dict_clientSecret) && dict_clientSecret== clientSecret), E* n; R- K1 L# @ f( R4 ?8 \. d {$ x. I" O; F% o

returntrue;: Z- b" U; G9 v$ D3 I- m, G }6 ^7 f* Y( \" U. e) h& U1 S else 5 {' ?' Y* n! A/ h1 i: x j {; m- Y* {: C# C7 S returnawaitTask.Run(() => {; V$ A) M) ^& A( L$ W. ?# S AuthClientInfoEntity entity =

new AuthClientInfoEntity();" F& l; p; j; a$ }/ O; w entity.ClientId = clientId; 2 n0 W/ U0 v8 `" {7 E; l& E entity.ClientSecret = clientSecret; , c" J+ z# w- x) Y OQL q = OQL.From(

entity); j% v0 w$ w$ H+ R: e( `: [ .Select(entity.ClientId)/ G' L: X" N* T. A. u .Where(entity.ClientId, entity.ClientSecret

)# o3 n7 g* w& t w# H: I5 H .END;8 P7 @& J/ e: ^5 b AuthDbContext context = new AuthDbContext(); # \6 V" ^, q' |" {8 g3 O) y AuthClientInfoEntity dbEntity = context.QueryObject(

q); 7 W4 n1 T! o3 \0 s/ v5 ?3 l if (dbEntity != null)6 @! I" \" E: S, q {. h" q. u& c# b# D5 g* Z dictClient.TryAdd(

clientId, clientSecret); 1 t: O- Q. \% k; G$ D! z* j0 _ returntrue;: ^$ j5 d" \- [# n0 @" o } + u$ V) W, v7 ^$ }

elsereturnfalse; ! f; L9 r Z g }); 1 C0 a1 E, E9 m' F }: P5 ]+ m8 Y9 r- T$ B: n0 v ( k4 A6 ?& o Y1 z% h$ H3 ]0 h3 }! v } : S( [; C+ P4 n: T# Y; D. i+ L' K3 ^# e+ _2 q publicasyncTask

> ValidatedUserPassword(string userName, string password)4 f- h2 j g( h! G {: g2 J5 E2 _' ?( x returnawaitTask.Run

>(() => # l) ^6 H2 X: C6 y4 H; ^8 U6 l% B { $ y* Y0 D5 d7 D UserInfoEntity user = new UserInfoEntity(); : V' H$ W4 g5 T0 E9 p user.UserName = userName;1 L1 k. c6 p8 U/ `$ L& ] user.Password = password; 2 @4 k1 m6 e6 s& g+ _: n- h# r+ v OQL q = OQL.From(

user), I J: M9 p+ P4 G9 y6 h6 x .Select() 0 `: r8 w( H6 [ A& r+ @ .Where(user.UserName, user.Password)% W& ^8 F1 s$ t) | .END;9 E8 ?9 {% W' R& F4 z0 c, f" X! W AuthDbContext context =

new AuthDbContext();- S+ d8 \0 B6 }2 J AuthClientInfoEntity dbEntity = context.QueryObject(

q);0 ?3 z" X# S5 ?! ^+ n return dbEntity != null; 6 Q- @: \6 @" O% s });) x$ Z: A/ `4 M$ U4 ?: O5 Q/ z } # P! F" y% a) w2 i8 ^9 M; [! q } ! I1 m: q5 b8 @! m! W; p }AuthDbContext 类非常简单，它会自动生成验证客户端所需要的表：

namespacePWMIS.OAuth2.AuthorizationCenter.Repository " F/ i* c9 F7 v( n- q { 7 M, E7 {" P& i* C publicclassAuthDbContextbContext) s2 X( r0 K9 K { # O, `6 Q/ _2 ~) C6 @

publicAuthDbContext() 7 E: e3 ?5 j2 m3 B$ j! o : base("OAuth2") . y$ d' s! Z: T# S4 ^0 x: ?5 @) R$ w. z { 4 L5 O. k) p! J( _* R: c1 H- p# ` \8 s7 y" V6 k& b, J6 e. C. B }! C' o" W) C8 ^3 L' c) z" J 7 w2 ~# b7 d* b; ?; J7 D 0 C! x* t% Z4 g1 f

protectedoverrideboolCheckAllTableExists() 6 h8 z9 `) V% z/ K% N3 T" H! ~. ~ { 4 K0 z. |+ g4 _ a, m+ u4 u0 e7 D. U4 \* n base.CheckTableExists(); + |7 `" s5 N0 h" T2 T

base.CheckTableExists();$ X. f) {, @( ~; f3 I' O returntrue; ! X. M `7 Y: ~8 o7 f }7 S: T: p5 p, _ } ' S- B$ F" a) }) o }3.3.2，认证用户，生成访问令牌生成访问令牌需要重写OWIN OAuthAuthorizationServerProvider类的 GrantResourceOwnerCredentials方法（方法的详细内容看前面【OpenAuthorizationServerProvider的定义】），方法里面使用到了IdentityService 对象，它有一个UserLogin 方法，用来实现或者调用用户认证服务：

IdentityServiceUserLogin方法提供了2种方式来认证用户身份，一种是直接访问用户数据库，一种是调用第三方的用户认证接口，这也是当前演示程序默认配置的方式当用户认证比较复杂的时候，推荐使用这种方式，比如认证的时候需要检查验证码。

需要在授权服务器的应用程序配置文件中配置使用何种用户身份验证方式以及验证地址：

="webpages:Enabled"value="false"/>

value="true"/>

/>

>如果认证用户名和密码通过，在GrantResourceOwnerCredentials方法最后，调用OWin的用户标识方式表示授权验证通过：3.4，项目 PWMIS.OAuth2.Tools项目 PWMIS.OAuth2.Tools 封装了OAuth2.0调用相关的一些API函数，前面我们介绍了基于OWIN实现的OAuth2.0服务端，下面我们来看看如何调用它生成一个访问令牌。

3.4.1，OAuthClient类--获取和刷新令牌看到 OAuthClient.cs 文件的 OAuthClient类的GetToken 方法////// 获取访问令牌///

///授权模式///刷新的令牌///

用户名///用户密码///授权码///

可选业务参数///publicasync Task GetToken(string grantType, string

refreshToken = null, string userName = null, string password = null, string authorizationCode = null

,string scope=null) ( I6 f8 `' Z0 o {3 O+ `" @' Q7 `3 f* p! ^& U* | var clientId = System.Configuration.ConfigurationManager.AppSettings[

"ClientID"]; ; q6 X2 w) m6 q6 X$ j var clientSecret = System.Configuration.ConfigurationManager.AppSettings["ClientSecret"

];6 c( C; u. G. _ this.ExceptionMessage = ""; . }0 X; D4 |$ W3 k: G; P, s var parameters = new Dictionary

>(); ' U0 P L2 D; \' p8 y& q parameters.Add("grant_type", grantType);1 v3 X$ Z) L# q7 E5 y8 ~ # R8 H& z, n& y- h! p& z* L if (!string.IsNullOrEmpty(userName) && !

string.IsNullOrEmpty(password)) " j) _ R. g' v: M$ h { ; z: d& V Y0 f0 c7 O( B& N9 j' I parameters.Add("username", userName); ) A/ Y b- x1 T, u4 E- }& f" g# X parameters.Add(

"password", password); : S8 A# ]3 f+ U; c parameters.Add("scope", scope);9 k- \1 O- ?. h% B8 L. O: f 6 U. N) ]2 K- w! k5 z2 [8 C } 8 }# m/ e8 e6 H& \

if (!string.IsNullOrEmpty(authorizationCode))+ O4 k' _& k6 K5 a7 g2 ?, N { ' z, Q' a$ g: ^+ G; _7 A var redirect_uri = System.Configuration.ConfigurationManager.AppSettings[

"RedirectUri"];& {$ B8 J1 A0 V9 k0 S4 f b0 _ parameters.Add("code", authorizationCode); 3 k9 t ~6 m' N" Z8 `6 T parameters.Add(

"redirect_uri", redirect_uri); //和获取 authorization_code 的 redirect_uri 必须一致，不然会报错: c7 K* D4 ?3 h' K5 B) @1 s4 g }1 m& B# L! i3 w7 H. f9 F# R

if (!string.IsNullOrEmpty(refreshToken)) 2 _7 I' g9 F; O# C! B { ; T; f. e, G! A0 T parameters.Add("refresh_token"

, refreshToken);* d. V0 ?% Q0 I5 _9 k. C3 U) ] }" |% n; T( y5 A. B( o 6 C9 _; |: a0 {. D httpClient.DefaultRequestHeaders.Authorization = new AuthenticationHeaderValue( & h9 A! Y7 h- @# x# p7 Y: `

"Basic", . x8 o+ j; k3 J( t$ G% K2 I Convert.ToBase64String(Encoding.ASCII.GetBytes(clientId + ":" + clientSecret))); ) c" {2 d; ]; q9 ~, E/ v W

string errCode = "00"; 0 `% Z; c% [7 R$ P' E1 Z try 2 f) D0 G. N2 o1 _3 ^+ X6 T { " H" J; s/ f* p: O c //PostAsync 在ASP.NET下面，必须加).ConfigureAwait(false)；否则容易导致死锁

//详细内容，请参考 http://blog.csdn.net/ma_jiang/article/details/53887967var cancelTokenSource = new CancellationTokenSource(

50000); 8 ]1 L5 o, I. q$ u. `7 S) i0 ] var response = await httpClient.PostAsync("/api/token", new FormUrlEncodedContent(parameters), cancelTokenSource.Token).ConfigureAwait(

false);" F1 R0 j3 X1 l; q. a var responseValue = await response.Content.ReadAsStringAsync(); ) D' D/ f4 ^* O

if (response.StatusCode != HttpStatusCode.OK)7 w W" U. q9 s8 G {; l1 ~' A4 m w4 V8 X: I7 @ try _! L6 u! i" a* N) g& Z5 S! d {# G: n3 U* F) t2 o: r1 |- N, f

var error = await response.Content.ReadAsAsync(); ( y7 L5 o/ }6 E0 P if (error.ExceptionMessage ==

null)4 k& l! X2 ?& Y" S; ~3 d { 6 i) y; j. q+ Y; \% j) d string errMsg = "";3 z9 A6 o; d( G6 v4 `

foreach (var item in error) : o0 g g# |' q2 x6 ] { . ?$ ]+ O3 ?! g7 \" V" Z errMsg += item.Key +

":\"" + (item.Value == null ? "" : item.Value.ToString()) + "\",";8 ~2 U# W; B* F1 L3 } }! z( N1 g" e+ \ E9 d* ?# S# ?

this.ExceptionMessage = "HttpError:{" + errMsg.TrimEnd(,)+"}"; ; T) F) D, Q; c3 \* K/ E }, {, P" S9 F' x( ^' S1 ?1 q

else 3 L+ {6 i; e: T$ W$ S) K5 b% | {1 K5 O# i8 M" B3 y# U% n8 _0 } this.ExceptionMessage = error.ExceptionMessage;" d& A+ O+ B7 d+ T7 s# v4 E4 P( T } * }' F' C' H$ ^: G errCode =

"1000"; : H' l* e5 E7 N; }5 F; k" y$ r } ) ?, V. T- F# |. ~2 Y8 v( U# V5 U& D catch (AggregateException agex)( N/ [# f( K- K8 X* b3 I { {& }+ j0 H t- e- Q. c

string errMsg = ""; y# C* g" D! ^- u foreach (var ex in agex.InnerExceptions)& {. `" c4 I( ^! B' O0 ^( ?, ^ {; O1 G* h( Y0 z/ G, M errMsg += ex.Message; , ]: O6 ?6 X) a. o9 K } ' S/ z7 }: U: @% b+ N n) R/ k2 `' R1 d errCode =

"1001"; ) g! Z" J9 L* l! @; ?. e this.ExceptionMessage = errMsg; & v7 D# S$ t& [4 s$ E0 M/ h6 m }; v) T) i1 Y+ c" l4 z6 [. Z- c% `

catch (Exception ex)$ x: p* {9 y! x* C4 }# z$ _ { - O. {' Z& u" c- R7 O _% v this.ExceptionMessage = response.Content.ReadAsStringAsync().Result; % _6 T: T6 a- o6 O- r# G- v errCode =

"1002";$ ~- o) I- J( g" D WriteErrorLog(errCode, ex.Message);) Q: b, @2 d( ~; _; _2 X. N4 g }$ f' P( z! H' _8 y & L% P7 n3 y3 ]0 o6 F" \/ k2 w3 x- | WriteErrorLog(errCode,

"StatusCode:" + response.StatusCode + "\r\n" + this.ExceptionMessage);) t5 D& O% w! w( u this.ExceptionMessage =

"{ErrorCode:" + errCode + ",ErrorObject:{" + this.ExceptionMessage + "}}";* D, L6 Q2 a" C6 S6 a3 T' r; y( o; O, @ return

null; 1 w; s0 C1 j K0 {1 x } 4 ^. n/ a$ R+ Z. W3 ]! D returnawait response.Content.ReadAsAsync(); 1 a3 F& k( u9 D# G N }# O' D5 `7 p8 Y1 W8 I" B% J c

catch (AggregateException agex) 6 O6 d6 j6 x# J% { { / X2 z0 [1 E- O string errMsg = "";. H7 ~9 C% N2 ~; K7 {* S$ a foreach

(var ex in agex.InnerExceptions) & x) Q+ t! ?/ O" M; u+ h. e { ( ~1 a* D4 o+ Q$ r z' s errMsg += ex.Message+",";0 z) z3 q' |6 X# `2 ~ } ! W: u1 P& `% L8 x" D* x/ g3 z; r, A# M/ i8 j3 _8 O" h errCode =

"1003";, [7 r9 V3 @5 ^8 w this.ExceptionMessage = errMsg;0 i9 ^. Q1 x' K1 a* {8 d WriteErrorLog(errCode, errMsg); 3 A8 m& l ?% B+ T. W% [6 T+ C) ?

this.ExceptionMessage = "{ErrorCode:" + errCode + ",ErrorMessage:" + this.ExceptionMessage + "}"; 3 f5 h$ h+ E) t/ T( n( z. U

returnnull;: A O2 k5 q3 I3 k/ _4 n0 t }3 s3 d7 s- K: f# t+ D; e( ~5 w catch (Exception ex)9 H/ H% ^7 A- W. _ {9 n& s) n, f4 |; B& l- @& h4 `# R this.ExceptionMessage = ex.Message;% r/ U9 q/ Q% M; x errCode =

"1004"; " G1 }; {. @! @, a7 \; R WriteErrorLog(errCode, this.ExceptionMessage); J. B' w$ R& P7 R6 n) T this.ExceptionMessage =

"{ErrorCode:" + errCode + ",ErrorMessage:" + this.ExceptionMessage + "}";: a& i/ u* L' t: y returnnull; # e0 X# z8 Y' ]6 |* X }+ h& Y+ w& g: l: i; X/ m) |- X, h }

方法首先要获取客户端的clientId 和clientSecret 信息，这个信息需要指定到本次请求的Authorization 头信息里面；然后在请求正文里面，指定授权类型，这里应该是"password"，再在正文里面添加用户名和密码参数。

接着，调用HttpClient对象，访问授权服务器的 /api/token ，该地址正是前面介绍的授权服务器项目里面指定的最后，对请求返回的响应结果做复杂的异常处理，得到正确的返回值或者异常结果在本例中，获取的令牌有效期只有1分钟，超过时间就需要刷新令牌：。

////// 使用指定的令牌，直接刷新访问令牌/////////public

TokenResponse RefreshToken(TokenResponse token)$ C. a; B0 X1 H, M- W, H" O { ( i2 m' a+ _; l8 H this.CurrentToken = token;1 G/ _/ _7 b- R$ |2 x& @

return GetToken("refresh_token", token.RefreshToken).Result; F! E3 C9 u0 K5 Z3 Z) V7 b+ ~ }3.4.2，TokenManager类--令牌的管理由于令牌过期后需要刷新令牌获取新的访问令牌，否则应用使用过期的令牌访问就会出错，因此我们应该在令牌超期之前就检查令牌是否马上到期，在到期之前的前一秒我们就立即刷新令牌，用新的令牌来访问资源服务器；但是刷新令牌可能导致之前一个线程使用的令牌失效，造成访问未授权的问题，毕竟授权服务跟资源服务器分离之后，这个可能性是比较高的，因此我们需要对令牌的使用进行管理，降低发生问题的风险。

首先看到 PWMIS.OAuth2.Tools.TokenManager 文件的 CreateToken 生成令牌的方法：////// 使用密码模式，给当前用户创建一个访问令牌///

///用户登录密码///验证码///

publicasync Task CreateToken(string password,string validationCode=null): u% @8 ?& C/ e9 d$ J9 [1 T { & `" c% P0 S% e4 i OAuthClient oc =

new OAuthClient();& H7 D0 R; ~5 S5 J oc.SessionID = this.SessionID;- d7 y. j4 c$ k7 P% b: Z" M var tokenRsp= await oc.GetTokenOfPasswardGrantType(

this.UserName, password, validationCode);. n2 c( z% Q0 I! t" b5 Y, e5 j [8 e if (tokenRsp != null) ' K4 @& X2 D4 A8 N% Q {+ P5 }! L. z; T9 r UserTokenInfo uti =

new UserTokenInfo(this.UserName, tokenRsp); # a5 y) ]; a% S; }& I dictUserToken[this.UserName] = uti; * `9 O: r+ a+ g: @3 E } 8 O1 Y( O; F! k$ x- m/ m& m0 p

else - Q k( }' `. O* h$ M* F {- Z2 B4 u( @) ~7 v- ~ this.TokenExctionMessage = oc.ExceptionMessage; ' J0 a V# M; Z& O } 3 Q. H1 r. W3 I7 S0 `" t4 Q9 V, H

return tokenRsp; 1 k7 I3 \; e4 B1 Q. ? \ }生成的令牌存储在一个字段中，通过登录用户名来获取对应的令牌然后看TakeToken 方法，它首先尝试获取一个当前用户的令牌，如果令牌快过期，就尝试刷新令牌：。

/// /// 取一个访问令牌/// /// 如果没有或者获取令牌失败，返回空public TokenResponse TakeToken(), ~5 Q e5 V3 J6 O6 j) j7 v {& W0 I; E. @% s

if (dictUserToken.ContainsKey(this.UserName)) ^' X3 y' N& O! ~/ s$ P. ^) p6 j {& N9 g: B& K. O; P( K( ~2 z8 u UserTokenInfo uti = dictUserToken[

this.UserName];' }" [ N3 @, Y5 [/ R$ T+ e u; y this.OldToken = uti.Token; , s0 G5 D# a# e: }/ R* H) `! H" \: K2 p9 N //如果令牌超期，刷新令牌if (DateTime.Now.Subtract(uti.FirstUseTime).TotalSeconds >= uti.Token.expires_in || NeedRefresh)* V" |6 H, A3 i4 r G W* y {1 {% k2 v0 p1 T4 V lock (uti.SyncObject) : y+ Y9 F+ F2 K/ t {$ n; _; R# O8 R; L/ U, w

//防止线程重入，再次判断if (DateTime.Now.Subtract(uti.FirstUseTime).TotalSeconds >= uti.Token.expires_in || NeedRefresh), B; i& F2 n$ W { { ) {4 {$ Y# G8 y [

//等待之前的用户使用完令牌再刷新while (uti.UseCount > 0) , Q4 ^* J1 r# T3 |, R( L {* M4 [9 i' Q0 `; }% }. u2 x8 x

if (DateTime.Now.Subtract(uti.LastUseTime).TotalSeconds > 5), H1 K# B$ L! s5 z/ i* i4 e& O { % q, l9 w6 o) n% V E7 t* r" z

//如果发出请求超过5秒使用计数还大于0，可以认为资源服务器响应缓慢，最终请求此资源可能会拒绝访问this.TokenExctionMessage = "Resouce Server maybe Request TimeOut."

;+ \8 v/ k3 t& X OAuthClient.WriteErrorLog("00", "**警告** "+DateTime.Now.ToString()+

"：用户"+this.UserName+" 最近一次使用当前令牌（"; ` x' c6 B+ ?1 @! H +uti.Token.AccessToken +"）已经超时（10秒）,使用次数："

+uti.UseCount+"，线程ID:"+System.Threading.Thread.CurrentThread.ManagedThreadId+"\r\n**下面将刷新令牌，但可能导致之前还未处理完的资源服务器访问被拒绝访问。

");6 s/ \" d% g' F) v break; & c( n9 D3 B0 G y } 8 q- n- b) O B System.Threading.Thread.Sleep(

100);( C" @9 X0 N5 b: X; N( p( \7 T } ( `5 p9 |5 `4 @& `5 N2 _ //刷新令牌try$ h: T2 J6 N7 n- Z { 8 V" R h' j- d( k OAuthClient oc = new OAuthClient(); 2 ^' i3 {& \7 ~

var newToken = oc.RefreshToken(uti.Token); / U7 ^5 }2 |5 S, |. V4 \0 H if (newToken == null) " C$ u: M* `5 o

throw new Exception("Refresh Token Error:" + oc.ExceptionMessage); + m) e1 ^9 t+ M* N9 ?3 { else

if( string.IsNullOrEmpty( newToken.AccessToken))5 a4 T! B0 K) Y& v, y throw new Exception(

"Refresh Token Error:Empty AccessToken. Other Message:" + oc.ExceptionMessage);4 m `/ r5 {' r " n) m: K# H0 D2 T+ `/ W" A/ J uti.ResetToken(newToken); 3 F% {9 l. ?0 P( G" t+ J2 e4 l

this.TokenExctionMessage = oc.ExceptionMessage; # Z* o, i$ t6 Y! o5 w: P( l$ X } - Y& |4 w1 _; v6 W7 J8 U: q* ~

catch (Exception ex)) `% V$ C/ h) V1 O { 8 M/ A0 U! b, D" m+ j this.TokenExctionMessage = ex.Message; % ^ Q9 i4 Y2 L ]. C5 L

returnnull;9 D; A5 G, w, {0 _# ` } 1 S& u! |& i4 T1 t8 h. Q1 l0 b0 g NeedRefresh = false;' e8 ^5 r: R' X0 }8 A* U } - a# ~: N, l+ f/ n! j: R, z }

//end lock , _5 K" L$ M/ g% a2 v9 t& F1 F* o } 5 m# C/ Q- @* ]# U 9 s& w& c: B9 L. o! M0 Q0 U. ~ this.CurrentUserTokenInfo = uti;9 l8 w/ M' A2 L' v8 r: \ uti.BeginUse(); 6 o& Z; P5 L+ S9 F2 M

//this.CurrentTokenLock.Set();return uti.Token; " M. b$ N. e& {6 Q, h3 h* c. x4 V } ' R) G. ^% W" b% h* p% }) k else / N: J* [, X$ Q& e$ z { 6 b# ], K) C/ a x/ F1 f" o

//throw new Exception(this.UserName+" 还没有访问令牌");this.TokenExctionMessage = "UserNoToken"; 9 c' ?1 v0 Y( v& x: ~ 。

returnnull; & j" w5 V' N+ k; C5 M1 U. C8 o }: c- C0 u9 I- a# U3 y0 i$ \1 S }有了令牌管理功能，客户端生成和获取一个访问令牌就方便了，下面看看客户端如何来使用它3.5，项目 Demo.OAuth2.Port项目 Demo.OAuth2.Port 在本解决方案里面有3个作用：

提供静态资源的访问，比如调用WebAPI的Vue.js 功能代码；提供后端API路由功能，作为前端所有API访问的网关代理；存储用户的登录票据，关联用户的访问令牌这里我们着重讲解第3点功能，网关代理功能另外详细介绍。

在方案中，用户的访问令牌缓存在Port站点的进程中，每当用户登录成功后，就生成一个用户访问令牌跟当前用户票据关联看到项目的控制器 LogonController 的用户登录Action： [。

HttpPost]0 K S& N1 u) G8 x, u7 _5 n0 Z [AsyncTimeout(60000)] u# P% }( {- D$ x% c9 d+ {' N; C& v publicasync Task Index(LogonModel model

)# }' k$ c- r0 b+ e* e0 O9 Q+ I# y { ) P* d& Z Z0 l( B1 e& x LogonResultModel result = new LogonResultModel();* O4 y' P, `8 d4 m) g3 ~/ ~' L( q 6 N9 y. {" q5 {" y1 M8 J //首先，调用授权服务器，以密码模式获取访问令牌

//授权服务器会携带用户名和密码到认证服务器去验证用户身份//验证服务器验证通过，授权服务器生成访问令牌给当前站点程序//当前站点标记此用户登录成功，并将访问令牌存储在当前站点的用户会话中//当前用户下次访问别的站点的WebAPI的时候，携带此访问令牌。

( Y/ N* E* `% k9 { ! `0 b1 G# u* b+ i/ t! [% C TokenManager tm = new TokenManager(model.UserName, Session.SessionID); m. r' N9 o# a

var tokenResponse = await tm.CreateToken(model.Password,model.ValidationCode);: F8 ~- v/ _2 W/ ` if (tokenResponse !=

null && !string.IsNullOrEmpty(tokenResponse.AccessToken)) 8 d0 i E- G2 B. X$ u {, C2 }9 D$ `% p, u8 J8 O; { result.UserId =

123; 4 W8 c2 B" {6 w9 N% E result.UserName = model.UserName;: o/ u5 Z9 U0 t! U$ ? result.LogonMessage = "OK"; ; p7 ]2 p$ I6 }: P0 d

/* OWin的方式 $ `! ~; j9 o" { ClaimsIdentity identity = new ClaimsIdentity("Basic");0 `# X0 P; F" D% ? identity.AddClaim(new Claim(ClaimTypes.Name, model.UserName));* T$ A# f& r. V7 G1 m2 I ClaimsPrincipal principal = new ClaimsPrincipal(identity); " j$ I: d$ t" x HttpContext.User = principal; % U- p' H6 D* u& ?: C4 L */

8 R5 [; f; Y0 S" m FormsAuthentication.SetAuthCookie(model.UserName, false); + T6 w" `$ D1 R* U0 d8 y9 j } / e# d; ?! p. d9 c# ^5 J

else' I: F7 w' T, N9 g1 a6 l ~ {! v! Q$ b! Y. D* s. ~5 h result.LogonMessage = tm.TokenExctionMessage;' L$ g/ a- H, O" ` } $ `9 V6 X0 l$ C

return Json(result);0 F$ P$ B& g( k6 ~1 c }Port站点作为授权服务器的客户端，需要配置客户端信息，看到Web.config文件的配置：

value="3.0.0.0" />

/>

="PWMIS.OAuth2.Port"/>

value="http://localhost:60186"/> 3 Z; N! L9 n' V# p ; M. k$ ~0 j& T# e4 `( Q8 G3 u