未创建死信队列
是指在消息队列中没有配置死信队列（Dead Letter Queue, DLQ）。死信队列是一种特殊的消息队列，用于存储那些无法被消费者成功消费的消息。
概念：死信队列是消息队列中的一种特殊队列，用于存储不能被消费者成功消费的消息。当消息被发送到队列中后，如果满足一定条件（例如消息被消费次数超过限制、消息过期等），则会被发送到死信队列中。
分类：死信队列可以根据使用场景进行分类，如延迟队列、异常处理队列等。
优势：
- 异常处理：通过死信队列，可以将消费失败的消息进行集中处理，方便排查问题和进行异常处理。
- 延迟消息处理：可以将某些需要延迟处理的消息发送到死信队列，在一定时间后再进行消费。
- 业务解耦：死信队列可以将不同业务之间的消息进行解耦，减少各业务之间的耦合度。
应用场景：
- 异常处理：当消息消费失败时，可以将失败的消息发送到死信队列进行异常处理。
- 延迟消息处理：某些场景下需要延迟处理的消息，可以发送到死信队列中，在一定时间后再进行消费。
- 业务解耦：不同业务之间需要解耦时，可以使用死信队列。
推荐的腾讯云相关产品和产品介绍链接地址： 腾讯云提供了丰富的消息队列服务产品，可以用于实现死信队列功能，以下是其中几个产品的介绍链接：
- 腾讯云消息队列 CMQ（Cloud Message Queue）：提供了消息发布与订阅、延迟消息等功能，可以实现死信队列。详情请查看：腾讯云消息队列 CMQ
- 腾讯云云托管消息队列 TDMQ（Tencent Distributed Message Queue）：分布式消息队列服务，具备高可用、高可靠、高性能的特点，支持死信队列等特性。详情请查看：腾讯云云托管消息队列 TDMQ
- 腾讯云云函数 SCF（Serverless Cloud Function）：通过事件触发的无服务器计算服务，可以与消息队列结合实现死信队列的功能。详情请查看：腾讯云云函数 SCF
相关·内容
我正在使用SQS来保存http请求。如何使消息保持活动状态(在队列中)，以便在请求失败时重新处理，而不被另一个进程捕获？
浏览 0提问于2020-07-24得票数 0
我创建了Azure服务总线，并使用Azure函数侦听消息。
如果我将在处理消息时抛出函数中的异常。然后，在消息被移动到死信队列之前，整个进程将被重复10次。
但是毒药队列呢？为什么我哪儿都看不见那个队列？我甚至用下面的名称约定{main_name}-poison创建了这样的队列，假设可能存在某种模式，但没有。
因此，这是否意味着在Azure服务总线中没有毒药队列，并且这个概念只属于eg。Azure队列存储
浏览 4提问于2022-03-17得票数 0
回答已采纳
使用Elastic Beanstalk，我从管理控制台创建了worker 1.1层(运行Ruby 1.9.3的64位Amazon Linux 2014.03 v1.0.3 )。当涉及到配置工作进程详细信息时，我选择了“自动生成队列”。当我这样做时，生成了两个SQS队列(worker和dead letter)，但是我的worker实例的"Worker queue URL“被设置为dead letter队列url。我想应该是工作队列吧？如果我尝试将其更改为worker配置中的worker队列，两个队列都将被删除(worker和死信)。谁能告诉我这是否是正常行为？
浏览 0提问于2014-06-12得票数 5
在使用WebJobs在服务总线中进行某些迭代(10)后，不会创建有害队列。目前，我运行Azure免费版和Azure 2.7。我知道，当Web作业无法处理时，应该在某些迭代之后创建Poison队列。是因为免费版。
浏览 5提问于2015-08-31得票数 0
回答已采纳
2回答
如果有一个在ActiveMQ中创建的队列，它有一个生产者(这是客户端确认模式)和一个侦听器，在它的onMessage方法中，只有在成功处理消息之后，它才会被确认。假设存在异常，消息保持未确认状态，因此保留在队列中。是否会再次发送给消费者？或者这样的消息会发生什么？
浏览 1提问于2020-02-18得票数 1
最近，我编写了一些代码，将从azure服务总线发出的死信队列消息处理为报表。
我正试图通过将大量的消息上传到死信队列中来测试该代码，以供其处理。
我组装了一个c# linqpad /控制台应用程序，该应用程序读取一个文本文件文件夹，并尝试使用Azure.Messaging.ServiceBus客户机库将每个文本文件作为消息发送给我的testqueue/$死信，如下所示：
var files = Directory.GetFiles(messagePath,filePattern);
var client = new ServiceBusClient(connectionString);
var
浏览 10提问于2021-12-06得票数 1
回答已采纳
据我所知，没有办法验证一个队列是否应该是另一个源队列的死信队列。例如，如果我有一个名为'my- queue‘的队列，它有一个名为'dlq- For -my- queue’的死信队列。我想通过API验证' dlq - for -my-queue‘是否被配置为'my-queue’的dlq。 我之所以这样问，是因为我想创建一个自动化，为我的所有队列配置死信队列，但如果我这样做，它将为我的死信队列创建死信队列……这是我不想发生的。 你有什么建议吗?我该怎么做？
浏览 19提问于2021-10-11得票数 1
我希望创建一个连接到死信队列的SQS队列。我希望将接收到但不能正确处理来自SQS队列的消息放到死信队列中。此外，我想设置这个做云形成。我看过了。但是我仍然对设置这个程序的过程有疑问。我看到了下面的代码片段，这些代码片段显示了如何做到这一点：
AWSTemplateFormatVersion: "2010-09-09"
Resources:
MySourceQueue:
Type: AWS::SQS::Queue
Properties:
RedrivePolicy:
deadLetterTargetArn:
浏览 1提问于2019-03-04得票数 4
我需要处理死信队列中的消息。我如何为这个创建处理程序？另外，我还需要处理来自错误队列的消息，这些消息也是死信的。
浏览 0提问于2017-03-29得票数 0
回答已采纳
1回答
@RabbitListener(queues="XYZ")
public void rabbitMsgReceiver(@Payload final UserProfile up, Message msg, Channel channel) {
}
如果接收到的消息不是UserProfile的有效JSON，则发生ListenerExecutionFailedException，消息转到unack状态。如何将消息发送到死信队列？
浏览 17提问于2018-11-28得票数 2
我使用的是rabbitMQ，我使用basic_get从队列中获取每条消息，而不是自动ack过程，这意味着消息会一直留在队列中，直到我确认或拒绝该消息。
有时我会遇到一些无法处理的消息，因为抛出了一些异常，导致它们无法被完全处理。
问题是，如果我同时确认成功和异常抛出的消息，这有什么关系呢?我的意思是，从结果消息总是从队列中出来的角度来看，那么在这种情况下使用ack或nack又有什么关系呢？也许我在使用每个操作时遗漏了一些东西？
浏览 0提问于2015-03-01得票数 33
回答已采纳
1回答
当使用MSMQ和WCF时，请描述确定死信队列 URI的算法/规则。
例如：net.msmq://localhost/private/MyQueue;DeadLetter或net.msmq://localhost/system$;DeadLetter或其他什么？
我问这个问题是因为我发现了一个我不同意答案的转变问题，但是我没有找到一个清晰的定义来准确地描述规则。我查过MSDN和两本鱼书。
浏览 2提问于2012-01-08得票数 2
回答已采纳
2回答
我们有一个监听Azure服务总线队列的服务。我们有另一个服务来监听这个队列的死信队列。我们也有一系列的测试，当我们的Azure应用程序已经部署好的时候，这些测试就会运行。
我们希望扩展我们的自动化测试，以便也测试处理死信的部分，但不确定如何编写测试，以确保消息到达死信队列，因为在正常情况下，消息不会死信。
目前我们正在手动测试，但我觉得这不是一个长期的选择。
有什么想法吗？
浏览 3提问于2013-04-25得票数 3
我正在尝试在我的应用程序中实现下面的场景
扩展e1 ->队列q1
DLX交换e2 -> q2
此外，我还提到了Quee-Q1中的DLE和DLK，然后消息在拒绝/失败/超时时移动到队列-Q2。
但是，我如何从Quee-Q2重新发送/重试消息到原始队列-Q1？
浏览 0提问于2018-10-09得票数 0
回答已采纳
我有lambda函数。它是由无服务器部署的。因此，规则总是自动在我的自定义事件总线中创建的。在我把一个测试事件发送到我的巴士上之后。这个规则可以触发。但总是被调用失败。我试图找出原因，但除了调用度量之外，什么都看不见。
奇怪的是，如果我手动为同样的规则创建规则。这个手动创建的规则总是可以触发并成功地调用lambda函数。
浏览 3提问于2022-09-16得票数 0
1回答
我在Azure服务总线中设置了一个队列，消息TTL为5秒(这是不是太短了？)我注意到它会在活动状态下停留超过5秒)。
在它过期后，我希望它被转发到另一个队列进行处理(超时队列)。我已经将ForwardDeadLetteredMessagesTo属性设置为超时队列的名称，但是当消息在原始队列上过期时，它只是进入原始队列--死信队列，而不是进入超时队列。
我是不是误解了这是怎么回事？
我的用例是，我有一些消费者只在一天中的某些时候监听主队列。如果没有侦听主队列，我希望它过期并被推送到超时队列。超时队列总是有一个使用者，因此它应该接收该消息并正确地处理它。我可以有多个主队列，所以我希望让所有的主队列
浏览 2提问于2018-05-31得票数 0
2回答
我想处理来自Amazon死信队列的消息。
处理它们的最佳方法是什么？
从死信队列接收消息并进行处理。
从死信队列接收消息，把它放回主队列，然后处理它？
我只需要偶尔处理一下死信队列中的消息。
浏览 0提问于2018-05-16得票数 3
回答已采纳
1回答
我能读DLQ消息。他们有4000人。我相信我只能读懂其中的250或270本。其余的信息只是重复他们自己。我认为这与接收时间有关：
IMessage msg = deadletterReceiver.receive(Duration.ofMinutes(10));
我做了几秒钟，或者几分钟，都不重要。我只能阅读其中的250-260，然后相同的重复。是否有不同的方法来读取所有4k DLQ消息？
我不想做这个deadletterReceiver.completeAsync(message.getLockToken()); ，但是会删除这些消息，而那些DLQ消息是无价之宝。
浏览 1提问于2019-05-09得票数 0
回答已采纳
我正在学习DLQ如何在Azure service bus queue中工作。也就是说，未使用的消息将在DLQ中。我在消息过期时启用了死字(deadLetteringOnMessageExpiration)。
参考资料：
AMR模板：
问题：
如果启用了screenshot)?If ，DLQ是否可用于该队列(如下面的“是的”，我如何处理来自DLQ的消息？(我想我可以在这里看到这样的消息，但不确定接下来会发生什么)
我的目标是使用DLQ创建一个队列，其中可以在某个点处理未处理的消息，实现这一目标的最佳方法是什么。
浏览 3提问于2022-08-10得票数 0
回答已采纳
1回答
我在我的应用程序中使用IBM Websphere和MQ，现在我想知道如何配置(或)使Websphere了解在MQ中创建了一个死信队列(比如DEAD.QUEUE )，并且在处理来自请求/响应队列的消息时，如果出现任何故障，它应该使用这个队列。
我之所以尝试这样做，是因为队列中有一个失败的消息，它试图一次又一次地将其重新发布到队列中。如果配置了死信队列，那么我猜这可能会被停止。如果我错了，请纠正我。
浏览 3提问于2013-05-28得票数 2
回答已采纳
据我所知，我目前正与Azure服务巴士公司合作：
超过最大传递尝试次数的消息将被移动到毒队列中。
将消息移动到死信队列是一种手动操作。
如果我没有任何特定的需求，那么将消息从有毒队列转移到死信队列(使用选项)是否是一个好做法？
浏览 4提问于2016-02-09得票数 1
回答已采纳
1回答
是否可以使用ServiceBusClient提前接收计划的消息？不管它们排队的时间是多少，我想现在就读取这些消息并立即处理它们。有一种方法可以读取延迟的ReceiveDeferredMessageAsync消息，但不能读取计划的消息。有没有解决这个问题的办法？
我知道ReceiveMessageAsync可能会占用最长的等待时间，所以我可以让它继续运行，但在这种情况下，我需要尽快处理消息。
var asbReceiver = new ServiceBusClient(namespaceConnectionString).CreateReceiver(queueName);
var messa
浏览 0提问于2021-06-01得票数 0
2回答
我在azure服务总线死信队列中有大量的消息。当我看到这些消息时，我发现大多数消息都已过期。
我想知道当我们尝试将过期的死信队列消息重新提交回其原始队列时会发生什么？
有人能帮我解释一下吗？
谢谢！
浏览 0提问于2017-02-22得票数 1
我有一个简单的Spring应用程序(SpringBootVersion1.5.3.RELEASE)，用于从ActiveMQ(Version5.14.5)队列中消费JMS消息。
我希望在JMS事务中使用这些消息。如果在消息消耗过程中出现异常，我希望事务将被回滚，而消息不会被退出队列(从消息队列中删除)。在Spring中，我可以看到事务正在回滚，但是消息仍然从ActiveMQ队列(经过六次重传尝试)中退出队列。
任何指示都将不胜感激。
以下是应用程序代码：
@SpringBootApplication
public class SpringJmsDemoApplication {
public
浏览 1提问于2017-05-24得票数 3
回答已采纳
1回答
我必须将一些消息从一个主题移动到一个队列，然后转发到另一个队列，以更改消息的到期日期。我这样做了几次，最终达到了最大跳数，正如用编写的那样，它是4。
如何更改MaxTransferHopCountExceeded的值，或者是否有什么技巧可以将一百万条消息从死信队列移动到活动队列，以便我可以使用它们？
我在azure上有一个高级订阅。
浏览 2提问于2020-01-13得票数 0
我希望我的pub/sub只将最后可用的消息存储在通道上，并转储由于用户太慢(或暂停)而不会被消耗的所有先前的消息。ZMQ有选项，但是RabbitMQ在Python (pika)上有类似的选项吗？
发布服务器以50 to进行更新，而一些订阅者处理的速度却不太快(在10到50 to之间)。我不希望他们处理队列中最古老的消息(这意味着处理已经过时的数据)；当它准备使用时，它必须只处理最后可用的消息。
浏览 1提问于2018-05-01得票数 0
回答已采纳
1回答
我有一个javascript Azure函数，它将一条消息放到服务总线队列上：
module.exports = function (context, req) {
var flatten = require('flat')
var message = flatten(req.body);
context.bindings.outputSbMsg = message;
context.done();
};
当它通过Http触发器运行时，函数成功完成。但是，消息最终出现在Service Bus中的死信队列中。我在日志中看不到任何错误。我应该在哪里调查这是什么原因
浏览 0提问于2018-05-31得票数 0
我正在使用Azure Service bus，目前有一个进程正在发送无法发送到死信消息队列的消息。但是，如果一天后死信队列上的消息没有重新排队，我希望自动将其从队列中删除。
根据的说法，消息的生存时间是没有观察到的，所以我不确定如何清除超过一天的消息。
浏览 49提问于2020-05-20得票数 0
我创建了一个从ActiveMQ读取消息的MDB
@MessageDriven(name = "MessageReaderEJB",
activationConfig = {
@ActivationConfigProperty(propertyName = "acknowledgeMode",
propertyValue = "Auto-acknowledge"),
@ActivationConfigProperty(propertyName =
浏览 3提问于2017-05-18得票数 0
回答已采纳
1回答
我在Windows Server2008上使用NServiceBus和MSMQ。在我们的一个场景中，我们向另一个服务器队列发送命令，但有时消息永远不会到达队列，MSQM也不会抛出异常。
我已经编写了一个小应用程序，它不使用NServiceBus直接将消息发送到队列，并且我遇到了同样的问题。
我认为这不是nservicebus的问题，而是MSMQ的问题: windows安全，网络，...
当消息无法保存到队列中时，如何强制MSMQ返回错误？导致这种行为的可能原因是什么？消失的消息在哪里？
浏览 2提问于2014-06-20得票数 0
我想在Azure中创建一个警报，当一条消息命中azure servicebus中的死信队列时，我检查了监控，但看不到一个“新”消息到达队列的选项。还有，有没有办法通过Azure本身或者通过Azure CLI而不使用第三方应用来查看DeadLetterQueues呢？
浏览 3提问于2021-05-05得票数 1
1回答
我正在处理Azure ServiceBus主题订阅。我在Service Bus命名空间中创建了一个主题和两个订阅。在我当前的应用程序中，我可以在通过使用订阅者接收消息之后向topic发送消息。
但是当一个订阅者从主题中读取消息时，这些消息就会进入死信队列。这就是为什么第二个订阅者无法从主题中读取消息的原因。
我在主题中的process message之后在我的代码中编写了这一行
await subscriptionClient.CompleteAsync(message.SystemProperties.LockToken);
我遵循这个来实现上面的场景。
那么，有没有人可以建议我如何一次使用
浏览 2提问于2019-03-07得票数 0
我有一个具有x-expires集的队列。我面临的问题是，如果队列过期，则需要对中的消息进行进一步处理。我最初的想法是在队列中设置x-dead-letter-exchange。但是，当队列过期时，消息就会消失，而不会进入死信交换。
我如何处理处于过期队列中的死信或其他消息？
浏览 1提问于2019-12-10得票数 1
有Azure服务总线消息过期事件吗？
根据这个TimeToLive属性，可以看到。我正在发送消息到azure服务总线队列，并需要确定这些消息何时过期。
浏览 2提问于2020-04-21得票数 1
我有一个lambda函数，它的触发器是SQS。当lambda执行时，它会抛出一个错误或不抛出错误。它将把作业放回队列中，并创建一个循环，您肯定知道AWS账单:)
我是否应该在lambda函数中返回一些内容，让SQS知道我得到了消息(完成了任务)？我该怎么写这条信息呢？据我所知，我们在SQS中没有ack和nack。
如果任何作业失败，SQS配置中是否有任何选项只能重试N次？
浏览 3提问于2021-11-20得票数 2
回答已采纳
2回答
我试图使用以下代码从死信队列中删除消息：
QueueDescription qd = _queueManager.GetQueue(queueID);
QueueClient qc = _senderFactory.CreateQueueClient(queueID, ReceiveMode.ReceiveAndDelete);
received = qc.ReceiveBatch(deadMessageCount);
while (received != null && received.Count<BrokeredMessage>() > 0)
re
浏览 2提问于2015-01-24得票数 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
回答已采纳
我使用一个CloudFormation模板为SQS创建一个堆栈。我有一个SQS队列集，它依赖于另一个SQS队列，用作DLQ。当我创建堆栈时，我会得到以下错误：
Value {"deadLetterTargetArn":"arn:aws:sqs:eu-west-1:xxxxxxxxx:services-abc-dlq","maxReceiveCount":"10"} for parameter RedrivePolicy is invalid. Reason: Dead letter target does not exist.
如
浏览 1提问于2015-09-10得票数 6
回答已采纳
我有Azure的主要功能应用程序，处理来自服务总线的消息。
如果由于API下降而发生异常，则将消息推入死信队列。
我有另一个天蓝色死神功能应用程序，它不断读取DLQ并将消息推回主队列。
并且主函数应用程序检查api是否下降，然后再将消息推送到DLQ，这应该继续下去，直到API上升，主函数应用程序成功地处理消息为止。
但问题是经过一段时间消息自动清除。
我检查默认的消息存活时间是2小时30分钟，但是消息不能停留这么长时间。当我将消息推回Main时，我认为在死函数应用程序中。在主队列中，消息可能是重复的，但不确定。
在给定的默认消息生存期内，我应该如何将消息保存到DLQ中？
死信功能应用
浏览 8提问于2020-10-01得票数 0
回答已采纳
1回答
在一个项目中，我的要求是得到蓝色死信的数量。如果计数大于0，那么我必须得到每条死信的详细信息，比如描述或死信的原因，然后保存到cosmos db中。为了获得死信计数，我使用了代码：
NamespaceManager namespaceManager=Microsoft.ServiceBus.NamespaceManager.CreateFromConnectionString(sbConnectionString);
var abc = namespaceManager.GetQueue("").MessageCountDetails;
var dead
浏览 1提问于2017-12-27得票数 0
回答已采纳
1回答
我通过生产者向RabbitMQ发送一条普通消息，然后发送第二条消息，并将expiration属性分配给一个值。然后使用rabbitmqctl list_queues命令监视消息的状态。
我发现，如果我先发送一条普通消息，然后发送一条带有expiration的消息，则rabbitmqctl list_queues总是显示队列中有两条消息处于挂起状态。当我消费它们时，我只得到一个。
另一方面，如果我只用expiration发送一条消息，一开始我会看到消息，然后在正确的过期时间之后，我发现它被删除了。
我的问题是，在第一种情况下，消息实际上是占用空间的吗？或者这是一个接口错误？
我的rabbitMQ
浏览 2提问于2015-01-17得票数 11
回答已采纳
1回答
死信队列
、
我的问题是关于WebSphere MQ的死信。
如何查看ISPF队列管理器的死信？
每个队列管理器都有一个默认的死信队列，或者我需要定义它？
非常感谢！
浏览 5提问于2014-05-24得票数 1
1回答
我有一个带有策略的队列：
{
"Version": "2012-10-17",
"Statement": [
{
"Effect": "Allow",
"Principal": {
"Service": "sns.amazonaws.com"
},
"Action": "sqs:SendMessage",
"Resource":
浏览 11提问于2022-06-06得票数 0
回答已采纳
1回答
每当我无法处理RabbitMQ中的事件/消息时，我都会存储到MongoDB中，以便进行自动和/或手动重试。问题是如何从MongoDB启用自动重试机制。我如何才能有效地收听MongoDB？在MongoDB中预先存储失败的事件/消息好吗？或者我应该创建错误队列，以便在自动重试失败时将失败的事件/消息推送到MongoDB进行手动重试？还有其他建议吗？ 我的目的是为失败的RabbitMQ事件/消息设计有效的重试机制
浏览 15提问于2019-01-10得票数 0
1回答
JMS会话接口有两种类似的方法:回滚和恢复。它们在不同的ack模式中使用:事务中的回滚和客户端ack中的恢复。但除此之外，这两种方法的主要区别是什么？
浏览 3提问于2016-09-02得票数 0
我已经创建了一个天蓝色服务总线主题应用程序，它可以查看死信中的所有消息。我查看过的一些特定消息(带有特定消息)需要从死信队列中删除。请提供执行这方面的帮助。
浏览 3提问于2016-02-04得票数 0
1回答
我们有一个外部的SB主题订阅，我们是它的消费者。我们当前正在读取最大并发线程计数为20的SB。 我想知道偶尔排出DLQ的最好方法是什么？是否应该将其包含在同一个应用程序中，或者我是否应该创建另一个应用程序来排出DLQ？ 任何被遵循的标准的指点都将受到高度赞赏。
浏览 22提问于2021-04-26得票数 0
回答已采纳
我正在尝试为Azure Service Bus中的消息计数创建图表，我看到有两个选项
i . Count of Messages in Queue/Topic
ii. Count of Active messages in Queue/Topic
这两者之间的区别是什么？
浏览 0提问于2020-06-16得票数 1
我注意到CloudQueue.ApproximateMessageCount会返回消息的数量，包括过期的消息。这可能是个bug。有没有办法查看队列中有多少消息？
浏览 1提问于2016-06-29得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
