Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
如何将多个 actor 作为源附加到 Akka 流?
我正在尝试构建并运行一个 akka 流 在 Java DSL 中 其中 2 个 actor 作为源 然后是一个合并结点 然后是 1 个接收器 Source
akka
akkastream
使用 Akka Stream 传输巨大的 json
我有一个 json 板的巨大 http 响应问题 其中只有部分是感兴趣的 我无法更改响应结构 这是一个例子 searchString search redirectUrl 0 numRecords 123 refinementViewMod
json
scala
playframework
akka
akkastream
使用 TCP 流并将其重定向到另一个接收器(使用 Akka Streams)
我尝试使用 Akka 2 4 3 将 TCP 流重定向 转发到另一个接收器 该程序应该打开一个服务器套接字 侦听传入连接 然后使用 tcp 流 我们的发件人不期望 接受我们的回复 因此我们从不发回任何内容 我们只是消耗流 在对 tcp 流进
scala
TCP
akka
akkastream
为什么 Akka-Http 仍然使用旧的 Akka-Actor?
我已将最新的 akka http 添加到我的项目中 但其中包括 akka actor 上非常旧的 2 4 19 版本 因此我还将 akka actor 版本 2 5 4 添加到依赖项中 但是 这会导致以下错误 Detected java l
Maven
akka
akkahttp
Akka 适合短暂网络覆盖的系统吗?
Akka 是否适合在节点需要进出 WiFi 覆盖范围的系统中使用 必须考虑哪些方面 例如首选哪些传输协议 Akka is适用于具有瞬态网络覆盖的系统 正如 Viktor 在对该问题的评论中指出的那样 主管层次结构可用于处理未交付错误 有关更
Java
scala
akka
Akka演员道具工厂
我和阿卡正在互相了解 From Akka 2 3 6 当前 Actor 推荐实践 http doc akka io docs akka current scala actors html actorselection scala Props
akka
Actor
Spray.io:何时(不)使用非阻塞路由处理?
如果我们正在考虑生产级 REST API 我们是否应该尽可能使用非阻塞 例如 def insertDbAsync rows RowList Future Unit val route path database insertRowList
scala
akka
spray
如何从akka actor获取消息队列的大小?
应用程序中有Akka Java API 参与者 UntypeActor 和消息 根据API合同 如果几条消息发送给同一个参与者 它们将被一一排队和处理 我想根据队列大小处理参与者中的消息 基本上 在 Actor onReceive 中处理当
Java
akka
如何在 Akka Classic 中向演员的家长发送消息?
Actor 向其父级发送消息的方法是什么 我正在使用阿卡 2 2 您正在寻找 getContext parent 它为您提供了父级的 ActorRef 因此您可以执行以下操作 getContext parent tell
Java
akka
有没有如何将 akka-http 与 servlet 容器一起使用的示例?
现在正在使用spray http spray io with Servlet30ConnectorServlet https github com spray spray blob master spray servlet src main
scala
servlets
akka
spray
akkahttp
动态合并 Akka 流
我尝试使用 Akka 流通过以下方式构建 pub sub 总线 发布者添加主题的源流 订阅者指定主题并获取该主题的所有内容 然而 主题可以由多个发布者发布 发布者和订阅者都可以随时加入 我的想法是合并所有源 然后将过滤后的源返回给订阅者 然
scala
MERGE
Stream
akka
akkastream
Akka 及其错误内核
我正在读 Akka Java lib 文档并需要对其自己声明的一些内容进行澄清Akka Actor 最佳实践 http doc akka io docs akka 2 0 2 general actor systems html Actor
Java
akka
immutability
Actor
如何在 Scala 中为具有构造函数参数的 Actor 创建 TestActorRef?
The Akka 测试文档 http doc akka io docs akka snapshot scala testing html给出以下创建 TestActorRef 的方法 import akka testkit TestActo
scala
Testing
akka
Actor
在 Scala/akka 中记录到文件:ClassNotFoundException:akka.event.slf4j.Slf4jLoggingFilter
我已经搜索了很多 但找不到有效的解决方案 有人可以帮我吗 akka event handlers akka event slf4j Slf4jEventHandler loggers akka event slf4j Slf4jLogger
scala
logging
akka
logback
在scala中调用akka actor的方法
我有一个演员定义如下 class nodeActor ID String extends Actor 其中包含一个方法 用于在启动之前设置 actor def addRef actor ActorRef 我这样实例化这个演员 val nod
scala
akka
Actor
从代码中取消 Apache Flink 作业
我现在的情况是想从代码中停止 取消 flink 作业 这是在我的集成测试中 我正在向我的 flink 作业提交任务并检查结果 当作业异步运行时 即使测试失败 通过 它也不会停止 我想在考试结束后在车站工作 我尝试了一些事情 我在下面列出 获
akka
apacheflink
将回调方法实现转换为 akka 流源
我正在与我无法控制的 java 库中的数据发布者合作 发布者库使用典型的回调设置 库代码中的某处 该库是java的 但为了简洁起见 我将在scala中进行描述 type DataType trait DataConsumer def onD
scala
akka
akkastream
如何使用参数化参与者在akka中创建路由器?
我正在尝试在 Scala 中使用广播路由器 如果我没有记错的话 它应该如下所示 val system ActorSystem My beautiful system val workerRouter system actorOf Props
scala
constructor
routes
akka
在Akka中,ActorContext线程安全吗?
根据标题 从演员中提取的 ActorContext 是否可以从多个线程 即使是演员当前未执行的线程 安全地使用 以创建作为原始演员的子级的演员 不 ActorContext 是不是线程安全的 https github com akka ak
threadsafety
akka
在Akka.NET中,(使用Akka.Cluster)如何配置多个种子节点(Lighthouse)相互了解?
如果我想让两个 Lighthouse 种子节点在不同的 PC 上运行 每个节点都应该了解另一个节点 我应该如何配置它们 尽管我发现提到使用多个 Lighthouse 实例 并看到使用多个种子节点的非种子节点配置 但我无法在了解一个的单独 P
akka
akkacluster
akkanet
akkanetcluster
«
1 ...
4
5
6
7
8
9
10
11
»