广播不转到输出Akka流
是指在Akka流中，广播操作不会将数据流转发到输出流中。Akka流是一种基于异步、可扩展和高性能的流处理框架，用于构建反应式系统。它提供了一种简洁而强大的方式来处理数据流，并支持并发处理、容错性和可伸缩性。
在Akka流中，广播操作是一种将数据流复制到多个目标流的操作。它可以用于将数据同时发送到多个消费者，以实现并行处理或多路复用的需求。然而，广播操作不会将数据流转发到输出流中，而是将数据流复制到多个目标流中，每个目标流都可以独立地处理数据。
广播操作在一些场景中非常有用，例如将数据同时发送到多个日志记录器、多个存储系统或多个分析引擎。它可以提高系统的灵活性和可扩展性，并支持并行处理和多路复用。
在腾讯云的产品中，可以使用腾讯云的云原生服务来构建和部署Akka流应用程序。腾讯云的云原生服务提供了一套完整的云原生解决方案，包括容器服务、容器注册中心、容器镜像仓库等，可以帮助开发者快速构建和部署云原生应用程序。
腾讯云的云原生服务产品介绍链接地址：https://cloud.tencent.com/product/tke
相关·内容
1回答
我想在Akka中创建一个带有Broadcast和Concat的图形，但是下面的代码不起作用。我想知道为什么不起作用。
val src = Source(1 to 3)
val sink = Sink.foreach(println)
RunnableGraph.fromGraph(GraphDSL.create() { implicit b =>
import GraphDSL.Implicits._
val bcast = b.add(Broadcast[Int](2))
val concat = b.add(Concat[Int](2))
浏览 1提问于2016-03-15得票数 0
回答已采纳
1回答
下面是我编写的用于尝试输出的代码，即从本指南中编辑的每条akka消息的总和：
import akka.Done;
import akka.NotUsed;
import akka.actor.ActorRef;
import akka.actor.typed.ActorSystem;
import akka.actor.typed.javadsl.Behaviors;
import akka.japi.Pair;
import akka.stream.CompletionStrategy;
import akka.stream.OverflowStrategy;
import akka.st
浏览 3提问于2021-10-16得票数 0
回答已采纳
2回答
我对Akka streams中的扇出策略有点困惑，我读到Broadcast -(1个输入，N个输出)给每个输出一个输入元素，而Balance -(1个输入，N个输出)给定一个输入元素发射到它的一个输出端口。
你能解释一下吗：
平衡如何与多个消费者一起工作？
短语“发射到其输出端口之一”的含义
港口到下游是一样的吗？
“Balance”是否表示将输入流复制到一些输出分区中？
"balance“是什么意思？”balance“是指将图分开，复制多个下游订阅者的实例来处理卷？
浏览 3提问于2016-10-24得票数 4
回答已采纳
1回答
只读一次日记
、、、
我正在使用akka-persistence的PersistenceQuery将初始状态加载到我的演员，负责管理内容。我希望它能够在启动时精确地重放一次，但它一直将这些发送到日志中。
14:11:28.405 [rooms-akka.actor.default-dispatcher-4] DEBUG a.p.q.j.l.LiveEventsByPersistenceIdPublisher - request replay for persistenceId [rooms] from [4] to [9223372036854775807] limit [100]
14:11:28.407 [ro
浏览 1提问于2016-07-18得票数 1
回答已采纳
1回答
我使用Akka HTTP在post请求中发送数据，并将其累积到一个列表中。我需要对这些数据执行一些规则，这些规则将对批处理进行聚合。要创建批处理，我需要在固定的时间内对数据进行窗口化
我在列表中的数据是这样的，
data = List(
Map("a" -> 1.0, "b" -> 267.0, "c" -> 26.0, "d" -> 2.0,"time" -> 12345678293), Map("a" -> 1.0, "b" ->
浏览 2提问于2018-12-17得票数 0
1回答
下面是用于计算对象列表中数据流平均值的代码：
import akka.NotUsed;
import akka.actor.ActorSystem;
import akka.stream.javadsl.Sink;
import akka.stream.javadsl.Source;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import java.util.concurrent.CompletionStage;
import java.util.concurrent.Executi
浏览 5提问于2021-05-29得票数 0
回答已采纳
2回答
我在Akka流中有一个以Sink结尾的TCP连接。现在所有的信息都进了一个水槽。我想把溪流分裂成一个未知数目的湖水，给出一些功能。
用例如下所示，通过TCP连接，我获得了类似List[DeltaValue]的连续流，现在我希望为每个DeltaValue.id创建一个actorSink，以便能够不断地为每个DeltaValue.id积累和实现行为。我发现这是流处理中的一个标准用例，但我无法在Akka中找到一个很好的示例。
这就是我现在拥有的：
def connect(): ActorRef = tcpConnection
.//SOMEHOW SPLIT HERE and create
浏览 3提问于2017-05-14得票数 1
回答已采纳
我有一个流代码
val source = Source.actorRef[Msg[T]](1000, OverflowStrategy.dropHead)
val flow=source.map(println(_)).to(Sink.onComplete{case _=>println("complete")}).run()
在运行代码之后，我从日志文件中发现，akka创建了两个参与者：
akka://xxxx/flow-0-0-unknown-operation#-969158424]
akka://xxxx/flow-0-1-actorRefSour
浏览 3提问于2016-05-01得票数 2
回答已采纳
1回答
我使用的是Alpakka，下面是我的玩具示例： val system = ActorSystem("system")
implicit val materializer: ActorMaterializer = ActorMaterializer.create(system)
implicit val adapter: LoggingAdapter = Logging(system, "customLogger")
implicit val ec: ExecutionContextExecutor = system.dispatcher
val log =
浏览 16提问于2019-05-03得票数 0
回答已采纳
package controllers
import javax.inject._
import play.api._
import play.api.mvc._
import play.api.libs.json._
import play.api.libs.streams._
import akka.stream._
import akka.actor._
import akka.actor.Actor
import akka.actor.ActorSystem
import akka.actor.ActorRef
import akka.actor.Props
import akka.
浏览 3提问于2016-06-13得票数 1
1回答
我很难理解NotUsed和Done在Akka流中的目的和意义。
让我们看看以下两个简单的例子：
使用NotUsed :
implicit val system = ActorSystem("akka-streams")
implicit val materializer = ActorMaterializer()
val myStream: RunnableGraph[NotUsed] =
Source.single("stackoverflow")
.map(s => s.toUpperCase())
.to(Sink.foreach(pr
浏览 4提问于2017-10-24得票数 5
回答已采纳
1回答
我目前正在使用Akka-HTTP构建一个客户端WebSockets消费者。我不想尝试在接收器中进行解析，而是希望将代码包装在一个函数中，该函数发出来自接收器的结果，然后使用该输出(来自该函数)进行进一步处理(更多parsing...etc。)。 我现在可以打印来自Sink的每条消息；但是，函数的返回类型仍然是Unit。我的目标是为落入接收器的每个项目从函数发出一个String，然后使用返回的字符串进行进一步的解析。我已经有了到目前为止的代码(注意:它主要是样板代码)。 import java.util.concurrent.atomic.AtomicInteger
import akka.
浏览 11提问于2020-07-08得票数 0
回答已采纳
1回答
我有一个愚蠢的问题，但不知道原因：
import akka.{Done, NotUsed}
import akka.actor.Status.Success
import akka.actor.{ActorRef, ActorSystem}
import akka.stream.scaladsl.{Flow, RunnableGraph, Sink, Source}
import akka.stream.{ActorMaterializer, OverflowStrategy}
import scala.concurrent.Future
object Generic {
def m
浏览 1提问于2017-07-19得票数 0
回答已采纳
1回答
Akka流管道工作良好，没有采取(2)，但与采取(2)不显示任何输出。()函数是如何起作用的？
import akka.NotUsed
import akka.actor.ActorSystem
import akka.stream._
import akka.stream.scaladsl._
import scala.util.Try
import scala.concurrent.ExecutionContext.Implicits._
object TestStream {
implicit val system = ActorSystem("MyTest")
浏览 2提问于2017-02-02得票数 0
在我的系统上，我使用akka框架。我需要从远程系统复制文件。我可以在我的主系统中使用akka从远程系统复制所需的文件吗？
浏览 5提问于2017-06-23得票数 0
3回答
为什么例外情况在
import akka.actor.ActorSystem
import akka.stream.ActorMaterializer
import akka.stream.scaladsl.Source
object TestExceptionHandling {
def main(args: Array[String]): Unit = {
implicit val actorSystem = ActorSystem()
implicit val materializer = ActorMaterializer()(defaultActorSystem
浏览 2提问于2016-02-25得票数 19
回答已采纳
1回答
反应性-卡夫卡流消费者:死信发生
、、、、
我试图使用akka的反应性卡夫卡库来消费卡夫卡的信息。我得到了一条信息，然后我得到了
[INFO] [01/24/2017 10:36:52.934] [CommittableSourceConsumerMain-akka.actor.default-dispatcher-5] [akka://CommittableSourceConsumerMain/system/kafka-consumer-1] Message [akka.kafka.KafkaConsumerActor$Internal$Stop$] from Actor[akka://CommittableSourceConsume
浏览 4提问于2017-01-24得票数 3
回答已采纳
我想计算akka流完成对象演示扩展应用程序{所需的时间。
implicit val system = ActorSystem("MyDemo")
implicit val materializer = ActorMaterializer()
val startTime = System.currentTimeMillis
System.out.println(elapsedTime)
val flowA = Flow[String].map { element ⇒
println(s"Flow A : $element ${T
浏览 2提问于2021-01-08得票数 0
我刚接触Akka和Scala，并且自学用websockets做一个小项目。最终目标很简单，做一个基本的聊天服务器，在一些网页上发布+订阅消息。 事实上，在仔细阅读他们的文档后，我已经找到了与我的目标相关的页面，即this和this。 使用动态连接(也称为MergeHub & BroadcastHub)和Flow.fromSinkAndSource()方法，我能够获得我想要的一个非常基本的示例。我们甚至可以使用我在下面展示的akka文档中的示例来获得一个kill开关。代码如下： private lazy val connHub: Flow[Message, Message, Uniqu
浏览 34提问于2020-12-29得票数 1
回答已采纳
1回答
使用下面的代码，我尝试使用一个参与者作为源，并发送双精度类型的消息以通过滑动窗口进行处理。
滑动窗口被定义为sliding(2, 2)，以计算发送的每个TWP值序列。
发送消息：
actorRef.tell(10, ActorRef.noSender());
actorRef.tell(20, ActorRef.noSender());
actorRef.tell(30, ActorRef.noSender());
actorRef.tell(40, ActorRef.noSender());
actorRef.t
浏览 29提问于2021-06-14得票数 0
回答已采纳
1回答
我在用可重新启动的源和接收器处理akka流中的错误。
object Main extends App {
implicit val system: ActorSystem = ActorSystem("akka-streams-system")
val restartSettings =
RestartSettings(1.seconds, 10.seconds, 0.2d)
val restartableSource = RestartSource.onFailuresWithBackoff(restartSettings) {() => {
浏览 8提问于2022-01-10得票数 1
回答已采纳
当我运行我的星火程序时，我看到这个输出，要慢到完成，它从这个上下文中意味着什么？
19/04/01 15:34:24 INFO ContextCleaner: Cleaned accumulator 82
19/04/01 15:34:24 INFO ContextCleaner: Cleaned shuffle 0
19/04/01 15:34:24 INFO ContextCleaner: Cleaned accumulator 69
19/04/01 15:34:24 INFO ContextCleaner: Cleaned accumulator 30
19/04/01 15:34:2
浏览 2提问于2019-04-01得票数 4
回答已采纳
我正试图将一个反应性的订阅者附加到akka的消息来源。
我的来源似乎对一个简单的水槽很好(就像一个预言片)--但是如果我把一个真正的水槽放在一个由订阅者制作的水槽里，我什么也得不到。
我的背景是：
import akka.actor.ActorSystem
import akka.stream.ActorMaterializer
import akka.stream.scaladsl.{Sink, Source}
import org.reactivestreams.{Subscriber, Subscription}
implicit val system = ActorSystem.c
浏览 2提问于2017-02-08得票数 0
回答已采纳
我正在将一个应用程序从Spray迁移到Akka HTTP。在配置中，我有：
spray {
can {
client.request-timeout = infinite
}
}
Akka HTTP的等效配置是什么？现在看来，request-timeout只在server上可用，而不是在client上。
请参阅
浏览 12提问于2016-12-03得票数 0
回答已采纳
我的应用程序有生产者和消费者。我的制片人不定期地发布信息。有时我的队列将是空的，有时我会收到一些消息。我希望让我的消费者收听队列，当消息在其中时，接受它并处理这条消息。这个过程可能需要几个小时，如果消费者还没有完成当前消息的处理，我不希望他接收队列中的另一条消息。
我认为AKKA和AWS可以满足我的需求。通过阅读文献和例子，阿克卡-骆驼似乎可以简化我的工作。
我在github上找到这个。
我更感兴趣的是消费者的配置( Thread.sleep只是模拟我的处理)：
class MySqsConsumer extends Consumer {
//The SQS URI is an in-o
浏览 4提问于2016-06-17得票数 0
1回答
现在我正在阅读Play Java的文档。我不明白这些句子解释了apply(RequestHeader header)到底在起什么作用。
方法的返回类型是累加器。蓄能器是阿克卡流水池周围的一层薄薄的一层。一个累加器异步地将元素流累加到一个结果中，它可以通过传入一个Akka流源来运行，这将返回一个CompletionStage，当累加器完成时将被赎回。它与Sink>本质上是一样的，实际上它只不过是这种类型的包装器，但最大的区别是，累加器提供了方便的方法，如map、mapFuture、recover等，用于处理结果，就好像它是一个承诺，Sink要求将所有这些操作包装在mapMateriali
浏览 0提问于2017-01-27得票数 1
我有以下akka http拒绝处理代码取自https://doc.akka.io/docs/akka-http/current/routing-dsl/rejections.html val message = "The requested resource could not be found."
implicit def myRejectionHandler = RejectionHandler.newBuilder()
.handleNotFound {
complete(HttpResponse(NotFound
,entit
浏览 25提问于2020-03-26得票数 0
回答已采纳
1回答
我尝试编写一些简单的基于akka-http和akka流的应用程序，它处理http请求，总是使用一个预编译的流，因为我计划在我的requestProcessor流中使用长时间的背压处理。
我的应用程序代码：
import akka.actor.{ActorSystem, Props}
import akka.http.scaladsl._
import akka.http.scaladsl.server.Directives._
import akka.http.scaladsl.server._
import akka.stream.ActorFlowMaterializer
import a
浏览 1提问于2015-06-09得票数 0
回答已采纳
2回答
WebRTC大规模广播
、、、
我是webrtc的新手。我在webrtc上关注了来自的一个教程，并且我能够进行一些聊天。
如果我想广播给更多的用户，比如1000个或更多的用户，那么在设计这样的应用程序时，我需要考虑哪些事情？
我用谷歌搜索了一下，但我得到的只是webrtc的实现和一些类似我的问题。但到目前为止还没有得到任何具体的答案。
浏览 6提问于2013-06-20得票数 5
我正在尝试在akka-http websocket服务器和简单的javascript之间建立一个基本的连接。
在大约20个连接中，有1个成功，其余的失败。我不知道为什么连接的设置如此不可靠。
Application.scala：
import akka.actor.ActorSystem
import akka.http.scaladsl.Http
import akka.stream.ActorMaterializer
import services.WebService
import scala.concurrent.Await
import scala.concurrent.durat
浏览 0提问于2015-07-23得票数 2
1回答
我有一个流程： A +----> B +----> D
| |
| +----> E
|
+----> C +----> G
|
+----> H 我想通过Akka Stream实现这个流程。节点B和C的输出是列表，D、E、G、H的输入是列表中的元素。我尝试过：-从流的汇点创建源A->B或A->C 但我并不走运。你有什么建议吗？
浏览 14提问于2019-01-11得票数 1
1回答
Akka流和事务边界
、、、
我仍在掌握Akka流的概念，并试图了解如何将它们映射到需要以原子方式处理的项目集合的场景中。假设我们有一个由多个项目组成的采购订单，我们需要对每个项目应用一些处理，然后将它们合并到一个值中。这样的工作流是否应该成为它自己的独立流(或子流)，一旦采购订单被完全处理，它就关闭了？也就是说，每个采购订单启动一个新的流？还是我的订单源源不断？但如果是这样的话，我会不会有一个问题，从不同的订单混合采购订单？
换句话说，我试图实现的是处理不同工作流的隔离，并想知道Akka流是否为它提供了一个很好的匹配。
浏览 0提问于2016-11-12得票数 2
回答已采纳
我必须实现一个进程，它从队列中轮询消息并将数据转发到http端点。通常，我认为最好的方法是使用Akka流(带有akka http)，因为它为您处理背压等。问题是，我必须在运行时(基于http调用)创建多个不同配置的管道。另一个要求是，应该可以在运行时动态地停止其中的一个管道，然后用另一个配置启动它。
目前，我不确定是否真的能够在运行时动态地旋转新的平行akka流管道(并删除和重新启动其中的一些管道)。对我来说，现在使用akka演员做这个听起来更好(基于队列使用者参与者和akka http参与者，我和我可以在运行时动态地创建一对)，但是要使用它们，我还必须手动实现背压等等。
你认为可以通过akk
浏览 1提问于2018-07-02得票数 0
回答已采纳
1回答
我从一些我无法控制的外部代码中得到了一个Flow<A, B> (这是一个花哨的流/图形，参见)。我需要包装这个流程，并对每个输入元素和每个输出元素进行一些处理。我可以很容易地将一个放在上面，如下所示：
Flow<I, O, Unused> flow = ...; // external source
BidiFlow<I, I, O, O, Unused> bidi = BidiFlow.fromFunctions(i -> preprocess(i), o -> postprocess(o)); // do something on every
浏览 0提问于2018-11-29得票数 5
回答已采纳
1回答
如何从Akka做SQL？
、、、、
从Akka应用程序发出SQL语句的惯用Akka方法是什么？
具体来说，我有一个Akka Http REST端点，它希望执行SQL命令。是否有正式的SQL支持或异步或消息传递样式的SQL库？
浏览 5提问于2017-02-22得票数 2
回答已采纳
1回答
在写这个问题的时候，我正在使用SpringFramework5.0.0.M5和Akka 2.4.17。在项目中，我目前正在使用来自Akka的参与者消息和流。我明白了，v5也有流。
根据
作为一个反应性引擎/SPI，反应堆核心和IO模块都为集中的用例公开反应流结构，最终与Spring、RxJava、Akka流、Ratpack相结合.作为一个反应性API，反应堆框架模块将提供丰富的易耗特性，如组合和发布子事件。“
它看起来像Spring在引擎盖下使用Akka流(加上其他东西)。
问题是:从Akka流切换到Spring流可能有哪些优点和缺点？
编辑:这里有更广泛的问题(Reactov对Akka一般)
浏览 2提问于2017-02-25得票数 0
回答已采纳
2回答
我有一个关于使用Akka Streams和Akka集群的问题。我正在尝试做一个使用Akka Streams和Akka Cluster的分布式字数统计版本。
我想构建一个Akka Streams客户端，它将文本文件作为流I/O读取，并将单词流发送到远程集群。这是客户端的代码：
final Path file = Paths.get("example.txt");
final Source<ByteString, CompletionStage<IOResult>> read = FileIO.fromPath(file);
final Source<
浏览 5提问于2018-11-10得票数 2
1回答
我正在从Packt了解Akka流通过Akka Cookbook模块。我运行了示例并得到了以下内容：
为了让参与者系统在流处理完成后退出，我添加了以下回调：
// Future[IOResult]
val future = stream.run()
future.onComplete(_ => system.terminate())
但这一次，应用程序直接退出，没有任何控制台输出：
我想出的一个解决办法是添加Thread.sleep(10000)
我想解释一下这种行为。
浏览 1提问于2018-02-27得票数 0
回答已采纳
编辑：问题已经解决，Artur提供的解决方案最终被添加到编辑中。
我试图实现的想法是，一个TCP服务器允许n个连接，如果我得到一个n+1连接，则不允许连接。
因此，我需要以某种方式取消连接，然后继续将特定的流连接到Sink.cancelled()。
我所拥有的是一个连接到自定义流的IncomingConnection，该流根据连接计数对IncomingConnection进行分区。一旦最大连接计数被破坏，分区逻辑就会将其定向到连接到Sink.cancelled的出口。
期望立即取消连接，但它允许客户端连接，然后在一段时间后断开连接。
也许我遇到了与的答案中提到的相同的问题，其中找不到要处理的流
浏览 2提问于2021-08-10得票数 0
回答已采纳
2回答
我知道在ActorMaterialzer上使用监控策略重新启动akka流是可能的
val decider: Supervision.Decider = {
case _: ArithmeticException => Supervision.Resume
case _ => Supervision.Stop
}
implicit val materializer = ActorMaterializer(
ActorMaterializerSettings(system).withSupervisionStrategy(decid
浏览 2提问于2016-03-31得票数 5
回答已采纳
我正在寻找一个解释的行为，我看到了以下代码。当
conn.handleWith被注释掉，我使用netcat建立的TCP客户端连接连接，并在几秒钟内显示由对等服务器断开连接(即服务器断开连接)。当conn.handleWith出现在代码中时，我不会看到断开连接。我最初认为这与为服务器设置的idletimeout有关，但事实并非如此。
那么，当没有处理连接的流时，服务器为什么要断开客户端的连接呢？
package com.example;
import java.util.concurrent.CompletionStage;
import akka.D
浏览 3提问于2021-08-09得票数 0
回答已采纳
2回答
关于如何在akka中使用事件总线，有什么很好的教程/解释吗？我已经通读了Akka文档，但我发现很难理解如何使用事件总线
浏览 0提问于2013-04-29得票数 16
回答已采纳
如何向akka.routing.Router中的所有路由器/执行者发送消息？
注意:我使用的是Java，而不是Scala
浏览 5提问于2015-05-08得票数 2
回答已采纳
2回答
是一个Scala程序员，从开发人员的角度理解Akka。我还没查过阿克卡图书馆的代码。在Akka模型中读过两种类型的角色--基于线程的和基于事件的--但是没有大规模运行Akka，我没有为生产配置Akka的经验。对Vert.x来说是完全陌生的。所以，从选择的角度来构建一个反应性的应用程序栈，我想知道-
Akka和Vert.x的消息传递模型有很大不同吗？多么?
Akka的演员背后的数据结构和Vert.x的缓冲信息的眩晕有很大的不同吗？
浏览 4提问于2014-01-31得票数 57
回答已采纳
2回答
我目前正在尝试在Scala中使用具有管道和过滤器架构的Akka Streams编写程序。我有一个特定的图形，它应该接受一个输入并将其输出到多个流。最后，应该将所有不同流的结果合并为一个。在我的例子中，输入将是所有类型的tweet。然后这些推文首先转到不同的过滤器，所有过滤器都在一种类型上过滤，然后进行扫描，这只是简单地计算它看到了多少某种类型。在此之后，我希望输出是这些扫描的返回值，并将其组合到一个元组中。 现在，我已经为此设置了一个特定的图形DSL，它使用Broadcast和ZipWith来完成此任务。我的代码如下： val splitStreams =
Flow.fromGraph(
浏览 23提问于2019-12-21得票数 0
回答已采纳
1回答
我是非常新的akka-http，我想流一个csv与任意数量的行。
例如，我想返回：
a,1
b,2
c,3
使用以下代码
implicit val actorSystem = ActorSystem("system")
implicit val actorMaterializer = ActorMaterializer()
val map = new mutable.HashMap[String, Int]()
map.put("a", 1)
map.put("b", 2)
map.put("c", 3)
val `text/c
浏览 2提问于2016-10-27得票数 1
1回答
我有一些有趣的场景，我在flink中使用keyedbroadcastprocessfunction函数计算传入的模式，当我在集成开发环境中运行程序时，当我试图访问ReadOnlyContext时，在processElements函数中得到空指针异常，但它在终端上运行良好，下面是我的keyedbroadcastprocessfunction函数
下面是我的主类
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
imp
浏览 0提问于2020-06-15得票数 2
1回答
使用IntelliJ的最新scala插件SBT13.8和Scala2.11.7的新sbt项目，我尝试添加一个库- akka 2.4.2。在之后，我简单地添加
libraryDependencies += "com.typesafe.akka" %% "akka-actor" % "2.4.2"
但是我得到了一个未解决的依赖错误：
错误:导入SBT项目时出错：
信息解析org.scala-sbt#任务；0.13.8.
信息解析org.scala-sbt#跟踪；0.13.8.
信息解析org.scala-sbt#cache;0.13.8 .
信息解
浏览 0提问于2016-02-23得票数 1
回答已采纳
1回答
我正在使用带有servlet容器的Akka。servlet为每个请求创建一个HTTP执行元，该执行元保存对异步响应对象的引用
public void search(@FormParam("search") String param, @Suspended final AsyncResponse response);
HTTP执行元创建一个“worker”执行元，然后使用异步驱动程序查询数据库。现在，异步驱动程序返回一个迭代器，我想知道它是否适合参与者相互传递消息的想法。因为迭代器不是真正的就绪响应消息，而是一个引用。如果演员在不同的主机上，这可能不会起作用。所以我的问题是，在A
浏览 2提问于2015-07-07得票数 1
akka文档解释了如何在使用ActorSelection ()时使用通配符。
以下代码将直接在/user下向所有参与者发送一条消息
context.actorSelection("/user/*") ! msg
是否可以使用通配符向参与者层次结构中的所有后代(不仅仅是直接子代)发送消息？我尝试了以下代码，但没有成功：
context.actorSelection("/**") ! msg
浏览 1提问于2014-07-23得票数 4
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
