Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
使用 Akka 1.3 的 actor 时,我需要注意生产者-消费者速率匹配吗?
使用 Akka 1 3 时 我是否需要担心当生成消息的 Actor 生成消息的速度比使用消息的 Actor 的处理速度快时会发生什么 如果没有任何机制 在长时间运行的进程中 队列大小将增大以消耗所有可用内存 The doc http doc
scala
concurrency
akka
Actor
Akka Scheduler() 每次重复都会迟到
我有一个简单的调度程序 用于每 1 秒重复一次任务 Cancellable task Akka system scheduler schedule Duration create 0 TimeUnit MILLISECONDS Durati
Java
playframework20
akka
scheduler
Akka 与现有 java 项目集成的示例
如果我已经有现有的javaWeb 应用程序使用spring and servlet容器 将 Akka 集成到其中的正确方法是什么 就像我将会有Actor1 and Actor2互相沟通的 开始使用这些演员的切入点是什么 例如 1 把它放在那
Java
Integration
akka
Akka :: 调度程序 [%name%] 未配置,使用默认调度程序
我创建了以下 application conf akka actor prio dispatcher type Dispatcher mailbox type my package PrioritizedMailbox 当转储配置时 act
configuration
akka
Dispatcher
如何在超时的情况下在单独的调度程序上运行 Akka Streams 图?
这个问题是基于我做过的一个宠物项目 这个SO https stackoverflow com questions 34641861 akka http blocking in a future blocks the server 34645
scala
akka
akkastream
akkahttp
如何在 IntelliJ IDEA 中运行 akka actor
来自 Akka 网站文档 然后 这个主要方法将创建所需的基础设施 运行演员 启动给定的主要演员并安排 一旦主要参与者终止 整个应用程序就会关闭 因此 您将能够使用类似于以下的命令运行上面的代码 下列的 java classpath akka
Java
intellijidea
akka
Akka Stream Graph 恢复问题
我创建了一个图表来并行化具有相同输入的两个流 这些流产生 Future Option Entity 如果 flowA 失败 我想返回 Future None 但恢复似乎没有被调用 val graph Flow Input Future Op
scala
akka
akkastream
在 Akka 中配置嵌套 Router
我有一些嵌套的路由器 应创建它FromConfig 我想要的是这样的 test akka actor deployment worker router round robin nr of instances 5 slave router b
scala
routes
config
akka
案例类和案例对象之间的区别?
我正在学习 Scala 和 Akka 并且在最近的查找中solution https stackoverflow com questions 22770927 waiting for multiple results in akka 我发现
scala
akka
知道 akka actor 何时完成
有几个人和我一起从事一个项目 一直在试图找出解决这个问题的最佳方法 看起来这应该是经常需要的标准东西 但由于某种原因我们似乎无法得到正确的答案 如果我有一些工作要做 并且我向路由器抛出一堆消息 我如何知道所有工作何时完成 例如 如果我们正在
Java
akka
玩 Scala Akka WebSockets 更改 actor 路径
我遵循使用 Scala Play 和 Akka Actor 创建 Web 套接字的示例 https www playframework com documentation 2 5 x ScalaWebSockets Handling Web
scala
playframework
WebSocket
akka
如何解析 Spray-routing 中的 get 请求参数?
这就是代码部分的样子 get respondWithMediaType MediaTypes application json entity as HttpRequest obj gt complete println obj ok 我可以
scala
HttpRequest
akka
spray
如何使 scalatest 与 Spraytestkit 和 HttpServiceActor 一起工作
我在看Spray 1 3 1 测试套件文档 http spray io documentation 1 2 1 spray testkit 但找不到下面我需要的正确示例 我有这个样本spray 1 3 1 service trait MyS
scala
akka
spray
Akka 和 ReactiveMongo
我正在尝试找到在集群工作人员之间共享相同连接池的最佳方法 我有以下结构 Master Actor gt Worker Actors 最多 100 个或更多 gt MongoDB 我想在工作人员和 MongoDB 之间放置reactivemo
MongoDB
scala
akka
Actor
reactivemongo
Akka Testkit 错误且版本不明确
我正在使用 Akka testkit 库来测试我的一些演员 这是我的 build sbt 中的内容 com typesafe akka akka testkit 2 6 10 Test 这是我得到的错误 java lang IllegalS
sbt
akka
如何将 sbteclipse 插件添加到 SBT 0.10.x
我想查看akka的源代码 似乎使用的是0 7 x版本的sbt 我将项目配置转换为0 10 x版本 当我在库依赖项中添加 sbteclipse 并运行 eclipse create src 生成 eclipse 项目时 它告诉 eclipse
eclipse
scala
sbt
akka
Akka、SQS 和 Camel 的消费者投票率
我正在做的一个项目需要从SQS读取消息 我决定使用Akka来分布式处理这些消息 由于 Camel 支持 SQS 并且在 Consumer 类中内置了 Akka 中使用的功能 因此我认为最好以这种方式实现端点并读取消息 尽管我还没有看到很多人
scala
apachecamel
akka
amazonsqs
为什么我的 akka 日志记录不能在游戏中运行
我的日志记录在我的播放代码中工作正常 但我的 akka 代码没有记录到文件 标准输出 class EmailActor extends Actor with ActorLogging import EmailActor log info e
scala
playframework
akka
如何隐藏 Akka 远程 Actor 来查找?
我正在运行 Akka 2 0 2 微内核 并希望为不受信任的远程参与者实现身份验证方案 首先想到的是设置一个身份验证参与者 当身份验证成功时 该参与者会返回对工作参与者的引用 但是 我应该如何保护工作参与者不被简单地通过 actorFor
scala
authentication
remoting
Actor
akka
使用 Akka java API 时 Kotlin 类型推断编译错误
我想在 Kotlin 程序中使用 Akka java API 当我想设置时onCompleteakka 的回调Future 我遇到了 Kotlin 编译器错误 而 java 等效项工作得很好 val future Future
Java
akka
typeinference
kotlin
1
2
3
4
5
6
...10
»