调用CMQ的createQueue返回创建成功，立马调用sendMessage方法推送消息，却报code:4440, message:(10100)queue name is not existed, or deleted, requestId:558230285180216186
浏览 809提问于2019-01-29
3回答
调用CMQ异常：code":4000,"message":"(10430)action name BatchReceiveMessage is not existed"
标题：批量消费消息 - 消息队列 CMQ API - API文档 - 腾讯云文档平台 - 腾讯云
地址：https://cloud.tencent.com/document/api/406/5924
浏览 1063提问于2018-03-12
我再cmq的广州节点创建了一个topic(ID为： topic-71efzxh6)， 同时对这个topic创建了一个订阅者，指定同样为广州节点的queue(ID为： subsc-lw3u5gq9)，我向topic发送消息， 消息无法到达订阅queue。
在topic中显示有消息堆积，查看topic的订阅者queue，显示有待投递消息，不知道为啥会出现这种情况？
看官方文档说明，向topic发送消息应该会立即投递到订阅者的啊？
浏览 562提问于2019-05-23
image.png
image.png
图一在订阅中显示 订阅有消息，但在图二中该队列中显示没有显示。怎么去拉取该订阅的消息？用文档中https://cloud.tencent.com/document/api/406/5839 队列拉取不到消息。请回答一下
浏览 490提问于2019-04-16
请描述您的问题
标题：投递消息 - 消息队列 CMQ - 产品文档 - 帮助与文档 - 腾讯云
地址：https://cloud.tencent.com/document/product/406/7420
浏览 341提问于2018-01-27
1回答
我已经创建了一个列表，让我们称它为主列表
master=['abc 1.2 px', 'pqr 5.4 tr', '1.8 cmq', 'pst 2.5']
现在我有了另一个列表，比如
l1=['1.2 abc px', 'pqr tr 5.4', 'cmq 1.8', '1.8 cmq', '2.5 pst', 'abc 1.2 px']
我想修改l1，它将从master中获取名称，其中所有单词都呈现而不考虑顺序。例如，修改后的列表将
浏览 1提问于2019-01-05得票数 3
Traceback (most recent call last):
File "C:/Users/Master The/PycharmProjects/cmq/cmq_sample_queue.py", line 41, in <module>
print "Set Queue Attributes Succeed! QueueMeta: \n%s" % str(queue_meta)
File "C:\Users\Master The\PycharmProjects\cmq\cmq\queue.py", line
浏览 318提问于2018-10-04
"投递 Subscription 指topic像订阅者投递消息的过程" <----- 这个是不是“deliver"，或transfer / transmit, 这是一个动作，subscription是A向B订阅的意思。
标题：名词解释 - 消息队列 CMQ - 产品文档 - 帮助与文档 - 腾讯云
地址：https://cloud.tencent.com/document/product/406/4552
浏览 324提问于2018-02-15
我有一些Azure服务总线队列正在达到配额，它们要么是非常小的活动和死信消息，要么是零消息。似乎还有其他既不是“活动的”也不是“死信”的信息。他们是什么?服务总线资源管理器指示队列的下列状态，例如：
服务总线资源管理器中的“消息计数”和“传输DL消息计数”非常高。显然，这些都是使用空间的东西。我无法在服务总线资源管理器中接收/删除它们，也找不到关于如何处理它们的任何信息。
Azure也有类似的报道。什么是“传输DL信息”？
浏览 2提问于2017-01-27得票数 0
回答已采纳
是否要删除/清除Azure门户中Azure服务总线队列中的活动/死信消息？目前，我们已经向队列发送了几条消息，而活动消息和一些死信消息都是免费的，而且我们的服务总线用户没有以某种方式触发，因此我们希望删除这些消息，以使队列再次干净。为了等到服务总线在过期后丢弃这些消息，我们可以自己手动删除它们吗？
浏览 1提问于2019-09-06得票数 6
回答已采纳
我的应用程序(在线游戏)在许多活动中都必须使用套接字连接，并且它应该始终保持连接。每个活动都需要实时接收来自套接字的消息，有时活动会向套接字发送消息。我试图将套接字从一个活动传递给其他活动，但失败了。我尝试使用服务，但无法发送或接收来自该服务的消息，只能在日志目录中的system.out.println()中看到它。游戏开发者有没有最好的方式或者常用的方式？对不起，我的英语很差。
浏览 3提问于2014-02-19得票数 1
我有一个使用MSMQ和NServiceBus进行消息传递的客户端服务器应用程序。在最近的一些测试中，客户端被闲置了一段时间，并发现了MSMQ的意外行为：
MSMQ具有用于处理队列的默认线程数(在注册表中设置为QMThreadNo)。当队列长期处于休眠状态时，它们会积累大量消息。这些大队列保持MSMQ所拥有的线程数量比通常长，因此处理实际处于活动状态的队列需要更长的时间。It可以将注册表项设置为较高的线程count.。
在一段时间内没有发送/接收消息的客户端(在注册表中设置为CleanupInterval)将更改为“非活动”状态，最终将删除它们的队列，直到从该客户端发送消息为止，这将迫使队列
浏览 1提问于2012-03-26得票数 1
回答已采纳
队列设置为TTL (生存时间)为5分钟。
当您从UtcNow添加ScheduledEnqueueTimeUtc为1分钟的消息时，消息将在5分钟或6分钟后过期？
我的假设是6，因为我预计一旦消息在队列中处于“活动”状态，TTL“倒计时”就会“开始”，而消息在经过预定的入队时间后才会处于活动状态。
然后，如果您将消息入队6分钟，它将在11分钟后过期。
我的假设正确吗？
浏览 18提问于2016-09-28得票数 1
回答已采纳
1回答
我们使用的是IBMMQ8.0。活动日志将记录我们发送到外部系统的传出消息。但是，对于从外部系统到Manager的消息，没有可用的日志。客户端通道配置有问题吗？还是MQ日志记录配置问题？
浏览 4提问于2017-01-26得票数 1
回答已采纳
7回答
如何并行处理MSMQ消息
、、、
我正在编写一个使用MSMQ消息的windows服务。该服务将具有高活动期(80k消息非常快速地传入)和长时间的不活动(可能有几天没有新消息)。
处理消息是非常受网络限制的，所以我从并行中获得了很大的好处。但在不活动期间，我不想占用一堆等待消息的线程，这些消息不会很快到来。
MSMQ接口似乎非常关注同步工作流-获取一条消息，处理它，获取另一条消息，等等。我应该如何组织我的代码，以便我可以在高活动期间利用并行性，而不会在不活动期间占用一堆线程？使用第三方物流的加分。伪码将不胜感激。
浏览 3提问于2011-04-01得票数 17
回答已采纳
2回答
/！这个问题基本上已经解决了，关于更多的细节和一个附属问题，请看下面我自己的答案/！
我试图根据特定的单词添加两行，但我所能找到的只是在某种模式之后添加所有内容：
这不是我要照顾的。
考虑以下输出：
aji 1
bsk 2
cmq 3
doh 4
enr 5
fwp 6
gzx 7
我想得到的是类似cmq + fwp的东西，输出应该是：
9
我确实知道如何添加值，但我忽略了select line containing cmq, then select line containing fwp部分。
那么，awk是否可以独立地严格选择两条特定的行(然后添加它们)？
编辑：
据我所知，匹配词是awk
浏览 0提问于2018-01-30得票数 1
回答已采纳
假设每个用户都有自己的队列。当用户脱机时，消息被放到队列中，当他们重新连接时，他们会接收所有这些消息。
但是，如果客户端离开而再也没有回来(停止使用服务)，该怎么办？如果有一段时间没有使用消息，RabbitMQ有办法删除队列吗？消息可能会传入，但它们不会发出，因为客户端不再是活动的。我如何用amqp.node插件来处理这个问题呢？
浏览 2提问于2015-09-22得票数 0
回答已采纳
1回答
我必须将一些消息从一个主题移动到一个队列，然后转发到另一个队列，以更改消息的到期日期。我这样做了几次，最终达到了最大跳数，正如用编写的那样，它是4。
如何更改MaxTransferHopCountExceeded的值，或者是否有什么技巧可以将一百万条消息从死信队列移动到活动队列，以便我可以使用它们？
我在azure上有一个高级订阅。
浏览 2提问于2020-01-13得票数 0
1回答
我是Apache活动消息队列的新手。在读取(消费)来自MQ的消息时，脱队列计数增加，从MQ存储中删除消息。在这里，我想扫描消息而不删除MQ和去队列计数中的消息。意思是，我只想扫描消息并将其存储在本地，或者在输出时打印出来。
有人能对此提出建议吗？我想用java实现它。
浏览 4提问于2016-01-06得票数 1
回答已采纳
我正在使用SQS来保存http请求。如何使消息保持活动状态(在队列中)，以便在请求失败时重新处理，而不被另一个进程捕获？
浏览 0提问于2020-07-24得票数 0
3回答
我有一个队列，队列中全天都有高优先级的JMS消息，我想让它们快速离开。该队列也被周期性地以大批量的低优先级消息加载。在繁忙的日子里，我看到的问题是，队列前面总是有足够多的高优先级消息，在该卷下降之前，不会选择任何低优先级的消息。通常他们会坐在队列上直到半夜。该应用程序分布在多个服务器上，但CPU并不紧张，JMS似乎是瓶颈所在。
我的直觉是实现某种老化算法，提高队列中已存在很长时间的消息的优先级，但当然，这就是中间件应该为我做的事情。我无法想象JMS提供者(IBM )或应用服务器(TIBCO BusinessWorks)没有某种工具来处理这种情况。所以在我写一些代码之前，我想我会问，有没有办法让
浏览 23提问于2014-12-12得票数 0
2回答
广播传送和性能
、、
我猜测广播消息被发送到接收线程的消息队列，并通过循环传递。广播是在消息队列中的其他消息之前传递，还是仅仅附加到队列的末尾？我没有特别的需要或类似的东西，只是出于好奇而想知道。
在服务和活动之间使用IPC广播的性能开销(CPU和内存)是多少？
总帐
浏览 1提问于2011-07-29得票数 3
我正在通过下面的创建一个具有以下片段的消息队列。
if((mq_open("/my_message_queue", O_CREAT, O_RDWR, NULL)) == -1) {
perror("mq creation failed");
}
运行这个片段，我会得到一个错误：“权限被拒绝”。我想检查一下，看看我以前是否创建了队列，而不是销毁它，所以我使用了ipcs。然而，ipcs不显示任何活动消息队列。我以前从未在我的开发环境中使用过POSIX IPC库(Ubuntu18.04)。是否设置了允许用户进程创建消息队列的设置？我是不是不正确地使用API？
浏览 5提问于2019-10-20得票数 2
在我的应用程序中，我在RabbitMQ适配器中使用Symfony Messenger。应用程序的逻辑是，来自同一队列的消息必须依次执行(顺序并不重要)，即使队列被多个使用者监听。换句话说，如果至少有一条消息未加标记，队列就不应该发出其他消息。
为了解决这个问题，我在文档中找到了一个选项，比如x单活动消费者()。
配置如下：
my-queue:
dsn: amqp://guest:guest@localhost:5672/%2f/my-queue
options:
queues:
my-queue:
arguments:
浏览 3提问于2022-06-21得票数 0
看起来，新的azure将visibilitytimeout扩展到<= 7天。我知道默认情况下，当我向蔚蓝队列添加消息时，活动时间是7天。当我收到消息后，将visibilitytimeout设置为7天。这是否意味着如果我不关心消息的可靠性，就不需要删除这条消息？消息将在7天后消失。
我想走这条路，因为DeleteMessage非常慢。如果我不删除消息，这对GetMessage的性能没有任何影响吗？
浏览 0提问于2013-12-22得票数 0
1回答
我有一个应用程序，它通过显示一个消息框(MessageBox.Show)来响应外部事件(在应用程序外部生成)。它将所有者设置到我的应用程序的主窗口。
如果第二个事件在第一个模式被解除之前进入，我将得到两个messageboxes。当我忽略第一个模型消息框而不是第二个模型消息框时，问题就来了。在这种情况下，第二个框仍然可见，但它失去了它的“模态”-我可以操作应用程序，就好像第二个模态窗口不在那里一样。
我尝试过的一种解决方案是从MessageBox.Show调用中删除owner参数。根据的说法：“默认情况下，消息框出现在当前活动窗口的前面。”我认为如果不指定所有者，那么“活动”窗口就是所有者。如
浏览 0提问于2014-09-26得票数 0
我正在尝试使用ScheduledEnqueueTimeUtc来调度消息以供将来处理，但Peek只返回活动和延迟消息。
这是我用来偷看消息的代码：
public static async Task<IEnumerable<BrokeredMessage>> GetMessagesAsync(string connectionString, string queueName, int take)
{
var queue = QueueClient.CreateFromConnectionString(connectionString, que
浏览 1提问于2017-09-06得票数 2
2回答
在谷歌搜索了whatsapp这样的聊天信使如何发送/接收消息后，我偶然发现他们使用了基于队列的消息传递系统。我只是想弄清楚这个特性的高级设计是什么？
HLD对地雷的理解:-说朋友1和朋友2在线。朋友1已经建立到web服务器1的HTTP连接，朋友2已经建立到web服务器2的HTTP连接，朋友1将消息发送给朋友2。
现在，一旦消息到达web服务器1，我需要将消息传送到web服务器2，以便通过已经建立的web连接将消息推送回朋友2。
我相信，这里可以使用分布式自定义java队列将消息从一个服务器传播到另一个服务器。一旦消息到达一台服务器，它就会将其推送到具有消息内容、fromUserId、toUse
浏览 10提问于2017-01-28得票数 7
回答已采纳
3回答
并发我是这样理解的:
2 个人同时下单, 库存只有 1, 那么肯定有一个人无法抢到。也就是说, 库存只会减 1, 订单也只会生成一条。
后来我用 Jmemter 模拟 1000 人同时操作, 发现订单确实只有一个, 而且库存也没有负数, 但是我并没有做什么锁啊或者队列这些一谈到并发就会涉及到的东西。
$a 是查询到的库存
$b = $a-1;
if($b>=0){
生成订单
修改库存
}
如果没有 if 判断, 确实会负。但是如果加了这个 if 判断就库存只减少 1, 订单只有一条
那么我的问题来了, 加个 if 判断就能解决并发? 还是说实际上真正要处理的
浏览 713提问于2017-11-21
我想比较SNS和SQS关于消息/主题的脱队列/消耗。
如果有1+使用者活动，SNS主题是否会被删除/消耗？如果没有使用者活动，SNS主题不会得到“去队列”吗？所谓消费者，我指的是任何http端点、lambda等。
浏览 0提问于2016-10-20得票数 5
回答已采纳
信息被卡在蔚蓝的服务巴士上长达24小时。它不是被传递给听者。活动消息:2条消息存活时间: 14天消息锁定持续时间:5分钟最大传递计数:1(我们已经将其减为1，因为5分钟不足以完成处理)是否有任何方法可以重新触发这些消息给侦听器？
浏览 4提问于2022-02-09得票数 0
如果使用SQS作为Lambda函数的事件源，是否有办法将“活动”消息的最大数量限制为x。因此，假设有一个包含1000条消息的SQS队列，而不是尝试处理尽可能多的消息(最多1000个默认并发限制)，我们只希望同时处理最多x条消息。这显然意味着它将花费更多的时间来处理所有消息，但它将为我们提供更好地控制写入数据库的可能性。
此外，如果消息不能被处理(例如，由于Lambda函数中发生的错误)，消息是否附加到队列的末尾(因此所有其他消息都是最先到达的)，或者是否有方法在一定的等待时间(可见性超时)之后确定它们的优先级？
非常感谢
浏览 0提问于2019-11-26得票数 1
2回答
我有一个简单的RabbitMQ测试程序随机排列消息，另一个读取消息，它们都使用Spring。如果使用者死亡(例如，杀死一个进程而没有机会关闭其连接或通道)，则它未确认的任何消息似乎永远不被确认。
我已经看到了许多引用(例如)，这些引用说通道在没有连接时会死掉，而剩余的解锁消息将被重新传递。这不是我所看到的行为-相反，我得到了一个越来越多的通道列表，标记为空闲，越来越多的连接列表被标记为正在运行，但没有活动。
是否需要配置才能注意到，一旦进程被终止，连接就死了吗？
编辑：i在VirtualBox VM中运行VirtualBox服务器，显然无法通过NAT正确管理死机入站连接。对于直接在物理主机上运
浏览 3提问于2011-11-28得票数 9
回答已采纳
我有一个线程，它使用处理程序和消息向活动发送数据。除了暂停活动之外，一切都很正常：
null sending message to a Handler on a dead thread
java.lang.RuntimeException: null sending message to a Handler on a dead thread
at android.os.MessageQueue.enqueueMessage(MessageQueue.java:196)
at android.os.Looper.quit(Looper.java:173)
at pocke
浏览 0提问于2011-08-16得票数 5
回答已采纳
1回答
在这个项目中，我正在利用"Gulp“来执行一些任务，但最近收到了添加源代码映射的请求。
我有源代码地图工作，但它似乎与其他插件有冲突，如'gulp-combine-mq'和"gulp-combine-media-queries" ，也就是"cmq"。
当使用"cmq“注释运行我的样式任务时，我得到了我期望的源代码地图。
gulp.task('styles', function () {
gulp.src('./assets/src/less/main.less')
.pipe(sourc
浏览 3提问于2015-05-18得票数 1
回答已采纳
1回答
我正在尝试在RabbitMQ中实现一个dlx队列。这个场景很简单，我有两个队列: 1)活着2)死了(x- dead -letter-exchange："immediate"，x-message-ttl: 5000)
和一个“立即”的交换，它被绑定到1)活动中
我尝试运行这个示例：，但似乎消息在ttl过期后被删除，并且它们不会在交换上发布，所以我的活动队列总是空的。
我还尝试在管理控制台中手动创建队列，我得到了相同的行为。
我用Ubuntu/rabbitmq 3.0.0以及Mac OS X和rabbitmq 2.8.7测试了它
我是不是遗漏了什么？
浏览 0提问于2012-11-29得票数 7
回答已采纳
发行：
将1个活动MDP (以下为jmsIn)附加到单个队列，并将第二个集群MDP保持在服务器2上的被动状态。我只需要一个活动的进程，因为我希望执行聚合而不丢失消息。
我一直在阅读关于控制总线的文章，但是由于它是一个集群环境，通道id和jms:消息驱动的通道适配器id将在两个服务器上都有保存名称。控制总线是否可以使用JMX在另一台服务器上停用，即使它们有id？或者可能先由消息驱动的通道适配器进行检查，以确定队列本身上是否已经有活动的连接。
Message-driven-channel-adapter示例代码：
<jms:message-driven-channel-adapter id=
浏览 2提问于2015-09-29得票数 1
当特定API在短时间内处于非活动状态/无活动时，是否可以在Sterling订单管理系统中创建电子邮件警报？例如，如果每隔10分钟从一个队列读取/抓取消息并放入另一个队列的自定义API变为非活动状态或没有记录任何活动，那么sterling OMS产品是否可以触发电子邮件警报？
提前感谢
浏览 4提问于2016-04-01得票数 1
我有一个活动队列，它将包含来自Publisher的所有消息。根据消息处理结果，我的使用者读取这些消息和Acks/Nacks。
while (true)
{
var ea = (BasicDeliverEventArgs)consumer.Queue.Dequeue();
var body = ea.Body;
var message = Encoding.UTF8.GetString(body);
var processed = ProcessMessage(message)
if (processed)
浏览 4提问于2016-03-22得票数 1
我使用RabbitMQ将所有消息排入队列，并将这些消息作为短信发送给各自的消费者。我正在使用直接交换，并且我已经正确地创建了一个到具有路由关键字的队列的绑定。问题是，当我试图发布一条消息时，我在消息率图表中看到一些活动，但是消息没有出现在队列中
这里肯定需要一些帮助。我确信绑定是正确完成的。我是不是遗漏了一些其他配置？
浏览 2提问于2018-09-26得票数 3
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
