1回答
, Ack(currentOffset)) buffer(data)在“经典”世界中，我可以创建一个线程从套接字中读取，另一个线程用于书写，并同时进行通信。
浏览 2提问于2015-05-05得票数 0
回答已采纳
我正在尝试实现一个Akka角色，它接收一条消息，然后等待接收另一条消息而不循环。我尝试以这种方式实现它的原因是因为我需要在第二个case语句中的第一个case语句中接收到的对象。下面是我的意思的一个例子。receive { println(f"Received ${s} and ${e}")
}
浏览 14提问于2019-12-17得票数 0
回答已采纳
1回答
我在我的项目中使用Akka.NET。
我想知道，我是否有任何保证，将收到的信息将按照相同的顺序，他们被发送给自我演员？
浏览 1提问于2018-01-09得票数 1
回答已采纳
我正在使用Akka HTTP，并有一个AnswerActor，我想做以下事情。M1)和另一个actor向AnswerActor发送消息M2，但没有回复，只有当我在下面(Case M1)中添加一些回复时才能工作 case message: M1 => requestMap.put(something 上面的逻辑可以用akka实现吗？
浏览 26提问于2021-04-19得票数 0
回答已采纳
3回答
我有一个小型的Akka应用程序，它在其参与者之间传递许多消息，每个参与者都对接收到的数据进行一些计算。我想要的是分析这个应用程序，以便查看代码的哪些部分占用了大部分时间，等等。我添加了分析器输出的图片。
Akka应用程序，因
浏览 6提问于2013-07-22得票数 25
回答已采纳
Scala Actor :在同一流程中从一个actor传递到另一个actor的消息是否总是按照发送时的原始顺序进行处理？
浏览 0提问于2015-12-20得票数 0
全
是否可以将akka.net参与者收件箱消息存储在数据库中？如果主机与akka.net系统崩溃会发生什么？
浏览 0提问于2015-12-04得票数 3
回答已采纳
1回答
假设我想在akka中实现ProgrammableRemote - 1. Tv !但是，这将导致1.1在与参与者的接收线程不同的线程上运行。如果我使用'pipeTo self'，我将需要在'PowerOn‘方法中处理来自电视的’接收完成‘消息的大小写。理想情况</e
浏览 0提问于2012-10-21得票数 4
1回答
Akka文档说邮箱不会扫描邮件。每个消息按到达顺序依次处理(默认情况下为FIFO)。但是，当我将一条消息从一个参与者发送到另一个与接收者不匹配的消息时，它既不会被移动到死信参与者(我想它会出现在日志中)，也不会阻止处理邮箱中的下一条消息，该邮件在一秒钟后到达，并且可以正确处理。来自邮箱的无与伦比的消息会发生什么
浏览 5提问于2016-05-16得票数 5
回答已采纳
使用遗留代码，在扩展到BaseActor的类中，有两个类似流程消息的入口点： private Receive active = receiveBuilder().matchAny((message)instanceof String){ } else if(...) { //some code} } else if(...) {
浏览 32提问于2020-09-22得票数 2
我有兴趣实现: 1.向事件流发送消息的akka参与者A；2.侦听已在事件流上发布的某种类型的消息的akka参与者L。我知道如何做2。我知道如何使A向另一个参与者(Ref)发送消息，但我不想将消息发送给任何特定的参与者(Ref)
浏览 0提问于2018-03-17得票数 0
回答已采纳
我有一个参与者，它聚合任意数量的子参与者消息。各次演员之间的联系顺序如下：这给了我一个想法，使用死信计数作为我的关闭例程触发后X字母和一些硬编码睡眠。鉴于下面的日志，Akka似乎没有在一个点之后进行聚合：
[...] was not delivered. [10] dead letters encoun
浏览 3提问于2019-07-08得票数 0
回答已采纳
如果远程参与者死亡，父参与者会得到通知，但是附加到远程参与者的邮箱会发生什么情况？如果没有办法检索，那么我们怎么能说akka是容错的呢？
浏览 2提问于2016-05-12得票数 0
回答已采纳
我曾尝试阅读Akka文档，以找出类型化和非类型化参与者之间的确切区别。什么时候使用什么？我不确定我错过了什么。有人能给我指出一些相关的东西，或者在这里给出这个问题的答案吗？
浏览 0提问于2011-11-15得票数 27
回答已采纳
一开始我只想说我是阿克卡和期货公司的新手。所以，要温柔:)。
在返回ListenableFuture<Boolean>的类中有init方法。该方法应该在单独的线程中执行一些耗时的代码，并创建akka参与者，它正在侦听akka集群中的一些消息。init方法返回的未来应该在此参与者接收到特定消息并完成耗
浏览 4提问于2017-09-23得票数 0
回答已采纳
2回答
我希望创建一个最小的参与者示例，该示例向参与者发送消息，然后等待该参与者的响应。这个例子的原因是我想在我的论文中使用它来讨论其他语言特性(如期货)的用法，而不是纯粹的参与者。到目前为止，我所掌握的情况如下：import akka.actor.ActorSystem
import
浏览 4提问于2015-05-02得票数 0
回答已采纳
1回答
如何处理要以特定顺序执行和完成的参与者之间的消息？
换句话说，如果Message A希望总是在Message B之前被接收，那么如何使用akka呢？
浏览 2提问于2013-12-19得票数 1
回答已采纳
1回答
我有一个问题，它要求我的参与者按照消息发送的顺序处理消息。在Akka中，参与者A和参与者B之间的消息总是保证按照发送的顺序到达。这似乎不是服务结构中的可靠参与者的情况。在我的测试用例中，消息是以不确定的顺序接收</
浏览 2提问于2015-12-08得票数 0
我正在使用Java+Akka创建一个演员系统。特别是，我通过提供onReceive()方法的实现来定义非类型化的参与者。public void onReceive(Object msg) throws Exception { elseif
浏览 3提问于2013-08-27得票数 1
回答已采纳
云服务器
ICP备案
云直播
对象存储
实时音视频
腾讯云开发者
