使用 Microsoft.AspNetCore.Identity.MongoDB 进行多租户。我们如何将动态租户注入 MongoDbContext答案

【问题标题】：Using Microsoft.AspNetCore.Identity.MongoDB for Multi Tenancy. How do we inject dynamic Tenant into MongoDbContext使用 Microsoft.AspNetCore.Identity.MongoDB 进行多租户。我们如何将动态租户注入 MongoDbContext
【发布时间】：2018-07-20 08:13:17
【问题描述】：

有谁知道我们如何在 .net core 2.0 中在运行时将上下文注入用户管理器 > MongoDB serStore。

由于上下文是动态的，我们无法在启动时执行此操作，但无法访问 UserStore 并且 UserManager 有太多变量要新建，这是错误的。有什么解决办法吗？

public class UserStore<TUser> :
        IUserPasswordStore<TUser>,
        IUserRoleStore<TUser>,
        IUserLoginStore<TUser>,
        IUserSecurityStampStore<TUser>,
        IUserEmailStore<TUser>,
        IUserClaimStore<TUser>,
        IUserPhoneNumberStore<TUser>,
        IUserTwoFactorStore<TUser>,
        IUserLockoutStore<TUser>,
        IQueryableUserStore<TUser>,
        IUserAuthenticationTokenStore<TUser>
    where TUser : IdentityUser
{
    private readonly IMongoCollection<TUser> _Users;

//这是我们要在运行时注入用户的地方

    public UserStore(IMongoCollection<TUser> users)
    {
        _Users = users;
    }

    public virtual void Dispose()
    {
        // no need to dispose of anything, mongodb handles connection pooling automatically
    }

    public virtual async Task<IdentityResult> CreateAsync(TUser user, CancellationToken token)
    {
        await _Users.InsertOneAsync(user, cancellationToken: token);
        return IdentityResult.Success;
    }

不幸的是用户在启动时为空，应该是因为那时尚未创建租户。

我们也一直在使用 saaskit.Multitenancy，但找不到解决方案。

任何帮助将不胜感激。

谢谢

【问题讨论】：

标签： mongodb asp.net-core-2.0 usermanager

【解决方案1】：

我认为你需要一个通用存储库来充当 IMongoCollection 的包装器，然后将存储库注入控制器中

 public class Repository<T>
{
    public IMongoCollection<T> Collection { get; private set; }

    public Repository(IDbFactory dbFactory)
    {
        MongoClient client = new MongoClient("ur connection string");

        this.Collection = client.GetDatabase("db").GetCollection<T>(typeof(T).Name);
    }



       public T Find(Expression<Func<T, bool>> filter)
    {
        return this.Collection.AsQueryable<T>().FirstOrDefault<T>(filter);
    }

    public async Task<T> FindAsync(Expression<Func<T, bool>> filter)
    {
        return await this.Collection.AsQueryable<T>().FirstOrDefaultAsync<T>(filter);
    }

            // here add more methods
}

然后在 Startup.cs 中注册如下依赖项

 public void ConfigureServices(IServiceCollection services)
    {          
        services.AddTransient(typeof(IRepository<>), typeof(Repository<>));

        services.AddMvc();
    }

最后在控制器内部你注入通用存储库，也不要忘记在通用存储库中实现 IDisopsible

 public class ProductController : Controller
{
    private readonly IRepository<Product> _productRepository = null;

    public ProductController(IRepository<Product> productRepository)
    {
        this._productRepository = productRepository;
    }
}

【讨论】：