问题标签 [akka.net]

在使用Akka.Persistence.Cassandra插件时，我无法确定是否有办法在 Akka.net 中设置 cassandra-snapshot-store 和 cassandra-journal 表的键空间。

在我当前的设置中，我在 Cassandra 中有两个单独的键空间（每个客户端一个），我希望将它们的数据和消息历史记录分开。

据我了解，这些表是在插件的 CassandraJournal 和 CassandraSnapshotStore 类的 PreStart() 方法期间创建的。

我不介意在加载 PreStart() 方法时使用虚拟键空间，但我希望能够在系统启动并运行后更改键空间。

任何有关此事的帮助将不胜感激。谢谢！

在我的 Akka.Net 集群中，我有几个节点。当我成功加入集群时，我想发起通信。我可以在日志中看到欢迎加入集群：

但我看不到为此引发的任何我可以订阅的事件。

我有一个 restful API，它使用 odata 请求来查询数据库前面的数据。我希望开始用 akka.net 交换域逻辑，但我不想更改客户端。有什么方法可以将询问模式挂钩以使用 IQueryable？

我已经制作了 2 个 Akka.NET 解决方案，希望在一个简单的 hello world 示例上测试 Remoting，但是，当进行通信尝试时，我不断收到 Disassociated 异常。我有理由相信这是因为共享类 Greet 应该是两个系统都应该理解的消息。不幸的是，他们没有。我怎样才能解决这个问题？

这是“服务器”应用程序的代码：

这是客户端的代码：

编辑：将客户端和服务器放在相同的解决方案但不同的项目中，并且在共享项目中的 GreetingActor 和 Greet 解决了这些问题。但是，我希望有完全独立的解决方案。

我是 F# 和 Akka.Net 的新手，并试图通过它们实现以下目标：

我想创建一个接收文件位置的actor（Tail），然后使用 FileSystemWatcher 和一些 Observables 在该位置监听事件，将它们作为消息转发给其他一些actor进行处理。

我遇到的问题是侦听事件的代码一次只拾取一个事件而忽略所有其他事件。例如，如果我将 20 个文件复制到正在监视的目录中，它似乎只会发送其中 1 个的事件。

这是我的演员代码：

这是监听事件的代码：

到这一步花了很多技巧，任何关于我如何更改它的建议，以便它在演员运行时拾取并处理所有事件，将不胜感激。

我想以与 Hystrix 或 Akka.net 相同的方式将对依赖项的调用包装在断路器/超时/重试中，但是因为我正在天蓝色中构建云服务和工作角色，所以我想知道是否有一个天蓝色的实现，可以让我们做到这一点。

有没有本地的天蓝色方法可以做到这一点？我正在查看服务结构，但我不确定它是否这样做，我们希望在 azure 平台上实现我们的服务，而不是在 azure 基础架构上。

我想将 Akka.net 添加到我的 Windows 10 应用程序中，但是在尝试安装 1.0.5 版的 nuget 包时得到了这个

Akka 1.0.5 与 UAP 不兼容，Version=v10.0。某些软件包与 UAP 不兼容，Version=v10.0。

这是我只需要等待的支持，还是我可以做些什么来解决？

我正在查看 Akka.net faulttolerance 并设置了一个简单的示例，其中 Actor1 告诉 Actor2 一条消息。Actor2 抛出异常。Actor1 有一个 SuperVisorStrategy 告诉失败的actor恢复。

我实际上预计该消息会再次传递给 Actor2。但事实并非如此。所以 Actor2 恢复并可以继续处理新消息。但是现在导致 Actor 失败的消息已经消失了。这应该如何处理？我不想丢失导致异常的消息。我希望 Actor2 再次处理该消息。

我正在尝试使用 Mongodb 实现 Akka Persistence，但我收到一条错误消息

这是我的配置：

我想我已经正确地创建了一个演员系统：

https://gist.github.com/amarwadi/a887b26e14b0d42191b7

并且正在向 Persistent Actor 发送消息，并且我不断收到以下消息

嘿，我正在 AKKA.Net 上阅读和观看一些视频，我很喜欢我所看到的。我想在现有的应用程序中尝试 AKKA.net，但我需要帮助澄清一些事情

场景
我想创建一个 Akka.net 集群：

• 3 个节点/机器

• 它们之间的共享资源（计数器）。

• 可从所有节点读取的共享资源统计信息

  每当一个节点兑现一张票时，它将获取计数器的值并将其加一，然后更新计数器。两张票不应具有相同的计数器值。共享的统计信息用于保存票证兑现的价值，因此应将其部署到集群中的所有节点。

问题

1. 如何确保票据具有唯一的计数器值？我习惯了锁的暗示，但演员的暗示是什么？
2. 如果一个节点与集群断开连接，我可以捕捉到一个事件以进行必要的调整吗？