Akka是一个开源工具包和运行时，简化了JVM上并发和分布式应用程序的构建。它实现了Erlang中已知的actor模型。
摘自akka文档：与对象不同，actor不仅封装了它们的状态，还封装了它们的执行。与参与者的通信不是通过方法调用，而是通过传递消息。虽然这...
我相信反应系统应该是异步的，但是我多次听到Akka有同步参与者吗？那么这是否意味着Akka是同步的？或参与者以同步方式工作，但系统...
我们计划创建少量新的微服务作为我们平台的一部分。当前，我们所有的微服务都基于Java-Spring，并且我们使用docker / kubernetes进行扩展。我们现在计划评估...
Akka Alpakka SqsSource足够奇怪，可以与queueUrl和queueName一起使用
我正在使用Akka Streams，还使用alpakka.sqs.scaladsl从sqs队列中读取消息。我已经做过很多次了，但是现在我上传了一个版本，该版本将队列名称而不是队列URL放置在源中...
我试图在Akka中创建基本的Actor，但是我发现了两种不同的创建Actor的方法。一种方法是扩展akka.actor.Actor特性并实现如下所示的接收方法import akka.actor ....
我有一个协议，其类型为协议：Flow [ByteString，ByteString，NotUsed]。进入流的元素是用户发送的消息，而离开流的元素是来自...
我们有一个可以处理事件的接收器：def parseEvent（）：Sink [T，Future [akka.Done]] = {Sink.foreach [T] {event => {//处理事件}}}使用单个源即可正常工作：...
您如何使用Akka Stream的Combine方法合并一系列Source？例如，val source = Seq [Source [T，_]]。似乎没有方法签名需要Seq / Iterable / etc ......>
摘自一本有关使用akka actor的反应式应用程序的书：由于系统组件仅在收到消息时才对消息做出反应，因此系统可以使用可用线程来运行...的部分...]
我们有一个可以处理事件的接收器：def parseEvent（）：Sink [T，Future [akka.Done]] = {Sink.foreach [T] {event => {//处理事件}}}使用单个源即可正常工作：...
假设存在如下定义的Akka流：def tee = {var writer：Writer = ??? Flow.fromFunction [String，String] {msg => writer.write（msg）msg}}当上游...
您如何使用AKKA合并方法来合并源序列？即val source = Seq [Source [T，_]]似乎没有方法签名采用Seq / Iterable / etc ...相反，它需要...
Akka.NET记录器未将日志发送到Application Insights
我已经在Akka.NET中将Application Insights设置为日志记录提供程序，并在Akka.Monitoring中设置了记录各种自定义指标（例如，对收到的消息进行计数和处理时间的计时）。这个...
如何避免在具有继承行为的Akka actor中改变状态变量？
我有一些具有相同行为的阿卡族演员。此常见行为在特征中定义：trait CommonBehavior {this：Actor => var history：List [String] = Nil protected def commonActions：...
我有一个流程，其中连接了两个S3Sink。在第一个s3Sink中，我希望文件没有标题，在第二个s3Sink（s3SinkHeaders）中，我希望文件具有标题。 val ...
在使用Akka Streams时，我面临着缓冲和背压问题。我有以下代码（为简化问题而进行了简化）：对象X扩展了App {...
我刚开始使用Akka框架，并且在他们的文档中看到了以下代码。有人可以解释一下这段代码吗？是否可以将顶级类声明为static？ ...
我正在将AKKA框架及其Java API用于创建actor系统。这是演员的要旨。参与者负责处理图中的节点。对于...