我需要介绍一种新的消息传递类型(PushNotification)，它包括让每个请求使用一个REST API (它还将处理数百万个请求)。我认为使用Webservice是一个阻塞操作，所以从我所读到的内容来看，我需要为这个新的Actor添加一个单独的分派器，我的问题是，它一定要像这里提到的那样是具有固定池大小的线程池执行器吗？(参见https:&
浏览 21提问于2019-06-14得票数 1
1回答
我们在应用程序中使用了Akka actors。参与者调用服务，在某些情况下，这些服务调用由第三方公开的rest API。现在第三方API需要很长时间才能响应。由于这一点，在高峰时间，系统吞吐量受到影响，因为线程在等待客户端API响应时被阻塞。
有时在高峰期，因为线程正在等待，消息只会在akka邮箱中等待很长时间，一旦阻塞的线程可用，消息就会被提取。我正在考虑<em
浏览 10提问于2020-05-22得票数 0
1回答
线程计数过多问题
、、
我有一些关于PlayFramework中线程名称的问题。我已经在游戏上开发了大约5个月的Rest-API服务。该应用程序只需访问MySQL，并将json格式的数据发送回客户端。我已经理解了“阻塞io”的缺陷，所以我创建了一个用于阻塞io的线程池，并在阻塞线程执行的所有Future块中使用它。线程池的定义如下。'application-<
浏览 3提问于2018-06-01得票数 0
1回答
我最近在做一些Akka，我想知道:我可以在Akka中做阻塞I/O而不会遇到大麻烦吗？比方说，我们有一个Actor，它执行一些阻塞I/O，因为它使用了遗产库或任何其他原因:难道我不能只对那些Actor使用特殊的分派程序，这些Actor具有合理大小的ThreadPool并执行阻塞I/O，而不阻塞所有其他Actor，因为它
浏览 0提问于2012-02-28得票数 18
回答已采纳
我对Akka和Scala比较陌生，但我想使用Akka作为一个通用框架，从各种web工具和cli命令中收集信息。
我理解Actor模型的一般原则，即在Actor模型中，最好不要让Actor阻塞。在http请求的情况下，有异步http客户端(例如Spray)，这意味着我可以在Actor框架内异步处理请求。但是，我不确定在将参与者与现有的阻塞API调用(如scala ProcessBui
浏览 2提问于2012-10-16得票数 4
回答已采纳
我的actor在默认的akka dispatcher上运行，然后它调用一个返回future的方法。我已经为所有要运行的未来配置了不同的执行上下文(因为它们是阻塞的(由于db调用)，并使参与者调度程序仅专用于非阻塞参与者)。想知道是否可以使用Akka Testkit测试这段代码(继续使用两个执行上下文等)？如果是这样的话，
浏览 0提问于2014-04-25得票数 0
1回答
负载平衡akka
、、、
我使用的是akka-http，我的build.sbt配置是：libraryDependencies += "com.typesafe.akka" %"akka-actor_2.11" % "2.4.2"
libraryDependencies += "com.typesafe.akka"
浏览 0提问于2016-03-21得票数 4
回答已采纳
1回答
我有一个配置了日志记录的应用程序，如akka文档中所述 version="2.3.0" event-handlers = ["akka.event.slf4j.Slf4jLogger"]和资源目录中的logback.xml： <
浏览 2提问于2014-04-29得票数 1
1回答
我正试图找到一种使用akka和akka创建REST的好方法。基于文档，请求/回复并不是跨角色通信的最佳解决方案。因此，我的问题是，如何使用tell实现类似于这个片段的功能？for { randomString <- (actor<
浏览 5提问于2020-12-07得票数 0
回答已采纳
找不到关于这个的任何信息。我有一个基于Akka/Spray的服务，如果我想用std scala Future编写一些异步代码，我总是使用ExecutionContext.global。在基于akka的应用中使用调度程序而不是导入全局调度程序有什么好处吗？此外，混合使用是否有任何缺点(一些部分使用akka的dispatcher，而其他部分使用scale<e
浏览 0提问于2014-04-25得票数 5
1回答
我在使用java的akka中使用了主从架构。主机接收表示他路由到从机的作业命令的消息。这些作业涉及调用非开源的第三方库，有时仅仅通过挂起和阻塞执行而不抛出任何异常就会崩溃。Akka没有意识到这是一个失败，并继续向此参与者正在使用的邮箱发送消息，但由于第一个调用无限期地阻塞，邮箱中的其余命令将永远不会执行。我的目标是用超时到期和异常来模拟这种类型<
浏览 2提问于2014-01-08得票数 1
1回答
我读到过使用Akka时的一个重要规则是避免任何阻塞的输入/输出操作、轮询、忙碌等待、睡眠等。但如果我真的需要一些流控制怎么办？我使用Akka演员向我们的客户发送邮件，并且为了对邮件服务器友好，每5秒发送一封邮件。我的计划是使用dispatcher actor执行流程控制，使用发件人actor执行邮件发送工作。class
浏览 2提问于2012-12-07得票数 0
回答已采纳
1回答
在本地一切正常，我可以通过"play run“启动服务。现在，我想将应用程序导出到prod服务器。我使用播放命令"dist"，并解压服务器上的文件。但是如果我启动这个服务，我会在几个操作上得到一个异常：
play.core.ActionInvoker$$anonfun$receive$1$$anon$1: Execution exception [$class.apply(Actor.scala:318) [com.typ
浏览 1提问于2012-12-05得票数 0
2回答
在调用rest时，我希望将参与者的路由切换到其他路由。请看下面的代码。几个问题：
package com.exampleimport akka.io.IO
import spray.htt
浏览 12提问于2014-11-21得票数 1
回答已采纳
假设我有一些通过ZeroMQ套接字进行会话的服务，并且我想向一个单页面web应用程序提供对该服务的访问。我希望web应用程序与一个提供REST API (用于控制和查询)和WebSockets (用于监控)的服务对话，它通过与第一个服务对话ZeroMQ来实现这一点。我想用Scala写这篇文章。我可以使用哪些选项来构建第二个服务？
浏览 0提问于2012-10-06得票数 1
回答已采纳
当我关闭播放服务器时，下面的代码会抛出一个java.lang.IllegalMonitorStateException异常；它是由onStop方法中的a.wait(1000)调用引起的。import play.api.GlobalSettingsimport akka.actor.{ Actor, PropsStopMessage("
浏览 1提问于2013-10-16得票数 3
谁能给我举一个使用Akka Camel集成模块的例子--使用Java API。我有一个用例，其中一个REST服务被调用，它会并行启动一些Akka Actor来处理请求，然后每个Actor都会将部分结果推送到web浏览器(Comet样式)。我看到了一个示例，但不幸的是，我不了解scala，我希望在Java中看到这一点。谢谢!
浏览 0提问于2011-09-27得票数 1
回答已采纳
1回答
我已经为应用程序将要执行的阻塞操作配置了一个dispatcher，如下所示： blocking-io-dispatcher {system-engine.blocking-io-dispatcher-7请查找以下代码：
import akka.actor.
浏览 0提问于2019-07-11得票数 0
2回答
我希望创建一个服务，其中它向特定的URL发出HTTP请求，如果它在1秒内没有得到结果，该请求将超时，然后它将使用另一个请求重试，最多重试3次。注意:在请求对服务器产生副作用的情况下，我希望不成功的请求不产生副作用。如何实现此行为？这有可能吗？
浏览 3提问于2019-01-25得票数 2
云服务器
ICP备案
云直播
对象存储
即时通信 IM
腾讯云开发者
