Akka是一个开源工具包和运行时，简化了JVM上并发和分布式应用程序的构建。它实现了Erlang中已知的actor模型。
我最近开始使用akka事件源/集群分片进行开发，由于有了在线资源，我认为我了解了基本概念以及如何使用它创建简单的应用程序。我...
如何使用Actor在Akka中创建源以为WebSocket连接提供服务>>
我尝试与Akka Actor，Streams和WebSockets建立简单的聊天。我想创建单独的接收器和源以服务WebSocket连接。我为每个roomId创建一个聊天室：path（“ ws” /“ room” / ...
..当没有使用http响应实体，或者客户端tcp缓冲区已满，或者当客户端从其tcp缓冲区中获取的速率较低时，则服务器将数据推送至该速率的情况？我...
我们在应用程序中使用Akka演员。参与者正在调用服务，在某些情况下，这些服务正在调用第三方公开的其余API。现在第三方API花费了很长时间...
我将使用Akka在Scala中创建TLS会话，并在客户端和服务器之间进行相互身份验证。我创建了两个CA证书，必须信任传入的各个证书...
我正在尝试使用Alpakka S3连接到minio实例以存储文件，但是由于我将库版本从1.1.2升级到了2.0.0，所以我遇到了问题。这是一个简单的服务...
我最近开始学习Akka-HTTP并努力获得一个答案。我们知道，像Jersey，RestEasy这样的库遵循一个通用接口/ API，即JAX-RS。而且Akka-HTTP也是......] >>
我是Akka的初学者。 （我正在使用Java）我正在使用Akka制作文件传输系统。目前，我已经完成了Actor1（Local）-> Actor2（Remote）文件的发送。现在，当我遇到问题时...
我应该如何测试akka-streams RestartingSource的用法
我正在开发一个具有几个长时间运行的流的应用程序，它在其中订阅有关某个实体的数据并处理该数据。这些流应该达到24/7，所以我们需要...
如何使用Spray-json的JsonFormat自定义序列化程序序列化作为案例类一部分的akka “ actorRef”？
我需要为一个看起来像这样的案例类创建一个Spray-json隐式转换：case class ExampleCaseClass（identified：String，actor：ActorRef）我一直在使用Spray-json来完成所有的工作...]] >
给定执行上下文和线程池，如何在其上调度/实现akka / scala actor？
从akka.stream.scaladsl.Source读取第一个字节
我正在尝试从akka.stream.scaladsl.Source [ByteString，Any]读取前16个字节，并返回[Array [Byte]，Source [ByteString，Any]]。读取前16个字节后，我想流式传输...
您如何为Spring编写Akka类型扩展，以进行构造函数依赖注入？
在Akka 2.6之前，或在经典Actor上，可以编写Akka扩展名，以访问Akka未类型化actor中Spring的@Inject注释。这样的一个例子是：https：//github.com/typesafehub / ...
我有一个带有声明的AMQP源和AMQP接收器：List 声明= new ArrayList （）{{add（QueueDeclaration.create（sourceExchangeName））;添加（...
我从https://doc.akka.io/docs/akka/current/index.html开始学习akka。 DeviceManager是...
如何使用主机应用程序提供的日志适配器从基于Akka的库进行日志？
我正在制作一个小型库-确实是一个Flow-并希望从其代码中进行一些调试日志记录。该库将在Log4J2和基于Logback的应用程序中使用。我会...
[如果我有一个测试，要在akka流中模拟来自Sink的响应，其类型为：Sink [String，Future [Integer]]我想找到一种方法来生成此类型的默认值，但是我...
我已经重构了一个播放应用程序中的大量电子邮件发送代码，以使用actor异步地执行此操作。当我需要发送电子邮件时，现在可以注入一个EmailActor，然后致电...
我不确定为群集分片配置Akka Actor，我不太确定的一件事是，是否可以为实体配置多个停止消息以正常关闭。例如，实体...
我正在使用Akka制作文件传输系统。我看文件已经有一段时间了。当前的进度状态是Actor2收到了Actor1发送的文件，并将其写入本地...