腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(4395)
视频
沙龙
1
回答
Apache诉Apache
RocketMQ
apache-kafka
、
rabbitmq
、
activemq
、
rocketmq
、
apache-pulsar
这两个平台都是开源的分布式
消息
传递和流式数据平台。 但它们的比较如何呢?就功能和性能而言,我什么时候应该更喜欢彼此?普尔萨尔(像卡夫卡一样)严格来说是更擅长流媒体,而
RocketMQ
(比如ActiveMQ)是严格来说更擅长
消息
传递吗?
浏览 5
提问于2018-06-12
得票数 10
回答已采纳
1
回答
如何设置rockemq
消息
过期时间?
spring-cloud
、
rocketmq
在这里,我使用spring-cloud-starter-stream-
rocketmq
和spring-message发送
消息
dn,例如 Message m = MessageBuilder.withPayload(obj).setHeader(RocketMQHeaders.TAGS, tag).build(); MessageChannel.output().send(m); 但我想在
队列
中设置
消息
过期时间,我知道
rocketmq
可以设置ttl,但我不知道它是否可以设置为不同的
消息
,以
浏览 588
提问于2021-01-07
得票数 0
回答已采纳
1
回答
为什么
rocketmq
只消耗部分
队列
java
、
rocketmq
在向
RocketMQ
4.8发送
消息
之后,我发现使用者只消耗了部分
队列
。这是
RocketMQ
消费者代码,如下所示: } consumer.start(); eventConsumers.put(appId, consum
浏览 14
提问于2022-06-27
得票数 -1
回答已采纳
1
回答
rocketmq
-客户端无法使用
消息
message-queue
、
rocketmq
我使用的是
rocketmq
4.3.1客户端,现在遇到了一些问题。已经使用了一段时间的消费者组有一些未消费的
消息
。现在我是
消息
队列
的新手,消费者不能正常使用它,我必须重新启动消费者服务才能使用
消息
。但是我改成了一个消费者组,消费者可以实时得到
消息
队列
中心的
消息
。我很想知道发生这种情况的原因problem.thanks
浏览 2
提问于2018-12-14
得票数 0
2
回答
readQueue和writeQueue有什么不同
rocketmq
在
RocketMQ
中,readQueue的数量和writeQueue的数量可以分别设置,在我看来,只有公共部分才能像预期的那样工作。例如,如果将readQueueNum设置为8,而将writeQueueNum设置为16,则不会处理一半的
消息
。 我试图在代码中找出这种设计的基本原理,但还没有找到任何线索。有人能帮我解释一下吗?
浏览 7
提问于2019-05-12
得票数 3
2
回答
Rocketmq
:MQBrokerException: CODE: 2 DESC:[TIMEOUT_CLEAN_QUEUE]
rocketmq
当我向代理发送
消息
时,偶尔会发生此异常。DESC: [TIMEOUT_CLEAN_QUEUE]broker busy, start flow control for a while 这意味着代理太忙(当tps>1,5000)无法处理这么多发送
消息
请求
浏览 3
提问于2017-04-01
得票数 2
1
回答
当用户组启动时,收到错误"CODE: 22 Not found,V3_0_6_SNAPSHOT this group consumer boot first“,
RocketMQ
rocketmq
版本: 3.2.6当一个新的消费者启动时,我将尝试从mq获取消费者偏移量:但是我碰巧遇到了返回-1的情况,并且我看到了错误:从错误日志中。
浏览 1
提问于2016-08-23
得票数 0
1
回答
如何知道哪个
队列
分配给了哪个consumer-
RocketMQ
?
rocketmq
消费者
队列
是在客户端分配的,broker对此一无所知。 那么,我们如何监控哪个
队列
被分配给哪个消费者客户端呢?
浏览 11
提问于2017-02-08
得票数 0
2
回答
分布式计时器服务
quartz-scheduler
、
distributed-computing
、
distributed
我正在寻找一个分布式计时器服务。多个远程客户端服务应该能够在指定的时间间隔后注册回调(通过REST )。间隔的长度可以是1分钟。我可以忍受大约1分钟的误差。目前,这类回调的数量可以增加到10万,但我需要以后再扩大规模。我一直在研究像Quartz这样的调度程序,但我不确定它们是否适合这个问题。使用Quartz,我可能必须将回调请求保存在DB中,并每分钟轮询100,000行上的过期请求。我不确定这是否会扩大规模。有什么现成的解决方案吗?否则,我该怎么做呢?
浏览 1
提问于2017-01-21
得票数 7
1
回答
从Sun JMS桥到ActiveMQ再到.NET
activemq
我有Sun的
消息
队列
4.3。使用imqbroker守护程序的本地主机上的默认安装。已打开一个
队列
。我知道有ActiveMQ解决方案,5.3
版
。已检查.NET的ActiveMQ (版本1.1),它对于类似于Sun的ActiveMQ
队列
工作正常。我的问题是,我希望将现有的SunMQ4.3连接到一个ActiveMQ
队列
,而中的文档并不是很清楚。谁能准确地指出如何将activemq的配置文件映射到桥: imqbroke
浏览 4
提问于2009-11-03
得票数 0
1
回答
Jenkins没有在SQS
消息
到达的基础上启动构建
build
、
jenkins
、
jenkins-plugins
、
amazon-sqs
工具: 我想知道我们缺少了什么?最后SQ
浏览 2
提问于2013-03-20
得票数 0
回答已采纳
3
回答
在带有HornetQ的JBoss 7中,JMS Queue的“耐久”属性是什么意思?
java
、
jakarta-ee
、
jms
、
jboss7.x
、
hornetq
在使用HornetQ在JBoss 7上配置JMS
队列
(基于standalone-full.xml配置)期间,我注意到一个属性‘耐久’。JBoss 7 HornetQ中的此属性是否指临时
队列
?或者这个属性是指某种非临时的、非持久的
队列
?
浏览 0
提问于2012-12-11
得票数 15
回答已采纳
1
回答
RocketMQ
使用者等待结果回调
spring-boot
、
consumer
、
countdownlatch
、
rocketmq
我正在使用
RocketMQ
,并且希望在每次新请求时从
队列
中获取
消息
public class GetMessageFromQueue extends BaseObject {private String springTopic
浏览 7
提问于2019-12-03
得票数 0
2
回答
RabbitMQ锁定
消息
组
rabbitmq
、
queue
在这里,每个用户都有自己的
队列
,并附加了一个使用者。我们在这里面临的挑战是,如何在创建新
队列
时自动启动消费者,并在
队列
一段时间未使用的情况下可能停止消费者? 提前感谢
浏览 22
提问于2020-07-28
得票数 0
回答已采纳
1
回答
如何防止后缀发送在传入/
活动
队列
中等待超过1天的
消息
?
postfix
我有第一行/墓地后缀服务器结构,当第一行服务器收到软故障时,第一行服务器向墓地发送
消息
。 但有时,我想
队列
太忙了,
消息
被锁定在传入
队列
中,只能在几天后发送。我宁愿丢弃邮件,也不愿寄很旧的邮件。设置maximal_queue_lifetime将无法工作,因为它至少需要发送一次
消息
,如果
消息
太旧,我不希望它被发送一次。
浏览 0
提问于2013-01-02
得票数 0
回答已采纳
1
回答
WMQ
消息
日志记录场景v7.5
ibm-mq
在下面的场景中,我很好奇会发生什么,因为它与所讨论的
队列
管理器的
活动
日志文件中的内容有关。正在使用线性测井。MQ
活动
日志所经历的
活动
(如果有的话)是什么
活动
,在这样一个场景中,一个带有100条
消息
的
队列
正在使用JMS上下文属性(寻找特定
消息
)读取--对于这种争论,它将永远找不到。所有
消息
都从
队列
中读取,但没有任何
消息
被提交。因此,这些
消息
从未真正从
队列
中删除;然而
浏览 0
提问于2013-10-28
得票数 0
回答已采纳
2
回答
如何使用lambda和SQS实现优先级
队列
结构?
amazon-web-services
、
aws-lambda
、
amazon-sqs
每个请求可以包含来自1条
消息
的
消息
,最多可包含数十万条
消息
。唯一的问题是,小请求有时必须等待
队列
中已经存在的大型请求(因为所有并发的lambda都已被占用,而且我不想增加lambda的并发性)。所以我想有两个
队列
,一个用于小请求,一个用于大请求,这样小请求可以被更快地处理。但是,挑战是如何为每个
队列
分配lambda并发数。有没有办法告诉lambda根据触发它的SQS
队列
部分使用并发lambda (假设20用于大请求,10用于小请求)?或者是否有其他最佳实践来实现这种需求
浏览 0
提问于2019-02-18
得票数 2
回答已采纳
1
回答
如何使用RabbitMQ处理蓝/绿部署?
testing
、
rabbitmq
、
integration
、
amq
然而,这变得很棘手,因为新代码在
队列
中为正在部署的服务注入
消息
,而现有实例(以前的版本)仍在运行。我们有一个蓝/绿部署。对于RabbitMQ来说,有可能有许多监听器监听一个
队列
,但只监听一个特定的版本吗?例如,所有正在运行的服务器都会读取2017.10.20
版
(以前的版本)或更早版本的
消息
,但不会读取较新版本的
消息
。 这样,我就可以部署一个新的服务,而其他read都不会读取它的测试
消息
。它生成和使用与当前运行的服务相同的
消息
类型。
浏览 27
提问于2017-12-19
得票数 1
回答已采纳
4
回答
如何从Azure服务总线
队列
中删除/清除
活动
/死信
消息
?
azure
、
azureservicebus
、
azure-servicebus-queues
是否要删除/清除Azure门户中Azure服务总线
队列
中的
活动
/死信
消息
?目前,我们已经向
队列
发送了几条
消息
,而
活动
消息
和一些死信
消息
都是免费的,而且我们的服务总线用户没有以某种方式触发,因此我们希望删除这些
消息
,以使
队列
再次干净。为了等到服务总线在过期后丢弃这些
消息
,我们可以自己手动删除它们吗?
浏览 1
提问于2019-09-06
得票数 6
回答已采纳
1
回答
MSMQ QMThreadNo和CleanupInterval
.net
、
client-server
、
msmq
、
nservicebus
我有一个使用MSMQ和NServiceBus进行
消息
传递的客户端服务器应用程序。在最近的一些测试中,客户端被闲置了一段时间,并发现了MSMQ的意外行为:在一段时间内没有发送/接收
消息<
浏览 1
提问于2012-03-26
得票数 1
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
消息队列之事务消息,RocketMQ 和 Kafka 是如何做的?
滴滴开源基于 RocketMQ 的分布式消息队列 DDMQ
滴滴出行基于RocketMQ构建企业级消息队列服务的实践
消息队列之推还是拉,RocketMQ 和 Kafka 是如何做的?
分布式消息队列RocketMQ与Kafka架构上的巨大差异之1
热门
标签
更多标签
活动推荐
运营活动
广告
关闭
领券