我正在向我的akka.net配置添加一个固定的调度器，因为我读到这将为我发送给我的参与者的调度消息提供一个及时的方式，但当我遵循akka配置时，我想到了这个 using (_actorSystemactorSystem.ActorOf(props, "TaskSchedulerAutoActionActor");
} 因为我想基于固定的调度程序运行它，但是目前我在我的终端中得到了这个错误Unhandled Exception: Akka.Co
浏览 44提问于2019-06-29得票数 1
1回答
我注意到2.1和2.0的文档略有不同：
akka.debug.receive = on
akka.actor.debug.receive = on
有一个类似于2.0的core-pool-size-max设置，但没有像2.1那样的poo
浏览 3提问于2013-05-12得票数 2
1回答
我使用的是Akka2.2-RC1，无法让Akka从application.conf加载dispatcher配置： type = PinnedDispatcher}当从代码实例化时，如根据日志，它仍然在使用akka.actor.default-dispatcher当我将.withDispatche
浏览 0提问于2013-06-13得票数 4
回答已采纳
1回答
我正在重构akka代码，在这种情况下我无法实例化参与者系统中的参与者。case "create" => addUser }虽然它不会在运行时抛出任何编译错误，但会抛出异常，因为未配置dispatcher，因此无法创建参与者，但是我可以在配置文件中看到它在这里。
HOST_NAME} //If environment
浏览 5提问于2021-08-20得票数 0
回答已采纳
我一直在尝试在visual studio 2017中支持.NetStandard 1.6的新版本的Akka.Net。由于Akka.Net配置的特点，采用HOCON格式进行配置。之前的版本在app.config或Web.config中嵌入了易于阅读的HOCON配置。另一种选择是使用接受string对象的ConfigurationFactory.ParseString方法。但是从字符串解析HOCON对于较小的配置节是很方便的。在我的例子中
浏览 0提问于2017-08-18得票数 4
我正在使用最新的play框架(2.8.12)，我试图在应用程序开始时打印akka吐露，这里是我的吐露的样子play { # The serverprovider class name loglevel= "INFO"
浏览 2提问于2022-01-09得票数 0
回答已采纳
1回答
我有一个简单的Akka HTTP应用程序，它是使用websocket的。我的请求处理程序有阻塞调用(比如JDBC)。因此，我需要使用一些固定大小的线程池来处理这些代码。但是我不知道，如何用固定线程配置自定义线程池。当我运行我的应用程序并执行线程转储时，我看到两个线程名：
Routes-akka.actor.default-dispatcher我尝试设置默认线程池，如下所示：
浏览 0提问于2019-02-11得票数 1
回答已采纳
1回答
我试图在application.conf配置文件中的2.2.x中配置自定义Akka调度程序，如下所示： fork-join-executor {, arg2)或者，最好是，我想直接在配置中完成。-7
Some mes
浏览 5提问于2013-12-30得票数 1
回答已采纳
1回答
我有一个一致的散列路由器(scala/akka)，它将特定的消息类型a分配给一组特定的每请求参与者A，并将一种消息类型b分配给一组特定的每请求参与者B...问题是:如何将一组参与者A应用到它自己的线程A中，并将一组参与者B应用到它自己的线程B中
希望actor set A不会阻止actor set B，B也不会阻止A。不幸的是，我的Akka调度器经验不足，我的多线程经验也是如此。谢谢。
浏览 4提问于2014-09-17得票数 0
1回答
但是，在从集群中删除之前，节点似乎工作了一段时间。基本上，这一个节点似乎认为它是其他人，同时也作为自己的行为。代码和配置在所有15个节点上完全相同，所以我不明白为什么只在一个节点上出现这个问题。//streaming@172.17.100.98:7000/system/cluster/core/daemon#1997515880] to Actor[akka://streaming/system'.
11:27:45.872
浏览 4提问于2014-07-01得票数 0
回答已采纳
早上好，我有一个问题，基本akka IO的TCP 我有一个客户端和服务器的基本实现，如akka文档所示： Client is https://github.com/akka/akka/blob/v2.5.20我有一个主要的测试方法，可以在第一次连接到服务器时停止： package core.september
import akka.act
浏览 12提问于2019-02-07得票数 2
Akka集成骆驼通过骆驼扩展。我们知道Akka有自己的线程池(dispatcher)。所以问题是:谁管理Akka Camel消费者/参与者线程？如果CamelContext管理线程，那么我如何在cfg文件或代码中配置线程池？
浏览 4提问于2013-02-06得票数 0
修正了akka.persistence.journal-store.sql-server.plugin-dispatcher中的双引号问题
akka.pers
浏览 2提问于2018-02-21得票数 1
回答已采纳
1回答
子项目中的Akka消息？
、、、
我觉得我对此有一个提示:我有一个有效的配置(前端打开并发送和接收消息很好)，但前端、后端和常见消息都在同一个包中。当我将它们拆分成单独的子项目(通用、前端和后端)时，代码就中断了。另外，stacktrace：
[INFO] [10/08/2014 17:00:32.385] [ClusterSystem-akka.actor.default-dispatcher-14] [Cluster-14] [akka://ClusterSystem/system&#
浏览 1提问于2014-10-09得票数 0
] [KillrWeather-akka.actor.default-dispatcher-3] [Cluster(akka://KillrWeather)] - Cluster Node [akka:] [akka://KillrWeather@127.0.0.1:2553] [akka.cluster.Cluster] [KillrWeather-akka.actor.default-dispatcher[<
浏览 31提问于2021-07-11得票数 0
回答已采纳
我一直在玩Akka的持久性，并编写了下面的程序来测试我的理解。问题是，每次运行这个程序时，我都会得到不同的结果。正确的答案是49995000，但我并不总是明白。程序简单地将所有数字从1加到n(在下面的代码中，n是9999 )。编辑:与JDK 7相比，JDK 8似乎更一致。= "2.3.7"
libraryDependencies ++= Seq(
浏览 2提问于2014-12-21得票数 7
回答已采纳
2回答
我一直在阅读文档，但我不太清楚是每个参与者都只有一个Dispatcher，还是只有一个。或者每个Actor都有自己的默认dispatcher实例？
浏览 15提问于2019-06-13得票数 3
我正在尝试使用Gradle运行Lagom服务--这似乎不是一个好主意，但我决定尝试一下，以便学习。当我在控制台中进入cd并执行gradle -t runPlayBinary时，服务就可以工作了。java.lang.NoClassDefFoundError: scala/Function1$class at play.docs.DocumentationHandl
浏览 9提问于2018-01-08得票数 0
回答已采纳
1回答
单例集群参与者没有启动。
、、、
为了提高度量的准确性，将“sigar.jar”添加到类路径中，并将特定于平台的本机libary添加到‘java.labary.path’。INFO集群节点akka.tcp://org.hyperic.sigar.Sigar transport@127.0.0.1:59592- Metrics集合已成功启动INFO galaxyFarFarAway-akka.actor.default-dispatcher-3群集节点akka.tcp://org.hyperic.si
浏览 1提问于2016-08-03得票数 4
1回答
我想限制并行运行的测试数量，因此我想限制默认分派程序中的线程数量。对于其他播放设置，可以正确读取application.conf。谢谢!-3default-akka.actor.default-dispatcher-3
default-akka.actor.default-
浏览 3提问于2013-06-19得票数 3
云服务器
ICP备案
实时音视频
云直播
对象存储
腾讯云开发者
