Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
端到端反应式流媒体 RESTful 服务(也称为 HTTP 上的背压)
我一直试图在网上澄清这个问题一段时间但没有成功 所以我会尝试在这里提问 我想找到一些资源或示例 其中展示了如何构建端到端完全背压的 REST 服务 客户端 我的意思是 我希望看到 给定一个实现响应式流的 REST 客户端 无论是在 Akka
scala
REST
akka
akkastream
reactivestreams
如何使用源队列并将其返回给调用者而不具体化它?
我正在尝试使用新的 Akka 流 想知道如何使用源队列并将其返回给调用者 而不在我的代码中实现它 想象一下 我们有一个库可以进行多次异步调用并通过以下方式返回结果Source 函数看起来像这样 def findArticlesByTitle
scala
akka
akkastream
Akka 在 Actor 之外进行日志记录
我有一个 Akka Actor 打电话给MyObject foo MyObject不是演员 如何设置登录 使用 Actor 就很简单 因为我可以混合 Actor Logging 在 MyObject 中 我无权访问 context syst
scala
logging
akka
使用 Akka 进行依赖注入
我在我的应用程序中经常使用 Guice 最近我开始学习 akka actor 并想用它重构我的应用程序 然而 一开始我就想知道我的所有技巧将如何与演员合作 我继续在谷歌上搜索 结果有点混乱 我找到的关于该主题的最新文档是 http leti
scala
dependencyinjection
akka
Actor
使用 Akka 以编程方式获取临时端口
如果我在 Akka 中将 ActorSystem 配置为使用临时 tcp 端口 更具体地说 我将 http 端口配置为 0 有没有办法在 ActorSystem 启动后以编程方式获取此端口 任何使用 actorOf 创建 Actor 的尝试
scala
akka
Scala Future 和 java 8 CompletableFuture
的简介CompletableFuturesJava 8 带来了可用的语言功能scala concurrent Future例如一元变换 有什么区别 以及为什么 Scala 开发人员应该更喜欢 Scala Futures 而不是 java 8
Java
scala
akka
java8
我是否需要重复使用相同的 Akka ActorSystem,还是可以在每次需要时创建一个?
Akka 2 x 需要很多命令来引用ActorSystem 因此 创建一个 actor 的实例MyActor你可能会说 val system ActorSystem val myActor system actorOf Props MyAc
scala
akka
Akka actor 查找或依赖注入
我刚刚开始使用 Akka 我无法决定是否应该使用依赖注入 如蛋糕模式 或 actor 查找来将 actor 彼此解耦 首选方法是什么 您应该更喜欢向彼此介绍 Actor 这意味着在消息中发送 ActorRef 或与消息一起发送 或者将其传递
akka
Actor
FSM actor 在转到相同状态后不会触发 onTransition
根据Akka FSM 文档 http doc akka io docs akka snapshot scala fsm html 笔记 可以使用 goto S 或stay 实现相同状态转换 当前处于状态 S 时 它们之间的区别在于 goto
scala
akka
使用 Maven 打包并运行 Scala Spark 项目
我正在 Scala 中编写一个应用程序 它使用Spark http spark apache org 我正在使用 Maven 打包应用程序 并在构建应用程序时遇到问题 uber 或 fat 罐子 https stackoverflow co
scala
Maven
apachespark
akka
MergeLatest 的默认值
官方文档 https doc akka io docs akka current stream operators Source or Flow mergeLatest html of MergeLatest状态 MergeLatest 为
scala
akka
akkastream
akka-streams 与 akka-cluster
我的 akka streams 学习马拉松仍在继续 我想将我的 akka streams 应用程序与akka cluster 和 DistributedPubSubMediator http doc akka io docs akka sn
scala
akka
akkacluster
akkastream
Akka 演员优先级
我有一个基于参与者的系统 它执行定期的 CPU 密集型数据摄取并为 RESTful 端点提供服务 我使用 Akka actor 来发出信号 控制摄取过程的各个阶段 并使用 Spray 当然是基于 Akka 构建的 来为我的宁静端点提供服务
Multithreading
scala
akka
spray
FSM 与 Akka 中的成为/不成为
Akka 提供了两种有些重叠的方式来管理 Actor 状态 有限状态机 http doc akka io docs akka 2 4 14 scala fsm html and 不成 成为 http doc akka io docs akk
akka
fsm
替换池中表现不佳的工人
我有一组无国籍的演员 执行类似的任务 这些工人中的每一个都是不可靠的并且可能表现不佳 在我的设计中 我可以轻松地产生更多演员来取代懒惰的演员 演员的演技是靠自己来评价的 有没有办法让主管 演员池进行此评估 以帮助决定哪些工作人员速度慢到足以
Multithreading
scala
akka
Actor
执行 io 时 akka jvm 线程与 os 线程
我在该网站上进行了一些搜索 以寻求帮助理解这一点 但没有找到任何非常清晰的内容 所以我想我应该发布我的用例 看看是否有人可以提供一些线索 我有一个关于在 akka 中用于 io 操作时 jvm 线程与操作系统线程的扩展的问题 来自 akka
Java
Multithreading
scala
akka
现代 Akka DI 与 Guice
这里是 Java 8 Guice 4 0 和 Akka 2 3 9 我试图弄清楚如何用 JSR330 风格注释我的演员类 Inject注释 然后通过 Guice 将它们全部连接起来 但实际上我读过的每一篇文章 下面的一些例子 要么使用 Sc
Java
akka
guice
Akka 会淘汰 Camel 吗?
My 理解Akka 的特点是它提供了一个模型 多个独立的线程可以通过该模型以高度并发的方式相互通信 它使用 参与者模型 其中每个线程都是一个 参与者 负责执行特定的工作 您可以编排在什么条件下将哪些消息传递给哪些参与者 我以前使用过 Cam
concurrency
apachecamel
akka
enterpriseintegration
等待多个 Akka FSM 消息
我有一个 Akka FSM actor 在收到消息后运行以下伪代码ReadyState lookupA Wrapper Lookup A lookupB Wrapper Lookup B lookupC Wrapper Lookup C g
scala
Asynchronous
akka
Actor
fsm
如何从类型安全配置中配置系统属性或 logback 配置变量?
我的变量中有默认值logback xml配置文件 我希望能够从我的类型安全配置中选择设置这些变量application conf file 我正在使用 one jar 部署应用程序 并且application conf打包在可部署 jar
scala
configuration
akka
logback
typesafestack
«
1
2
3
4
5
6
7
8
...10
»