sender()指向来自参与者系统的消息的死信
sender()指向来自参与者系统的消息的死信。
死信是指在消息传递过程中无法被正确处理的消息。当参与者系统接收到一条消息，但无法处理或者处理失败时，该消息就会被标记为死信。sender()是一个指向死信消息来源的标识符。
死信的产生可能是由于多种原因，例如消息格式错误、消息超时、参与者系统故障等。为了确保消息的可靠传递和处理，参与者系统通常会将无法处理的消息发送到一个专门的死信队列中，以便后续进行处理或者分析。
死信的处理可以采取多种方式，例如重新发送消息、记录日志、通知相关人员等。具体的处理方式取决于参与者系统的设计和需求。
腾讯云提供了一系列的云计算产品和服务，可以帮助开发者构建可靠的消息传递系统。其中，腾讯云消息队列 CMQ 是一种高可靠、高可用的消息队列服务，可以用于处理消息的发送和接收。您可以通过腾讯云 CMQ 来实现死信消息的处理和管理。
更多关于腾讯云消息队列 CMQ 的信息，请参考以下链接：
请注意，以上答案仅供参考，具体的实现方式和产品选择应根据实际需求和情况进行评估和决策。
相关·内容
我在玩Actor路由，我不能将回复发送回路由器，这样路由列表中的另一个参与者就可以找到它。我在用：
sender.tell([Message], context.parent)
要像akka docs那样回复路由器，路由参与者将发送者设置为自己，他们的父节点就是实际的路由器。
在回复时，它将在控制台中给出以下消息：
信息星巴克-akka.actor.default-Dispatcher-2消息net.addictivesoftware.starbucks.MakeCoffee$从Actorakka://StarBucks/user/Melanie#-847662818到Actorakka:/
浏览 1提问于2013-12-13得票数 3
回答已采纳
在上，我读到(强调我的)：
您可以创建一个参与者，终止它，然后使用相同的参与者路径创建一个新的参与者。新创造的演员是演员的新化身。不是同一个演员。演员对旧化身的引用对于新化身是无效的。发送给旧的参与者引用的消息即使路径相同，也不会传递给新的化身。*
*为了完整起见，发送给“旧”引用的消息将发送到一个死信邮箱/参与者/队列/任何东西。
它们进一步指出(强调我的)：
当两个参与者引用具有相同的路径并指向相同的参与者化身时，比较它们是相等的。
好吧，这很清楚。可以说，参与者引用指向对象的特定实例。
但是在执行远程调用时，实例/“化身”似乎并不重要。在同一页下面还说(强调我的)：
当
浏览 2提问于2021-06-06得票数 0
我正在构建一个应用程序，它需要对指向上游发件人的sender引用延迟响应。为了清楚起见，如果参与者A向参与者B发送消息，则A是B的sender。
当A失败并由其主管重新启动时，B持有的sender引用是否仍然指向重新启动的A演员？
浏览 3提问于2020-08-23得票数 1
回答已采纳
参与者的默认行为是重新启动。为了更好地理解，我创建了两个参与者和一个崩溃来导致重新启动：
class PingActor extends Actor with ActorLogging {
import PingActor._
override def postRestart(reason: Throwable): Unit = {
log.info(s"RESTARTING")
super.postRestart(reason)
}
var counter = 0
val pongActor = context.actorOf(PongAc
浏览 5提问于2017-09-28得票数 1
回答已采纳
我正在学习DLQ如何在Azure service bus queue中工作。也就是说，未使用的消息将在DLQ中。我在消息过期时启用了死字(deadLetteringOnMessageExpiration)。
参考资料：
AMR模板：
问题：
如果启用了screenshot)?If ，DLQ是否可用于该队列(如下面的“是的”，我如何处理来自DLQ的消息？(我想我可以在这里看到这样的消息，但不确定接下来会发生什么)
我的目标是使用DLQ创建一个队列，其中可以在某个点处理未处理的消息，实现这一目标的最佳方法是什么。
浏览 3提问于2022-08-10得票数 0
回答已采纳
我有一个集成测试，它向远程Akka (2.0.5)参与者发送大量消息。每次测试运行后，远程执行元树都会重新启动。在成功运行43次测试后，根据调试级日志消息，远程参与者开始向自己发送回复，这显然会导致测试失败。
为什么会发生这种情况？
在代码库中只有一个地方我要发送这种类型的消息，它清楚地写着
sender ! generateTheMessage()
浏览 0提问于2013-01-22得票数 0
回答已采纳
我的用法:我想通过群集和(群集)客户端使用Akka.Streams Remote 在文档https://getakka.net/articles/clustering/cluster-client.html中提到，“如果客户端应该直接与集群中的参与者通信，则可以在回复消息中传递原始发送者。”但这似乎对我不起作用。我使用集群客户端从集群(不是回复的参与者，而是另一个参与者)获取包含参与者引用(IActorRef)的消息。 之后，当我尝试向该参与者发送消息时，我收到了一封死信，甚至客户端有时也会失去与集群的联系。是这里的文档错了，还是我的理解错了？ 备注:通过ClusterClient.Send
浏览 8提问于2020-06-19得票数 0
1回答
我想使用ActorRef作为Map密钥。但是，由于Akka在发送消息时充当临时参与者，所以我不能使用sender()作为密钥。
是否有从消息的发送方获得真正的ActorRef？
浏览 7提问于2016-10-16得票数 2
回答已采纳
我有Azure的主要功能应用程序，处理来自服务总线的消息。
如果由于API下降而发生异常，则将消息推入死信队列。
我有另一个天蓝色死神功能应用程序，它不断读取DLQ并将消息推回主队列。
并且主函数应用程序检查api是否下降，然后再将消息推送到DLQ，这应该继续下去，直到API上升，主函数应用程序成功地处理消息为止。
但问题是经过一段时间消息自动清除。
我检查默认的消息存活时间是2小时30分钟，但是消息不能停留这么长时间。当我将消息推回Main时，我认为在死函数应用程序中。在主队列中，消息可能是重复的，但不确定。
在给定的默认消息生存期内，我应该如何将消息保存到DLQ中？
死信功能应用
浏览 8提问于2020-10-01得票数 0
回答已采纳
我使用“询问”模式，在一个名为fun的函数中，向名为actor的演员发送请求。参与者将以异步方式获得由另一个系统生成的ID，完成后，我将将包含此ID的消息转发给另一个名为actor-B的参与者-B将执行一些DB操作，然后将DB操作结果发送给发送方，因为在我的示例中，我使用转发模式，因此参与者-B识别发送方为my F，akka将给娱乐-F一个临时的参与者名称，因此返回的值应该被传递给临时参与者。
我的问题是：
如果我使用同步-方法从另一个系统获取ID，然后在参与者-B的DB操作之后，将此消息转发给参与者-B，则可以将结果传递到fun F的值，并且由akka框架运行时将fun定义为临时参与者Act
浏览 0提问于2017-11-21得票数 0
回答已采纳
2回答
我想处理来自Amazon死信队列的消息。
处理它们的最佳方法是什么？
从死信队列接收消息并进行处理。
从死信队列接收消息，把它放回主队列，然后处理它？
我只需要偶尔处理一下死信队列中的消息。
浏览 0提问于2018-05-16得票数 3
回答已采纳
在我的消息应用程序中，我决定为客户端分配一个单独的队列。这样，路由和安全性就很容易了。但我不知道如何处理死信队列(当消息过期时，比方说)。我想使用Azure函数的无服务器方法来处理来自DLQ的消息。当消息放在队列中时，很容易设置触发函数。但是如果我有1000个客户，那就需要1000个功能？.根据我所看到的，您可以将一个函数附加到单个“触发器”--意思是单个队列。我是不是漏掉了什么？统一处理DLQ消息的正确方法是什么？
任何帮助都是非常感谢的。谢谢。
浏览 1提问于2022-09-02得票数 0
我试图在关闭我的Akka演员系统的两种不同方法之间做出决定：
PoisonPill选项1:向 Master (根用户)参与者发送：
val master = actorSystem.actorOf(Props[Master], name = "Master")
// Lots of code doing stuff
master ! PoisonPill
Shutdown选项2:创建自定义消息并发送到自定义的参与者：
case class Shutdown()
class Killswitch extends Actor {
override def receive:
浏览 0提问于2018-05-15得票数 1
回答已采纳
1回答
我正在使用spring在我的web应用程序中使用来自RabbitMQ的消息。Web应用程序由多个组件组成，如(Redis，OracleDB)
现在我有了一个场景，如果由于基础设施(如Oracle服务器故障)、Redis连接问题而出现任何异常，我希望将消息推回同一个队列，并且在指定的延迟之后，我想要使用该消息。
在经过一定的延迟之后，消息也会导致相同的异常，可能是，我想使用最大尝试选项，或者执行上面的相同操作，将消息推回队列，并向管理员发送一封邮件，声明“基础设施问题”。
Spring支持上述场景吗？如果是，请提供给我如何提出这样或类似的解决方案。
我尝试了下面的一段代码。消息不是用于死信队列，
浏览 2提问于2018-01-02得票数 2
我试图在akka的帮助下创建简单的tcp服务器。
我的主
import java.net.InetSocketAddress
import akka.actor._
import akka.io._
import Tcp._
object Main extends App {
implicit val actorSystem: ActorSystem = ActorSystem()
val serverRef = actorSystem.actorOf(server.Server.props)
val tcpManager = IO(Tcp)
tc
浏览 2提问于2019-11-08得票数 0
回答已采纳
我试图将一些常见的Akka代码的通用测试纳入一个特性，但是sender ref正在成为deadLetters。使用此FSM代码：
import akka.actor.FSM
import akka.testkit.TestFSMRef
import akka.testkit.TestKit
import akka.actor.ActorSystem
import org.scalatest.Matchers
import org.scalatest.WordSpecLike
import akka.testkit.ImplicitSender
sealed trait MyState
cas
浏览 0提问于2014-11-30得票数 0
回答已采纳
1回答
我正在使用Akka集群，我有一个有趣的问题。节点A上有一个演员Actor1 (akka.tcp://as@127.0.0.1:2554)。此参与者在另一个节点上发现另一个参与者
val actor2sel = context.actorSelection(RootActorPath(m.address) / "user" / "actor2")
其中m是集群的成员。actor2sel是
ActorSelection[Anchor(akka.tcp://as@127.0.0.1:2553/), Path(/user/actor2)]
稍后，Actor1将一条消息转
浏览 0提问于2017-10-16得票数 0
回答已采纳
1回答
在“我的主管参与者”中，子参与者发送一条消息以指示其已完成。然后在onReceive方法中停止这个参与者：
@Override
public void onReceive(Object msg) {
if (msg == Messages.SUCCESS) {
getContext().stop(getSender());
}
}
但这会导致以下信息被打印出来：
[INFO] [10/24/2014 12:12:43.102] [Main-akka.actor.default-dispatcher-6] [akka://Main/user
浏览 4提问于2014-10-24得票数 2
回答已采纳
我试图在一段时间后安排一条信息发送--一次简单的重试。
override def receive = {
case Worked => ???
case DidNotWork =>
val target = sender() // Avoid closing over sender().
import context._
context.system.scheduler.scheduleOnce(500.milliseconds, target, TryAgain)
}
但是，当我接收到TryAgain消息并访问sender()以尝试将这个Acto
浏览 1提问于2014-07-25得票数 0
回答已采纳
我正在使用Azure Service bus，目前有一个进程正在发送无法发送到死信消息队列的消息。但是，如果一天后死信队列上的消息没有重新排队，我希望自动将其从队列中删除。
根据的说法，消息的生存时间是没有观察到的，所以我不确定如何清除超过一天的消息。
浏览 49提问于2020-05-20得票数 0
1回答
我在Windows Server2008上使用NServiceBus和MSMQ。在我们的一个场景中，我们向另一个服务器队列发送命令，但有时消息永远不会到达队列，MSQM也不会抛出异常。
我已经编写了一个小应用程序，它不使用NServiceBus直接将消息发送到队列，并且我遇到了同样的问题。
我认为这不是nservicebus的问题，而是MSMQ的问题: windows安全，网络，...
当消息无法保存到队列中时，如何强制MSMQ返回错误？导致这种行为的可能原因是什么？消失的消息在哪里？
浏览 2提问于2014-06-20得票数 0
关于的问题，之一说：
始终从Actor-子系统线程发送消息。如果这意味着通过Actor.actor方法创建一个临时的Actor，那么就这样吧：
案例ButtonClicked(src) => Actor.actor {控制器！SaveTrade(trdFld.text) }
答案是在2009年写的。这目前是一种良好做法吗？这适用于阿克卡演员吗？
我不认为我的问题是重复的，因为这是指的是一个较老的实现的参与者系统。它确实解释了“最坏做法”职位背后的理由。
浏览 1提问于2014-05-21得票数 4
回答已采纳
2回答
我有以下参与者，它向WebService发送请求：
class VigiaActor extends akka.actor.Actor {
val log = Logging(context.system, this)
context.setReceiveTimeout(5 seconds)
import VigiaActor._
def receive = {
case ObraExists(numero: String, unidadeGestora: String) =>
WS.url(baseURL + s"""/o
浏览 0提问于2017-07-19得票数 1
回答已采纳
2回答
如果我在我的Actor的构造函数中安排了一条消息，而参与者在发送消息之前失败(异常)，那么会发生什么？
当参与者恢复或重新启动时，消息会像什么都没有发生一样发送吗？
当演员被停止时，信息会发送到死信箱吗？
当我在preStart()中启动计时器时，当参与者在失败后重新启动时，我会有两条预定消息吗？
浏览 3提问于2014-04-03得票数 1
回答已采纳
我有一个主管角色，它根据接收到的命令选择子演员，每当它创建一个新的子参与者并发送消息(询问模式)时，它会超时，因为子演员试图发送回响应，但是它会变成死信。
这是子演员代码
class IdActor(id: String, injector: Injector) extends Actor {
override def receive: Receive = {
case cmd: GenerateIdCmd =>
val parent = sender()
...
Future(idEvent) pipeTo sender //Issue
浏览 3提问于2017-11-17得票数 0
回答已采纳
1回答
我必须将一些消息从一个主题移动到一个队列，然后转发到另一个队列，以更改消息的到期日期。我这样做了几次，最终达到了最大跳数，正如用编写的那样，它是4。
如何更改MaxTransferHopCountExceeded的值，或者是否有什么技巧可以将一百万条消息从死信队列移动到活动队列，以便我可以使用它们？
我在azure上有一个高级订阅。
浏览 2提问于2020-01-13得票数 0
我正在按照nodejs示例检索发送到死信队列的消息。我用这种方式向Q推送死信：
await brokeredMessage.deadLetter({
deadletterReason: 'bad',
deadLetterErrorDescription: 'too bad, so sad.',
});
我确实看到死信计数是2在Azure。无论这些邮件是由于我上面的死信代码而到达的，还是由于其他一些事故导致了死信，我在DLQ中有2条。但是，我不能用以下方法检索它们：
const client = ns.createQueueCl
浏览 0提问于2019-02-22得票数 1
回答已采纳
我有一个参与者，它聚合任意数量的子参与者消息。各次演员之间的联系顺序如下：
system.actorSelection(s"/user/$groupId-${index + 1}*") ! Declare
这给了我一个想法，使用死信计数作为我的关闭例程触发后X字母和一些硬编码睡眠。鉴于下面的日志，Akka似乎没有在一个点之后进行聚合：
[...] was not delivered. [10] dead letters encountered, no more dead letters will be logged.[...]
但是这告诉我，有一种可靠的方法可以设置一个听者来统
浏览 3提问于2019-07-08得票数 0
回答已采纳
3回答
我正在使用azure服务总线主题和订阅机制，并希望处理所有在死信队列中的消息。
此外，我想通过C#中的azure web作业处理消息，并将它们发送回队列。所以我想知道如何通过我的应用程序处理死信队列中的消息？
浏览 0提问于2017-10-20得票数 6
我正在使用Service Bus Queue将项目从生产者传递到消费者。生产者能够成功地将项发送到队列，而消费者可以正确地接收，但随后它显示出奇怪的行为，即接收方法返回null (没有错误)代理消息，即使队列有数千条消息也是如此。我的队列出了什么问题？
这里要提到的一件事是，在测试中，我对队列调用了Close()方法。但它只做过一次，而且是在测试时。但是现在，每次我运行接收方法时，都会返回null代理消息。
浏览 0提问于2013-05-08得票数 0
回答已采纳
每当参与者在scala中收到消息时，我们都可以通过使用关键字' sender‘来访问参与者的发送者，这是一个特征AbstractActor的对象。
我的问题是，每当收到消息时，这个“发送者”是如何变得可访问的。
此外，我们是否可以覆盖这种实现，其中除了发送者之外，还可以访问一些其他数据，例如数据来自的is地址和端口。
据我所知，您无法从消息传入的位置获取is地址和端口。有没有什么方法可以从这个' sender‘对象中获取发送者的Is地址和端口号？
谢谢你的帮助。
浏览 8提问于2012-11-14得票数 6
实际上“为每个逻辑应用程序创建一个”是什么意思？我在Scala中有一个企业应用程序，其中有5个模块将独立部署。我使用过ActorSystem.create("...")在每个模块中创建大约4或5个系统参与者，如消息，财务，销售，工作流程，安全。
我必须做ActorSystem.create("...")吗？只有一次？对于我的企业应用程序，上面有5个模块。或者我做得对吗？
浏览 0提问于2015-08-29得票数 1
我使用的是一个azure函数，每当一个新消息发布到主题+订阅(而不是队列！)时，它就被调用。
在azure函数体中，我到底需要做什么才能显式地将它移到死信子队列中？
根据天蓝色的说法，
超过MaxDeliveryCount的队列和订阅分别具有QueueDescription.MaxDeliveryCount和SubscriptionDescription.MaxDeliveryCount属性；默认值为10。每当消息在锁(ReceiveMode.PeekLock)下传递，但已显式放弃或锁已过期时，消息BrokeredMessage.DeliveryCount将递增。当DeliveryCount
浏览 1提问于2019-01-12得票数 2
3回答
我有一个参与者，在接收到消息时，在文件系统中搜索一个文件并返回文件的完整路径。
为了保持它的异步性，我做了以下工作：
def receive = {
case s:String => {
val f = future{
val ans = search(s)
println("Input Request: "+s+" output:"+ans+" "+sender.path)
}
f.onComplete{
case Success(x) => sender ! x
浏览 2提问于2013-06-03得票数 20
回答已采纳
1回答
我试图使用具有复杂逻辑的参与者模型来构建跨消息传递的系统，因此有一个参与者从一开始就发送消息并侦听传入的响应。此外，使用UDP数据报完成消息传递。
因此，给定的actor依赖于消息sender，这意味着系统必须首先创建消息sender。为了将传入的消息传递给参与者，message listener必须依赖于参与者(它执行类似于actor.Post incomingMessage的操作)。
问题是初始化顺序:似乎我应该先创建sender，然后创建actor，最后创建listener，但是如果系统是以这种方式构建的，那么当参与者已经发送消息并侦听应答时，可能会出现传入消息丢失，但侦听器尚未初始化。
浏览 2提问于2017-08-24得票数 3
回答已采纳
1回答
我想要处理其中一个类中的一组异常，该类使用@Named进行注释。
我正在使用AKKA角色来实现并发。也使用Hibernate。
在我的Akka actor类中，我调用了用于插入操作的hibernate方法。我想知道如何全局处理所有actor类中的异常。我可以使用@ExceptionHandler和@ControllerAdvice做到这一点。但我相信它只在@Controller层起作用。
示例代码如下：
@Named("SaveDepartmentService")
public class SaveDepartmentService extends BaseCommonSe
浏览 4提问于2014-05-28得票数 1
3回答
不确定这个问题的措辞是否清晰(这是我能想到的最好的)，但这里有一个例子来澄清问题。我有一个观点，Chats，它应该总结两个人之间的对话历史。视图由以下列组成：Sender、Recipient、Timestamp、LatestMessage和UnreadMessageCount。
Chats视图的列都来自一个表Direct_Messages，该表存储系统用户之间交换的个人聊天消息的详细信息。下面是它的列：ID、Sender、Recipient、Body、Timestamp、TimeRead (如果收件人没有读取消息，则为null )。视图的Timestamp和LatestMessage列具有两个
浏览 2提问于2019-01-14得票数 0
回答已采纳
1回答
我有一个MSMQ队列，由五个windows服务监听。为此，我使用了BeginPeek和PeekCompleted事件。我的问题是在五个服务中，只有一个服务是消息的正确接收者。所有四个只读取消息，但不执行任何操作。只有当我们读取MQ消息时才能识别这一点。现在，我在我的服务中添加了一个代码来检查，如果条件匹配并且消息是由正确的服务处理的，那么我将使用接收从MSMQ中排出消息的队列。这是个好主意吗
第二，如果消息不满足条件，所有五个服务都只是查看它，但没有接收到，则消息仍然位于队列中。我明白。但是相同的消息被处理了无限次，因为消息从未被删除。
private void queue_PeekCompl
浏览 1提问于2017-10-14得票数 0
回答已采纳
我试图捕捉从子角色到父角色的“终止信号”，但是在死信消息池中，信号未能到达父参与者的队列。解决这个问题的最好方法是什么？
下面是我正在编写的代码片段：
class MinerActor extends Actor {
var count:Int = 0
def receive = {
case Mine =>
//some task here
//if success
count = count + 1
//
if (count
浏览 2提问于2015-09-11得票数 1
回答已采纳
1回答
我最近开始工作的Azure服务总线模块，这是目前在我们的项目中使用。当前的模型是，我们向一个主题发送消息，并且该主题有多个订阅。订阅没有过滤器，订阅者使用它(目前不想添加筛选器)。
问题:假设有一个主题和三个订阅。发送到主题的消息被广播到所有订阅，来自两个订阅的应用程序使用它。第三个订阅的应用程序会下降，并且消息不会被消耗。
来自第三次订阅的消息发生了什么，在TTL有方法找出消息没有消耗之后，它会被发送到死信队列中吗？
浏览 0提问于2019-10-18得票数 0
1回答
我目前有一个azure函数，它处理来自服务总线的DLQ的消息。我想要实现的是尝试手动处理它，但是如果它不能成功地将消息转发回DLQ，并且基于自定义逻辑进行处理3次。我正在接收ServiceBusReceivedMessage对象，但是当我试图将它发送回DLQ时，要么通过创建一个新的ServiceBusClient，要么通过使用ServiceBusMessageActions，我要么得到一个The lock supplied is invalid. Either the lock expired, or the message has already been removed from the
浏览 8提问于2022-07-06得票数 0
回答已采纳
1回答
我正在编写简单的spray客户端代码：
// ActorSystem("main-actor-system") initialized earlier in code
implicit val system = actorSystem
implicit val execctx: scala.concurrent.ExecutionContext = system.dispatcher
implicit val timeout = Timeout(10.seconds)
val pipeline: Future[pipelining.WithTransformerConca
浏览 3提问于2016-02-17得票数 0
1回答
我最近升级到了Akka 2.6.10。现在，当我用ActorTestKit为我的角色运行测试时，我看到了很多类似这样的警告 [WARN] [12/16/2020 09:03:14.995] [AsyncTestWithControlledTime-akka.actor.internal-dispatcher-3] [akka://AsyncTestWithControlledTime/user/$a] received dead letter: GotCriticalFailure(my custom error message,akka.stream.AbruptStageTerminat
浏览 15提问于2020-12-16得票数 0
我读到，Akka消息是按任意两个角色A和B之间的顺序排列的，如果A按照1，2，3，4的顺序发送消息，他们必须按照这个顺序到达。
我还读到阿克卡的消息不可靠。
这两件事怎么可能是真的？如果消息到达1，然后是4，然后是3，但是2从未被传递，那么会发生什么呢？
为了澄清，如果消息1、2、3和4存在，并按该顺序从行为者A发送。
让我们考虑这些要点( a)、b)、c( d) )。
( a)在演员B，信息1到达。
( b)然后在演员B处，消息4到达。
( c)然后在参与者B处，消息3到达。
( d)信息2丢失。
在a点)我认为没有问题，参与者B处理消息。
在b点)我看到了一个问题，因为消息排序规则，参
浏览 3提问于2014-04-16得票数 6
回答已采纳
在我的akka应用程序中，我使用一个主参与者作为控制器，它接收命令并在完成后将其委托给处理器参与者.Processor参与者(完成每个任务大约需要2分钟)，将消息传递给控制器，然后将消息发送给数据库参与者，以便持久。处理器参与者和db数据库参与者都使用路由器进行管理，每个路由器都有5个路由器。我使用的是默认调度程序，所有其他的akka配置都是默认的，只有下面的.Now是场景。
控制器参与者正在接收大约100条消息，这些消息被传递给处理器参与者，我可以从日志中看到处理器已经完成了一些消息(大约5条)，并将完成消息传递给控制器参与者。但是数据库参与者在大约5分钟后开始执行。然而，在这5分钟内，处理
浏览 2提问于2020-03-07得票数 0
回答已采纳
我有一个演员系统，由3个演员组成，如下所示
RMQreaderActor -这是一个参与者，它从RMQ读取消息，并告诉下面两个参与者转换并处理消息。
ConverterActor
ProcessorActor
我的要求是将actorsystem集群到4个节点中，但我不希望所有节点中的RMQreaderactor从队列中读取消息。只有一个节点应该读取消息并告诉其他参与者进行处理。
注意:如果我使所有节点的RMQreaderactor从队列中读取消息，那么它将导致重复读取(因为我读取时不会立即发出Ack )。
你能帮我解决我的要求吗？
浏览 1提问于2016-12-14得票数 0
1回答
我有一个Google /Sub订阅，它使用的是一个死信主题。最近，我遇到了一次中断，这使得许多消息无法被处理&它们最终出现在死信的话题中。
中断问题已经解决，我想很容易地将死信订阅的内容发送回原始订阅。它们都还在队列中(我没有使用死信子)，所以我只需要将它们路由到某个地方。
这是一个管理任务，所以我希望它是手动启动，如果这有任何区别。理想情况下，通过UI，但我看不到任何东西。
浏览 1提问于2020-05-07得票数 7
回答已采纳
2回答
我有一个子“消费者”参与者，它连接到一些外部数据流，解析其消息，并在应用程序中进一步转发它们。此“生产者”系统具有发布-订阅体系结构，但在重新连接后不会恢复订阅。目前，我将这些订阅存储在父actor中，并在supervisor中重新发送它们，但问题是，当子进程重新启动时，它们会被转发到死信队列。我可以在一些延迟之后尝试将这些安排到父级，但这可能会干扰订阅顺序，这是很重要的。
那么，当子进程重新启动时，我该如何将这些“重新订阅”消息传递给子进程呢？
浏览 14提问于2016-09-13得票数 1
回答已采纳
1回答
我知道参与者模型的一个优点是，一次只处理一条消息，就简化了并发问题。但在我看来，我的演员正在处理多条信息。在伪代码中
var status = 0
def receive = {
case DoSomething =>
val dest = sender()
status = 0
for {
otherActor <- resolveOtherActor("/user/OtherActor")
} yield {
for {
res <- {status = 1
浏览 2提问于2017-07-31得票数 0
回答已采纳
2回答
然后，代理接收消息并将其发送到死信队列，以便稍后对其进行分析。
以下是activemq文章的引号。我的策略也是一样的。稍后我想分析死信队列中的消息。我怎么能这么做？
浏览 2提问于2017-10-19得票数 3
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储活动推荐
腾讯云开发者
