消息队列TDMQ
（Tencent Distributed Message Queue）是腾讯云推出的一种高性能、高可靠、分布式的消息队列服务。它基于云原生架构设计，为用户提供了可靠的消息传递机制，用于解耦和异步处理各种分布式应用程序之间的通信。
TDMQ的主要特点包括：
- 高性能：TDMQ采用了多种优化技术，如零拷贝、批量发送等，以提供高吞吐量和低延迟的消息传递能力。
- 高可靠：TDMQ通过数据冗余和多副本机制，确保消息的可靠性和持久性。它还支持消息的事务性处理，保证消息的一致性。
- 分布式架构：TDMQ采用分布式架构，可以水平扩展，以满足大规模应用的需求。它支持多个消息队列和多个消费者组，实现了消息的负载均衡和故障恢复。
- 简化开发：TDMQ提供了丰富的开发工具和SDK，支持多种编程语言，如Java、Python、Node.js等。开发者可以快速集成TDMQ到自己的应用程序中，实现消息的发送和接收。
- 应用场景：TDMQ广泛应用于微服务架构、大数据处理、实时数据分析、日志收集、事件驱动架构等场景。它可以帮助开发者构建高可靠、高性能的分布式应用系统。
腾讯云提供了TDMQ的相关产品：云消息队列CMQ、消息队列TDMQ、消息队列RocketMQ。其中，TDMQ是基于RocketMQ的企业级消息队列服务，具有更高的性能和可靠性。您可以通过腾讯云官网了解更多关于TDMQ的详细信息和产品介绍：https://cloud.tencent.com/product/tdmq
相关·内容
2回答
已接受的重新排队消息
、、、、
我有一条消息在队列中，但是当消息被成功触发时，我不想从队列中删除该消息。我想将消息保留在那里，以便在另一个时间重新触发，有人知道如何为此配置rabbitMQ吗？
浏览 1提问于2016-08-30得票数 0
1回答
假设我有两个独立的服务，A和B，其中的SQS队列都订阅了SNS主题“topic”。然后，我向SNS主题“主题-foo”发布一条消息m1。
如果服务A( SQS )拥有的SQS队列看到并处理消息m1 (即从队列中弹出消息并处理消息，使其不再在sqs上)，是否仍然可以保证服务B(Sqs)拥有的单独的sqs队列始终能够看到和处理消息m1？(换句话说，AWS发布是否保证将多个消息传递到SQS队列并隔离单独的SQS队列处理？)
浏览 1提问于2017-12-20得票数 0
回答已采纳
3回答
在CMS上进行并发仲裁
、、、
我正在建立一个自定义的CMS，允许用户发布消息到它。消息很短，就像推文一样。
问题是这些消息是由真正的版主主持的。并且有多个版主同时处理消息流。我担心的是，如果这些版主都在处理同一条消息，那该怎么办呢？这既是低效的，也是不一致的。因为一条消息可以被一个版主拒绝，然后由另一个版主传递。
因此，我希望建立某种机制，以便CMS可以将这些消息分发给不同的版主，并避免重复。CMS期望在短时间内处理大量的消息。因此，这个问题变得更加严重。
任何想法都是值得欣赏的。干杯。
浏览 2提问于2010-08-21得票数 0
我正在使用由IronMQ提供的IronIO服务的警报功能来启动工作人员。
我设置了一些东西，以便将消息推送到推送队列中。推送队列发送启动工作人员的警报。工作人员在推送队列中删除消息，并保留它。有时，由于作业失败的原因，对消息的保留过期，消息再次可用。然而，据我所知，当预订在消息上过期时，不会发送任何警报。因此，该消息位于队列中，直到另一条消息被添加到队列中，触发警报并启动工作人员。但是新消息没有被处理。
是否在IronMQ中为有保留的邮件创建了警报？有没有什么我错过的描述会发生什么的文件？
我的工作是让员工获取多条消息，但在处理同一员工中的多条消息时，我遇到了与铁io无关的问题。
还有一种方法
浏览 5提问于2014-08-15得票数 1
回答已采纳
我在一个生产系统上有一个Tibco EMS消息队列，它将消息从一个生产者路由到一个消费者应用程序。
我们正在垂直扩展应用程序，但由于财务限制，我们无法成对扩展这两个应用程序。
单个生产者将消息路由到消息代理，并且消息代理将需要基于消息选择器将消息桥接到3个消费者中的1个。
我已经设置了一个队列桥和选择器来将生产者队列上的消息路由到消费者队列。这是一个1对多的队列桥。
我注意到桥接的消费者队列具有连接到它们的消费者，并且它们基于选择器正确地接收消息，但是生产者队列保留了必须在一天结束时手动清除的消息的副本。
使用桥接器和选择器处理此场景的最佳方式是什么，以便消息保留在代理上，直到它被使用(持久)
浏览 39提问于2016-09-27得票数 1
回答已采纳
通过阅读许多JavaScript事件循环教程，我看到了用于标识队列存储消息的不同术语，这些消息可以在调用堆栈为空时由事件循环获取：
队列
消息队列
事件队列
我找不到标准术语来识别这一点。
就连MDN似乎也在上感到困惑，因为它首先将其称为队列，然后表示消息队列，但在标记中我看到了事件队列。
循环的这一部分是在某个细节中定义的，还是仅仅是一个没有“固定”名称的实现细节？
浏览 0提问于2018-04-09得票数 15
我想知道是否可以编写一个Powershell脚本将消息从一个MSMQ队列移动到另一个？
我在错误队列中有几条失败消息(例如，由于消息涉及对服务器的调用而未完成)，我想通过将它们移回原来的处理队列来重试。我使用NServiceBus v6处理程序来侦听进入原始处理队列的消息，如果消息被放回该队列，这些消息将重新发送消息。
在使用Powershell之前有人这样做过吗？
特别是，我想在Powershell中做以下几点：
根据消息正文中的特定标识符(字符串)查找消息
将此消息移动到特定队列。
我知道Powershell有一些命令，比如。我一直找不到一个例子，我可以在网上重复使用这个功
浏览 6提问于2020-04-01得票数 2
假设有一个发件人一个一个地向一个队列发送100条消息，而三个接收者从队列接收消息，那么JMS默认情况下是否定义接收者不会接收相同的消息，以便每个接收者分配不同的消息？或者它是否可以配置来执行呢？
浏览 0提问于2014-10-24得票数 1
回答已采纳
我们使用以下设置：
我们使用带有队列触发器的Azure函数来处理JSON消息队列。
这些消息都是通过HTTP转发到API端点的，以供进一步处理。
API可以返回3个可能的HTTP状态代码: 200 (OK)、400 (坏请求)、500 (内部服务器错误)。
如果API返回200，则消息被正确处理，一切正常。队列触发器函数似乎自动删除队列消息，这对我们来说很好。
如果API返回400，则API具有接收消息并将其添加到状态指示格式错误或无法处理的表的逻辑。因此，我们可以自动从队列中删除消息，Azure函数可以正常结束。
如果API返回500，我们确保函数重新尝试将消息发送到API，直到状态代码为2
浏览 0提问于2017-05-13得票数 2
回答已采纳
我正在浏览由Rabbitmq官方网站提供的AMQP的。上面写着
队列持久性持久队列被持久化到磁盘，从而生存代理重新启动。不能持久的队列称为临时队列。并不是所有的场景和用例任务队列都是持久的。
队列的持久性不会使路由到该队列的消息持久。如果代理被删除，然后重新启动，则在代理启动期间将重新声明持久队列，但是，只有持久消息才会被恢复。
然而，当Message崩溃时，我对以下情况感到困惑:-
消息由生产者传递到消息交换，但不路由到标记为持久性的队列。
消息由生产者传递到Message，而后者又将消息路由到标记为持久性的队列，但消息在队列中而不是由使用者使用。
消息由生产者传递到Me
浏览 0提问于2018-04-11得票数 4
回答已采纳
我读到了一些关于消息通道和消息队列之间的区别的信息，
据我了解，通道用于连接到队列管理器，而不是连接到队列。
所以通道可以检索/发送消息到不同的队列，或者仅仅是一个特定的队列？但是，当生产者需要将消息放入队列中时，它会指定队列和队列管理器的名称，但是如果不需要生产者指定该信息，则通道知道该信息，对吗？
什么时候有发布/订阅消息的风格，总是使用发送/接收通道？
浏览 0提问于2018-06-20得票数 0
回答已采纳
例如，我有一个具有两个队列的队列管理器。我向Q1发送消息，而不是发送到另一个队列Q2。在Q1中，我的消息在它的体内得到了一些新的东西，比如唯一的ID。
因此，问题是，我是否可以使用Java从Q1获得消息，然后再转到Q2？或者至少能得到一些关于它的信息。
实际上，这个例子非常简单，我只想知道是否有可能在消息离开队列之前获得消息。
更新：
我还有一个具有一些逻辑的消息代理。我的队列管理器和它的队列是本地的。Q2是一个传输队列，从该队列向适配器发送消息。因此，我对浏览我的消息很感兴趣，我将其放在Q1中，然后再转到适配器或Q2中。我可以在不改变消息流触发器和处理程序或更改适配器源代码的情况下使用Jav
浏览 2提问于2017-03-28得票数 0
在Linux中，msgsnd可以从用户空间发送消息。但是，如果发送的消息数量达到最大消息数，msgsnd将阻塞，是否有方法更改最大值？谢谢
浏览 0提问于2020-06-15得票数 0
1回答
我在Azure存储中有一个队列，名为“messages”。每1小时，某个服务推送到这个队列，需要更新数据的消息数量。但是，在某些情况下，我也从另一个地方推送到这个队列消息，我希望这个消息被立即进行，并且我不能为这个消息设置优先级。
解决这个问题的最好办法是什么？我是否可以使用两个不同的队列(“消息”和“消息-优先级”)，或者这是一种糟糕的方法？
浏览 2提问于2014-01-19得票数 11
回答已采纳
我需要安排延迟消息，所以我声明了一个带有x死信交换和x死信路由密钥的延迟队列DELAY_STAT，它将路由到默认的交换到我的目标队列统计数据。
当我需要为队列STAT安排延迟消息时，我会在到期时将消息发布到DELAY_STAT，当到达消息ttl时，它将是一个死信，然后路由到STAT，以便可以使用它。
但是我遇到了一个问题，据说
当设置每条消息时，TTL过期消息可以排在未过期消息的后面，直到后者被使用或过期为止。
这意味着如果B更早地发送，一些短延迟消息A将被长延迟消息B所堆积。
浏览 1提问于2018-06-22得票数 0
是否有办法防止队列中出现重复的消息？但是，一旦使用了消息，队列中就应该再次允许完全相同的消息。
不幸的是，RabbitMQ的标准复制消息插件做了一些不同的事情。它只会阻止重复的消息在一定时间内进入队列。它实际上不检查消息是否已经在队列中。
浏览 15提问于2022-05-09得票数 1
回答已采纳
1回答
我有一个消息主机，它执行来自asb队列的消息。我想创建一个新的消息主机(扩展)(.NET核心)时，它的第一个消息主机的负载是上升的。为了做到这一点，我想将一些消息从一个队列发送到另一个队列，然后消息主机从新的asb队列读取消息。这怎麽可能？
浏览 3提问于2022-09-26得票数 0
我试图理解RabbitMQ中消息删除的逻辑。
我的目标是使消息保持不变，即使没有连接到读取它们的客户端，以便当客户端重新连接时，消息正在等待它们。我可以使用持久的、懒惰的队列，以便将消息持久化到磁盘，并且可以使用HA复制来确保多个节点获得所有排队消息的副本。
我希望使用主题或头路由将消息转到两个或多个队列，并让一个或多个客户端读取每个队列。
我有两个队列，A和B，由报头交换提供。队列A接收所有消息。队列B只获取带有“归档”头的消息。队列A有3个用户正在阅读。队列B有一个消费者。如果B的使用者死了，但是A的使用者继续确认消息，RabbitMQ会删除这些消息还是继续存储它们？在重新启动B之前，队列
浏览 2提问于2018-02-15得票数 4
回答已采纳
需求：I需要我的消息驱动bean ( MDB )能够从四个不同的队列中读取消息，并且应该根据队列的优先级读取消息。
假设-我有4个JMS队列A、B、C和D，优先级分别为8(最高)、7、6和5。所以，如果队列C中有500条消息，而队列A和B是空的。我的MDB应该使用来自队列C的消息。但是，当我在高优先级队列(A或B)中收到消息时，MDB应该停止从C中读取消息，并使用来自较高优先级队列的消息(直到队列为空)，然后继续从低优先级队列中消费。
设置完成：，我正在使用JMS7.0，并在管理控制台中正确地设置了JMS队列的优先级。
高级性能
*优先权:指定
具体优先次序: 8*
问题：，但我的MDB仍然无
浏览 0提问于2015-01-14得票数 0
我正在编写用于监视和修复Azure上的dead letter queue of a topic subscription中的消息的功能。
我可以使用_subscriptionClient.PeekBatch(10)获得一个消息列表，以供显示；但是，当我们想要实际删除其中一条消息时，我们会陷入困境。
工作流程如下：
获取所有消息的列表
将特定消息(例如集合中的第5个on )发送回原始队列进行重新处理。
将相关的死信消息标记为.Complete()。
问题是，虽然我们有消息列表，但如果不首先使用.Complete()，就不能在特定消息上调用.subscriptionClient
浏览 2提问于2013-12-05得票数 9
回答已采纳
1回答
在清理process_B的主线程(它在IPC消息队列上接收消息)时，我有这个调用：
if (msgctl(qId, IPC_RMID, NULL) < 0) {
perror("msgctl");
}
联系到时，报告如下：
msgctl : Invalid argument
Error: failed to remove message queue.
我有另一个process_A，它向process_B发送消息，而不是关机。
然后在man msgctl里有这样的陈述..。
IPC_RMID
Immediately remove
浏览 2提问于2021-10-20得票数 1
回答已采纳
1回答
只想确认MQ向MQOutput节点传递消息的正确方式。最近遇到一种情况，我感到有点困惑.这是一个场景。
我在Qmgr上有一个本地队列，例如(A)，它接收来自应用程序的消息，并有一个与此qmgr(A)相关联的本地代理，并部署了一个消息流，该消息流消耗来自该队列的消息，并将其放到队列管理器(B)上的另一个本地(L.B)队列中。
要成功地将消息传递给qmgr(B)，我是否必须
在Qmgr(A)上创建一个与远程队列管理器名称匹配的传输队列名的远程队列定义，此处(B)将MQOutput节点值设置为，队列->远程队列定义名称(A)，队列管理器值为空白
或
若要只创建与远程队列管理器名称匹配的
浏览 0提问于2015-05-18得票数 3
回答已采纳
1回答
交流和信息优先事项
、、、
我正在努力实现以下目标，
消息到达具有消息优先级的Message
他们根据消息优先级找到进入不同队列的方法。
所以Q1有优先级为1的消息，Q2有优先级为2的消息，等等。
是否有办法使Message处理Q1比其他方法更快。
是否有可能在队列之间设置优先级？
Q1比Q2具有更高的处理优先级，还是更好地处理Q1阻止其他队列被处理？
一个交换本身是否是一个优先级队列，而这个队列反过来又为其他队列提供服务？
我看到可以通过插件扩展默认的交换，有什么已经实现了上述要求的东西吗？
这是可行的吗？还是这违背了消息代理的基本理念？
在使用优先级消息时，是否有与最佳实践的链
浏览 4提问于2012-09-11得票数 2
我正在学习RabbitMQ，它是如何工作的。
根据内部文档，消息存储保存消息内容，队列只保存消息的索引。
因此，当同一条消息被路由到多个队列时，它不会复制消息内容，而是只存储一次，在这些队列中保留对消息的引用(消息id)。
那么，如果一条消息被排队到属于不同机器的多个队列中呢？信息会只存储在其中一台机器上吗？
这个问题可以重新表述如下:支持存储的消息是全局的、跨集群的还是针对每台机器的本地的？
谢谢,
浏览 4提问于2016-08-11得票数 1
回答已采纳
2回答
我们有从MSMQ读取数据的MVC应用程序。我们正在尝试找出一种方法，只有当用户在队列上成功完成操作时，才能从队列中读取消息并将其从队列中移除。消息应该保留在队列中，直到用户完成处理，在处理消息对象的用户完成操作之前，消息不应该对其他任何人可用。
是否有一个设置为Peeked的消息对象的属性，该属性将不允许再次读取此消息，直到它被放回队列或从队列中删除？
我们不确定在这种情况下使用MSMQ是否是一个好主意？
浏览 4提问于2009-09-02得票数 3
回答已采纳
AWS sqs FIFO队列限制使用者一次只能提取10条消息。我是否可以让多个使用者一次拉动10条消息，以增加一次处理的消息量？
浏览 1提问于2018-05-07得票数 7
回答已采纳
我们有一个代表多个客户端的分布式应用程序。现在，当工作到达时，消息被放在单个队列中。消息是以FIFO顺序提取的，这在大多数情况下都工作得很好。
在某些情况下，我们将为单个客户端获取数千条消息，然后这些消息将占用队列中的前几个thousand+插槽。这意味着在处理这些消息之前，不能(或很少)为任何其他客户端执行任何工作-这会使较小的客户端处于饥饿状态。
我的想法是，在我们引用客户端列表之前，以及每次从队列中获取消息之前，我们都会查看消息，看看是哪个客户端提交了该消息。如果它是针对我们刚刚处理的同一客户端，我们将其推回，直到我们找到针对不同客户端的消息，或者迭代所有客户端，但找不到其他工作。
这是
浏览 0提问于2016-01-19得票数 1
所以，我是MSMQ和NServiceBus的新手。我尝试了一下演示，并得到了一个使用NServiceBus的工作场景。(多亏了新的建模工具，让我自己启动和运行比遵循演示更容易！)
然后，我去向我的同事展示了我的计划(基于我与演示和我自己的模型的工作)。他们中的两个精通MSMQ的使用，并开始问我关于如何处理“死信”的问题。
我从来没有听说过“死信”。他们解释说，它是用于消息的队列，不能发送东西(要么是因为另一端拒绝了它们，要么是因为另一端不在那里)。
我的同事担心的是，如果我们没有死信队列，那么我们如何阻止消息阻塞队列？(如果队列是FIFO，并且顶部的消息不能被发送，那么它会阻塞它后面的其他消息
浏览 1提问于2011-10-22得票数 0
回答已采纳
我有两个RabbitMQ队列：
incoming_message =>，在这里，我推送我以后要处理的所有消息。
incoming_message_dlx =>，其中我推送处理失败的消息。
正如您可以使用其名称所设想的那样，incoming_message_dlx队列使用特性，这意味着当消息过期时，它将被请求到我的incoming_message。
我试图实现的是，每次处理失败时增加消息的expiration，并将它们推送到DLX队列。
问题是，即使消息过期，它也不会被请求到我的incoming_message，而不是在队列的底部(头)。因此，如果DLX队列中有一条过
浏览 0提问于2017-08-10得票数 2
我有一个消息传递用例问题。
到目前为止，我们在AWS中有一个队列，例如，该队列上的和origQueue。
现在，为了满足基于优先级(高、中、低)的消息消耗(基于消息中设置的“优先级”号)的一个特殊特点，我认为有一组3条队列，其中每个队列属于不同的优先级级别。在最高优先级队列中，将继续发生。一个批处理过程将以5分钟的间隔继续运行。每条消息都可以从中、低优先级队列中提升一些消息。目前还没有考虑到这个批处理过程的逻辑，但是它可以是任何东西，比如取起10条中优先级消息和5条低优先级消息，这两条消息的使用时间都超过1小时，并将它们提升到高优先级队列，以便上述out-of-the-box-lambda-b
浏览 0提问于2019-04-25得票数 3
1回答
，蔚蓝存储队列消息可以退出队列的最大no是多少?
无法在MSDN上找到有关此问题的任何文档。
是正确的，只有在出现异常时，消息才会移动到毒队列，而不是基于排队列计数?。
注意:我们正在处理来自windows服务的消息。
浏览 4提问于2021-08-20得票数 1
回答已采纳
1回答
什么属于DLQ /无效消息队列？
、、、、
关于允许应用程序拒绝哪种类型的消息，有没有一个好的最佳实践？
我的理解是，所有无法处理的消息都应该被拒绝到死信队列中-无论问题是消息中的语法错误还是语义错误，或者应用程序暂时无法处理消息(例如，因为数据库刚刚宕机)。
当然-如果应用程序已经预先知道它将无法处理消息(DB down)，它应该停止接受消息。
那么，通常的理解/最佳实践是什么呢？
浏览 2提问于2013-06-05得票数 3
回答已采纳
2回答
是否有任何方法(C#或本机)对消息队列(子队列)中的消息进行计数。使用队列名称"DIRECT=OS:slc11555001\private$\file-queue;retry“
我想知道子队列中有多少条消息。目前，我可以使用管理控制台看到该队列中实际上存在消息。如果操作系统可以做到这一点，我也应该做到。
MQMgmtGetInfo返回0xc00e0020 (这不是文档记录的错误代码)。
因此，我感到困惑。我在这里使用代码：
浏览 4提问于2011-09-27得票数 2
回答已采纳
1回答
下面是一个场景：
我们正在使用API和EC2实例在AWS上运行一个微服务风格的体系结构。假设有五种服务:照片服务、主题服务、用户发布服务、用户消息服务和用户配置文件服务。还有一个SQS消费者服务，“消息工作者”。每个微型服务都有自己的数据库。以下是用户向用户Posts服务(例如)发出请求时发生的一系列事件：
API网关将请求路由到用户Posts服务。用户Posts更新其数据库中的必要项。用户Posts服务将消息发布到消息工作者(SQS)。消息工作者复制所需的多个服务的消息，即如果用户评论服务、用户配置文件服务和用户消息服务都需要更新，则重复消息3次。消息工作者通过HTTP将数据发送到每个服务，
浏览 0提问于2017-09-05得票数 2
回答已采纳
大家好，
我正在寻找一种方法来计算ActiveMQ中匹配消息的数量。下面是添加消息的代码：
ObjectMessage myBeanMessage = session.createObjectMessage();
myBeanMessage.setObject(myBean);
myBeanMessage.setStringProperty("myProperty", myBean.getProperty());
producer.send(myBeanMessage);
现在，我想要计算myQueue中myProperty = "a property String“的
浏览 0提问于2014-06-16得票数 0
2回答
我有多个源将原始数据推送到S3。我已经在我的S3桶上配置了一个SQS事件通知。问题在于滞后和局限。
我预计在不久的将来会有更多的消息来源，而且由于我们在一次投票中只能从SQS获得10条消息，我认为在不久的将来，当有更多的源将数据推送到S3时，SQS将充满数千条消息，我将无法更快地处理它们。
我正在考虑通过将消息从我的主SQS队列扩展到更多的SQS队列，从而使我的处理层能够轮询多个队列，例如:5个队列，并处理更多的消息。可能的方法应该是什么？
浏览 0提问于2019-01-29得票数 6
回答已采纳
2回答
我理解死信队列和毒信队列之间的区别。我将在事务和持久性的背景下发言。
DLQ:客户端发送消息。MSMQ无法传递该消息。消息保持在队列中，等待发送到目标队列。
PQ:消息下发成功。WCF服务处理该消息。在WCF操作期间发生了一些错误。消息被放入有毒队列中。
(以上错误请指正)
现在，如果WCF服务遇到错误，并且事务作用域(属性)已就位，那么它如何将消息放入有毒队列中，或者是否必须开发此功能？如果它需要开发，那么它是如何完成的？如何处理有害消息？有没有办法把它们放回队列中，以便再次处理？如何确定消息是否是有毒的？例如，WCF中的操作可能会遇到错误，但可以从中恢复。
浏览 1提问于2012-04-21得票数 2
1回答
Oracle 10g中的触发器为常规表中的行子集生成向上插入和删除消息。这些消息由两个字段组成：
一个独特的行id一个非唯一的id.
在使用这些消息时，我希望在deque流程上强制执行一项遵守以下约束的命令：
必须以插入方式将属于同一id的order.Messages 消息排出队列，这种方式必须使任何其他去队列进程都不能用该id对潜在的后续消息(或消息)进行排队列。由于消息是使用触发器生成的，因此不能为此使用组。
我正在为AQ使用Oracle Java接口。关于如何实现这一点，有什么建议吗？
浏览 1提问于2009-11-19得票数 1
1回答
我有以下任务，涉及ibm消息队列：
存在一个从输入队列Q1获取消息并将消息放入Q2的应用程序(JMS客户端)。有几个将消息放入Q1的应用程序客户端。客户端为每条消息指定相关id。应用程序从从Q1接收的消息中检索id，创建新的输出消息，添加检索到的id，并将消息放入Q2。则每个客户端基于相关id仅检索其自己的消息。
我的问题是：
如果客户端没有指定任何id，他将从队列中读取所有消息。我想要一个限制，当没有指定相关id时，禁止读取队列。
是否可以仅使用ibm消息队列来完成此任务？如果没有其他建议的话。
浏览 9提问于2016-09-09得票数 2
回答已采纳
2回答
SQS队列中的确认消息
、、、、
我正在使用Amazon 和java 7中的Amazon Java库。我想要实现的是在接收消息之后，根据应用程序的业务逻辑，要么确认(消费)消息，要么重新将消息重新发送到队列，然后在3次失败的重试之后将其移到DLQ。
我想在JMS中使用CLIENT_Acknowledge模式，并且只确认已成功处理的消息，但这来自于它们的正式文档：
在这种模式下，当消息被确认时，在此消息之前接收的所有消息也被隐式地确认。例如，如果接收到10条消息，并且只有第10条消息被确认(按接收消息的顺序)，那么前面的9条消息也都被确认了。
这个例子似乎也证实了这一点：。
对我来说，这是一种奇怪的行为，与我期望的cl
浏览 15提问于2017-10-21得票数 6
回答已采纳
我通过网络在两个服务器之间设置了，它运行良好。目前我正在执行错误处理。我已经将存储过程附加到两个队列以处理消息。
在发送消息失败的情况下，例如试图发送格式错误的XML时，消息将保留在发送方队列中。传输状态是
Service在此会话中收到一条错误消息。Service不会发送消息；它将一直保存到应用程序结束会话为止。
当使用select * from sys.transmission_queue查询队列(为了调试而关闭存储过程)时，is_conversation_error和is_end_of_dialog字段是0，message_type_name与我发送时使用的相同，而不是通常的错误类
浏览 1提问于2016-07-18得票数 0
回答已采纳
AWS SQS FIFO队列的批处理设置为1，延迟为1秒。接收到的每一项都与MessageGroup相关联。
队列一次收到来自10个不同消息组的30条消息，每个消息组占3条消息.
延迟1秒是否适用于队列级别，即30条消息经过30秒才能传递？
或者队列会在3秒内清空队列，10个消费者，每个消息组一个？
浏览 3提问于2020-07-06得票数 0
回答已采纳
1回答
对于消费者来说，当声明队列为“排他的”时，当使用者根据文档断开连接时，队列将被删除。
假设队列中有消息等待处理，并且使用者脱机，则当队列被移除时，该“独占”队列上的所有消息都将丢失。
是否有任何策略或方法来保持队列“排他性”，但保留队列/代理中的消息，这样就不会丢失任何消息？
提前谢谢。
浏览 0提问于2016-06-10得票数 1
用例--我的任务的用例:就目前而言，用例是用表单填充诸如名字、姓氏等细节，然后单击Submit按钮，数据直接进入Amazon ，然后有一个已定义的侦听器，其中包含一个按钮，然后在该按钮上单击数据从侦听器到MSSQL数据库。
到目前为止，所有属于不同消息属性的消息都正在发送。
需求：--我想发送属于特定消息属性的特定消息。例如：假设A类、B类和C类是三个不同的消息属性，A类包含一条消息，B类包含两条消息，C类包含四条消息，我只想要发送B类属性的消息，而不是A类和C类。
我想知道，是否可以根据从Amazon到SQL的消息属性，只发送选定的/特定的消息？
任何帮助都将不胜感激。提前谢谢。
浏览 0提问于2018-05-24得票数 1
回答已采纳
我有一个用例，其中我有两个SQS队列，每个队列都收到消息。但条件是，如果我在第一个队列中获得消息，我将停止从第二个队列读取消息，并优先处理第一个队列消息。我可以只用一个SQS计票器来处理这个问题吗？
问题陈述:我经常在第一个队列中得到消息，但它们是重要的消息。但我不断地在第二个队列中获取消息。因此，如果轮询器正在处理第二个队列的消息，并且突然在第一个队列中出现一个新消息，那么在处理第二个队列的消息之后，它应该跳到第一个队列，并从那里开始接收消息，直到第一个队列为空。
有解决办法吗？
浏览 8提问于2020-01-29得票数 0
我们有一个HA应用程序，它运行在几个服务器上，指向同一个队列管理器。由于消息排序很重要，所以我们使用一个信号量队列来确保没有两个应用程序正在从一个业务队列中读取消息，即使在该队列上等待处理的消息有多个。
工作流程如下所示：
业务队列上设置了一个MQTT_DEPT触发器，以便在队列部门等于1时触发
业务队列接收一个或多个按摩。
当queue变成一个并将触发器消息放入启动队列时，触发器就会触发。
作为一个队列部触发器，它应该在将触发消息传递到启动队列之后关闭自己。
有一个MDB侦听该启动队列，该队列获取触发器消息。
由于序列对于我们来说至关重要，所以我们对初始队列设置了一个
浏览 5提问于2015-08-17得票数 1
回答已采纳
1回答
从的AWS文档中可以看出：
FIFO队列也提供精确的一次处理，但限制在每秒300个事务(TPS)。
..。
FIFO队列支持允许单个队列中多个有序消息组的消息组。
..。
属于同一消息组的邮件始终按相对于消息组的严格顺序逐一处理(但是，属于不同消息组的邮件可能会按顺序处理)。
有没有人知道这是否意味着将300 TPS限制应用于Does队列或每个消息组？
浏览 6提问于2017-06-20得票数 1
复制步骤
向队列中添加消息(大约500条消息)。添加一个队列触发函数应用程序，它将处理队列消息。
期望行为
队列中的所有消息都将被处理。如果在处理消息时抛出异常，则将消息发送到毒队列。
实际行为
消息开始被处理。经过一段时间(大约30-60秒)，所有留在队列中的消息都会被移动到毒队列中。在该时刻处理的消息不会引发任何异常。
我们检查了队列消息生存期是默认消息：7天。我们尝试将WindowsAzure.Storage包降级为7.2.1，但没有成功。
我们使用的WindowsAzure.Storage版本是8.5.0。
函数应用程序会崩溃，这会导致所有消息被移动到毒队列中吗？
编辑
以下是将消息添
浏览 5提问于2017-11-02得票数 0
回答已采纳
在Websphere MQ中，使用队列的CURDEPTH属性，我们可以很容易地找出本地队列中有多少消息。
但是，我如何才能找到这些消息占用的实际磁盘空间？因为队列中的消息可能具有不同的大小，即它们可能占用不同的磁盘空间。
提前谢谢。
浏览 0提问于2013-06-18得票数 2
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
实时音视频
云直播活动推荐
腾讯云开发者
