akka unstashAll()不重放消息
akka unstashAll()不重放消息是指在Akka框架中的一个方法，用于清除Actor的消息队列中的所有已存储的消息，并将它们发送给Actor进行处理，而不会重新播放这些消息。
Akka是一个基于Actor模型的并发编程框架，用于构建可扩展和高性能的分布式应用程序。在Akka中，Actor是并发执行的基本单元，它们通过消息传递进行通信和协作。
unstashAll()方法是ActorContext接口中的一个方法，用于处理Actor的消息队列中已存储的消息。当Actor处于某种状态，无法立即处理消息时，可以使用stash()方法将消息存储在Actor的消息队列中。而当Actor恢复到可以处理消息的状态时，可以使用unstashAll()方法将所有已存储的消息发送给Actor进行处理。
unstashAll()方法的调用可以确保Actor在处理已存储的消息时不会重新播放这些消息。这在某些情况下非常有用，例如当Actor的状态发生变化时，重新播放已存储的消息可能会导致不一致的结果。
推荐的腾讯云相关产品：腾讯云容器服务（Tencent Kubernetes Engine，TKE），它是腾讯云提供的一种高度可扩展的容器管理服务，可帮助用户轻松部署、管理和扩展容器化应用程序。TKE提供了高可用性、自动伸缩、安全可靠的特性，适用于各种规模的应用程序。
产品介绍链接地址：https://cloud.tencent.com/product/tke
相关·内容
1回答
如果我在中使用。我为藏物设置了一个配置：
akka{
actor {
queued-dispatcher {
mailbox-type ="akka.dispatch.UnboundedDequeueBasedMailBox"
}
}
}
我想去藏起来的消息应该存储在UnboundedDequeueBasedMailBox中。我的见解是错误的吗?如果是的话，UnboundedDequeueBasedMailBox的真正目的是什么？
我能收到去stash的消
浏览 3提问于2016-10-25得票数 2
回答已采纳
当接收事件时，Akka Actors将一次处理一条消息，在进入下一条消息之前阻塞，直到请求完成。
这对于同步/阻塞任务很有效，但是如果我想执行异步/非阻塞请求，Akka将继续处理，而不等待任务完成。
例如：
def doThing():Future[Unit] = /* Non blocking request here */
def receive = {
case DoThing => doThing() pipeTo sender
}
这将调用doThing()并开始处理将来的消息，但不会在处理下一条消息之前等待它完成-它将尽可能快地简单地执行队列中的下一条消息
浏览 1提问于2016-04-13得票数 19
我正在尝试实现一个Akka角色，它接收一条消息，然后等待接收另一条消息而不循环。我尝试以这种方式实现它的原因是因为我需要在第二个case语句中的第一个case语句中接收到的对象。下面是我的意思的一个例子。 def receive: Receive = {
case s @ start =>
receive {
case e @ end =>
println(f"Received ${s} and ${e}")
}
} 我知道这可能不是理想的模式。然而，我仍然是Akka和Scala的新手，不知道
浏览 14提问于2019-12-17得票数 0
回答已采纳
我想用FSM Akka Acctor进行隐藏/解除隐藏。我不知道该把stash()和unstashAll()放在哪里。
我有一个简化的例子如下：
import akka.actor.{ActorSystem, FSM, Props, Stash}
trait TestState
case object StateA extends TestState
case object StateB extends TestState
case class TestData()
case class MessageA(msg: String)
case class MessageB(msg: Str
浏览 5提问于2017-02-20得票数 4
回答已采纳
我想使用akka.actor.Stash接口。在Java中可以使用unstashAll(filterPredicate: Any⇒Boolean)方法和谓词吗?如果可以，请给出一个使用示例代码。
浏览 0提问于2015-10-29得票数 2
1回答
Akka持久性-力量重播
、、、
我的应用程序需要记录由一个参与者处理的所有消息，有时还需要在minSequenceNr和maxSequenceNr之间重播消息。
对于这个用例，akka持久化是一个好的选择吗？如果是，我如何才能强制重播日记中的信息？我可以使用Persistence(actorSystem).journalFor("x")获取日记的ActorRef，但是我不能将JournalProtocol.ReplayMessages发送给它，因为JournalProtocol是akka.persistence的私有。
浏览 3提问于2014-07-17得票数 3
回答已采纳
我正在做响应式编程课程中的一个练习，它要求学生装饰一个类型化的Actor行为来支持stash未处理的消息。这就是我到目前为止写的程序。
package protocols
import akka.actor.typed.Behavior
import akka.actor.typed.scaladsl._
import scala.reflect.ClassTag
object SelectiveReceive {
def apply[T: ClassTag](bufferCapacity: Int, initialBehavior: Behavior[T]): Behavior[T
浏览 24提问于2020-02-09得票数 0
我正在尝试使用Akka persisten actors实现事件采购。接收方参与者是持久化的，他们在处理消息之前持久化消息。我有一个持久化的接收者角色的循环池。现在，由于这些参与者池的持久化id是相同的，如何处理恢复？或者我想了解使用持久化的正确方法……
我在考虑使用这个属性'akka.persistence.max-concurrent-recoveries = 1‘。
注意:我使用的是java
浏览 0提问于2019-08-20得票数 2
我有这个：
val receive = beforeLoadReceive // my default receive
override def preStart(): Unit = {
doSomeLoadFromDB()
unstashAll()
context.become(connectedReceive)
println("I also get to here..."
}
def connectedReceive: Receive = {
case GetData =>
println("for some reas
浏览 3提问于2017-07-25得票数 1
回答已采纳
我有一个名叫buildingCoordinator的父母akka演员，它创建了孩子的名字elevator_X。现在，我只创建一个elevator。buildingCoordinator发送一系列消息并等待响应以移动elevator。顺序是:发送? RequestElevatorState ->接收ElevatorState ->发送? MoveRequest ->接收MoveRequestSuccess ->更改状态。如您所见，我正在使用ask模式。运动成功后，buildingCoordinator使用context.become更改其状态。
我正在运行的问题是，电梯在
浏览 2提问于2021-02-11得票数 0
回答已采纳
3回答
我有一个演员"ItemProvider“，它可以接收"getItems”消息。ItemProvider管理项目的项。因此，我可以有几条"getItems“消息请求项目A的项，还有其他的"getItems”消息请求项目B的项。
当"itemProvider“第一次获得这样的消息时，它需要调用一个服务才能真正获得这些项(这可能需要一分钟的时间，服务返回一个未来，这样它就不会阻止参与者)。在此等待期间，其他"getItems“消息可以到达。
一个项目"ItemProvider“缓存它从服务接收的”项“。因此，在1分钟的装载时间后，它可以立即服务
浏览 2提问于2014-10-31得票数 1
回答已采纳
假设我覆盖了preStart挂钩并向self发送了一条消息
Class SomeActor extends Actor {
override def preStart(): Unit = {
self ! SomeMessage
}
...
}
我能期望SomeMessage是队列中的第一条消息吗？
浏览 2提问于2013-05-02得票数 13
回答已采纳
当我正在使用最新版本的Akka时，我注意到耐用的邮箱现在已经从Akka移除了。
我需要确保我的消息在崩溃后重新启动时被恢复。是否有另一种不使用持久邮箱或其他人自定义实现的工作方式。
我也尝试过Akka持久化，但是它会重播这些消息，而且我不想在崩溃时发送两次相同的消息，因为所有消息的执行成本都很高。
浏览 5提问于2015-09-18得票数 10
回答已采纳
我遇到了一个问题，试图在Akka.NET集群中设置集群单例，其中有多个单例实例正在我的集群中启动和运行。集群由灯塔(种子节点)和存在集群碎片的主集群节点的x个实例以及该节点中存在的这个单例组成。
为了重现这个问题，我设置了一个，但不幸的是，这里我遇到了一个不同的问题，因为我总是得到Singleton不可用的消息，而我的独生子女从未收到消息。这是我最初遇到的相反的问题，但我还是想整理一个集群单例的工作示例。
0015akka://singletontest/user/my-singleton-proxy#1237572454] DEBUGThread Singleton不可用，正在缓冲消息类型
浏览 4提问于2016-08-22得票数 1
回答已采纳
1回答
在我的应用程序中，我有一个服务，可以发送电子邮件来响应各种用户事件。有一个正在进行的问题，其中电子邮件发送将由于某种原因而失败，因此我们丢弃消息，不尝试重试它。此故障模型中包括正在关闭的JVM。规则是不应该发生重复的电子邮件，不发送电子邮件是非常不受欢迎的，但可以接受。基本上，我们应该能够重试，而不用担心重复。
Akko-Persistence将出现在表面上来解决上述问题，然而，它似乎是为了存储所有消息，然后重放它们的子集来恢复。
所需的行为是在参与者恢复时重播任何未处理的消息(包括发生故障时正在处理的消息)。此外，如果系统被退回，则会发送所有挂起的电子邮件。
有没有我遗漏的Akka文档中的某
浏览 19提问于2016-07-27得票数 2
回答已采纳
2回答
更新:这个问题的源代码可以找到。丹鲁的礼遇。
是否有一种标准的方法来取代actorFor，因为它已经被废弃了？我发现的所有东西都涉及到actorSelection --但是通过设置获得3项依赖项是一个真正的皮塔。大多数在线讨论只是说不要使用actorFor，但是关于akka的所有书籍仍然使用它(因为它们的目标是2.2Akka前)。
例如，假设我有两个演员Pilot和Copilot，他们都是Plane演员的子角色。下面是他们目前如何相互引用(Akka并发，德里克·怀亚特，2013年)：
// Plane.scala
...
override def preStart(){
// Get
浏览 0提问于2014-04-09得票数 7
回答已采纳
我正在实现一个具有多个状态的参与者，并使用Stash不丢失任何消息。我的状态正在初始化(从DB获取一些信息)、运行(处理请求)和更新(更新我的状态)。我的问题是，在以后的解决方案中，当我尝试unstashAll()时，我会丢失消息。
def initializing: Receive = {
case Initialize =>
log.info("initializing")
(for {
items1 <- db.getItems("1")
items2 <- db.getItems("2")
}
浏览 2提问于2017-02-20得票数 0
回答已采纳
在这里，我创建了一个单例演员。主节点和种子节点是相同的。来自不同的项目，我正在尝试添加到集群中，并希望发送消息。我可以加入集群，但不能发送消息。
我的主节点和种子节点：
package Demo
import akka.actor._
import akka.cluster.singleton.{ClusterSingletonManager, ClusterSingletonManagerSettings, ClusterSingletonProxy, ClusterSingletonProxySettings}
import com.typesafe
浏览 0提问于2017-08-06得票数 0
我的应用程序有生产者和消费者。我的制片人不定期地发布信息。有时我的队列将是空的，有时我会收到一些消息。我希望让我的消费者收听队列，当消息在其中时，接受它并处理这条消息。这个过程可能需要几个小时，如果消费者还没有完成当前消息的处理，我不希望他接收队列中的另一条消息。
我认为AKKA和AWS可以满足我的需求。通过阅读文献和例子，阿克卡-骆驼似乎可以简化我的工作。
我在github上找到这个。
我更感兴趣的是消费者的配置( Thread.sleep只是模拟我的处理)：
class MySqsConsumer extends Consumer {
//The SQS URI is an in-o
浏览 4提问于2016-06-17得票数 0
从Akka获取序列化错误，如下面所示，如何对您的Akka消息中冒犯的不可序列化成员/字段进行包装？异常确实指出了不能序列化的成员值(在com.our.member.object下面)，但该对象包含许多嵌套成员本身，错误消息似乎对不能序列化的违规嵌套对象没有什么线索：
2018-05-24T06:30:51.897Z错误VCA-akka.actor.default-dispatcher-4 akka.remote.EndpointWriter -未能使用序列化器类akka.remote.EndpointWriter序列化远程消息类akka.actor.ActorSelectionMessage
浏览 1提问于2018-05-24得票数 0
回答已采纳
1回答
当前的应用程序使用Akka 及其发布/订阅用于导入大量数据的用例，在接收到每一行的数据时，它会发布事件，并且有一个订阅者。如果发布者/订阅者出现问题，这种设计将面临丢失事件的风险。
我想知道在这里使用Akka持久性是否有意义，原因如下
1)保留事件2)审核历史记录3)使用快照重新创建方案
请注意，系统中没有共享/全局状态(在几乎所有Akka持久性博客/示例中通常被描述为用例)。
Akka坚持在这里有意义吗？
浏览 4提问于2014-11-07得票数 1
2回答
Akka:保护异步资源
、、、、
虽然我的SRP方法的错误已经纠正了，但我仍然想知道您如何干净地保证对akka中的异步资源(如文件句柄)的单线程访问。显然，我不想允许来自不同线程的多个读写操作被分派给它，但是如果我的参与者在该文件上调用了一个未来的基于API的API，这很可能会发生。
我想出的最好的模式是：
trait AsyncIO {
def Read(offset: Int, count: Int) : Future[ByteBuffer] = ???
}
object GuardedIOActor {
case class Read(offset: Int, count: Int)
case class
浏览 6提问于2014-05-14得票数 0
回答已采纳
我有以下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参与者用作邮箱的死锁
、、、、
我只想使用Akka角色作为邮箱，也就是说，我想创建n个线程，每个线程创建一个远程角色。
每个线程获得对其他线程的所有远程参与者的引用，使得它们可以经由其各自的参与者向彼此发送消息。
执行元的定义如下：
case class Receive
case class GroupReceive(id: Symbol)
case class GroupMsg[T](id: Symbol, msg: T)
class FooParActor(val distributor: Distributor) extends Actor
with Stash {
import context._
va
浏览 0提问于2013-03-06得票数 1
我正在研究使用一个参与者模型框架(具有akka.net持久性的akka.net，但我正在寻找一个通用的案例答案)来构建一个“小部件订单处理工作流”。
相当标准：
客户订单小部件
付款处理
发送给客户的电子邮件确认
向仓库发送选择列表消息
仓库发送一条‘小部件已发运’的消息
给客户发一封‘你的商品已经发运’的电子邮件
现在，假设在4到5之间进行服务器部署/重新启动。这将导致演员的体液补充(让我们假设还没有快照)。这意味着我们将再次处理付款，并重新发送订单的电子邮件。然而，事实证明，我们的客户不喜欢这个‘功能’！
如何防止非幂等动作在使用参与者模型框架时再次发生？
浏览 0提问于2018-11-16得票数 0
3回答
是否可以通过TCP / IP向AKKA参与者发送消息？
例如，编写如下所示的客户端：
mySocket = new Socket("theactor", 75);
os = new DataOutputStream(smtpSocket.getOutputStream());
os.writeBytes("HELLO");
可以向AKKA演员发送消息？
谢谢
浏览 3提问于2012-10-19得票数 4
2回答
我们将Akka.net框架用于能源领域的高伸缩性应用程序。
我们将Akka.net用于各种任务，主要采用以下形式：
var system=ActorSystem.Create("actorSystem");
var props=Props.Create<UpdateActor>();
.WithRouter(new SmallesMailboxPool(100));
var actorRef=system.ActorOf(props,"UpdateActor");
foreach(var timerow in timeR
浏览 3提问于2018-11-22得票数 2
有什么方法使源代码可重用吗？
我有一个akka-http服务器，它接收一个大文件上传，然后通过HTTP将(块)数据流到订阅者websockets和其他HTTP服务器。在这两种情况下，都有一个接受SourceByteString的API，
HttpEntity(.，源)在HTTP的情况下
websocket的BinaryMessage(源)
与使用单个ByteString的版本相比，使用这些API有一些优点(只需要做一个HTTP，就可以重新创建相同的分块消息，等等)。
那么，是否有一种方法可以使类似的事情工作(而不缓冲内存中的一切)？
val allSinks: Seq[Sink
浏览 0提问于2018-07-09得票数 1
我目前喜欢在akka中使用redis，因为我可以通过查询redis来监视处理了哪些消息。Redis也存留到磁盘上。
阿克卡坚持与仅仅使用红宝石相比有何不同？
浏览 1提问于2015-11-09得票数 3
回答已采纳
2回答
当我为我的play应用程序启动sbt shell时，我一直看到以下消息：
[warn] * com.typesafe.akka:akka-actor_2.11:2.5.21 is selected over {2.3.13, 2.4.20}
[warn] +- com.typesafe.akka:akka-slf4j_2.11:2.5.21 () (depends on 2.5.21)
[warn] +- com.typesafe.play:play_2.11:2.6.23 () (depends on 2.5.21)
[warn]
浏览 4提问于2019-10-10得票数 0
对于具有我想连接到的远程参与者的系统，我使用以下配置：
akka {
loggers = ["akka.event.slf4j.Slf4jLogger"]
loglevel = DEBUG
debug {
lifecycle = on
receive = on
}
actor {
provider = "akka.remote.RemoteActorRefProvider"
warn-about-java-serializer-usage = false
浏览 4提问于2020-08-26得票数 0
1回答
我刚接触过akka remoting，我只想向远程演员发送一条消息，并得到回应。我在本地主机上有两个参与者系统--不同的端口: MasterSystem和WorkerSystem。我在WorkerSystem中创建了一个演员，并尝试向它的远程地址发送消息。但我一直收到一条“遇到的死信”的消息！会很感激你的帮助。谢谢!
MainMaster.java
package pi_swarm_approx;
import akka.actor.ActorRef;
import akka.actor.ActorSelection;
import akka.actor.ActorSystem;
impor
浏览 1提问于2021-11-22得票数 0
回答已采纳
1回答
我有以下单元测试：
it should "return xml" in new TestScope {
val testProbe: TestProbe = TestProbe()
val someActor = system.actorOf(Props[SomeActor])
testProbe.send(someActor, MakeXmlApiCall())
testProbe.expectMsgPF() {
case Success(message) => {
assert(message == &
浏览 2提问于2016-12-15得票数 1
回答已采纳
试着用
val nullablestr = hornetQMessage.getBodyBuffer.readNullableSimpleString.toString
或
val strMessage = hornetQMessage.getBodyBuffer.readString
获取
org.hornetq.core.buffers.impl.ChannelBufferWrapper.readSimpleStringInternal(ChannelBufferWrapper.java:83) at org.hornetq.core.buffers.impl.ChannelBuffer
浏览 1提问于2013-06-09得票数 0
我在scala中有一个已经存在的应用程序，它使用akka远程将消息从webserver发送到appserver。我将把这个改为http请求。
我看到今天，akka-remote已经为我处理了的所有序列化和反序列化，而没有编写任何序列化/反序列化器，但是协议是协议缓冲区。
对于http请求-响应，我希望使用json而不是协议缓冲区。
从webserver发送到appserver的消息是复杂的案例类。我不想编写所有编写器/读取器/格式化程序来执行json序列化，就像不需要用akka remote编写协议缓冲区序列化一样。
有什么解决方案可以让我在不写所有作者/读者的情况下进行json序列化？
谢谢
浏览 1提问于2018-01-07得票数 0
回答已采纳
1回答
我正在为akka集群中两个单独的akka微服务/有界上下文之间的通信进行适当的设计。
假设每个节点在集群中有两个微服务。
这两种微型服务都以akka为基础。
显然，在特定的有限制的上下文中的通信将通过从参与者发送消息到参与者或者从node1上的参与者发送到node2上的参与者(如果有必要的话)来处理。
Q:，但是在单独的akka应用程序之间使用类似的通信可以吗？例如有界message 1.参与者--消息-->有界message 2.参与者
或者应该通过更清晰的边界来完成:在bc1中，引发一个事件--发布到broker中，并在bc2中读取事件。
//编辑目前我们已经实现了一个服务注册中心，
浏览 0提问于2018-05-11得票数 1
2回答
经过最近的调查和一次，我意识到集群分片比集群一致性散列路由器更好的选择。但是我在运行一个双进程集群时遇到了麻烦。
一个进程是种子进程，另一个是客户端进程。种子节点似乎不断抛出死信消息(请参阅此问题的末尾)。
此种子HOCON如下：
akka {
loglevel = "INFO"
actor {
provider = "Akka.Cluster.ClusterActorRefProvider, Akka.Cluster"
serializers {
wire = "Akka.Ser
浏览 13提问于2017-05-07得票数 0
2回答
我在Akka 1.3中对消息使用zlib压缩。我现在正在迁移到Akka 2.0 RC2，似乎在Akka文档(用于Akka 2.0 RC2)中不再提到消息压缩。
这是否意味着在Akka 2中不再支持消息压缩，或者压缩正在幕后进行，但压缩选项不再可配置？
谢谢。
浏览 0提问于2012-02-24得票数 4
回答已采纳
我有一些发行演员，我需要ActorRef为这些演员。因此，我尝试了这一行(在MemberUp代码中)。
implicit val resolveTimeout = Timeout(5 seconds)
var act=Await.result(context.system.actorSelection(RootActorPath(member.address)/"user"/"myactor2").resolveOne(), resolveTimeout.duration)
但我总是得到以下例外：
错误集群系统-akka.actor.default-5 Act
浏览 2提问于2015-11-05得票数 2
我试图在F#中使用远程发送一条消息，但是我一直遇到这样的问题:没有发送带有类型的消息。当我使用以下代码时：
Server.fsx
#r "nuget: Akka.FSharp"
#r "nuget: Akka.TestKit"
#r "nuget: Akka.Remote"
open System
open Akka.FSharp
open Akka.Remote
open Akka.Configuration
let configuration =
ConfigurationFactory.ParseString(
浏览 2提问于2020-12-01得票数 3
回答已采纳
1回答
Akka远程共享类
、、、
我有两个不同的Java 8项目，它们将生活在不同的服务器上，它们都将使用Akka (特别是Akka远程处理)来相互交谈。
例如，一个应用程序可能向另一个应用程序发送Fizzbuzz消息：
public class Fizzbuzz {
private int foo;
private String bar;
// Getters, setters & ctor omitted for brevity
}
我以前从没用过阿克卡远程处理。我假设我需要创建第三个项目，一个库/jar，用于保存共享消息(如Fizzbuzz和其他消息)，然后将该库作为依赖项拖到两个项目中
浏览 0提问于2018-10-23得票数 1
回答已采纳
在过去的几天里，我一直在努力掌握AKKA和我得到的演员模型，我通过消息等方式进行交流，但如果我能得到一个简单的HelloWorld项目来编译，我就会受不了。下面是单个helloWorld.java文件...我已经在这里包含了两个类(Actor)...
import akka.actor.Props;
import akka.actor.UntypedActor;
import akka.actor.ActorRef;
public class helloWorld extends UntypedActor {
@Override
public void preStart() {
浏览 1提问于2013-10-05得票数 1
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
回答已采纳
我为编写了一个自定义记录器，将日志消息传递给远程系统。我有第二个记录器，它使用和作为后端打印到控制台和日志文件。
奇怪的是，我注意到一些消息没有被我的自定义记录器接收，但是slf4j记录器接收得很好。
例如，作为监督策略的一部分，由失败的子参与者生成的错误消息被记录：
[DEBUG][akka://Test/system/remote-deployment-watcher]: started (akka.remote.RemoteDeploymentWatcher@b342d63)
[DEBUG][akka://Test/system]: now supervising Actor[akka:
浏览 0提问于2014-09-03得票数 3
回答已采纳
2回答
在阿克卡暂停一个演员
、、、
我有一个演员在阿克卡，将处理信息，以创建特定的实体。这些实体上的某些字段是根据创建时数据库中其他实体的状态计算的。
我希望避免创建参与者处理速度快于数据库能够持久化实体的争用条件。这可能导致数据不一致，如下所示：
参与者创建一个Foo并将其发送给其他参与者以进行进一步的处理和保存。
演员被要求创建另一个Foo。由于还没有保存第一个数据库，因此将根据DB的旧内容创建新的数据库，从而创建错误的Foo。
现在，这种可能性是非常遥远的，因为Foo的创建将手动触发。但是，仍然可以想象，双击可能会在高负荷下造成问题。谁知道明天是否会自动创建Foo。
因此，我需要某种方法来告诉参与者等待，并
浏览 2提问于2013-01-28得票数 14
回答已采纳
2回答
在正确使用scala (和akka)参与者框架的大多数示例中，人们倾向于从单个特征派生每条消息。例如：
trait Message
object Ping extends Message
object Pong extends Message
然而，在Scala和Akka中，消息接收根本不是键入的。有什么理由去实现一个共同的特征吗？
浏览 0提问于2011-06-12得票数 11
回答已采纳
在使用Akka HttpRequest并将请求传递给参与者时，我无法识别响应。参与者将处理将接收到的每条消息，但它不知道用于获取此响应的请求。是否有任何方法来识别与响应匹配的每个请求？
注意:我没有服务器再次重新发送请求体的任何部分。
提前感谢
MySelf.scala
import akka.actor.{ Actor, ActorLogging }
import akka.http.scaladsl.Http
import akka.http.scaladsl.model._
import akka.stream.{ ActorMaterializer, ActorMaterializer
浏览 1提问于2018-05-27得票数 1
回答已采纳
如果远程参与者死亡，父参与者会得到通知，但是附加到远程参与者的邮箱会发生什么情况？如果没有办法检索，那么我们怎么能说akka是容错的呢？
浏览 2提问于2016-05-12得票数 0
回答已采纳
1回答
case class FeatureFilter(s3Client: AmazonS3) extends Actor with ActorLogging {
override def preStart(): Unit = {
self ! Initialize
}
override def receive: Receive = {
case Initialize =>
// long running operaton
val tryfile = S3Connection(s3Client).downloadObject(..
浏览 2提问于2020-03-18得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
即时通信 IM活动推荐
腾讯云开发者
