我目前正在与akka合作一个新项目。但现在我遇到了一个问题。 我在我的项目中添加了一个mongo db，并设置了日志和快照存储。我可以持久化事件，这些事件将存储在数据库中。这很好用。 ? 但是当我重新启动应用程序，执行元开始恢复事件时，执行元只恢复第一个事件。似乎恢复的SequenceNr上限设置为1，但我已经检查过了。在恢复第一个事件之后，参与者收到消息RecoveryCompleted，恢复过程就结束了。(
浏览 83提问于2021-07-06得票数 1
我一直在阅读和研究Akka.NET，我觉得它非常适合我将要开发的一个非常基本的在线多人游戏。我对Akka.NET中的Persistence模块特别感兴趣，我想要做的是在任何时间点对我的整个Actor系统进行快照，并在我选择的时间恢复快照(本质上是游戏状态的保存/加载机制)。Actor持久性的保存和加载似乎是自动发生的，而我希望手动快照系统的当前状态，并在我选择的时间进行恢复。
使用Akka.NET持久化可以实现这种情况吗？
浏览 9提问于2017-10-25得票数 0
我正在使用Akka.net构建一个解决方案，该解决方案将允许查询多个标记的持久性查询。我认为这样做的方法之一是简单地为每个标记物化一个流，然后使用akka.net流抽象将流与顺序合并。我想知道，这是因为akka.net leaves会阅读日志实现到单个插件，还是排序和akka.net流本身就有问题呢？如果我使用基于SQL的事件存储，它看起来就像基本的抽象QueryExecutor允许创建一个有序流： $@&qu
浏览 2提问于2022-07-24得票数 0
回答已采纳
1回答
我正在用Akka.Net实现CQRS/ES解决方案，用Server实现Akka.Net.Persistence。到目前为止，使用默认的sql-server插件似乎一切都很好。最后要验证的是能够从特定的AR重新加载/重播事件，例如重建读取模型或为读取模型填充新实现的投影。我这样做的方法是读取DB中的事件，并将它们放在事件总线上，或者直接放到“投影参与者”的邮箱中。我似乎找不到任何手动重新加载事件的例子，除了自己查询Journal表(执行sql查询)和使
浏览 1提问于2016-02-16得票数 0
回答已采纳
我在这方面经常使用Akka.Net，但无法通过UAP中的Nuget加载它。我得到一个无法安装的错误，因为它说Akka.Net不包含WindowsVerison8.1的程序集引用。还是我一直在等待Akka.Net添加Windows8.1构建目标？
谢谢!
浏览 4提问于2015-06-03得票数 3
回答已采纳
.);
我不习惯于膨胀我的消息类/结构，以及具有显式依赖于Akka.net IActorRef类型的API接口(可能会切换到其他实现，如幕后的Proto.Actor )。
浏览 0提问于2018-06-06得票数 0
1回答
作为将我们的应用程序从巨大的单体转变为麦克风的一部分，我们正在开发一个通知微服务，它可以被所有其他模块用来发送通知，比如电子邮件、短信、推送通知等等。此通知服务的一个客户端是我们计划开发的windows服务，它为用户注册、密码重置等各种事件触发电子邮件通知。windows服务将包含两个部分。一个基于REST的API，可以由诸如用户注册之类的模块调用来触发通知。当调用ReST API时，该服务将加载适当的模板，填写必要的值，并调用通知服务发送电子邮件。水流会是这样的
Client -> ReST AP
浏览 1提问于2016-12-27得票数 1
回答已采纳
1回答
我是Akka.NET的新手(和一般的演员)，我有一些关于事件来源和Akka.NET中的CQRS的问题 { });}});
然后，我只需订阅该消息，并将其传输到一个负责将消息存储在数据库中的参
浏览 1提问于2021-03-07得票数 0
回答已采纳
1回答
嘿，我在AKKA.Net上做一些阅读和看一些视频，我很喜欢我看到的东西。我想在我现有的应用程序中尝试使用AKKA.net，但是我需要帮助澄清一些事情我想用以下内容创建一个Akka.net集群：
它们之间共享的资源(计数器)。如果一个节点与集群断开连接，是否引发了一个我可以捕捉到的事件，以进行必要的调整？
浏览 0提问于2016-01-04得票数 2
回答已采纳
像AKKA.net这样的参与者模型给表带来了许多好处，比如可伸缩性、响应性、内存缓存等.当我试图将AKKA与进行比较时，除了内存中缓存的好处之外，我在Azure中也看到了几乎相同的主要好处。
浏览 5提问于2015-05-20得票数 5
回答已采纳
我正在尝试创建一个由多个节点组成的网络的模拟，以分析网络流量。节点本身将使用Akka.Net实现，并且应该能够使用一些Akka.Net集群功能。在单个参与者系统中，是否仍然可以使用集群模块及其功能，如角色、分布式广播、成员上/下事件等？
有没有可能伪造远程部署它们，并创建一个伪造的传输，简单地将所有流量路由回相同的参与者系统？
浏览 27提问于2017-12-21得票数 0
我已经阅读了Akka.NET的在线文档。 我看到持久性插件可以使用事件源模式来存储参与者的状态。 但是我没有在邮箱中找到任何关于邮件的具体信息。当一个进程死亡或重新启动时，参与者的邮箱会恢复消息吗？
浏览 32提问于2019-05-22得票数 2
回答已采纳
我有一个持续接收演员和监督策略，以重新启动该演员在任何例外情况下。我使用的是来自akka.net持久性的快照和事件日志，重新启动后一切都如预期的那样工作。在akka.net文档中，我找到了类恢复，所以我猜我可以这样做
var recovery =新恢复(fromSnapshot: SnapshotSelectionCriteria.None，toSequenceNr
浏览 0提问于2021-01-19得票数 0
我在oracle persistence中使用Akka.net。 现在我需要从我的聚合事件创建一个投影，我需要事件发生的时间戳。 不幸的是，我没有将此属性添加到事件中。但是，查看持久性使用的EventJournal表时，有一个时间戳列 ?
浏览 24提问于2020-12-08得票数 2
回答已采纳
1回答
我有在MongoDB中结构化为事件的源数据，我们正在雪花中构建一个数据仓库。每种类型的事件都与DW中的操作相关，例如行插入或更新等。
如何连续地将数据从MongoDB加载到雪花中？
浏览 1提问于2022-03-14得票数 1
回答已采纳
1回答
Akka.NET和MVVM
、、、、
在我目前正在开发的一个新的WPF Akka.NET框架应用程序中，我正在使用.NET。具体来说，关于如何处理参与者中的接收和处理事件，有两个选项。的另一种选择似乎实际上是让我的ViewModels本身成为演员。当我尝试这样做时遇到的问题是正确地配置我的Ioc (Castle )以正确构建Akka.NET实例
浏览 3提问于2019-11-24得票数 2
有没有办法在Akka.net中删除某个序列号之后的消息？我知道DeleteMessages(seqNumber)会删除某个序列号之前的所有消息，有没有在seqNumber之后删除的方法？显然可以手动编辑数据库(或者将这些事件的is_deleted设置为true )，但我不确定这是不是一个好主意。
谢谢
浏览 1提问于2018-04-12得票数 1
1回答
根据Akka.Net文档，不推荐使用PersistentView，而应该使用PersistenceQuery。在ASP.Net Core2.0Web-API应用程序中，我使用的是Akka.Net和事件源。我使用Server插件进行持久化，使用事件和快照。当应用程序启动时，事件会被回放以恢复参与者的状态。
我已经实现了一个日志阅读器，即接收事件，并使用它来组成一个视图。问题是，我如何知道最后一次回放事件已经到来，以便可以保存组合视图(作
浏览 5提问于2018-03-05得票数 0
我们正在使用AKKA.Net进行多个进程之间的通信。
我们使用的AKKA.Net版本是最新的: 1.0.7。使用AKKE.Net的进程大约有20个。这些进程是windows服务。我们为AppDomain.CurrentDomain.UnhandledException添加了一个事件处理程序，这样我们就有机会记录一些关键的异常。我们检查日志，它似乎是由AKKA.Net的异常导致的。
浏览 4提问于2016-04-21得票数 1
云服务器
ICP备案
实时音视频
对象存储
云直播
腾讯云开发者
