IdentityServer4 + SignalR Core +RabbitMQ 构建web即时通讯（二）

时间：2018-06-10 15:06:18 阅读：363 评论：0 收藏：0 [点我收藏+]

标签：stat 结构 image public ONBUILD await bsp config reac

IdentityServer4 + SignalR Core +RabbitMQ 构建web即时通讯（二）

IdentityServer4 用户中心种子数据

上文已经创建了所有的数据库上下迁移代码，这里开始种子数据的迁移，EF Core 2.1刚好新增了种子数据的功能，文档地址，一开始的想法是使用这种方式，看起来很简洁与方便，需要在OnModelCreating中配置，不过IdentityServer4中的2个数据库上下文我不知道怎么配置进去了，所以还是用比较原始的方式吧。

1.在SeedData添加客户端Client ApiResource IdentityRecouse的种子数据；

        public static List<Client> Clients()
        {
            return new List<Client>
            {
                new Client{
                    // 客户端id
                    ClientId ="chat_client",
                    // 客户端名称
                    ClientName ="chat client",
                    // TOKEN有效时长
                    AccessTokenLifetime = 3600,
                    // 配置TOKEN类型,reference为引用类型,数据不会存在TOKEN中
                    AccessTokenType= AccessTokenType.Jwt,
                    // 配置客户端授权模式
                    AllowedGrantTypes= GrantTypes.ResourceOwnerPassword,
                    // 配置客户端连接密码
                    ClientSecrets={ new Secret("123123".Sha256())},
                    // 客户端允许的请求范围
                    AllowedScopes={
                        "chatapi",
                        IdentityServerConstants.StandardScopes.OfflineAccess,
                        IdentityServerConstants.StandardScopes.OpenId,
                        IdentityServerConstants.StandardScopes.Profile },
                    //允许离线,即开启refresh_token
                    AllowOfflineAccess =true,
                    RequireClientSecret=false
                }
            };
        }

        public static IEnumerable<ApiResource> ApiResources()
        {
            return new List<ApiResource>
            {
                // 定义api资源 这里如果使用构造函数传入Name会默认创建一个同名的Scope，
                // 这点需要注意，因为这个Api如果没有Scope，那根本无法访问
                new ApiResource
                {
                    Name="chatapi",
                    DisplayName="chat api",
                    ApiSecrets= { new Secret("123123".Sha256()) },
                    Scopes={
                        new Scope("chatapi","chat api")
                    }
                }
            };
        }

        public static IEnumerable<IdentityResource> IdentityResources()
        {
            return new List<IdentityResource>
                {
                    new IdentityResources.OpenId(),
                    new IdentityResources.Profile()
                };
        }

2.StartUp中增加迁移方法，Configure中调用 Migration(app).Wait();

        public static async Task Migration(IApplicationBuilder app)
        {
            using (var scope = app.ApplicationServices.CreateScope())
            {
                // 迁移DemoDbContext上下文
                scope.ServiceProvider.GetRequiredService<DemoDbContext>().Database.Migrate();
                // 迁移PersistedGrantDbContext上下文
                scope.ServiceProvider.GetRequiredService<PersistedGrantDbContext>().Database.Migrate();
                var configurationDbContext = scope.ServiceProvider.GetRequiredService<ConfigurationDbContext>();
                // 迁移ConfigurationDbContext上下文
                configurationDbContext.Database.Migrate();

                // 注入用户管理 增加用户
                var userManager = scope.ServiceProvider.GetRequiredService<UserManager<DemoUser>>();
                foreach (var user in SeedData.Users())
                {
                    if (userManager.FindByNameAsync(user.UserName).Result == null)
                    {
                        await userManager.CreateAsync(user, "123123");
                    }
                }

                // 增加ApiResources IdentityResources Clients
                if (!configurationDbContext.ApiResources.Any())
                    configurationDbContext.ApiResources.AddRange(SeedData.ApiResources().Select(r => r.ToEntity()));
                if (!configurationDbContext.IdentityResources.Any())
                    configurationDbContext.IdentityResources.AddRange(SeedData.IdentityResources().Select(r => r.ToEntity()));
                if (!configurationDbContext.Clients.Any())
                    configurationDbContext.Clients.AddRange(SeedData.Clients().Select(r => r.ToEntity()));
                await configurationDbContext.SaveChangesAsync();
            }
        }

这里有个不算坑的坑，Add-Migration命令创建迁移代码时需要把Migration(app).Wait()注释掉，为什么呢？这个命令实际上会启动应用，并执行里面的代码，当首次执行时，数据库并不存在，迁移代码也不存在，所以数据结构都还不存在，如果执行种子数据操作肯定会失败了，当然Add-Migration本身就算是一个代码生成器，输入开发时操作，所以这是一个不算坑的坑。

4.启动程序，控制台能看到迁移信息，

技术分享图片