调用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
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
1回答
我在我的项目中使用AWS、SQS和Spring。我的方法是使用@JmsListener(目的地= "queue_name")。我想对两种不同类型的消息使用这个队列。
由于此侦听器被配置为此队列，它将接收两种类型的消息。我试图实现的是忽略一种类型的信息。(发送方在向队列发送消息时添加MessageAttribute )。那么，是否有一种方法可以忽略来自发送方2的消息，这样这个方法就不会处理它们了。
另外，我在这个队列上设置了DLQ，max接收为5。因此，如果在前5次尝试中没有处理消息，它将被移动到DLQ。
请分享你的建议。
谢谢。
浏览 3提问于2017-10-03得票数 3
回答已采纳
"投递 Subscription 指topic像订阅者投递消息的过程" <----- 这个是不是“deliver"，或transfer / transmit, 这是一个动作，subscription是A向B订阅的意思。
标题：名词解释 - 消息队列 CMQ - 产品文档 - 帮助与文档 - 腾讯云
地址：https://cloud.tencent.com/document/product/406/4552
浏览 324提问于2018-02-15
2回答
关于高性能流数据处理的问题
、、、、
我有一个接收流数据的套接字连接。每天的消息数大约是150Mil。收到消息后，我需要对它们进行处理。因为消息数量相当大。我正在多线程处理消息处理代码。现在我有8个线程，有8个消息队列。套接字进程将按顺序将消息放入这些队列。每个进程只需要在自己的队列中处理消息。
我现在的问题是我的队列溢出了。
我应该有更多的队列吗？所有线程都将使用同步方法写入一个共享对象。更多的队列是否会相互影响并使情况变得更糟？
我应该有更大的缓冲区吗？这些似乎是安全的，但我真的想更快地处理消息。
我应该改变我的设计吗？有什么好的推荐吗？要遵循的指南？
欢迎提出任何意见。
浏览 1提问于2011-06-17得票数 2
1回答
我在java引导应用程序中实现了一个SQS队列。为了在不同的环境中实现，我已经进行了以下的探讨。
为每个环境实现多个队列，以便对队列流量进行排序。
我在消息中传递env变量，如果在错误的环境中接收到的消息抛出异常，我相信它将再次将消息放入队列中。这种方法不是很有希望，但由于消息数量较少，我认为也是如此。
除了这个，还有别的办法吗？
这是我找到的链接之一，它是2=1和半年前的。
浏览 2提问于2017-11-01得票数 2
回答已采纳
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
回答已采纳
6回答
我的邮件在MSMQ队列中，我想查看完整的邮件。
我知道我可以编写代码来查看队列，但是我想知道是否有一个已经存在的查看器可以让我读取整个消息？
浏览 1提问于2010-12-21得票数 44
回答已采纳
我在一个应用程序中工作，在这个应用程序中，我们用来发送tibco队列中的一些消息，我们通过spring jms发送消息，我们已经提供了一个定制的界面，在这个界面中，我们可以看到消息计数，并且可以看到如果这个数字增加，那么消息就会被发送到那个队列中，但我正在寻找一些有GUI的工具，在这个工具中，我可以连接到我的tibco队列，也可以看到消息体，这是详细的消息内容，请建议这样的免费工具，我认为类似于队列工具。
这是一个付费的免费的
浏览 3提问于2013-07-21得票数 2
很抱歉，如果这是一个副本，我试着搜索这个，但不确定使用什么搜索词，没有真正找到任何东西。
我有一个Ruby on Rails应用程序，它将被用来发送文本消息给用户，其中包含一个多项选择题的链接，可能使用clickatell。这些问题有一个与之相关的日期和时间。我想让ruby on rails应用程序在指定的日期自动将这些SMS消息发送到用户的手机。
我真的不知道该怎么做。有没有人能告诉我在ruby on rails中安排这样的事件的大致方向。我不需要一个确切的解决方案，也许有人可以澄清一下这到底叫什么，这样我就可以在网上找到一些资源。
谢谢
浏览 2提问于2013-03-30得票数 0
回答已采纳
我正在制定一个场景，其中有一个向Azure存储队列发送消息的场景。出于测试目的，我开发了一个控制台应用程序，在这里我可以获得消息，并能够使用try计数更新它，当逻辑完成时，我会删除该消息。
现在我正在尝试将我的代码移植到Azure函数。有一件事看起来非常不同，当Azure函数被调用时，消息就会从队列中被删除。
我发现很难找到关于这个特定主题的任何文档，我觉得我遗漏了将这两者结合在一起的概念。
我的问题：
我说得对吗，当您在一个新队列项上触发一个函数时，该函数接受消息并从队列中删除它，即使该函数失败了？
如果1是正确的，那么如何确保重新尝试消息并将其发送到死队列以供以后处理？
浏览 2提问于2016-10-12得票数 17
回答已采纳
我们有一个遗留应用程序，它使用MQSeries C例程调用向MQ服务器发送消息。我们内部不再有MQ服务器，我们需要测试对这个遗留应用程序所做的更改，然后再将其发布给我们的客户端，该客户端拥有自己的(生产) MQSeries服务器。 我们有没有一种方法可以模拟一个MQSeries服务器，它将模拟一个具有通道和队列的MQSeries队列管理器，并且可以接收发送到特定队列的消息。我们不需要它来实际处理消息，我们只希望它看起来像一个标准的MQSeries服务器，并与客户端进行适当的通信。 如果有一种方法可以在Java中做到这一点，那将是最好的，因为这是内部知识的主要来源。
浏览 14提问于2019-01-14得票数 2
回答已采纳
我想使用客户端v7.5。我正在编写独立的JMS客户端应用程序，以发送和使用来自IBM服务器的消息(该服务器运行在其他地方，但我有权发送/接收消息)，我遵循了以下步骤：
安装Websphere MQ客户端(免费版本6个月)，并完成所有基本安装。
我将所需的Jar复制到其他位置/主机，并编写了一个示例JMS应用程序来发送/接收消息。我能够与服务器进行通信。
我的问题是:我是否可以在任何主机上独立使用这些罐子(即使在生产中)，或者我应该购买适当的许可证，安装客户端，然后使用这些罐子？
谢谢,
阿努吉
浏览 3提问于2015-11-02得票数 3
3回答
并发我是这样理解的:
2 个人同时下单, 库存只有 1, 那么肯定有一个人无法抢到。也就是说, 库存只会减 1, 订单也只会生成一条。
后来我用 Jmemter 模拟 1000 人同时操作, 发现订单确实只有一个, 而且库存也没有负数, 但是我并没有做什么锁啊或者队列这些一谈到并发就会涉及到的东西。
$a 是查询到的库存
$b = $a-1;
if($b>=0){
生成订单
修改库存
}
如果没有 if 判断, 确实会负。但是如果加了这个 if 判断就库存只减少 1, 订单只有一条
那么我的问题来了, 加个 if 判断就能解决并发? 还是说实际上真正要处理的
浏览 713提问于2017-11-21
1回答
我找不到关于在一段时间内(例如一秒)发送到Firebase数据库(或类似数据库)的最大消息数的最佳实践的文档，以及应用程序可以在不显著减速的情况下处理接收的速率。例如：
//send updated location of user character in MMORG
MyDatabaseReference.child(LOCATIONS).child(charid).setValue . . .
//recieive locations of other characters in a MMORG
MyDatabaseReference.child(LOCATIONS).addValue
浏览 2提问于2017-10-24得票数 1
我需要异步的，快速处理队列中的所有东西。作业是由CURL请求组成的，所以它永远都需要一个接一个地处理它们(它们基本上与sleep(3)相同)。我希望队列中的所有消息同时运行，或者至少设置一个限制，比如50。我之所以使用队列，而不是立即运行它们，是因为我需要确保如果任何事情都失败了，它会再次尝试。
浏览 0提问于2013-07-01得票数 0
3回答
我想从安装在linux机器上的WebSphere MQ中的队列中转储一条消息。如何使用mqm授权用户检查队列中的消息？我已经在opt/mqm/bin中检查过了，还找到了一些MQ命令，比如dmpmqaut等等。但是我找不到一个命令来在队列中转储消息。
编辑-I使用WebSphere MQ v.7.1
浏览 6提问于2015-04-22得票数 4
回答已采纳
我希望构建一个发布/订阅分布式消息传递框架，该框架可以管理大量的消息流量，并具有代理级别的一些智能。我不知道是否有一个拓扑结构来描述这一点，但这是我要研究的模型：
示例模型A
( A)有两个正在运行的消息代理(如果可能的话，最好全部放在本地主机上，以便更容易地演示)：
经纪人-A
经纪人-B
( B)每个代理将有2个侦听器和1个发布者。
示例图
订阅服务器A1、订阅服务器A2、发布服务器A1 <-> BrokerA <-> BrokerB <->发布服务器B1、订阅服务器B1、订阅服务器B2
如果消息-X被发布到broker A，
浏览 0提问于2010-05-10得票数 3
我希望看到当前在队列中等待发送的消息(及其内容)。这样的工具存在吗？或者我应该为此编写自己的解决方案？
浏览 1提问于2012-04-06得票数 36
回答已采纳
有我的应用程序的应用服务器(SUSE 64位)。它发出"ip_queue: full“消息，并拒绝连接(例如不能ping)。
我的应用程序。是一个使用JBoss5的EJB应用程序，它对网络没有什么特别的作用(只是一些普通的Servlets)。
由于JBoss处理所有低级别的网络内容，并且测试得很好，所以我怀疑某些内核参数不合适，但我无法在互联网上找到我所希望的那么多信息。
有人能建议我该怎么做吗？
谢谢。
浏览 0提问于2011-01-28得票数 0
回答已采纳
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
回答已采纳
我正在为发布到MQ的每个消息创建自定义messageId，但为少数消息生成相同的messageId。 Anypoint MQ如何处理在先进先出和标准队列中具有相同messageId的消息？ 我不想创建重复的记录。另外，希望保留邮件的最后一个副本，并丢弃旧的副本。有什么想法吗，我该如何做到这一点？
浏览 29提问于2020-09-24得票数 0
2回答
我有两个队列，分别是Q1和Q2。当我使用MQPUT将消息插入到Q1中时，是否可以将此消息复制到Q2中？WMQ是否支持队列复制？注意:队列驻留在不同的队列管理器中。
谢谢，哈德森
浏览 4提问于2013-09-27得票数 2
回答已采纳
1回答
我试图下载VxWorks 5.x (特别是5.11)手册，以了解任务数量、消息队列、堆栈大小、内存限制和信号量方面的限制。你们中有没有人可以发布任何链接来下载或分享上述限制？
浏览 15提问于2017-08-29得票数 0
AWS允许通过SQS队列触发Lambda函数。对于documentation，Lambda轮询队列并使用一批消息同步调用该函数。 AWS在对Lambda函数收费时会考虑执行时间。轮询时间是否计入执行时间并收费？或者它是免费的？
浏览 7提问于2019-12-23得票数 4
回答已采纳
2回答
嗨，我经常遇到的activemq问题是：- 1.推送的消息没有被消费2.由于点1，队列大小变得很大3.队列中的消息不断重试
你们中有没有人在project中用过当队列大小超过某个阈值时发送邮件的开源软件呢？我们是否也可以发送消息详细信息或将其存储在某个位置，以便稍后诊断这些消息未被使用的原因。
浏览 15提问于2019-04-27得票数 1
2回答
我正在开发高可伸缩性的应用程序，所以我决定使用Hazelcast。我有一个前端服务器，它为节点提供消息。在分布式映射中，集群中的每个节点都会在后台线程中改变其工作负载，因此，前端服务器选择队列(每个节点都有自己的消息队列)来放置消息。我的问题是: Hazelcast是否适合这样的设计(我们需要工作负载分布和负载平衡)，或者可能是一些替代方案？我喜欢Hazelcast，因为它的简洁和漂亮的设计。
浏览 1提问于2010-11-17得票数 5
回答已采纳
1回答
我们在客户端运行了一些CRUD web应用程序，我们需要实现一个审计系统来跟踪用户在这些产品中所做的更改。
前：
用户ABC创建了一个新的交易(在交易应用程序)
用户DEF用id 123更改了客户端的地址信息(在客户端应用程序中)
我在考虑一种基于事件的解决方案，其中包含一个消息队列，当任何用户进行更改时，我们的所有服务都会发布消息，而审计服务将是所有这些消息的订阅者。
这种模式的一些优点是：
旧服务将有一些小的更改(存储库将开始发布消息)
所有审计逻辑和数据将集中在一个项目中。
你们对这种方法有什么看法，我应该记住什么？
浏览 0提问于2012-08-13得票数 0
我有一个程序，它通过MQAX200接口将数据发布到IBM Websphere MQ。我正在努力想办法测试它。
设置应用程序以使用队列中的消息并确认其正确性的最简单方法是什么？我目前在这里没有任何MQ基础设施(在客户端的站点上)。
我需要消息代理吗？有没有开源的实现？或者我需要购买Websphere MQ，在这种情况下，我需要的最低许可是多少？
谢谢
本
浏览 0提问于2012-06-22得票数 4
我愿意用django做一个简单的聊天应用程序。
在用户发送消息并将消息保存在Message模型中后，我想发出发布事件的信号，以便我的移动应用程序收到消息。
我查阅了SNS文档，在其定价中找到了Data transferred between Amazon SNS and Amazon EC2 within a single region is free of charge (i.e., $0.00 per GB)
我的应用编程接口是/将托管在与sns相同的区域的ec2中。如果我在我的移动应用程序中发布了一个收到消息的事件，是否会花费我或将其视为相同的区域？
谢谢
浏览 2提问于2018-02-23得票数 0
3回答
有没有消息传递解决方案(最好支持Python)，我可以像邮箱一样使用，例如，从任何给定的队列中检索消息，而不必订阅？我认为消息队列可以工作，但我必须重复订阅，从队列中抓取消息，然后取消订阅，这听起来并不是最优的。
浏览 1提问于2011-03-30得票数 0
回答已采纳
2回答
我正在寻找最轻量级的消息总线(排队？)它可以处理以下问题：
A制片人预订了公共汽车。总线是通过众所周知的标识形式(如名称、套接字或其他东西)指定的。
使用者B订阅同一总线，并只注册到特定类型的消息。
使用者C订阅同一总线，并注册到与B的消息重叠的另一种消息。
生产者A在总线中放置一个信息，使B和C都感兴趣。B和C都接收消息(不仅仅是其中一条，而且两者都是)。
A，B，C和公共汽车住在不同的机器里。
浏览 0提问于2015-01-21得票数 0
1回答
我有这个模式来接收http请求，并对Windows EC2实例下的文件进行一些处理。
API Gateway -> Lambda -> EC2 (Node.js + Express)
目前，每天都有几个请求，因此实例将停止，直到请求出现。当请求出现时，Lambda函数将启动实例，但第一个请求将丢失。如果实例正在运行，请求将被转发。
我想要一个解决方案，在这个解决方案中，我不会失去第一个请求。我有几种方法，但似乎没有一种是正确的：
1)将该请求保存到ElastiCache (Redis/memcached)。在启动Express服务器时，检查是否保存了任何请求。
2)使用Amazon
浏览 0提问于2016-10-14得票数 1
回答已采纳
4回答
什么是队列访问并发解决方案？
、、、、
我正在尝试找出实施排队系统的困难之处。我知道如何实现一个基本的队列，所以我将用一些背景知识来解释一下我所追求的东西：
我将实现一个队列，消息将被放置在其中，这将来自几个用户，消息将被安排在用户定义的时间发布(从UI的角度来看，我将限制：“每分钟或每小时”的发生，但我希望系统仍然能够处理这一点)。
这就是我的问题所在:最终，我可能会遇到(也可能不是)当前需要发布许多消息的情况，我希望运行几个进程(脚本的多个实例)，以便一次从队列中获取x、10、25个消息并处理它们。问题是:如何做到这一点，以便每个实例处理唯一的消息(而不处理已经被另一个实例处理的内容)？我担心当前的连接，如何锁定记录，以及其他我
浏览 0提问于2009-07-04得票数 0
回答已采纳
1回答
RabbitMQ非圆罗宾调度
、、、、
我对在RabbitMQ中实现“工作队列”模型感兴趣。然而，我发现代理执行一个简单的基于循环的任务分配给工人。
如果某个特定的工作人员忙于执行一项非常繁重的任务，并且还有其他空闲的工作人员，那么代理应该能够在队列中向next worker和发送消息，而不是循环序列中的下一个工作人员。是否有一种使用RabbitMQ实现这一目标的方法？
浏览 4提问于2014-03-26得票数 6
回答已采纳
我所看到的对我来说似乎很奇怪。并不是队列的所有使用者都会收到消息。我是不是错过了什么场景？
浏览 1提问于2010-10-23得票数 2
回答已采纳
3回答
如何提高amazon的排队速度？
、、、、
我试图将数千条消息排队到sqs。我正在循环一个基于计数的for循环，并向队列发送消息。下面是我的循环
$sqsClient = AWS::createClient('sqs');
for($i=0; $i<=$count;$i++){
$sqsClient->sendMessage(array(
'QueueUrl' => 'https://sqs.us-west-2.amazonaws.com/xyz123/QueueName',
'MessageBody' =>
浏览 12提问于2016-05-26得票数 1
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
