1回答
我有一个列表的列表，我期待着使用akka运行它，并希望在所有子列表完成处理后执行一个操作。但是Complete是在所有子进程完成之前运行的。基本上，我正在尝试读取excel中的所有工作表，然后读取excel中的每一行。为此，我希望使用akka来分别处理每张纸，也在每张纸上，我希望分别处理每一行。
浏览 3提问于2018-01-06得票数 0
1回答
在这个问题上，我正在寻找更多的解决方案，题为“”。
虽然不是公认的答案，但Akka自己的Viktor使用了一个，他说RESTful web服务是基于参与者的框架的一个很好的用例。但是，这似乎与Akka最基本的主要功能发生了直接冲突:Akka用于异步系统，而REST服务需要是同步的，并且通常需要在200 me内产生结果(例如，我不需要等6秒就可以简单地得到一些JSON )。所以我问:
浏览 3提问于2015-04-10得票数 1
回答已采纳
1回答
currentOffset)) buffer(data)在“经典”世界中，我可以创建一个线程从套接字中读取，另一个线程用于书写，并同时进行通信。
浏览 2提问于2015-05-05得票数 0
回答已采纳
1回答
在Akka和Akka.Net中，有处理异步内容(如I/O)的，并将消息输送回参与者的消息箱。如何在中做到这一点？
浏览 3提问于2017-11-02得票数 6
回答已采纳
2回答
我们正在考虑使用Akka-使用路由DSL。
还不清楚如何使用路由功能来响应HttpRequest；使用非类型化的Akka Actor。例如，在匹配路由路径时，我们如何将请求传递给“处理程序”ActorRef，然后“处理程序”HttpResponse以异步方式进行响应？类似的问题也被发到了Akka用户邮件列表上，但是没有后续解决方案- 。
浏览 2提问于2015-06-19得票数 5
回答已采纳
我发现我的Akka Streams程序有意想不到的CPU使用量。下面是一个简单的例子：import akka.stream.ActorMaterializer .to(Sink.ignore)上面的代码段将允
浏览 3提问于2018-10-19得票数 6
回答已采纳
1回答
目标：在中，您可以阅读以下内容：
由于当前版本的Akka (2.3.x)需要支持JDK6，所以当前提供的文件IO实现无法使用异步文件IO操作，因为这些操作是在JDK7 (和更新版本)中引入的。目前版本的akka流是'2.11‘或'2.12’。在<e
浏览 3提问于2017-08-18得票数 0
回答已采纳
如图像所示，如果client1向服务器发送了一些信息，而在另一边-- client2、client3、client4 --也打开了client1更改的相同页面，我想将这些更改显示给同一页面上的所有用户我们可以做以下工作：我正在使用Java，这能用套接字来完成吗？我的想法是，客户1的更改将通过某种通知被client2、client3、client4接收，只有这样他们才会调用服务器来获得所需的更改。
如何才能做到这一点
浏览 0提问于2012-05-12得票数 1
回答已采纳
1回答
更改akka流的源数据
、、、
source.runWith(sink, system);
}
运行此代码的行为与预期相同Akka流解决了这个代码可以重复执行的问题。
在现实世界中，sourceData不会是静态的，Akka对如何处理变化的数据有自己的看法，还是由开发人员决定？在最简单的情况下，
浏览 1提问于2021-04-10得票数 0
回答已采纳
在are应用中，我们大量使用Akka Event Stream来处理与主业务流无关的逻辑。例如:发送电子邮件、同步记录等。所有这些事件目前都被触发和遗忘了。system.eventStream.publish(<event>)
在大多数情况下，它们都是由侦听器异步处理的。然而，我现在正在研究一种通过事件系统扩展类功能的选择，有时需要事件的返回值？甚至有可能从一个事件中得到一些结果吗？在这方面我找不到任何具
浏览 0提问于2016-05-11得票数 0
我已经设置了运行在Akka.net应用程序中的ASP.net参与者，以处理一些异步和轻量级过程。我想知道当我在Azure上扩展网站时，Akka是如何扩展的。比方说，在代码中，我只有一个参与者来处理FooBar类型的消息。当我有两个例子的网站，仍然有一个演员还是现在有两个演员？
浏览 0提问于2018-02-27得票数 1
回答已采纳
我对Camel的FTP2组件有一个问题，它是生活在Akka系统中的消费者角色。import akka.actor.Props;
import akka.ca
浏览 1提问于2013-02-15得票数 2
回答已采纳
1回答
我是akka流的新手，所以想问一下如何重现本文中的行为Source(1 to 3) .map { i =>s"C: $i"); i }得到如此相似的A: 2A: 3C: 1C: 2我尝试添加一些随机的Thread.sleep但是，对于
浏览 1提问于2016-02-07得票数 0
回答已采纳
1回答
我在用可重新启动的源和接收器处理akka流中的错误。newVal + " sink") newVal }}
我是打破源和下沉分别与不同的情况我首先断开接收器，希望接收器重新启动，并一次又一次地重新处理newVal == 3消息。但是似乎接收器中的</em
浏览 8提问于2022-01-10得票数 1
回答已采纳
1回答
据说在上
异步部分使我感到困惑，因为HTTP是一个同步协议。您能解释一下HTTP不是异步的情况下喷雾是如何异步<
浏览 0提问于2014-12-07得票数 5
回答已采纳
2回答
我在IIS中使用RESTful API创建了一个服务，该服务托管在ASP.NET中。在这个服务中，我想用Akka.NET创建一个参与者系统。异步操作只能在异步处理程序或模块中启动，或者在页生命周期中的某些事件期间启动。如果在执行页时发生此异常，请确保该页标记为<%@ Page Async="true“%>。此异常还可能表示试图调用“异步空”方法，该方法在ASP.NET请求处理中
浏览 5提问于2014-12-24得票数 13
回答已采纳
2回答
}
case Get =>
}
如您所见，如果在名为sender的方法中使用Future和blocking，那么getIdList就变成了getIdList。为什么会这样呢？
浏览 3提问于2013-12-18得票数 6
回答已采纳
2回答
我正在构建一个Akka流应用程序，该应用程序经历了几个步骤。有一个特定的步骤会产生0或更多的结果，事先不知道有多少结果。每个结果都必须异步处理(由相同类型的组件处理)，最后必须合并所有结果。我应该如何在Akka流中建模？我注意到，GraphDsl有一个广播元素，可以让您模拟一个风扇，然而，这似乎是可能的，只有事先知道的网点数量。在Akka流中是否
浏览 0提问于2018-04-29得票数 3
回答已采纳
我在Play应用程序中有一个WebSocket服务器，我想将其移动到akka-http服务。我目前使用的是ActorFlow.actorRef，它是在Akka中不存在的Play的一部分。当我收到来自WebSocket的消息时，我会在本地处理一些消息，并将其他消息转发到RabbitMQ交换。
我如何使用akka-http来做同样的事情呢？我可以使用Sink.actorRef创建一个接收器并在那里<em
浏览 1提问于2016-09-20得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
云直播活动推荐
腾讯云开发者
