Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
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
如何在不使用 zip() 的情况下将不同类型的 Future 组合成一个 Future
我想创造一个类型的未来Future Class1 Class2 Class3 从下面的代码 然而 我发现做到这一点的唯一方法是使用 zip 我发现这个解决方案很丑陋而且不是最佳的 谁能启发我 val v for a lt val f0 Fu
scala
akka
Future
applicative
为什么 Actor.receive 是偏函数?
Why is Actor receive部分功能 我总是可以使用带有匹配表达式的正则函数来代替它 It is a PartialFunction捕获消息被处理或未处理的可能性Actor 未处理的消息将 不让演员失败MatchError 产卵
scala
akka
Akka 2:如何暂停消息处理?
在我使用 Akka 掌握 Actor 模型的过程中 出现了很多问题 这是另一张 假设我们有一个 Actor 由于某些业务逻辑或可用资源 它必须在给定时间内停止处理消息 可能发生这种情况的情况可能是 节流 可能有一个发送电子邮件的 Actor
Actor
akka
我可以从任意异步任务访问 Http.Context.current() 吗?
我正在开发一个移动应用程序的后端 该应用程序当前在 Play 2 1 1 上运行 作为处理某些请求的一部分 我们会发送推送通知 发送推送通知的下游请求应该完全异步 并且与移动客户端的原始请求响应分离 我想访问Http Context cur
Java
playframework
akka
playframework21
如何每天在特定时间触发 akka 调度程序?
我创建了一个 Akka 的调度程序 每天在固定时间发送邮件 例如每天上午 6 00 那么如何称呼演员呢 我的意思是我应该使用什么逻辑 谢谢 只需计算现在和接下来的下午 6 点之间的差异 将其作为初始延迟 然后每 24 小时重复一次
Scheduling
quartzscheduler
scheduler
akka
jobscheduling
Akka 2.1.2 Scheduler 出现问题(“系统”无法识别)
根据这些示例 我试图运行一个非常简单的循环函数循环 http doc akka io docs akka 2 1 2 scala scheduler html http doc akka io docs akka 2 1 2 scala s
scala
akka
如何检测scala执行上下文耗尽?
我的 Playframework 应用程序有时没有响应 我想在运行时检测到这一点 记录有关当前在耗尽的执行上下文上运行的内容的信息 实现这一目标的最佳策略是什么 我考虑过将小型可运行对象发布到执行上下文 如果它们没有及时执行 我会记录一条警
scala
playframework
ThreadPool
akka
executioncontext
Akka 的语言和产品替代品是什么?
现在我正在看游戏框架 https www playframework com 并且非常喜欢它 Play 中提供的功能中最受宣传的部分之一是Akka http akka io 为了更好地理解 Akka 以及如何正确使用它 您能告诉我其他语言或
playframework
rabbitmq
akka
Actor
通过连接池发出 http 请求时 Akka Flow 挂起
我正在使用 Akka 2 4 4 并尝试从 Apache HttpAsyncClient 迁移 未成功 下面是我在项目中使用的代码的简化版本 问题是 如果我向流程发送超过 1 3 个请求 它就会挂起 到目前为止 经过6个小时的调试 我什至找
scala
akka
akkastream
akkahttp
Actors 中 future 的执行上下文
我有一个 Actor 并且在某些消息上我正在运行一些返回 Future 的方法 def receive Receive case SimpleMessge gt val futData Future Int futData map data
scala
akka
Actor
Future
如何通过 Scala 中的 Play Framework 2.5 流式传输压缩文件(即时)?
我想流式传输一些文件并即时压缩它们 以便用户可以将多个文件下载到一个压缩文件中 而无需向本地磁盘写入任何内容 但是 我当前的实现将所有内容保存在内存中 并且不适用于大文件 有什么办法可以解决吗 我正在研究这个实现 https gist gi
scala
playframework
zip
akka
akkastream
«
1
2
3
4
5
6
...10
»