Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
如何使用 Akka HTTP 从多个参与者/Web 处理程序正确调用单个服务器?
我有一个服务 我们称之为服务 A 它使用 Akka Server HTTP 来处理传入请求 我还有第 3 方应用程序 服务 B 它提供了多种 Web 服务 服务 A 的目的是转换客户端请求 调用服务 B 的一个或多个 Web 服务 合并 转
Java
akka
akkahttp
远程创建 Akka Actor,无需新的 ActorSystem
我已经仔细阅读了文档好几次了 http doc akka io docs akka 2 1 4 scala remoting html http doc akka io docs akka 2 1 4 scala remoting html
scala
JVM
akka
Actor
remoteactors
持久 Akka 邮箱和无损
在 Akka 中 当一个 actor 在处理消息时死亡 内部onReceive 该消息丢失 有没有办法保证无损 有没有办法配置 Akka 始终保留消息before将他们发送到onReceive 以便在演员死亡时可以恢复并重播 也许像持久邮箱
Queue
persistence
akka
Actor
为 testProbe 提供 ActorPath
我有一些代码使用 ActorPath 而不是 ActorRef 向演员发送消息 system actorSelection user myActor a message 我需要确保这条消息确实被发送了 因此 我需要在测试中创建一个位于此 a
scala
Testing
akka
使用 Akka HTTP(正式名称为 Spray)的 GET 请求的查询参数
Akka HTTP 正式名称为 Spray 的功能之一是它能够自动将数据从 json 来回编组和解组到案例类等 我已经成功地使其正常工作 目前 我正在尝试创建一个使用查询参数执行 GET 请求的 HTTP 客户端 目前的代码如下所示 val
akka
spray
akkahttp
在 Akka 中等待多个结果
在 Akka 中等待多个 actor 结果的正确方法是什么 The 反应式编程原理 https www coursera org course reactiveCoursera 课程有一个使用复制键值存储的练习 在不详细讨论分配的细节的情况
akka
Actor
nonblocking
考虑到可扩展性的基于组件的应用程序:OSGi 还是 Akka?
在我的硕士论文中 我正在开发一个用于销售大型活动门票的应用程序框架 我的主要要求是可修改性 可扩展性和性能 我的客户 活动组织者 应该能够在运行时轻松替换组件并添加功能 此类组件的一个示例是座位分配组件 我的导师说看看 OSGi 松散耦合的
OSGI
akka
Akka HTTP 错误响应实体 1 秒后未订阅
我正在使用 Akka HTTP cachedHostConnectionPoolHttps 池作为 Akka Streams Flow 的一部分发送请求 private val requestFlow Flow HttpRequest He
http
request
akka
subscribe
节点如何知道哪些节点已经看到集群当前状态?
我正在阅读 akka 文档 并在理解他们的实现方式时遇到了一些麻烦Gossip 文档在这里 http doc akka io docs akka 2 4 common cluster html Gossip Protocol 让我困惑的部分
Java
scala
akka
DistributedSystem
gossip
用于处理接收中的异步操作的 Akka 模式
我有一个 Actor 它接收指标数据点并定期聚合并将它们保存到磁盘 后一个操作执行 I O 因此我不想使用阻塞操作 但是 如果我将其切换为异步 如何防止在聚合完成之前接收其他数据点而不阻塞某处 我见过的一种模式是使用Stash 像这样 cl
scala
Asynchronous
IO
akka
akka java 编程覆盖配置
我能找到的几个关于此问题的主题都是针对 Scala 而不是 Java 而且没有一个涉及远程参与者 我有一个基本配置文件 SERVER CONFIG FILE Include akka common TheSystem akka actor
Java
configuration
akka
typesafeconfig
Akka TestProbe 测试 context.watch() / 终止处理
我正在使用 TestKit 测试 akka 系统 我正在测试的系统的一个参与者在收到某种消息类型后 context watches 发送者 并在发送者死亡时自杀 trait Handler extends Actor override de
akka
如何将参与者消息限制为特定类型?
In Akka http akka io 除了使用 RPC 风格编程模型的 Typed Actor API 之外 是否有其他方法可以将发送给 Actor 的消息限制为特定的静态类型 我可以在 Akka 中使用消息传递风格而不放弃 Actor
scala
Actor
akka
自定义 Spring Bean 参数
我正在使用 activator 上发布的 Spring Akka 示例来创建 Spring 托管 bean actor 这是我当前使用的代码 包括演示类 Component class Test extends UntypedActor A
Java
Spring
akka
停止系统中的所有参与者而不关闭系统本身?
在Akka 2 0中 有没有一个好的方法来关闭 user路径下的所有actor 例如 假设我执行以下操作 val system ActorSystem create mySystem system actorOf Props new MyA
scala
akka
Scala + Play Framework + Slick + Akka - 来自 Akka Actor 的数据库访问
在收到 TCP 特定消息时 我需要查询我的数据库 为此 我创建了一个名为 DBActor 的 Actor 并将其加载到Application scala file class Application Inject system ActorS
scala
playframework
akka
slick
将 ActorRef 传递给其他 Actor 是好是坏?
我想弄清楚我是否使用传递 AkkaActorRef围绕其他参与者并不是一种反模式 我的系统中有一些演员 有些寿命很长 restClientRouter publisher 有些人在完成工作后就死了 geoActor 短命参与者需要向长命参与
scala
DesignPatterns
akka
Actor
antipatterns
akka-camel 2.2.1 使用 Spring XML 定义路由
我使用的是 akka camel 2 2 1 需要分别配置往返于 Consumer 和 Producer Actor 的路由 我目前正在定义路由并以编程方式将它们添加到 CamelExtension 内的内部 Camel 上下文中 如下所示
Spring
apachecamel
akka
在 akka Receive 中保留类型信息
是否可以在消息处理程序部分函数中保留类型信息 我有部分函数 eventHandler 通过某些特定参数匹配事件 def eventHandler Receive case event Event val matchingReactions
scala
Reflection
akka
通过 Akka IO 和套接字的协议缓冲区消息
我碰到这篇博文 http cognitiveentity wordpress com 2012 02 23 simpler akka io example 我发现它很棒并且很有启发性 展示了如何对发送到 Akka IO 套接字服务器的字符串
Sockets
scala
protocolbuffers
akka
«
1
2
3
4
5
6
...10
»