Host ASP.NET WebApi in Owin

 1 [RoutePrefix("api/persons")]
 2     public class PersonController : ApiController
 3     {
 4         [Route("{id}/name")] 6         public string getName(string id)
 7         {
 8             return id + "@boss";
 9         }
10     }

public class Startup
{
        public void Configuration(IAppBuilder appBuilder)
        {var configuration = new HttpConfiguration();
            configuration.MapHttpAttributeRoutes();//配置web api的router
            appBuilder.UseWebApi(configuration);//这个扩展是由package Microsoft.AspNet.WebApi.Owin提供，它负责注册web api到owin的处理管道中，
　　　　　　　　　　　　　　　　　　　　　　　　　　　　//并在处理请求时将Owin语义与web api中的语义进行转换
        }
}

WebApp.Start<Startup>("http://localhost:8088/");//WebApp利用katana实现的OwinHttpListener来在指定url上监听http请求。

Console.WriteLine("Started!");
Console.ReadKey();

public class AuthenticateMiddleware
{
        private Func<IDictionary<string, object>, Task> nextAppFunc;
        public AuthenticateMiddleware(Func<IDictionary<string, object>, Task> nextMiddleWareFunc)
        {
            nextAppFunc = nextMiddleWareFunc;
        }

        public async Task Invoke(IDictionary<string, object> parameters)
        {
            Console.WriteLine("Authenticating");
            string queryString = parameters["owin.RequestQueryString"] as string;//获取http请求的query string
            var respStream = parameters["owin.ResponseBody"] as Stream;//获取http请求的response stream
            var streamWriter = new StreamWriter(respStream);
            var queryDic = ParseQueryString(queryString);

            const string tokenKey = "token";
            const string predefineToken = "88888888";
            if (!queryDic.ContainsKey(tokenKey)||queryDic[tokenKey]!=predefineToken)//检查请求中所带token是否合法，此处仅为测试需要，直接硬编码。
            {
　　　　　　　　  //如果token非法，则直接写入Access Denied到response中。停止继续执行管道中其他middleware.
                streamWriter.WriteLine("Access Denied!");
                streamWriter.Flush();
                return;
            }

　　　　　　
            var identity = new GenericIdentity("boss zhang");
            parameters["server.User"] = new GenericPrincipal(identity, new string[] { "admin" });//token合法，生成principal对象到parameters中,key "server.User"
　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　//用于存储当前请求的user信息，相当于HttpContext.User
            if (nextAppFunc != null)
            {
                await nextAppFunc.Invoke(parameters);//继续执行管道中下一个middleware
            }
        }

        private Dictionary<string, string> ParseQueryString(string originalString)
        {
            string[] queryStringItems = originalString.Split(new string[] { "&" }, StringSplitOptions.RemoveEmptyEntries);
            var queryStringDic = new Dictionary<string, string>();
            foreach (var item in queryStringItems)
            {
                string[] queryStringKvp = item.Split(new string[] { "=" }, StringSplitOptions.None);
                if (queryStringKvp.Length == 2)
                {
                    queryStringDic[queryStringKvp[0]] = queryStringKvp[1];
                }
            }

            return queryStringDic;
        }
}