0回答
我正在尝试将来自actorA的所有消息转发到actorB。在actorA的接收方法中，def receive = {}
但actorB似乎没有收到来自actorA的任何消息。
浏览 0提问于2017-06-13得票数 1
回答已采纳
我是AKKA的新手，并试图扩展akka-java-spring示例代码，以添加另一个参与者，并有一个不可变的对象计数器作为消息发送给CoutingActor，后者打印一条消息并将其转发给PrintMessageActor如何从PrintMessageActor向CoutingActor转发消息。如何在本例中使用文档中的以下片段。target.forward(result, getContext());
如何在第一个演
浏览 0提问于2013-08-19得票数 1
回答已采纳
我在Play应用程序中有一个WebSocket服务器，我想将其移动到akka-http服务。我目前使用的是ActorFlow.actorRef，它是在Akka中不存在的Play的一部分。当WebSocket被接受时，我订阅一个RabbitMQ队列，并将每条消息转发给WebSocket。当我收到来自WebSocket的消息时，我会在本地处理一些消息，并将其他消息转发到RabbitMQ交换。
我如何使用akka-http
浏览 1提问于2016-09-20得票数 0
1回答
在Akka和Akka.Net中，有处理异步内容(如I/O)的，并将消息输送回参与者的消息箱。如何在中做到这一点？
浏览 3提问于2017-11-02得票数 6
回答已采纳
1回答
, Ack(currentOffset)) buffer(data)在“经典”世界中，我可以创建一个线程从套接字中读取，另一个线程用于书写，并同时进行通信。
浏览 2提问于2015-05-05得票数 0
回答已采纳
我有一个简单的转发演员 def receive = {我的问题是:如何向转发器参与者发送消息？也许我不明白Akka Remote在这种情况下是如何使用的。-0@192.168.192.7:52369] /**
* A default ActorSystem creator.start an Actor
浏览 5提问于2017-01-29得票数 1
2回答
我是scala的新手，我正在尝试用scala编写一个程序，它可以创建多个(比方说，30个)参与者，并在它们之间传递消息。Broadcast this msg to all actors" }该程序的目标是创建多个参与者，并将字符串从一个参与者转发到另一个参与者。Main应该只向上面创建的参与者中的一个发送消息。从Main接收消息的actor应该将相同的消息转发给另一个已经创建/启动的actor。
这个
浏览 1提问于2012-09-29得票数 1
我有一个演员，他的唯一职责是转发从外部接口(命令行、用户等)接收的消息。合适的话题。我想测试它是否正确地发布了这些消息。我需要创建一些虚拟订阅者，他们将期望消息发布到某个主题，并对接收到的消息进行断言。{ActorSystem, Props}import akka.cluster.pubsub.DistributedPubSubimport akka.t
浏览 3提问于2016-12-27得票数 0
回答已采纳
基本上，我有一个akka集群，在节点和参与者之间进行负载平衡(使用akka路由器)，到目前为止，它工作得很好。因此，我需要在一个play实例中接收一个websocket连接，但我希望使用路由器(akka actor)将其转发到另一个play实例。这一点很重要，因为有了它，我就达到了负载平衡的要求。JsValue, JsValue] { request =>}
问题是这会立即返
浏览 1提问于2017-05-11得票数 0
1回答
在我看来，要使Akka框架对云友好，这是一件直观的事情。我感兴趣的是，是否有人有这样做的经验，或者未来是否有计划让Akka框架开始利用云提供的功能，或者Akka是否会继续保持云不可知论。
浏览 2提问于2018-03-25得票数 0
回答已采纳
1回答
{ case _ => Ok("error")这将在myActor的接收方法中触发更多的参与者消息传递:当anotherActor响应myActor时，后者将消息AllGood发送给其父节点。HelloBack}
在myActor试图向context.parent发送消息之前，一切都很正常。我在控制台中得到一条deadLetters消
浏览 1提问于2013-11-14得票数 2
回答已采纳
我打算用Akka流来建模一个简单的游戏(HTTPReq/HTTPResp)。在一轮中，玩家被要求由服务器猜测一个数字。典型的流是这样的：
import akka.{Done, NotUsed}import jav
浏览 0提问于2018-08-08得票数 1
回答已采纳
我是Akka.NET的新手，我正在构建某种websockets，我想使用Akka.NET来处理(转换和转发)传入的流量，使用它的参与者系统。但我想知道怎样才是最好的办法。我是否应该与“发送”websocket客户端一起创建转发和转换逻辑？或者我应该把我的客户放在演员之外，并把它放在Akka.NET消息中？
浏览 1提问于2017-10-10得票数 2
回答已采纳
2回答
在Akka，如何模拟网络延迟？
、、、、
我目前正在使用Akka (我们正在从经典到类型化)来实现Raft集群，使用Java版本。我们的任务要求集群--就像文件实现一样--在恶劣的网络条件下运行，因此我想实现Akka端一种系统延迟消息的方法。时间和选择性并不重要--例如，假设我们想将所有通过系统的消息延迟200 by。我的想法是使用路由器-- --但是我想知道什么是最好的方法来编写既可伸缩又不添加不可预测的bug的东西(比如使用Thread.sleep()可以延迟消息队列处理)
编辑: raft集群是托管在一台机器上的，所以现在传输基本上是瞬时
浏览 11提问于2022-01-15得票数 0
回答已采纳
我正在创建一些参与者，它应该用自己的消息包装所有传入的消息，并进一步转发它们。不幸的是，我没有任何用于用户消息的公共基类，所以我将使用Object.class来捕获它们
现在我不确定Akka是否能给我的演员发送自己的信息。我不想偶尔转发一些发送给我的包装器的系统消息。
浏览 5提问于2017-07-17得票数 0
回答已采纳
1回答
aktor path = akka://SchedulerAutoAction/user/TaskScheduleraktor
[INFO][7/1/2019 5:22:32 AM][Thread 0007][akka://SchedulerAutoAction/user/TaskScheduleraktor/$a] Message Messages from akka://SchedulerAutoAction
浏览 0提问于2019-07-01得票数 0
1回答
我正在开发一个使用Akka Kafka连接器的Kafka消费者应用程序。我希望消费者并行处理消息。我应该选择哪个消费群体？？如何在消费者端配置并行度？
浏览 16提问于2020-05-06得票数 0
1回答
负载平衡akka
、、、
我使用的是akka-http，我的build.sbt配置是：libraryDependencies += "com.typesafe.akka" %"akka-actor_2.11" % "2.4.2"
libraryDependencies += "com.typesafe.akka" % "akka-http-experimental_2.1
浏览 0提问于2016-03-21得票数 4
回答已采纳
3回答
(或zeroMQ中的模式)
、、、、
我希望Linux(服务器)主机上的一个应用程序与VM中的Win7(客户端)上的应用程序进行通信。Lib的首选是ZeroMQ。但是如何管理异步任务呢？让我举一个例子: VM中的应用程序以任意间隔生成任务，并将它们发送到Linux盒。这将处理它们，但需要一些时间来回答。此时，REQ/REP模式中的套接字被阻塞，来自WinApp的传入任务不能转发给LinuxApp。我该怎么解决这个问题？这通常是如何解决的，即使没有0MQ。(一些隧道)
-> (每个客户端-工作线程对之间的REQ/REQ在一个套接字上
浏览 5提问于2012-11-06得票数 3
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
腾讯会议
云直播
对象存储活动推荐
腾讯云开发者
