akka.net 相关问题

akka.presistance.postgresql 客户端已经太多了

我正在使用 akka.presistance.postgresql 库，由于大量参与者并行运行，我面临着“抱歉，客户端太多”异常。 我想知道什么是最好的...

对 Akka.NET 流进行故障排除：在源-接收器模式中消息未到达远程接收器 Actor

背景： 我正在使用 Akka.Streams 处理 Akka.NET 集群，实现源-接收器模式。我的设置涉及两个 Actor，SourceActor 和 SinkActor，其中 SourceActor 发送消息...

如何在Akka.NET中重启Actor时清除邮箱

我正在开发一个小型参与者系统，当参与者层次结构中出现问题时，我希望关闭所有参与者并重新启动顶层参与者，因此一切都从干净的开始......

Akka.net .NET Core 配置

我正在尝试在 ASP.NET Core 7 Web API 中配置 akka.net。 我将 akka.net 配置添加到 appsettings.json 但配置仍然不起作用。我究竟做错了什么？如何配置akka....

使用Akka.Net Graphs时如何访问Source.Queue的OfferAsync方法？

我正在开发一个使用 Graph API 的 Akka.net Streams 应用程序。我想通过 Source.Queue 的 OfferAsync 方法提供源数据。 如何访问 ISourceQueueWithComplete.OfferAsync m...

Akka.管理DiscoveryMethod.Config

使用 Akka.Management 可以在不使用种子节点的情况下创建集群。 我正在使用“Akka Cluster”作为我的主要工具包来开发一项服务，并且我正在使用“Akka Cluster Boo...

Akka.Hosting - Actor 参数中的依赖注入

如何使用 Akka.Hosting 向 Actors 注入参数？ 即 public ExampleActor(Service1 service){ _service = service; .... } Service1 是在启动时添加到 IServiceCollection 的服务。

Akka.Net Async await行为在Untyped Actor中的表现。

我在Windows 10环境中使用Akka.Net 1.4.1。我在Untyped actor中使用async await任务，到目前为止没有遇到任何问题。正如预期的那样，只有当前消息被处理，直到...

如何解决 "Tried to associate with unreachable remote address [akka.tcp:/actorsystem@address:port]"错误？

我在我的kubernetes上部署了3个lighthouse pods和3个crawlers pods，从这个例子中得到的。现在集群看起来像这样：akka.tcp:/[email protected]:5213 ... ...

为什么akka.net IActorRef.Tell（），消息参数的字段不需要是可变的？

为什么要学习akka.net，我在调用IActorRef.Tell时释放，所以参数的字段不需要是volatile public class Model {public volatile string Name; }在下面的示例中，...

[Akka.Net：网络上的反应流

我试图分别在AkkaStreamsModel中将Source作为源，将Sink作为远程，然后将Sink作为源，并将Source作为远程，分别实现Type 1和Type 2工作流程。 ...

Akka.Net中的UntypedActor和ReceiveActor有什么区别？

我正在尝试找出UntypedActor和ReceiveActor之间的区别。我阅读了两个文档，https://getakka.net/articles/actors/untyped-actor-api.html https：//getakka.net/articles/actors / ...

我如何创建泛型角色-Actor 和Message 在Akka.Net中？ ] >>

我是否可以创建Actor 类型的actor，以将Message 类型的消息作为输入？简而言之，我正在尝试类似下面的内容。公共类SomeActor ...

配置Akka.Net远程处理，以使（windows）docker容器内的进程可以与本地主机上的进程进行通信

我有2个Akka.Net进程通过远程相互通信。进程1具有以下app.hocon：akka {演员{提供者=提供者=远程}远程{dot-netty.tcp.port = 1111}}进程...

Akka.net调度程序仅发送第一个值，并且不更新它，如何解决它

我找不到有趣的时刻的答案。在akka.net中，我有调度程序。它将在演员中挑选出一个数字。这里是一个简单的实现_statusScheduler = Context.System ....

在不阻止父级演员的情况下发送询问

停止重复的计划邮件

[我们希望演员在一段时间不活动后停止播放（即，它在x分钟内未收到某种消息后停止播放）。我没有对此的任何内置支持，因此我选择了...

如何防止我的Akka.net演员阻止我的整个演员系统？

我有一个使用6个角色的C＃Akka.net项目。一个参与者（LoggingActor）负责获取对象并将其传输到Web服务器。每当LoggingActor遇到网络故障时，...

Akka.NET记录器未将日志发送到Application Insights

我已经在Akka.NET中将Application Insights设置为日志记录提供程序，并在Akka.Monitoring中设置了记录各种自定义指标（例如，对收到的消息进行计数和处理时间的计时）。这个...

Akka.Net从非Actor类中调用Actor类内的动作

标题几乎说明了一切。我想从与Actor不在同一文件夹中的非Actor类中调用Actor类中的Action，如果可能的话。