问题标签 [akka.fsharp]
For questions regarding programming in ECMAScript (JavaScript/JS) and its various dialects/implementations (excluding ActionScript). Note JavaScript is NOT the same as Java! Please include all relevant tags on your question; e.g., [node.js], [jquery], [json], [reactjs], [angular], [ember.js], [vue.js], [typescript], [svelte], etc.
f# - 如何使用 Akka.FSharp API 在 Akka.NET 集群中实现故障转移?
如何使用 Akka.FSharp API 在 Akka.NET 集群中实现故障转移?
我有以下集群节点用作种子:
然后我有一个可能会死的任意节点:
在集群中实施故障转移的推荐做法是什么?
具体来说,是否有一个代码示例说明当其中一个节点不再可用时集群的行为方式?
- 我的集群节点应该启动替换还是有不同的行为?
- 是否有一个配置可以自动处理这个我可以设置而无需编写代码?
- 我必须在哪里实现什么代码?
f# - 如何让在一个进程上运行的参与者向在单独进程上运行的另一个参与者发送消息?
我想让在不同进程(或节点)上运行的参与者向运行在不同进程(或节点)上的其他参与者发送消息,同时保持容错和负载平衡。我目前正在尝试使用 Akka.Cluster 的 Sharding 功能来完成此操作。
但是,我不确定如何做到这一点......
我有以下代码反映了我的种子节点:
输出看起来像这样:
在节点 'localhost:2552' 上活动的分片:
然后我有一个单独的进程来执行以下代码:
我的集群系统(在单独的进程上运行)识别正在加入的新节点:
结论:
总之,我希望让在不同进程(或节点)上运行的参与者向运行在不同进程(或节点)上的其他参与者发送消息,同时保持容错和负载平衡。我目前正在尝试使用 Akka.Cluster 的 Sharding 功能来完成此操作。
附录:
akka.net - 使用 Akka.Persistence 配置时出现 System.Format 异常
我正在努力解决解析我的Akka.Net配置文件导致的System.Format异常。
我知道异常源于配置的持久性块:
反映异常的输出如下:
我的整个配置如下:
以下行导致我描述的异常:
总之,我是 Akka.Net 的新手,并且正在努力解决为什么会发生此异常。
f# - 是否有使用“Akkling.Cluster.Sharding”在演员之间发送消息的示例?
这可能是重复的。
因此,我取得了一些进展。但是,我发现将参考文档从 C# API解释为所需的Akka.FSharp API 具有挑战性。
是否有使用“Akkling.Cluster.Sharding”在演员之间发送消息的示例?
到目前为止,我只能从我的客户端程序发送消息,而不是演员。
上面的代码有效。但是,它仅适用于作为消息的字符串。我仍在努力让演员使用各种类型的消息相互发送消息。
笔记:
我得到了 Akka.Persistence.SqlServer 插件工作。
但是,我不清楚如何在 Akkling.Cluster.Sharding中改造以下设置:
具体来说,我的印象是分片集群系统中需要一个分片区域,以便在参与者之间来回发送消息。
作为对这种范式不熟悉的人,我正在努力使用分片功能在两个参与者之间创建一个简单的“hello world”类型的消息传递程序。
有什么建议么?
f# - Actor 无法接收发送到`mailbox.Sender()` 的消息?
我创建了以下测试代码 - .Net core 2.1 控制台应用程序。它仅打印以下消息
TestActor 从 [akka://MySystem/user/Scheduler#1426101451] 收到消息 MyTask ("Test1","Test1")
但是Ok 0
演员无法接收到消息scheduler
?
更新:
在我将参数从更改(mailbox: Actor<Result<int, string>>)
为(mailbox: Actor<_>)
?
c# - 使用 Akka F# 惯用 API (Akka.FSharp) 扩展自定义 C# Akka actor
我有一个用 C# 编写的 .NET 库,其中包含许多 Akka 演员类(继承自 Akka.ActorBase 子类,如 UntypedActor 或 ReceivActor)。我想使用这个库(用于应用程序或扩展它),使用 F#。当然我知道我可以用 F# 编写 OO 代码,但我想做的是使用 Akka.FSharp 惯用 API。这可能吗?有人已经做过了吗?如果有一些例子,将不胜感激。