Apache RocketMQ 正在参加 2020 年度 OSC 中国开源项目评选,请投票支持!
Apache RocketMQ 在 2020 年度 OSC 中国开源项目评选 中已获得 {{ projectVoteCount }} 票,请投票支持!
投票让它出道
已投票
Apache RocketMQ 获得 2020 年度 OSC 中国开源项目评选「最佳人气项目」 !
Apache RocketMQ 获得 2020 年度 OSC 中国开源项目评选「最佳人气项目」「最积极运营项目」 !
Apache RocketMQ 获得 2020 年度 OSC 中国开源项目评选「最积极运营项目」 !
授权协议 Apache
开发语言 Java
操作系统 Windows
软件类型 开源软件
开源组织 Apache
地区 国产
投 递 者 linkgo
适用人群 未知
收录时间 2014-02-18

软件简介

RocketMQ是什么?

RocketMQ 是一款开源的分布式消息系统,基于高可用分布式集群技术,提供低延时的、高可靠的消息发布与订阅服务。同时,广泛应用于多个领域,包括异步通信解耦、企业解决方案、金融支付、电信、电子商务、快递物流、广告营销、社交、即时通信、移动应用、手游、视频、物联网、车联网等。

具有以下特点:

  • 能够保证严格的消息顺序

  • 提供丰富的消息拉取模式

  • 高效的订阅者水平扩展能力

  • 实时的消息订阅机制

  • 亿级消息堆积能力

  • Metaq3.0 版本改名,产品名称改为RocketMQ

展开阅读全文

代码

的 Gitee 指数为
超过 的项目

评论 (26)

加载中
阿西吧,这玩意是怎么登顶的。。。
2019/12/12 14:18
回复
举报
可惜文档不咋样
2019/11/20 18:32
回复
举报

引用来自“Quiter”的评论

RocketMQ 支持MQTT协议吗 #RocketMQ#
阿里云用钱买,开源的没有mqtt也找不到相关文档
2019/01/06 13:43
回复
举报
https://blog.csdn.net/weixin_41715077/article/details/85170893 最新版配置参数详解
2018/12/21 19:58
回复
举报
打分: 力荐
有人知道queue模式怎么配置的吗,为什么没有看到这相关的文档
2018/06/13 15:27
回复
举报
@paulzhu 为什么一定要用zk做注册中心呢
2018/03/05 08:37
回复
举报
打分: 力荐
代码结构清晰
2017/12/15 13:46
回复
举报
这个不是捐献给阿帕奇了么
2017/09/29 16:23
回复
举报
打分: 力荐
如果对RocketMQ源码有兴趣,可以看看我的博客 http://www.yunai.me/categories/RocketMQ/?oschina&02 目前一共14篇文章。后面会继续更新的哟。
2017/08/03 22:37
回复
举报
4.1.0 版本,你们出现过这个问题吗:Caused by: org.apache.rocketmq.remoting.exception.RemotingConnectException: connect to <*****:10911> failed
2017/03/31 00:44
回复
举报
你这个应该是连接客户端失败,启动下客户端
2020/10/30 16:19
回复
举报
更多评论
发表于软件架构专区
01/01 12:18

Apache RocketMQ 4.8.0 发布,升级 DLedger 模式

Apache RocketMQ 4.8.0 已发布。发布公告显示,在此版本中,社区对 RocketMQ 完成大量的优化和问题修复。此外,该版本从性能、功能和稳定性三个方面提升了 DLedger 模式能力。 据介绍,DLedger 是 OpenMessaging 中一个基于 Raft 的 CommitLog 存储库实现,从 RocketMQ 4.5.0 版本开始,RocketMQ 引入 DLedger 模式解决了 Broker 组内自动故障转移的问题,而在 4.8.0 版本中,社区对 RocketMQ DLedger 模式进行了全面升级。 以下...

1
12
发表于服务端专区
2020/01/07 08:44

Apache RocketMQ 社区正在评选优秀贡献者

2019年是Apache RocketMQ毕业的第3年,开源生态得到了进一步的壮大和发展,在国内外备受关注,并且连续多年获得开源中国发起的“年度最受欢迎中国开源软件”奖。 日前,为了表彰社区优秀的贡献者,同时鼓励更多的开源爱好者参与到Apache RocketMQ项目中,RocketMQ社区发起了“优秀贡献者评选”活动。 活动说明 支持者为每个候选人或者团队最多投1票,投票截止时间2020年01月10日24点 。 候选人或团队一共4类,投票截止后进入各类...

4
2
发表于运维专区
2019/12/25 08:33

“Apache RocketMQ社区最佳贡献者评选”参选征集中

2019年,Apache RocketMQ开源生态得到了进一步壮大和发展。内核仓库先后发布了三个大版本,新增了消息轨迹、多副本存储、ACL、RPC模式、IPV6等重要特性,孵化了Connect、RocketMQ Operator、Prometheus Exoprter、CPP SDK、Golang SDK等20+的生态项目。同时在北京、上海、广州、深圳、苏州、西安、大连(筹)、长沙(筹)等地先后建立了城市社区,involve更多的开发者和用户,目前RocketMQ在全球有300+的社区贡献者。近期Apach...

1
1
2019/04/10 08:44

Apache RocketMQ 4.5.0 发布,实现自动容灾切换

近日,分布式消息开源项目 Apache RocketMQ 发布了 4.5.0版本,该版本引入了 Dledger 的多副本技术,可实现多地多中心场景下的自动容灾切换,并保障切换过程中数据的完整性和一致性,同时,发布 Apache RocketMQ 开发者指南,该指南分为概念和特性、架构设计、样例、最佳实践、运维管理和 API Reference 6大内容,帮助开发者快速了解和使用 Apache RocketMQ。 新特性: [ISSUE-1046] - 引入了 Dledger 的多副本技术 提升: [RIP...

3
25
2019/01/28 09:50

Apache RocketMQ 4.4.0 发布,5.0 快要到来

近日,Apache RocketMQ 发布了 v4.4.0,该版本主要增加了权限控制(ACL)和消息轨迹(Message Trace)两大特性,并做了8项优化,和修复了4处bug。 权限控制(ACL) 该特性主要为 RocketMQ提供权限访问控制。其中,用户可以通过yaml配置文件来定义权限访问的相关属性,包括白名单IP地址、用户的AK/SK访问秘钥对、Topic和ConsumerGroup的访问权限。这样,Topic资源之间也就具备了一定的隔离性,用户无法访问没有权限的Topic资源。...

3
7
发表于运维专区
2019/01/24 10:37

Apache RocketMQ 4.4.0 发布

万众期待的 4.4.0 版本终于在昨天成功发布,值得关注的新特性包括权限控制(ACL)和消息轨迹(Msg Trace)。 下面大家解读该版本引入的这两大特性。 权限控制(ACL) 该特性主要为 RocketMQ 提供权限访问控制。其中,用户可以通过 yaml 配置文件来定义权限访问的相关属性,包括白名单 IP 地址、用户的 AK/SK 访问秘钥对、Topic 和 ConsumerGroup 的访问权限。这样,Topic 资源之间也就具备了一定的隔离性,用户无法访问没有权限的 To...

1
8
2018/12/10 10:22

RocketMQ CPP客户端更新至1.2.0,兼容多语言、简化项目编译流程

RocketMQ CPP客户端是RocketMQ的C/C++客户端,与1.0.1版本相比,1.2.0版本的发布是一个巨大的进步。它提供了C++和C两种不同风格的接口,其他语言也可基于这两个客户端进行构建,例如Python、Node.js、C#、Golang 等。同时,我们还简化了项目编译过程,只需要一个命令就可以编译整个项目。 新特点: 1. 支持高可靠的同步、单向和顺序传输; 2. 支持推动消费和拉动消费; 3. 支持设置延迟时间; 4. 支持消息压缩; 5. 支持建立消息消...

2
5
2018/12/10 10:05

Apache RocketMQ (TLP) 发布首个子项目:RocketMQ-Spring-Boot

近期,Apache RocketMQ在社区中上线首个子项目RocketMQ-Spring-Boot。第一个版本中包含了若干新特性,修复并改进了针对rocketmq-external孵化报告中提到的若干问题。 新特性: 1. 在事务中发送消息; 2. 支持发送 DelayTimeLevel 消息; 3. RocketMQ 原生 API透明化,只需要使用 Spring Message API而非RocketMQ客户端API 即可实现相应功能; 改进: 1. 添加示例以演示RocketMQ-spring-boot/starter的使用,并涵盖所有客户端场景...

8
27
2018/12/07 15:21

RocketMQ 发布第一个 Python 客户端,由社区 contributor 贡献

Apache RocketMQ 发布第一个 Python 客户端,该客户端基于CPP客户端的内核,通过使用boost python封装C语言的API而实现,并由社区开发者贡献, 该版本提供以下特征: 支持消息的可靠同步发送; 支持可靠的推送消费模式; 支持默认集群消费; 支持延迟消息; 支持自定义消息属性; 支持消息压缩。

2
9
发表于运维专区
2018/11/22 10:53

Apache RocketMQ 4.3.2 发布,分布式消息系统

Apache RocketMQ 4.3.2 已发布,RocketMQ 是一款开源的分布式消息系统,基于高可用分布式集群技术,提供低延时的、高可靠的消息发布与订阅服务。同时,广泛应用于多个领域,包括异步通信解耦、企业解决方案、金融支付、电信、电子商务、快递物流、广告营销、社交、即时通信、移动应用、手游、视频、物联网、车联网等。更新如下: Improvement [ISSUE-411] - Fixed ClassCastException when get the instance of the store. [IS...

2
9
发表于运维专区
2018/09/12 14:16

Apache RocketMQ 4.3.1 发布,包含改进和 bug 修复

Apache RocketMQ 4.3.1 发布了,更新内容如下 改进 [ISSUE-395] - 增强事务生成器 API 的兼容性,并将默认 topic 修改为 "TBW102",确保服务器可以向后兼容较旧的客户端 [ISSUE-396] - 增强事务性消息实现,为 EndTransactionProcessor 添加管理工具和分离的线性池 [ISSUE-430] - 删除与 mqfilter 服务器相关的脚本 Bug 修复 [ISSUE-392] - 修复在生产者关闭过程中发现的 Nullpointer 异常 [ISSUE-408] - 恢复在合并过程中丢失的...

0
1
发表于DevOps专区
2018/08/01 10:47

Apache RocketMQ 4.3.0 发布,分布式消息系统

Apache RocketMQ 4.3.0 发布了,RocketMQ 是一款开源的分布式消息系统,基于高可用分布式集群技术,提供低延时的、高可靠的消息发布与订阅服务。同时,广泛应用于多个领域,包括异步通信解耦、企业解决方案、金融支付、电信、电子商务、快递物流、广告营销、社交、即时通信、移动应用、手游、视频、物联网、车联网等。 更新如下: New Feature [ISSUE-203] - Add support of IDC-aware allocator in the consumer [ISSUE-292] -...

5
9
发表了资讯
2017/12/19 08:25

Apache RocketMQ 4.2.0 发布,阿里开源的消息中间件

Apache RocketMQ 4.2.0 已发布,RocketMQ 是一款开源的分布式消息中间件,基于高可用分布式集群技术,提供低延时的、高可靠的消息发布与订阅服务。同时,广泛应用于多个领域,包括异步通信解耦、企业解决方案、金融支付、电信、电子商务、快递物流、广告营销、社交、即时通信、移动应用、手游、视频、物联网、车联网等。 此版本支持一些新功能: 1.支持传输层的安全 2.在客户端支持 log4j2 3.支持客户端更灵活的流量控制机制 此...

18
23
发表了资讯
2017/09/26 08:17

RocketMQ 孵化成为 Apache 顶级项目

美国时间 2017 年 9 月 25 日,Apache 软件基金会(ASF)宣布 Apache®RocketMQ™ 已孵化成为 Apache 顶级项目(TLP ),是国内首个互联网中间件在 Apache 上的顶级项目,也是全球继 ActiveMQ,Kafka 之后,分布式消息引擎家族中的新成员。 RocketMQ 是一款开源的分布式消息系统,基于高可用分布式集群技术,提供低延时的、高可靠的消息发布与订阅服务。于 2012 年在阿里巴巴发起,并处理 1.2 万亿次并发在线消息。据悉,Rocke...

12
25
发表了资讯
2017/02/21 18:53

Apache RocketMQ 4.0.0 (INCUBATING) 发布

Apache RocketMQ 4.0.0 (INCUBATING) 发布了。此次发布为 RocketMQ 带来了众多的特性,包括慢请求优化,优化过后99.996%的延迟落在了10ms以内,而99.6%的延迟在1ms以内。以及多个Bug修复和改进点。 更新内容: Bug [ROCKETMQ-2] - 代理测试失败,显示“地址已在使用” [ROCKETMQ-5] - 无法在UtilAll中创建#getDiskPartitionSpaceUsedPercent()目录 [ROCKETMQ-19] - MQAdminImpl#queryMessage 中线程不安全 ...... 提升 [ROC...

13
6
发表了资讯
2016/11/28 15:31

阿里巴巴向 Apache 软件基金会捐赠消息中间件 RocketMQ

继向 Apache 软件基金会捐赠 JStorm 后,阿里巴巴在开源界又有一大举动。 11 月 28 日,阿里巴巴宣布将开源分布式消息中间件 RocketMQ 捐赠给 Apache,成为 Apache 孵化项目,孵化成功后 RocketMQ 有望成为国内首个互联网中间件在 Apache上 的顶级项目,成为全球继 ActiveMQ,Kafka 之后,分布式消息引擎家族中的新成员。此次捐赠,意味着以 MQ(消息队列)为代表的互联网中间件在新兴物联网、大数据领域会发挥着越来越大的作用...

32
56
发表了资讯
2016/09/21 00:00

RocketMQ 3.5.8 发布,消息中间件

RocketMQ 3.5.8 发布了,是由阿里巴巴开源的一个消息中间件项目。本次更新带来了Bug修复和一些优化,具体如下: Bug修复: 正在远程的模块保持相同的超时#issue270 当状态转换时消费队列偏移不会重复 当中间者下线时客户端不会抛出异常 修复排序信息死锁问题 优化: 消息deliver.context最大支持重试次数的优先级超越消费者的优先级。 移除isWriteable检查 通道 一些性能改进 下载地址: Source code (zip) Source code (tar.gz)...

12
31
没有更多内容
加载失败,请刷新页面
点击加载更多
加载中
下一页
2020/04/26 22:30

RocketMQ-mac安装rocketmq

1.官网下载rocketmq指定版本的二进制压缩文件,然后解压 2.配置mq环境变量到.bash_profile export ROCKETMQ_HOME=/Users/dengpingxu/software/rocketmq-all-4.7.0-bin-release export PATH=$PATH:$ROCKETMQ_HOME 以下操作都需要切换到 rocketmq-all-4.7.0-bin-release目录下 3.启动NameServer(类似zookeeper注册中心) 以后台运行的方式启动:nohup sh bin/mqnamesrv & 查看启动日志: tail -f ~/logs/rocketmqlogs/namesrv.log ...

0
0
发表于服务端专区
2020/04/26 22:38

RocketMQ-rocketmq事务原理

一个简单的基于rocketmq事务消息实现的分布式事务 消息生产者代码-发送事务消息 public class Producer { private static TransactionMQProducer producer = null; private static ExecutorService executorService = Executors.newFixedThreadPool(1); public static void main(String[] args) { TransactionListener listener = createTransactionListener(); producer = new Trans...

0
1
发表了博客
2019/01/18 10:05

阿里rocketmq与自建rocketmq

一、搭环境 阿里rocketmq不用搭建, https://help.aliyun.com/document_detail/34411.html?spm=a2c4g.11186623.6.546.1787650eShM7ho 开源rocketmq(window+rocketmq) https://www.cnblogs.com/amuge/articles/10275292.html 二、发送消息类型: 三、名词解释 https://help.aliyun.com/document_detail/29533.html?spm=a2c4g.11186623.6.542.1cfa77d7wLCfvb 消息相关名词: Topic:消息主题 , 一级消息类型 Tag:消息标签,二级...

0
0
2019/04/11 21:22

rocketMq

公司是做零售领域的。现在在做追溯系统,需要对外提供接口和对内提供接口。一些东西是通过触发器来触发的。然后调用接口。这样的方式问题在于,有可能系统会启动,导致数据的丢失情况。面对这种问题,一种方式在建立临时表,然后会写。这种方式会增加维护量。个人建议是通过消息队列的方式来实现。目前选型rocket,因为这个具有事物消息的能力。后期如果需要消息事物,这个会比较有利点。 [Rocketmq原理&最佳实践](https://www...

0
0
发表了博客
2018/08/01 16:18

RocketMQ

应用场景 主要作用解耦、滑峰填谷 异构系统的整合,这个问题比较容易理解,在原阿里SOA ESB比较火的年代,很多异构系统需要进行互联互通。 应用和应用之间的松耦合,这个在阿里巴巴内部很多的同步链路到异步链路里面,使用的非常多。 事件驱动机制和复杂事件架构模型里面的Backbone,底层的机制可以通过MQ来玩转。 数据复制通道,这个有很多比较典型的应用场景,比如模拟MySQL的binlog解析,将数据的变更封装为消息,进而复制到...

0
0
发表了博客
2018/06/06 19:52

RocketMQ

一.RocketMQ安装 用git把代码拉取到本地, https://github.com/apache/rocketmq.git 使用maven打包工程,mvn clean install -D skipTests -P release-all -U 二.启动RocketMQ 进入distribution\target\apache-rocketmq\bin目录。 先启动nameserver 服务,以管理员权限运行mqnamesrv.cmd, 然后执行broker服务,在dos窗口输入.\mqbroker.cmd -n 127.0.0.1:9876 三.发送消息与消费消息 1.消息生产方代码如下: package org.chw.pr...

0
0
发表于开发技能专区
2018/03/08 11:25

rocketmq

F:\rocketmq.txt 新建一个文件,内容如下: listenPort=80 启动命令行中新增 -c F:\\rocketmq.txt,即可。 在windows 下,启动broker失败。 报错是 找不到或无法加载主类 Files 修改如下: runbroker.cmd 中,将 ```cmd set "JAVA_OPT=%JAVA_OPT% -cp %CLASSPATH%" 改为 set "JAVA_OPT=%JAVA_OPT% -cp "%CLASSPATH%"" ``` spring boot 使用log4j2 与 rocketmq-client 对接,笔者使用的是rocketmq-client-4.2版本,发现配置的log...

0
0
发表于AI & 大数据专区
2018/06/14 14:38

RocketMQ

一、背景 随着移动互联网的迅猛发展,各大互联网公司的体量、业务呈现指数式增长,在业务的反哺与逼迫下,分布式技术架构随之遍地开花,其中以SOA服务技术架构,微服务技术架构等为主的分布式架构如火如荼地发展。在这种大趋势之下,互联网企业也开始面临着数据采集,数据异构,系统整合等诸多问题,而CORBA、DCOM、RMI等RPC中间件技术也应运而生,但由于采用RPC同步处理技术,在性能、健壮性、可扩展性上都存在着诸多缺点,消息...

0
0
没有更多内容
加载失败,请刷新页面
点击加载更多
加载中
下一页
04/06 17:25

Mq流量削峰怎么落地

比如秒杀环节,怎么做到让用户点击抢购被异步削峰,但是又要实时把抢购的结果反馈给用户.

2
0
发表于大前端专区
2019/09/29 00:15

RocketMQTemplate切面失效

1.场景 实现调用链路传递,使用aop拦截rocketmqtemplate的sendMessageInTransaction并注入traceId 2.环境 <dependency> <groupId>org.apache.rocketmq</groupId> <artifactId>rocketmq-spring-boot-starter</artifactId> <version>2.0.3</version> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-dependencies</artifactId> <version>2.1.7...

5
1
发表于运维专区
2018/09/06 19:36

rocketmq 消费者消息延迟怎么解决?

在使用MQ的过程中,出现了消费者消费消息延迟的情况,比如我推送消息,一些是直接能被消费者消费的,一些则处于未被消费的状态,也就是延迟了。 这个时候如果重新发送该消息,有两种情况,一种是直接发送成功, 一种是出现异常, 此时的配置是一台服务器上部署的rocketmq,配置信息如下: # 请教下各位大佬,有没有碰到过这类情况,或者是怎么解决的。跪谢....

3
2
发表于软件架构专区
2019/10/10 21:49

RocketMQ奇葩问题,在windows 10服务正常启动,但是发送消息时就报错

背景先声明下,同样的一段发送对象信息的代码,使用 <dependency> <groupId>org.apache.rocketmq</groupId> <artifactId>rocketmq-spring-boot-starter</artifactId> <version>2.0.3</version> </dependency> 依赖对应的最新的依赖包, 配置 rocketmq.name-server=192.168.11.162:9876 rocketmq.producer.group=my-group1 发送代码 OrderPaidEvent orderPaidEvent = new OrderPaidEvent("T_001", new BigDecimal...

3
0
2019/05/27 14:32

rocketmq消息重发时,发现一个错误code208,console web页面没有查到该消息

报错信息如下: Java HotSpot(TM) 64-Bit Server VM warning: ignoring option PermSize=128m; support was removed in 8.0 Java HotSpot(TM) 64-Bit Server VM warning: ignoring option MaxPermSize=128m; support was removed in 8.0 org.apache.rocketmq.tools.command.SubCommandException: QueryMsgByIdSubCommand command failed at org.apache.rocketmq.tools.command.message.QueryMsgByIdSubCommand.execute(QueryMsg...

2
0
发表于AI & 大数据专区
2018/11/02 14:32

rabbitmq 事务消息是否支持?

想请教一下rabbitmq是否支持分布式事务消息? rocketmq4.3开始支持分布式事务消息. 如果rabbitmq不支持事务消息,一般采取什么机制?

1
0
发表了问答
2016/04/14 10:04

RocketMq 时间点消费消息无效怎么办?

我的业务场景是,前10天一直有消息堆积,业务方没有消费,第11天业务方开始消费,但希望从当前时间开始消费,以前的消息不处理; 通过看官方提供的例子,找到如下测试代码,但测试时发现,重新定义一个新消费组,1分钟前的消息依然能消费,请高手指点。 public static void main(String[] args) throws InterruptedException, MQClientException {  DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("PushC...

5
0
2020/05/25 12:29

rocketmq读写队列不同,会带来问题

通过rocketmq控制台创建topic可以填写不同读写队列的个数。 消费者组的消费者数量和读队列有对应关系。一个读队列只对应消费者组的一个消费者。 多个读队列可以对应一个消费者。 也就是读队列越多可以供连接的读消费者就越多。那是不是写反过来写队列越多,可以供写的生产者越多? 关于严格按照消息顺序读写,如果读写队列不一致,如写队列是按照用户的规则存放消息(eg:key%队列个数),读消息的时候还会有分区队列消息顺序吗...

4
0
发表于DevOps专区
2020/05/17 15:07

rocketmq配置优化

针对rocketmq的配置优化,希望各位大佬能提供下帮助

1
0
发表于软件架构专区
2020/03/24 21:38

RocketMQ的Consume一直打印DEBUG日志信息,哪位大佬遇到过

最近遇到一个新项目,用到了RocketMQ, 在Consume端接收Producter发出的日志消息,并进行入库操作。项目自己的日志配置使用log4j2,DAO层用的mybatis。上线发现mybatis的Mapper操作数据库的sql全部被打印在控制台上,等级是debug,但是log4j2的配置默认是info。这是因为rocketMQ采用了自身的日志而没有使用系统自定义的么? 哪位大佬遇到过,求教。。。...

2
0
发表于服务端专区
2019/10/16 16:31

rocketmq消息事务,已提交事务如何回滚?

rocketmq的事务, 假如银行转账操作,银行A和银行B要执行分布式事务 ,银行A执行账户减钱操作成功了,半消息commint,银行B获取到消息后执行DB操作给账户加钱,失败了的话,银行A如何回滚呢?

3
0
发表于AI & 大数据专区
2019/10/10 21:51

RocketMQ奇葩问题,在windows 10服务正常启动,但是发送消息时就报错

背景先声明下,同样的一段发送对象信息的代码,使用 使用docker启动,nameserver、broker还有rocketmq的控制台,显示如下 <dependency> <groupId>org.apache.rocketmq</groupId> <artifactId>rocketmq-spring-boot-starter</artifactId> <version>2.0.3</version> </dependency> 依赖对应的最新的依赖包, 配置 rocketmq.name-server=192.168.11.162:9876 rocketmq.producer.group=my-group1 发送代码 rocketMQTe...

5
0
发表了问答
2015/07/12 12:48

RocketMQ 如何使用MQTT 作为通信协议?

@linkgo 你好,想跟你请教个问题:RocketMQ 使用netty 作为协议层的辅助处理,看官网上写的已经支持mqtt,然而并未发现对应的mqttclient 包。而使用eclipse的paho mqtt 包也无法直连rocketmq,是否需要自己在rocketmq上扩展netty组件来匹配mqtt 协议?

7
1
发表于开发技能专区
2019/08/14 17:38

RocketMq延迟消息没有在当时消费掉,后期去消费,就可以一直消费

图一是延迟消息投递的时间,但是当时没有开消费者,后期去消费,可以一直消费成功,差值和消费时间也不会更新,这是为什么

2
0
发表了问答
2014/12/24 17:13

rocketmq老是自动停掉

rocketmq部署在阿里云上,老是自动停掉,为什么啊?

5
0
2019/07/22 17:03

RocketMQ中的start()和shutdown

通常生产者 生产完消息需要shutdown吗,还是让它一直开着。 producer我是通过@Bean拿到的。拿出时,已经start()过了。 @RequestMapping(value = "/produceMessage", method = RequestMethod.POST) public GeneralResponseDto produceMessage(@RequestBody JSONObject json) throws InterruptedException, RemotingException, MQClientException, MQBrokerException { Message message = new Message(); message.setB...

1
0
发表了问答
2019/06/21 14:48

阿里巴巴微服务开源生态报告 No.1

从关注开源,到使用开源,再到参与开源贡献,越来越多的国内开发者通过开源技术来构建业务。 截止目前,Arthas / Dubbo / ChaosBalde / Nacos / RocketMQ / Seata / Sentinel / Spring Cloud Alibaba / Tengine 等微服务领域的开源项目在 GitHub 上已获得近 8w 的 star,contributor 数量达738位,以一种社区协作的方式,来提升项目的生产效率和分发效率。 这里面,大家既是项目的开发者,也是项目的使用者,作为项目的需求方一...

6
54
发表了问答
2016/12/19 10:50

rocketMq客户端这某个时间点突然不消费了

@linkgo 你好,想跟你请教个问题: rocketmq有两个消费者,一段时间运行正常,突然一个节点不消费了,通过customerConnection命令查看链接依然保持的.重启异常消费者节点后又可以正常消费,mq服务端日志没找到异常信息.请问能否提供下一些处理的思路?

3
0
2019/05/14 09:49

rocketMq 消费者疑问

@Override public void receiveResult(String id, long timeout) { //计数器 LOGGER.info(">>>开始接收订单结果:{}", id); CountDownLatch countDownLatch = new CountDownLatch(1); DefaultMQPushConsumer defaultMQPushConsumer = new DefaultMQPushConsumer(consumerGroup); defaultMQPushConsumer.setMessageModel(MessageModel.CLUSTERING); defaultMQPushConsumer.setNamesrvAddr(namesrvAddr); //从消息队列头开始消费 ...

3
0
发表了问答
2019/05/06 19:20

奔向 968221398.17

上边这个图片是什么? 这是 4 月 26 日杭州云栖小镇“2050 大会”现场的一角,与会者自由地在墙上留下各种乐高拼图。 今年的 2050 大会是第二届了,在三天的“因科技而团聚”中,笔者很难将所有见闻框到一个较为具体的主题下,如果非要总结成一个词,那可以是:不确定。这种不确定对于参与者来说,是新奇、好玩、探索、活跃、惊喜、懵圈、憧憬、未知与期待。 “年青,充满了青春活力,充满着未知” 2050 大会是什么?按照官方的...

10
2
没有更多内容
加载失败,请刷新页面
点击加载更多
加载中
下一页
26 评论
863 收藏
分享
OSCHINA
登录后可查看更多优质内容
返回顶部
顶部