腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(832)
视频
沙龙
1
回答
Apache诉Apache
RocketMQ
、
、
、
、
这两个平台都是开源的分布式
消息
传递和流式数据平台。 但它们的比较如何呢?就功能和性能而言,我什么时候应该更喜欢彼此?普尔萨尔(像卡夫卡一样)严格来说是更擅长流媒体,而
RocketMQ
(比如ActiveMQ)是严格来说更擅长
消息
传递吗?
浏览 5
提问于2018-06-12
得票数 10
回答已采纳
1
回答
如何设置rockemq
消息
过期时间?
、
在这里,我使用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
只消耗部分
队列
、
在向
RocketMQ
4.8发送
消息
之后,我发现使用者只消耗了部分
队列
。这是
RocketMQ
消费者代码,如下所示: } consumer.start(); eventConsumers.put(appId, consum
浏览 14
提问于2022-06-27
得票数 -1
回答已采纳
1
回答
rocketmq
-客户端无法使用
消息
、
我使用的是
rocketmq
4.3.1客户端,现在遇到了一些问题。已经使用了一段时间的消费者组有一些未消费的
消息
。现在我是
消息
队列
的新手,消费者不能正常使用它,我必须重新启动消费者服务才能使用
消息
。但是我改成了一个消费者组,消费者可以实时得到
消息
队列
中心的
消息
。我很想知道发生这种情况的原因problem.thanks
浏览 2
提问于2018-12-14
得票数 0
2
回答
readQueue和writeQueue有什么不同
在
RocketMQ
中,readQueue的数量和writeQueue的数量可以分别设置,在我看来,只有公共部分才能像预期的那样工作。例如,如果将readQueueNum设置为8,而将writeQueueNum设置为16,则不会处理一半的
消息
。 我试图在代码中找出这种设计的基本原理,但还没有找到任何线索。有人能帮我解释一下吗?
浏览 7
提问于2019-05-12
得票数 3
2
回答
Rocketmq
:MQBrokerException: CODE: 2 DESC:[TIMEOUT_CLEAN_QUEUE]
当我向代理发送
消息
时,偶尔会发生此异常。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
版本: 3.2.6当一个新的消费者启动时,我将尝试从mq获取消费者偏移量:但是我碰巧遇到了返回-1的情况,并且我看到了错误:从错误日志中。
浏览 1
提问于2016-08-23
得票数 0
1
回答
如何知道哪个
队列
分配给了哪个consumer-
RocketMQ
?
消费者
队列
是在客户端分配的,broker对此一无所知。 那么,我们如何监控哪个
队列
被分配给哪个消费者客户端呢?
浏览 11
提问于2017-02-08
得票数 0
2
回答
分布式计时器服务
、
、
我正在寻找一个分布式计时器服务。多个远程客户端服务应该能够在指定的时间间隔后注册回调(通过REST )。间隔的长度可以是1分钟。我可以忍受大约1分钟的误差。目前,这类回调的数量可以增加到10万,但我需要以后再扩大规模。我一直在研究像Quartz这样的调度程序,但我不确定它们是否适合这个问题。使用Quartz,我可能必须将回调请求保存在DB中,并每分钟轮询100,000行上的过期请求。我不确定这是否会扩大规模。有什么现成的解决方案吗?否则,我该怎么做呢?
浏览 1
提问于2017-01-21
得票数 7
1
回答
RocketMQ
使用者等待结果回调
、
、
、
我正在使用
RocketMQ
,并且希望在每次新请求时从
队列
中获取
消息
public class GetMessageFromQueue extends BaseObject {private String springTopic
浏览 7
提问于2019-12-03
得票数 0
1
回答
NServiceBus,什么时候
消息
用的太多?
、
当在NServiceBus中考虑一个服务时,你会在什么时候开始质疑一个服务处理多少
消息
是太多了,并开始将这些
消息
分解成一个新服务?考虑以下几点:我有一个销售服务,目前可以分为几个不同的业务组件,它们是销售订单验证、销售订单处理、
采购
订单验证和
采购
订单处理。 目前在此服务中使用了大约20个
消息
处理程序和2个sagas。我担心的是,在我网站的高流量期间,这可能会导致最初的
消息
峰值跃升至数百条。考虑到需要按照从
队列
中取出
消息
的顺序来处理
消息
浏览 1
提问于2013-03-19
得票数 0
1
回答
如何在Masstransit/RabbitMQ中组织
队列
?
、
、
、
、
我有一个api (承载一个总线实例),它发布
消息
。这些
消息
是不同的,因为这个api不是一个微服务(用于购买、销售等的
消息
)。 用于
队列
类型的一个进程?进程(按域分组
队列
)的多个
队列
?例如,有一个进程让多个消费者消费与
采购
相关的
消息
,并管理不同的
队列
,如purchases.stock、purchases.suppliers.这个选择对我来说更有意义,但我不确定。
浏览 3
提问于2017-10-20
得票数 6
回答已采纳
1
回答
在SQL-Server表中存储事件
消息
、
、
、
、
我有一个创建
采购
订单的Web API。一旦创建了此
采购
订单,我必须通过该服务的API调用向另一个第三方web服务确认创建。在成功创建订单时,我希望将事件/
消息
存储在Sql Server表中以调用第三方API。我倾向于以STOMP/STOMP-like的格式存储这些内容。注意:目前,我不打算使用真正的
消息
队列
。我也不希望引发同步事件来调用第三方API。
浏览 2
提问于2014-01-30
得票数 0
2
回答
在崩溃的情况下保持Akka状态
、
、
、
其他一些系统(我被告知JMS就是其中之一)更进一步,持续持久化参与者之间发送的
消息
。这样,如果机器在物理上崩溃--比如说由于硬件故障--仍然可以将状态恢复到故障之前的状态。
浏览 0
提问于2012-10-05
得票数 4
回答已采纳
1
回答
在哪些情况下,使用
消息
队列
比使用Twitter Storm更好
、
我正在阅读Twitter Storm,它似乎为构建数据管道提供了比
消息
队列
更高级别的抽象。我想知道在什么情况下(如果有),直接使用
消息
队列
而不是Storm会更好。
浏览 1
提问于2014-11-04
得票数 0
1
回答
如何使用RabbitMQ处理蓝/绿部署?
、
、
、
然而,这变得很棘手,因为新代码在
队列
中为正在部署的服务注入
消息
,而现有实例(以前的版本)仍在运行。我们有一个蓝/绿部署。对于RabbitMQ来说,有可能有许多监听器监听一个
队列
,但只监听一个特定的版本吗?例如,所有正在运行的服务器都会读取2017.10.20
版
(以前的版本)或更早版本的
消息
,但不会读取较新版本的
消息
。 这样,我就可以部署一个新的服务,而其他read都不会读取它的测试
消息
。它生成和使用与当前运行的服务相同的
消息
类型。
浏览 27
提问于2017-12-19
得票数 1
回答已采纳
3
回答
异步
消息
传递(特别是发布/订阅样式的
消息
传递)是作为域服务体系结构可行的,还是仅在以SOA为中心的环境中可行?
、
我一直在研究异步
消息
传递,我喜欢它优雅地处理某些领域中的一些问题的方式,以及它如何使领域概念更加明确。但是,对于一般的域驱动开发(至少在服务/应用程序/控制器层中),它是一种可行的模式吗?
浏览 0
提问于2008-09-16
得票数 3
回答已采纳
1
回答
RabbitMQ中Pub/Sub与工作
队列
的混合
、
我使用RabbitMQ作为
消息
队列
/
消息
总线进行评估,并一直在查看RabbitMQ页面上的示例。 当订单被发送时,我想通过RabbitMQ作为
消息
发送它。如果我正确理解,使用pub/sub将导致
消息
被处理两次(帐户)或trice (物流)。使用工作
队列</
浏览 2
提问于2015-11-29
得票数 4
回答已采纳
1
回答
JMS ActiveMQ createBrowser始终返回空
队列
、
、
ActiveMQ 5.10.0
新春
4.1.2谢谢!如果连接没有启动,那么
消息
是如何添加到
队列
中的呢? 有人知道这个@param startConnection whether to start the Connection是什么意思吗
浏览 1
提问于2014-12-07
得票数 1
2
回答
Spring AMQP Java客户端中的
队列
大小
、
、
我使用Spring amqp 1.1
版
本作为我的java客户端。我有一个
队列
,大约有2000条
消息
。我想有一个服务,检查这个
队列
大小,如果它是空的,它将发送一条
消息
说“所有项目已处理”。我不知道如何获取当前
队列
大小?请帮帮忙 我用谷歌搜索了一下,发现在较早的1.0
版
本中有一个类"RabbitBrokerAdmin“。我认为它在1.1中还没有出现。在获取当前
队列
大小方面有什么建议吗?
浏览 0
提问于2012-07-12
得票数 11
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
消息队列之事务消息,RocketMQ 和 Kafka 是如何做的?
滴滴开源基于 RocketMQ 的分布式消息队列 DDMQ
滴滴出行基于RocketMQ构建企业级消息队列服务的实践
消息队列之推还是拉,RocketMQ 和 Kafka 是如何做的?
分布式消息队列RocketMQ与Kafka架构上的巨大差异之1
热门
标签
更多标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
活动推荐
运营活动
广告
关闭
领券