如何在 ServiceStack.net 中使用 Funq 注册多个 IDbConnectionFactory 实例

本文关键字：注册 Funq 实例 IDbConnectionFactory ServiceStack net | 更新日期: 2023-09-27 18:19:43

您将如何在Funq中注册不同的IDbConnectionFactory实例，然后直接在您的服务中访问它们？ 命名实例是否以某种方式在这里发挥作用？

跨服务使用不同的数据库时，这是最佳方法吗？

谢谢！

编辑：

一个例子;)。 我可能离这里很远，因为我对 IoC 很陌生，但例如，我想注入 2 个单独的数据库连接。 在ServiceStack中，这是在Global.asax中完成的。

container.Register<IDbConnectionFactory>(c =>
            new OrmLiteConnectionFactory(@"Connection String 1", SqlServerOrmLiteDialectProvider.Instance));                                             
container.Register<IDbConnectionFactory>(c =>
            new OrmLiteConnectionFactory(@"Connection String 2", SqlServerOrmLiteDialectProvider.Instance));

这两者似乎都被注入了嘟嘟嘟。

然后通过如下内容在服务端自动访问这些内容：

public IDbConnectionFactory DbFactory { get; set; }

在这种情况下，它似乎给了我第一个注册的。 如何在服务端访问特定的服务？ 希望这使它更清楚一点。

下面是一个来自 ServiceStack.Example 的完整示例，它只使用 1 个 IDbConnectionFactory：电影休息

如何在 ServiceStack.net 中使用 Funq 注册多个 IDbConnectionFactory 实例

我上面的问题仍然有效，但以下内容可能会对您有所帮助。

Funq 不支持自动构造函数注入(又名自动连线(，您必须通过构造Func<T> lambda 表达式手动执行此操作。由于您已经在手动执行构造函数注入，因此很容易选择要注入到服务中的IDbConnectionFactory。例：

IDbConnectionFactory yellowDbConFactory =
    new YellowDbConnectionFactory();
IDbConnectionFactory blueDbConFactory =
    new BlueDbConnectionFactory();
IDbConnectionFactory purpleDbConFactory =
    new PurpleDbConnectionFactory();
container.Register<IService1>(c =>
    new Service1Impl(yellowDbConFactory,
        c.Resolve<IDep1>());
container.Register<IService2>(c =>
    new Service2Impl(blueDbConFactory);
container.Register<IService3>(c =>
    new Service3Impl(purpleDbConFactory, 
        c.Resolve<IDep2>());

当然，您也可以使用命名注册，如下所示：

container.Register<IDbConnectionFactory>("yellow",
    new YellowDbConnectionFactory());
container.Register<IDbConnectionFactory>("blue",
    new BlueDbConnectionFactory());
container.Register<IDbConnectionFactory>("purple",
    new PurpleDbConnectionFactory());
container.Register<IService1>(c =>
    new Service1Impl(
        c.Resolve<IDbConnectionFactory>("yellow"),
        c.Resolve<IDep1>());
container.Register<IService2>(c =>
    new Service2Impl(
        c.Resolve<IDbConnectionFactory>("blue"));
container.Register<IService3>(c =>
    new Service3Impl(
        c.Resolve<IDbConnectionFactory>("purple"), 
        c.Resolve<IDep2>());

由于缺乏对自动布线的支持，您最终会得到这些相当尴尬的注册，这很快就会导致您的组合根的维护噩梦，但这与您的问题无关;-(

您通常应尽量防止注册中的歧义。在您的情况下，您有一个界面，它可以做两件事(连接到两个数据库(。除非两个数据库共享完全相同的模型，否则每个数据库都应该有自己的接口(如果两个实现不可互换，你将违反 Liskov 替换原则(：

interface IYellowDbConnectionFactory : IDbConnectionFactory
{
}
interface IPurpleDbConnectionFactory : IDbConnectionFactory
{
}

由于 ServiceStack 的工作方式，您可能需要为每个实现：

class YellowDbConnectionFactory : OrmLiteConnectionFactory,
    IYellowDbConnectionFactory
{
    public YellowDbConnectionFactory(string s) : base(s){}
}
class PurpleDbConnectionFactory : OrmLiteConnectionFactory,
    IPurpleDbConnectionFactory 
{
    public YellowDbConnectionFactory(string s) : base(s){}
}

现在，您应该更改服务的定义以使用特定接口，而不是使用IDbConnectionFactory：

public class MovieService : RestServiceBase<Movie>
{
    private readonly IYellowDbConnectionFactory dbFactory;
    public MovieService(IYellowDbConnectionFactory factory)
    {
        this.dbFactory = factory;
    }
}

请注意，此类现在使用构造函数注入而不是属性注入。您可以让它与属性注入一起使用，但通常最好使用构造函数注入。这是一个关于它的问题。

使用 Funq，您的配置将如下所示：

container.Register<MovieService>(c =>
    new MovieService(
        c.Resolve<IYellowDbConnectionFactory>());

这两个新接口和两个类以及对MovieService的更改并没有为你赢得很多好处，因为 Funq 不支持自动连线。您将是手动将所有内容连接在一起的人。但是，当您切换到支持自动连线的框架时，此设计允许容器毫无问题地注入正确的依赖项，因为没有讨论要注入的内容。

虽然 Funq 不支持自动布线，但它的 ServiceStack 实现支持。最新版本的ServiceStack包括Funq.Container重载：

container.RegisterAutoWired<T>();
container.RegisterAutoWiredAs<T,TAs>();
container.RegisterAs<T,TAs>();

所以在史蒂文的例子中，你也可以做：

container.RegisterAs<YellowDbConnectionFactory,IYellowDbConnectionFactory>();

它会自动为您注册依赖项。

以为我会在这里投入 2 美分，尽管我意识到这个问题已经很老了。我想从ServiceStack访问事务数据库和日志记录数据库，这就是我最终从AppHostBase Configure((方法执行此操作的方式：

            container.Register<IDbConnectionFactory>(
                c => {
                    OrmLiteConnectionFactory dbFactory = new OrmLiteConnectionFactory(ConfigurationManager.ConnectionStrings["MyTransactionalDB"].ConnectionString, MySqlDialect.Provider);
                    dbFactory.ConnectionFilter = x => new ProfiledDbConnection(x, Profiler.Current);
                    dbFactory.RegisterConnection("LoggingDB", ConfigurationManager.ConnectionStrings["MyLoggingDB"].ConnectionString, MySqlDialect.Provider);
                    return dbFactory;
                });

默认情况下，从工厂打开连接时使用"MyTransactionalDB"，但我可以通过以下方法从服务显式访问日志记录数据库：

        using (var db = DbFactory.Open("LoggingDB"))
        {
            db.Save(...);
        }

尝试使用存储库模式而不是此 IoC(这只会使事情变得不必要地复杂化(。 上面的代码似乎不起作用。怀疑有什么变化。 我仍然不清楚注册 IDbConnectionFactory 如何神奇地填充 IDbConnection 属性。 希望对此进行一些解释。如果有人确实使用ServiceStack IoC容器可以正常工作。那我很想看看如何。 更新SS文档将非常有益(我很乐意这样做(

您也可以使用字典

使用数据库键名称创建枚举

public enum Database
    {
        Red,
        Blue
    }

在 Startup.cs 中，创建一个打开新 SqlConnection 的函数字典，然后将依赖项字典注入为单例

Dictionary<Database, Func<IDbConnection>> connectionFactory = new()
   {
      { Database.Red, () => new SqlConnection(Configuration.GetConnectionString("RedDatabase")) },
      { Database.Blue, () => new SqlConnection(Configuration.GetConnectionString("BlueDatabase")) }
   };
services.AddSingleton(connectionFactory);

在您可以像这样获取对对象构造函数的依赖

关系之后： 
public class ObjectQueries
{
   private readonly IDbConnection _redConnection;
   private readonly IDbConnection _blueConnection;
   public ObjectQueries(Dictionary<Database, Func<IDbConnection>> connectionFactory)
   {
      _redConnection = connectionFactory[Database.Red]();
      _blueConnection = connectionFactory[Database.Blue]();
   }
}

它干净易读;)

相关文章：