LayIM.AspNetCore Middleware 开发日记（五）Init接口实现细节

时间：2018-06-01 19:43:00 阅读：296 评论：0 收藏：0 [点我收藏+]

标签：部分 rabl 博客加油 dapper 程序地址 delete 数据

前言

　　“一旦开始了就要坚持下去“。为什么本文的第一句话是这么一句话呢，因为我经常就是开头轰轰烈烈，结果越来越枯燥，就不想做下去了。但是版图就放弃又那么不甘心，继续加油吧。

　　吐槽完毕，进入正题。在上一篇中我们的主角LayIM已经登场了。而且界面已经实现，那么有些小伙伴就有疑惑了，详细流程是什么样的，今天我就介绍一个东西，那就是 /layim/init 接口的实现细节

　　另外，项目已经升级至 .NET CORE 2.1 ，最新代码在 dev-netcore2.1 分支上

需求

　　需求是什么?需求是将LayIM的主界面显示出来。如下：

　　技术分享图片

　　嗯，就是这么个东西。在上一篇中我已经介绍到，init接口就是为了实现主界面的，那么主界面的数据是什么样的呢？（其实在两年前的博客中已经讲过，这里在稍微提一下）我们看一下DEMO中的getList.json.

　　技术分享图片

　　如上图，我们只要定义一个接口然后输出上图格式中的json数据即可。由于我在框架中用SQLServer给了一个默认实现，关系型数据库那肯定是各种关系啦。首先定义最基本的表。

　　用户表，用户好友分组表，用户好友关系表，群组表，群组群员关系表。目前这五个表足够了。

　　下面逐个分析击破：

　　mine:当前用户信息，从用户表取出即可

　　friend:首先从用户好友分组表取出当前用户所有的分组，在从用户好友关系表取出好友。然后程序中去匹配该好友对应的分组即可。及分组和好友是一对多的关系

　　group:从群组群员关系表中取出当前用户所在的群，然后在从群组表取出相应的群信息，组合数据即可

具体代码实现

　　下面的代码如果有不理解的地方，可以先从前面几篇中补补课。

　　首先，毋庸置疑，先将路由配置上：

  routes.AddQuery("/init", async context => await GetInitData(context));

　　GetInitData 做了什么事呢?它就是获取注册的 ILayIMStorage 实例，然后调用接口方法获取数据。

   public interface ILayIMStorage
    {
        /// <summary>
        /// 初始化数据
        /// </summary>
        /// <param name="userId"></param>
        /// <returns></returns>
        Task<LayIMInitModel> GetInitData(string userId);

        /// <summary>
        /// 保存聊天记录
        /// </summary>
        /// <param name="message"></param>
        /// <returns></returns>
        Task<int> SaveMessage(LayIMMessageModel message);
    }

接口实现类

　　在项目 LayIM.AspNetCore.Storage.SqlServer中实现ILayIMStorage接口.Repository具体代码就不在粘贴了，就是一系列Sql的查询然后数据组合。

        /// <summary>
        /// 获取初始化数据
        /// </summary>
        /// <param name="userId"></param>
        /// <returns></returns>
        public async Task<LayIMInitModel> GetInitData(string userId)
        {
            var mineTsk = userRepository.GetUserById(userId);
            var friendGroupsTask = friendGroupRepository.GetUserGroups(userId);
            var friendRelationsTask = friendRelationRepository.GetFriendRelations(userId);
            var groupIdsTask = groupMemberRepository.GetUserBigGroups(userId);

            LayIMInitModel initModel = new LayIMInitModel
            {
                //用户自己
                mine = await mineTsk
            };
            //好友列表
            List<FriendGroupModel> friend = new List<FriendGroupModel>();

            IEnumerable<FriendGroupModel> friendGroups = await friendGroupsTask;
            IEnumerable<FriendRelationShip> friendRelations = await friendRelationsTask;
            IEnumerable<long> friendIds = friendRelations.Select(x => x.FriendId);

            IEnumerable<UserModel> friends = await userRepository.GetUsersByIds(friendIds);

            if (friendIds?.Count() > 0)
            {
                foreach (var group in friendGroups)
                {
                    var friendIdsInGroup = friendRelations.Where(r => r.GroupId == group.id).Select(r => r.FriendId);

                    group.list = friends.Where(x => friendIdsInGroup.Any(f => f == x.id));
                }
            }

            friend.AddRange(friendGroups);

            initModel.friend = friend;

            //群组列表
            IEnumerable<long> groupIds = await groupIdsTask;
            var bigGroupsTask = bigGroupRepository.GetBigGroups(groupIds);
            initModel.group = await bigGroupsTask;

            return initModel;
        }

　　写完方法之后，记得要注册服务。

        /// <summary>
        /// 使用SqlServer
        /// </summary>
        /// <param name="services"></param>
        /// <param name="setConfig"></param>
        public static IServiceCollection AddSqlServer(this IServiceCollection services,string connectionString)
        {
            var dbConfig = new DBConnectionConfig(DBType.SqlServer)
            {
                ConnectionString = connectionString
            };
            services.AddSingleton(dbConfig);
            services.AddSingleton<ILayIMStorage, LayIMDapperStorage>();
            return services;
        }

　　然后在Demo中的使用方法如下：

 services.AddLayIM().AddRongCloud(config =>
                    {
                        config.AppKey = "appkey";
                        config.AppSecret = "appsecret";
                    })
                .AddSqlServer("connectionString");

　　重启项目，测试一下 layim/init 接口。数据返回正常

　　技术分享图片

　　当然，一个好友的用户数据一般变化不大，所以对于接口要增加缓存设计。不过这里我暂时没有实现，只是先临时用了 IMemoryCache。

请求回放

　　首先，由于请求的 Path 是 /layim 开头的，所以中间件判定为LayIM请求，然后在经过路由转发器，找到对应的处理器。

 var dispatcher = LayIMRoutes.Routes.FindDispatcher(path);

　　之前已经介绍过，Dispatcher 是实现了Dispatch 方法的。

 internal interface ILayIMDispatcher
    {
        Task Dispatch(HttpContext context);
    }

　　所以，最终的请求其实都会落到路由注册的方法中，也就是上文中的 routes.AddQuery("/init", async context => await GetInitData(context)); 那么其他的返回ContentType,转JSON就是框架实现了，业务没必要关心它了。

　　说到这里可能大家还是比较迷糊，下面是一个Dispatcher之间的关系图.

　　技术分享图片