我可以在Visual代码中的F#文件中使用AKKA参与者,但是当我在.fs文件中使用它们时,它会报告一个错误:
error FS0039:未定义命名空间或模块'Akka‘。
即使我在我的项目中下载了带有dotnet add Project package Akka和dotnet add Project package Akka.FSharp --version 1.4.10的AKKA包,并将它们包括在.fs文件中:
module P
open System
open Akka
open Akka.Actor
open Akka.FSharp
我想要开始使用演员的沉重费率信息。actor的最后一个状态非常重要--我遵循这里显示的持久性示例 --我尝试发送大量消息
for (i <-0 to 100000){
persistentActor ! Cmd("foo"+i)
}
然后像这样使用persistAsync
val receiveCommand: Receive = {
case Cmd(data) =>
persistAsync(Evt(s"${data}-${numEvents}"))(updateState)
case "snap"
比方说我使用akka persistance,我支持像Users这样的东西。 如果存在需要扫描所有用户和任何已过期用户的夜间作业,请将其对象标记为已过期。 在使用sql的更传统的设置中,您只需执行以下操作: update u
set u.is_expired=1
from users u
where u.expired_at >= getdate() 现在,如果你这样做,你的akka坚持将是不同步的,你将不得不以某种方式广播到所有演员重新加载。 否则,您将不得不向所有演员发送广播,以检查您是否已过期。 如果你有数百万用户,你有什么现实的选择?如果这是一个数据库存储过程,这种类型的查
我是AKKA世界的新手
我从上面的帖子中得到了如何使用Akka-HTTP在RESTAPI响应中发送文件的解决方案,但我想为该文件提供一个名称和扩展名。那么,用文件名和扩展名将文件作为响应发送的方法是什么呢?这意味着我希望下载的文件在Akka-HTTP with scala中应该有一个带有.zip扩展名的名称
我一直在尝试实现简单的示例。
我在Server中创建了所需的表,如GitHub存储库和HOCON配置中所述。应用程序运行时没有出现错误,但没有持久存在。我确实看到了一个早期的讨论,其中其他人也有同样的问题,解决方案应该是调用SqlServerPersistence.Init()函数,并注意到这很快就不再需要了。事实上,这种方法已经不复存在了。
class Program
{
private static void Main(string[] args)
{
try
{
using (var actorSystem = Ac