-
ZipOutputStream的块结果
我目前正在尝试使用Play框架2.7构建并发送zip存档。我想即时生成档案以避免使用存储(或填满RAM)。 -
如何根据某些条件处理Akka流?
假设存在一些要处理的文件流,并且满足条件时仅应处理(消耗)特定文件。<br/> 即仅当流包含 -
如何使用Akka创建TCP服务器?
我试图在akka的帮助下创建简单的tcp服务器。 我的主要人 <pre><code>import java.net.InetSocketAddress imp -
测试AKKA 2.6类型的持久性参与者(Kill和PoisonPill的替代品)
我对“ Akka Classic”演员进行了测试,正在测试持久性。 逻辑很简单: <ol> <li>创建一个演员并 -
如何将数据从队列传递到客户端?
我正在尝试使用<code>akka-streams</code>编写tcp-server。 我有: <ul> <li>服务器:客户端连接服务器时 -
如何实现Akka HTTP请求发布客户端标头授权
我正在尝试实现Akka http客户端以进行邮寄请求,其中授权将在邮递员的标头中给出。我无法授权,以下 -
收到毒药后演员的主要行为
我有一个正在神秘死亡的演员,我认为原因可能是有人在向演员发送毒药。 当演员接收到PoisonPill -
演员被解职意味着什么?
我已经问了一个有关我看到的错误的相关问题<a href="https://stackoverflow.com/questions/58810757/overriding-behavior-of- -
重用角色的Akka Dispatcher配置
我正在尝试为受CPU约束的角色安排调度程序,并且有点困惑它如何适合我的角色布局。 我在akka上 -
尝试连接到主节点时在OCI akka.actor.ActorNotFound上触发火花
我在Oracle Cloud Instance上有3个实例,每个实例在同一子网下都有私有IP和公共IP。它们的私有IP就像10.0.0.2/3 -
如何设置Lightbend的Telemetry Developer沙盒
我正在尝试为Lightbend提供的遥测设置开发人员的沙箱。 在有关遥测<a href="https://developer.lightbend.com/ -
Akka如何根据参数值有条件地转发请求
我有一条与此相似的现有路线: <pre><code>pathPrefix("foo") { pathPrefix(IntNumber) { id => post { -
Akka HTTP WebSocket服务器在构建用于消息处理的Flow时如何基于接收器内容声明Source?
我正在使用Akka Stream / Http并试图弄清楚如何在websocket服务器中执行以下操作(希望不使用Actor模式): <b -
无法在Akka Stream中使用GraphStage类运行SourceShape
我正在尝试使用GraphStage构造创建Redis Akka流源。这个想法是,每当我从subscription方法获得更新时,我都会 -
kubernetes k8s上的Akka。调度无法访问的节点
在k8s上运行Akka集群,它正在使用下降策略(即自动下降),因此,在节点不可达的情况下,不可达的容 -
构建Fat JAR时不会合并Typesafe应用程序和参考配置文件
我有一个sbt应用程序,该应用程序将在通过intellij或使用sbt run的终端运行时运行。但是,当我创建一个 -
来自Spark执行者的节流并发HTTP请求
我想从Spark作业内部向限速API发出一些Http请求。为了跟踪<strong>非分布式</strong>系统(在Scala中)中的并 -
如何使用Scala Akka流检测重复的行
我们有一个Scala应用程序,该程序可从文本文件中读取行并使用Akka Stream处理它们。为了获得更好的性能 -
Actor消息处理程序中捕获了哪个发件人?
我是Akka演员的新手,我做了如下实验以了解演员的工作方式。 <pre class="lang-scala prettyprint-override"><cod -
system.teminate()不在akka中调用CoordinatedShutdown的所有阶段
我的工作需要在应用程序终止期间进行一些高级清理,因此我在CoordinatedShutdown的服务取消绑定之前阶段 -
如何解决所有错误并成功运行Akka分布式工作者示例项目?
我正在按照<a href="https://developer.lightbend.com/guides/akka-distributed-workers-scala/" rel="nofollow noreferrer">https://develop -
当akka.actor.ActorSystemImpl根据非法请求吞下请求时,如何记录详细信息?
我正在使用Scala Play Framework 2.7.3。我在日志中发现的警告 <blockquote> akka.actor.ActorSystemImpl:非法 -
清理Akka演员获得的资源的最佳做法
我的Akka演员获得了一些资源,应该在完成工作后释放这些资源,如下面的代码片段所示。<br/> 问题是, -
使用Java在Akka测试套件中测试流
<a href="https://doc.akka.io/docs/akka/current/stream/stream-testkit.html" rel="nofollow noreferrer">https://doc.akka.io/docs/akka/curre -
Source.Single()会提前终止带有2个源的流
我定义了一个简单的图形,该图形将恒定流(通过<code>Source.Single(5000)</code>定义)与非恒定源(例如<code> -
Akka与Java的兼容性
Akka流是否支持Java 11? 我正在尝试将Akka应用程序作为Spring引导项目运行。但是我面临下面的问题 -
Akka.NET和MVVM
我正在在当前正在使用的新WPF .NET Framework应用程序中使用Akka.NET。 大多数情况下,在应用程序中使 -
如何使两个actor系统在docker中运行以形成集群
我正在努力了解Akka和Akka群集。 到目前为止,当我在两个不同的控制台中分别启动每个Actor系统( -
Akka:演员没有发送回复
我想通过api代码从Akka Actor返回一个字符串响应。但是,我一直在超时,我不知道我的代码可能出什么毛 -
akka-http net :: err_incomplete_chunked_encoding 200(确定)
我正在尝试使用Akka-http向浏览器发送较大/通常较慢的响应,以使其呈现为excel文件: 即: <h1>使用ui