LayIM.NetClient 组件开发记录

前言

　　好久没写博客了。前阶段看了下Hangfire组件，后来对其代码比较感兴趣，当时不太了解他如何生成的页面和一些访问请求等。后来看了下源代码，发现原来是 OWIN 在搞怪。于是乎开始深入研究Hangfire源代码，当然只是Route和Razor部分，具体他的核心业务后台执行任务我没研究。因为，我想到了之前做的LayIM的一个对接。那时候写的代码和项目耦合度太高，于是冒出一个写LayIM Owin插件的想法。直接开工吧。

开工

　　主要参考了Hangfire的Dashboard部分。https://github.com/HangfireIO/Hangfire/tree/master/src/Hangfire.Core/Dashboard

　　与之前的代码相比，这些代码都没有放入WebUI 端中，而且，分层也比较少。就一个 Owin中间件和SqlServer的实现。代码结构如下：（我自己当然写不出啦，参考上文链接中的代码）

　　 LayIM.NetClient 组件开发记录-LMLPHP

　　用过OWIN的都知道，就是通过IAppBuilder接口注册中间件。其实还是挺复杂的，虽然照着写了出来。为了避免误导观众，我就不多解释了。不过路由那一块我我可以说一下我的理解。

　　首先定义路由集合，集合中包含所有注册的路径和实现 ILayIMDispatcher 接口的 Dispatcher。

  public class RouteCollection

    {

        private readonly List<Tuple<string, ILayimDispatcher>> _dispatchers = new List<Tuple<string, ILayimDispatcher>>();

        /// <summary>

        /// 注册路由

        /// </summary>

        /// <param name="pathTemplate">路由地址</param>

        /// <param name="dispatcher">处理方法</param>

        public void Add(string pathTemplate, ILayimDispatcher dispatcher)

        {

            Error.ThrowIfNull(pathTemplate, nameof(pathTemplate));

            Error.ThrowIfNull(dispatcher, nameof(dispatcher));

            _dispatchers.Add(new Tuple<string, ILayimDispatcher>(pathTemplate, dispatcher));

        }

        /// <summary>

        /// 根据Path寻找对应的Dispatcher

        /// 通过正则表达式来找到匹配的结果

        /// </summary>

        /// <param name="path">路径</param>

        /// <returns></returns>

        public Tuple<ILayimDispatcher, Match> FindDispatcher(string path)

        {

            if (path.Length == ) path = "/";

            foreach (var dispatcher in _dispatchers)

            {

                var pattern = dispatcher.Item1;

                if (!pattern.StartsWith("^", StringComparison.OrdinalIgnoreCase)) {

                    pattern = $"^{pattern}";

                }

                if (!pattern.EndsWith("$", StringComparison.OrdinalIgnoreCase)) {

                    pattern += "$";

                }

                var match = Regex.Match(path, pattern, RegexOptions.CultureInvariant | RegexOptions.IgnoreCase | RegexOptions.Singleline);

                if (match.Success) {

                    return new Tuple<ILayimDispatcher, Match>(dispatcher.Item2, match);

                }

            }

            return null;

        }

    }

　　请求，进入中间件的处理代码：

                var owinContext = new OwinContext(env);

                var context = new OwinLayimContext(storage,options, env);

                var path =  owinContext.Request.Path.Value;

                //匹配路由

                var findResult = routes.FindDispatcher(path);

                //如果没有匹配到，执行下一个

                if (findResult == null) {

                    return next(env);

                }

                //匹配成功之后执行 Dispatch

                context.UriMatch = findResult.Item2;

                //执行具体disptach方法，返回相应结果

                return findResult.Item1.Dispatch(context);

　　举例来说：Layim中的初始化接口。定义为 /init 需要参数为 id. 那么在路由中，注册如下：

       //AddQuery只是又封装了一层，内部还是调用了Add方法。

       Routes.AddQuery<long>("/init", "id", (context, uid) =>

             {

                  //返回处理结果

             });

　　在上边的例子中，AddQuery方法，注册了一个 SingleParameterQueryDispatcher<T> 的处理类。他的作用就是处理拥有单个参数的类型为T的请求。具体代码如下：

        public async Task Dispatch(LayimContext context)

        {

            var request = context.Request;

            var response = context.Response;

            var parameterValue = request.GetQuery(_parameterName);

            //如果不是Get请求，返回方法不允许

            if (!CommandMethod.Equals(request.Method, StringComparison.OrdinalIgnoreCase))

            {

                response.StatusCode = (int)HttpStatusCode.MethodNotAllowed;

                await Task.FromResult(false);

            }

            //返回结果为"application/json";

            context.Response.ContentType = "application/json";

            //将参数转化为相应的类型，有 null 异常

            T value = (T)Convert.ChangeType(parameterValue, typeof(T));

            //执行具体处理函数

            var result = _command(context, value);

            //序列化结果

            var json = context.Options.Serializer.SerializeObject(result);

            //返回

            await context.Response.WriteAsync(json);

        }

总结

　　简单了介绍一下路由部分的内容，相信很多小伙伴也是看的云里雾里的。看懂OWIN机制，就能够懂了。我也是大部分借鉴（抄袭）了Hangfire中的代码。

　　基本思路：

注册路由
实现路由匹配方法
找到对应的处理器
处理方法，返回结果

　　在不懂的话，建议直接阅读源代码，阅读源代码能有意想不到的收获。

附：LayIM.NetClient中间件的使用方法。其中IM通讯我使用了融云，所以在其中也做了一些封装。

 public class Startup

    {

        public void Configuration(IAppBuilder app)

        {

            //使用SQL Server

            GlobalConfiguration.Configuration.UseSqlServer("LayIM_Connection");

            //使用layim api 6tnym1brnmpt7

            app.UseLayimApi("/layim", new LayimOptions

            {

                RongCloudSetting = new RongCloudSetting()

            });

        }

    }

　　LayIM中注册的路由如下：

　　 LayIM.NetClient 组件开发记录-LMLPHP

　　运行结果：

　　 LayIM.NetClient 组件开发记录-LMLPHP

　　获取融云token的方法：

　　 LayIM.NetClient 组件开发记录-LMLPHP

　　代码运行正常

　　 LayIM.NetClient 组件开发记录-LMLPHP

　　最后：我觉得Owin中间件真的很方便。首先能够避免web项目中写太多的重复的业务逻辑。（当然，layim部分抽出成api也可以）通过封装成 LayIM.NetClient中间件以后，不管是webform还是mvc都可以通过Owin来适配。后边还会继续完善。今天就到此为止吧~~

OWin

LayIM.NetClient 组件开发记录

前言

开工

总结