Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
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
Akka HTTP 连接池在几个小时后挂起
我有一个 HTTP 连接池 在运行几个小时后挂起 private def createHttpPool host String SourceQueue HttpRequest Promise HttpResponse val pool Ht
scala
akka
akkahttp
如何处理 Akka 子 actor 的长时间初始化?
我有一个演员 它创建一个子演员来执行一些冗长的计算 问题是子 Actor 的初始化需要几秒钟 并且父 Actor 在子 Actor 创建和完全初始化之间发送给子 Actor 的所有消息都将被丢弃 这是我正在使用的代码的逻辑 class Ch
scala
akka
Actor
为什么参与者“询问”模式被视为反模式或“代码味道”?
据我所知 询问 模式被认为是一种不好的做法 应该避免 相反 推荐的模式是 每个请求的参与者 模型 然而 这对我来说没有意义 因为 询问 模式正是这样做的 它为每个请求创建一个轻量级参与者 那么为什么这被认为是不好的 特别是当 future
scala
akka
Actor
Akka 通过可堆叠行为拦截接收
Akka 和 Scala 新手 请根据需要随意编辑问题 以便清楚地表达我在 Scala 和 Akka 领域的意图 在展示代码片段之前 这是我想要解决的问题 我本质上想开发一个通用模块 供我的团队在使用 Akka Actor 开发应用程序时使
scala
akka
slf4j
Interceptor
MDC
Akka Actor 询问和类型安全
我如何使用 Akka Actor Ask 并维护类型安全 或者避免使用 询问 而使用 告诉 打电话时 or ask在 Akka Actor 上 Future Any 返回 我必须通过进行显式转换future mapTo MyType 我不喜
scala
Asynchronous
akka
Actor
Future
我应该使用 akka.http.scaladsl.util.FastFuture 而不是 scala.concurrent.Future 吗?
我应该使用 akka http scaladsl util FastFuture 而不是 scala concurrent Future 吗 评论说 Provides alternative implementations of the b
scala
concurrency
akka
reactiveprogramming
akkahttp
Java反应式框架的比较[关闭]
Closed 这个问题是基于意见的 help closed questions 目前不接受答案 我看到许多框架 库声称它们可以帮助用 Java 构建响应式应用程序 例如 Akka Vert x RxJava Reactor QBit 等 他
Java
akka
reactiveprogramming
RXJava
projectreactor
akka 远程处理中出现“最大允许大小 128000 字节,编码类 scala 的实际大小”错误
我想使用 Akka Remoting 在参与者之间通过网络交换消息 但是对于大型字符串消息 我收到以下错误 akka remote OversizedPayloadException Discarding oversized payload
serialization
akka
akkacluster
akkaremoting
Akka 流如何不断实现?
我在用阿卡流 http doc akka io docs akka stream and http experimental 1 0 scala stream index html在 Scala 中进行轮询AWS SQS https aws
scala
akka
amazonsqs
awssdk
akkastream
Actor 中的 WebSocket.acceptWithActor 和 @Inject()(播放 2.5)
WebSocket acceptWithActor不使用 Guice 实例化一个新的 Akka actor 在 Play 2 4 中 仍然可以通过导入来为我的 actor 使用注入器play api Play current 片段来自Rea
dependencyinjection
playframework
akka
guice
playframework25
如何确定 akka 中生成的 actor 数量?
我最近开始研究 Akka 2 0 框架 并且能够运行一些代码 生成执行简单 Oracle 数据库调用 执行简单计算等的 Actor 但是在生产中什么也没有 我想知道的是 是否有一般的经验法则或最佳实践来确定为某些类型的任务生成多少个参与者
Actor
akka
Scala.2.10.1 的标准库还是 Akka?
我要使用Futures and Promises from scala concurrentScala 中的包2 10 1 我应该使用Akka反而 Akka future 和 Promise 在 2 10 中被移入 Scala 标准库 所以
scala
concurrency
akka
控制 Akka 中消耗大量内存的 actor 的生成
我使用 akka 的 actor 模型构建了一个分布式流机器学习模型 通过向 Actor 发送训练实例 训练数据 来异步训练模型 对这些数据的训练会占用计算时间并改变参与者的状态 目前我正在使用历史数据来训练模型 我想运行一堆不同配置的模型
scala
concurrency
machinelearning
akka
1
2
3
4
5
6
...10
»