- c - 在位数组中找到第一个零
- linux - Unix 显示有关匹配两种模式之一的文件的信息
- 正则表达式替换多个文件
- linux - 隐藏来自 xtrace 的命令
在构造函数中使用类似字符串参数的东西会使依赖注入(inject)变得非常困惑。思考:
public class CurrencyActor
{
public CurrencyActor(string currency, IRepository repository)
{
...
还有其他问题(例如 this one)来解决这个依赖注入(inject)的特殊问题。这通常可以通过重新思考设计和重构来解决。
但是,如果拥有一个对象的多个版本,每个版本负责不同的数据(例如,每种货币都有一个 CurrencyActor),那会怎样呢?这在使用 Akka .NET 等参与者模型时非常正常,但即使在该域之外也是有意义的。
在传递所需的初始状态时,使用依赖注入(inject)创建这些多个实例的最佳方法是什么?
最佳答案
在构造函数中有依赖关系并不麻烦,这很常见。这没有错。
您可以在接受您的依赖项的 CurrencyActor 上创建默认 Prop 静态方法:
public static Props CreateProps(string currency, Irepository repo)
{
return Props.Create(() => new CurrrncyActor(currency, repo));
}
然后创建任意数量的:
var usCurrency = system.ActorOf(CurrencyActor.CreateProps("US", someRepo), "US");
var swedishCurrency = system.ActorOf(CurrencyActor.CreateProps("SEK", someRepo), "SEK");
[更新]
关于在 Akka 中使用 DI 容器,这被列为否。人们在使用 akka.net 时犯的前 7 个错误中的 2 个
https://petabridge.com/blog/top-7-akkadotnet-stumbling-blocks/
Thus it’s considered to be a good practice for actors to manage their own dependencies, rather than delegate that work to a DI framework.
所以基本不做。如果必须,根据那篇文章,Autofac 是最佳选择
[更新 2]
如果你想动态创建同一个 Actor 的新实例但改变一些初始状态,那么你可以有一个主管来负责创建它们:
public class MatchesSupervisor : ReceiveActor
{
List<IActorRef> _matches = new List<IActorRef>();
public void MatchesSupervisor()
{
Receive<SomeCommandToStartANewMatch>(msg =>
{
// store the currently active matches somewhere, maybe on a FullTime message they would get removed?
_matches.Add(Context.ActorOf(MatchActor.Create(msg.SomeMatchId)));
}
}
}
在上面的例子中,没有使用 DI 容器,如果每个 MatchActor 都需要其他东西,比如 IRepository,那么它会在创建时传递给 MatchesSupervisor,然后在创建时传递给每个 MatchActor创建。
这在某种程度上也取决于状态的来源,以及开始新 Match 的机制是什么——我只是假设其他 Actor 正在发送消息。
(我在 ipad 上打字,所以上面的代码可能无法真正编译,但希望你明白了,我也遗漏了 MatchActor 的实现,但它只是一个将一些值传递到其构造函数的 Actor )
希望这对您有所帮助!
关于c# - 具有状态构造函数参数的 Akka .NET 中的依赖注入(inject),我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/38295099/
我正在尝试使用 Scala 2.12.3、sbt 0.13.6 以及 build.sbt 文件中的以下库依赖项构建一个项目: libraryDependencies ++= Seq( "com.t
我根本没有任何 Akka 经验。我想知道 Akka 消息传递如何在 JVM 内以及 JVM 之间工作。 JVM 中的消息是一些类似 POJO 的对象吗? JVM之间的通信是否需要任何类型的JMS(如服
Akka的EventBus是否可以与远程 Actor 一起使用? 据我所知,它本身不支持此功能。任何人都可以确认吗? 看起来有可能对提供相似功能的Actor进行编码。例如。在订阅远程服务器上的Even
我在单个 JVM 上使用 Akka 开发了我的应用程序。现在我想在多台机器上分配工作负载。我开始阅读文档并感到困惑。 有两种方法可以通过集群和远程处理使 Akka 应用程序分发。 我不明白两者之间的区
我想使用 Akka HTTP 构建一个连接到现有接收器(带有 Kafka react 流)的 REST 服务,但我不知道如何将 HTTP 流链接到 Akka 流接收器... 我应该选择使用 Flows
我在某处听说默认情况下是一个 Actor 系统,这意味着它的 ExecutorService/Dispatcher 正在创建一个非 Deamon 线程池来运行 Actor。如果确实如此,那将解释我所经
在我的应用程序中,我有一个角色需要在等待某些操作完成时存储消息,同时它需要支持高优先级消息(控制消息)。 stash trait 需要一个 Dequeue邮箱类型,我找不到控制感知出队邮箱是否有意义。
Akka.NET 和原始 Akka 可以使用 Remoting 进行通信吗? 换句话说,Akka 可以用于连接系统中的 JVM 和 CLR 吗? 最佳答案 这个问题在 akka.net Github
Akka 新手。创建一个扩展 SupervisorStrategy 的新 Scala 类为我提供了以下模板: class MySupervisorStrategy extends Supervisor
我正在尝试为包含并行处理流的 Akka 流定义一个图(我正在使用 Akka.NET,但这应该无关紧要)。想象一个订单的数据源,每个订单由一个订单 ID 和一个产品列表(订单商品)组成。工作流程如下:
我有一个 akka actor(worker)接收请求并回复它。请求处理可能需要 3-60 分钟。来电者(也是 Actor )目前正在使用 !!!并等待 future.get,但是如果需要,可以更改
我应该如何在 Akka 持久化 (Eventsourcing/CQRS) 中构建我的 Actor? 分层 平行 我的电子商务应用程序中有这些域对象 用户 - 用户可以创建帐户 商店 - 用户可以创建商
我正在尝试构建和运行一个 akka 流(在 Java DSL 中),以 2 个 actor 作为源,然后是一个合并结点,然后是 1 个接收器: Source src1 = Source.act
我正在尝试监督 Akka Actor ,更具体地说是 Cluster Singleton创建使用 ClusterSingletonManager .我试图更好地控制异常、日志和 Actor 的生命周期
我试图了解何时何地使用不同的 built-in Akka mailboxes以及何时适合自己滚动。但是,该页面上的任何地方都没有解释“ 有界邮箱 ”实际上是什么,或者它的行为方式与无界邮箱有何不同。此
在Akka中等待多个actor的结果的正确方法是什么? Principles of Reactive Programming Coursera 类(class)有一个带有复制键值存储的练习。无需深入研
我正在为一个项目评估 Akka,我正在尝试弄清楚我是否可以通过将参与者状态保存在高可用数据存储中来使用 Akka-Persistence 实现服务的高可用性。 (我不打算使用 Akka-Cluster
我阅读了 Akka 文档并找到了这个 As mentioned before, if a node is unreachable then gossip convergence is not poss
我正在使用 akka 流,并且我有一段我需要有条件地跳过的图表,因为流程无法处理某些值。具体来说,我有一个接受字符串并发出 http 请求的流,但是当字符串为空时,服务器无法处理这种情况。但我只需要返
我们正在考虑使用 Akka 进行客户端服务器通信,并尝试对数据传输进行基准测试。目前我们正在尝试发送一百万条消息,其中每条消息都是一个具有 8 个字符串字段的案例类。 目前,我们正在努力获得可接受的性
我是一名优秀的程序员,十分优秀!