写点什么

Apache RocketMQ

0 人感兴趣 · 28 次引用

  • 最新
  • 推荐

【活动】30 秒上云体验,一键体验 RocketMQ 六大生产环境

立足于企业业务集成的核心场景,RocketMQ在高可靠低延迟方面重点优化,构建了全新的低延迟存储引擎和多场景容灾解决方案;面向业务集成过程中链路逻辑的多样性,RocketMQ提供了丰富的业务消息类型,这些特性的积累使得RocketMQ成为金融级业务消息的首选方案。

最高等级!Apache RocketMQ 入选可信开源项目星云象限领导型象限

Apache RocketMQ 凭借团队在开源领域的持续投入与卓越的产品力,入选星云象限领导型象限。

https://static001.geekbang.org/infoq/f0/f0cd3acb3f13b4b385c4434b6df734fc.jpeg?x-oss-process=image%2Fresize%2Cw_416%2Ch_234

【深度挖掘 RocketMQ 底层源码】「底层源码挖掘系列」透彻剖析贯穿 RocketMQ 的消费者端的运行核心的流程(Pull 模式 - 上)

负责消费消息,一般是后台系统负责异步消费。一个消息消费者会从Broker服务器拉取消息、并将其提供给应用程序。从用户应用的角度而言提供了两种消费形式:拉取式消费、推动式消费。我们接下来主要介绍Pull模式

Apache RocketMQ 入选 SegmentFault 年度中国技术品牌影响力企业榜单!

回首这一年,数字经济的蓬勃发展,风云变幻的市场环境下众多企业与个人的卓绝奋斗。SegmentFault 思否作为中国领先的新一代开发者社区,依托数百万开发者用户数据分析,及各科技企业和个人在国内技术领域的行为、影响力指标,推出了 “中国技术先锋” 年度评

Apache RocketMQ 斩获 InfoQ 2022 年度十大开源新锐项目

以“深入数字经济·洞见技术价值”为主题的【InfoQ 2022 中国技术力量年终榜单】正式公布获奖名单。其中,Apache RocketMQ以其卓越的易用性、社区活跃性、成熟度、产品优越性、代码健康度等荣获【2022 年度十大开源新锐项目】。

https://static001.geekbang.org/infoq/65/65dffeeaa4fb7e21887f44150dc13998.webp?x-oss-process=image%2Fresize%2Cw_416%2Ch_234

RocketMQ 在物流行业的应用与运维

用户头像
Apache RocketMQ
2022-11-11

RocketMQ 的能力与快递业务场景非常吻合,因此在快递行业的应用极为广泛,作为快递行业龙头企业,中通双11期间日均消息流转超过万亿。一起来了解中通是如何保证 MQ 服务器性能与数据可靠性吧!

https://static001.geekbang.org/infoq/53/534372b2e6f5efcda9a59132f2b2ad68.png?x-oss-process=image%2Fresize%2Cw_416%2Ch_234

RocketMQ 在同程旅行的落地实践

用户头像
Apache RocketMQ
2022-11-10

随着同城快递业务需求的增长,时常会出现平台爆单的情况,因此十分需要稳定性保障服务。综合选型对比后,RocketMQ 以低成本、高可靠等核心优势成为了系统升级的不二选择,快来查收这份 ActiveMQ 平滑迁移 RocketMQ 技术方案一起来了解学习吧~

https://static001.geekbang.org/infoq/e6/e672b23df2b218208dfe186bc3f9fca6.jpeg?x-oss-process=image%2Fresize%2Cw_416%2Ch_234

大数据生态中的 RocketMQ 5.0

用户头像
Apache RocketMQ
2022-11-10

随着 RocketMQ 5.0 的发布,RocketMQ 在处理消息、事件和流上实现了统一,有了越来越强大的优势,使企业上云更省钱、更省时,也更省人力,一起来看看大数据生态中的 RocketMQ 5.0 吧~

https://static001.geekbang.org/infoq/00/00f514422ecb78b353994a467879faf0.jpeg?x-oss-process=image%2Fresize%2Cw_416%2Ch_234

RocketMQ Flink Catalog 设计与实践

用户头像
晓双
2022-11-01

Flink 是一个分布式计算引擎,目前已经实现批流一体,可以实现对有界数据和无界数据的处理。需要有效分配和管理计算资源才能执行流式应用程序。本文主要介绍了 RocketMQ 和 Flink 结合,基于 RocketMQ 实现的 Flink Catalog。

vivo 鲁班平台 RocketMQ 消息灰度方案

实践是检验真理的唯一标准,我们进行了详细的灰度功能校验,分别是灰度版本订阅的topic&tag不变、灰度版本订阅的topic增加、灰度版本订阅的topic减少、灰度版本订阅的tage变化以及灰度版本订阅的topic&tag混合变化。

RocketMQ Streams 在云安全及 IoT 场景下的大规模最佳实践

RocketMQ Streams的第三个应用场景是IOT。IOT是典型的边缘计算场景,挑战在于需要用4core 8g来混部其业务和RocketMQ Streams任务,几百个任务的压力非常大。而且它需要采用MQTT这样标准的IOT协议输入,也需要自定义规则引擎的能力进行统计计算、特

Apache RocketMQ 5.0 在 Stream 场景的存储增强

RocketMQ的诞生是为了解决微服务解耦的问题。微服务解耦指将传统的巨大服务拆分为分布式的微服务。

从 RabbitMQ 平滑迁移到 RocketMQ 技术实战

本文将介绍基于RocketMQ建设消息中间件平台并实现在线业务无感知的平滑迁移

https://static001.geekbang.org/infoq/dd/dd8cb4c8f0cf52eef0e414cb6a96f4be.jpeg?x-oss-process=image%2Fresize%2Cw_416%2Ch_234

RocketMQ 5.0: 存储计算分离新思路

在阿里云上,RocketMQ 的商业化产品也以弹性云服务的形式为全球数万个用户提供企业级的消息解决方案,被广泛应用于互联网、大数据、移动互联网、物联网等领域的业务场景,成为了业务开发的首选消息中间件。

RocketMQ—Producer(二)路由动态更新

用户头像
IT巅峰技术
2022-04-04

从NameServer章节分析得知,路由信息存储在NameServer,生产端和消费端定时向NameServer获取topic相关的路由信息; 从生产者启动流程得知:路由信息的动态更新源码在MQClientInstance#startScheduledTask定时任务里面具体方法:updateTopicRouteInfoFromNam

https://static001.geekbang.org/infoq/12/121b991cea843a9fb0d5326fee33cdc4.jpeg?x-oss-process=image%2Fresize%2Cw_416%2Ch_234

🏆【Alibaba 中间件技术系列】「RocketMQ 技术专题」系统服务底层原理以及高性能存储设计分析

用户头像
洛神灬殇
2022-01-23

消息中间件的本身定义来考虑,应该尽量减少对于外部第三方中间件的依赖。一般来说依赖的外部系统越多,也会使得本身的设计越复杂,采用文件系统作为消息存储的方式。

https://static001.geekbang.org/infoq/12/121b991cea843a9fb0d5326fee33cdc4.jpeg?x-oss-process=image%2Fresize%2Cw_416%2Ch_234

🏆【Alibaba 中间件技术系列】「RocketMQ 技术专题」Broker 服务端自动创建 topic 的原理分析和问题要点指南

用户头像
洛神灬殇
2022-01-19

使用RocketMQ进行发消息时,一般我们是必须要指定topic,此外topic必须要提前建立,但是topic的创建(自动或者手动方式)的设置有一个开关autoCreateTopicEnable,此部分主要会在broker节点的配置文件的时候进行设置,运行环境中会使用默认设置autoCreateTop

https://static001.geekbang.org/infoq/e4/e420c473255e7d0dc9b242606ed1f2ce.jpeg?x-oss-process=image%2Fresize%2Cw_416%2Ch_234

🏆【Alibaba 中间件技术系列】「RocketMQ 技术专题」带你一起去探索 RocketMQ 服务架构的线程模型分析

用户头像
洛神灬殇
2022-01-04

RocketMQ 是个消息服务器,也是个网络服务器。接下来我们将从网络 IO 模型,线程模型,看看 RocketMQ 是如何设计的。

https://static001.geekbang.org/infoq/c0/c0f0d826888ce6a50dc0089825cf9b31.jpeg?x-oss-process=image%2Fresize%2Cw_416%2Ch_234

🏆【Alibaba 中间件技术系列】「RocketMQ 技术专题」RocketMQ 消息发送的全部流程和落盘原理分析

用户头像
洛神灬殇
2021-12-21

RocketMQ目前在国内应该是比较流行的MQ 了,目前本人也在公司的项目中进行使用和研究,借着这个机会,分析一下RocketMQ 发送一条消息到存储一条消息的过程,这样会对以后大家分析和研究RocketMQ相关的问题有一定的帮助。

https://static001.geekbang.org/infoq/21/21d8847d02e7188928f9b1cd118e97e1.png?x-oss-process=image%2Fresize%2Cw_416%2Ch_234

再下一城!两大社区携手打造 API 日志监控新利器

12 月 26 日(周日),Apache APISIX 社区将联合 Apache RockMQ 社区为大家带来更多实践内容的线上分享。想要了解更多应用实践内容,一起来参与此次的线上 Meetup 吧!

https://static001.geekbang.org/infoq/12/121b991cea843a9fb0d5326fee33cdc4.jpeg?x-oss-process=image%2Fresize%2Cw_416%2Ch_234

🏆【Alibaba 中间件技术系列】「RocketMQ 技术专题」Broker 配置介绍及发送流程、异常 (XX Busy) 问题分析

用户头像
洛神灬殇
2021-12-10

Rocketmq官网:http://rocketmq.apache.org/,针对前4种 broker busy ,主要是由于 Broker 在追加消息时持有的锁时间超过了设置的1s,Broker 为了自我保护,会抛出错误,客户端会选择其他 broker 服务器进行重试。

https://static001.geekbang.org/infoq/12/121b991cea843a9fb0d5326fee33cdc4.jpeg?x-oss-process=image%2Fresize%2Cw_416%2Ch_234

🏆【Alibaba 中间件技术系列】「RocketMQ 技术专题」让我们一起实践 RocketMQ 的服务搭建及配置操作

用户头像
洛神灬殇
2021-12-03

分别将alibaba-rocketmq-x.x.x.tar.gz使用rz命令上传到两台机器,也可以直接官网在线下载。

https://static001.geekbang.org/infoq/ae/ae195edbfef390de7f9430bf337f7c91.jpeg?x-oss-process=image%2Fresize%2Cw_416%2Ch_234

RocketMQ 这样做,压测后性能提高 30%

从官方这边获悉,RocketMQ在4.9.1版本中对消息发送进行了大量的优化,性能提升十分显著,接下来请跟着我一起来欣赏大神们的杰作。

https://static001.geekbang.org/infoq/12/122a8516fee68ce808025275b9f130c9.jpeg?x-oss-process=image%2Fresize%2Cw_416%2Ch_234

7 张图揭晓 RocketMQ 存储设计的奥妙

本文从存储、顺序写、内存映射、刷盘策略、内存级读写分离等方面详细阐述了RocketMQ存储设计之精髓。

https://static001.geekbang.org/infoq/a5/a5c0eba38f60c0d0c5d432b833cd436f.jpeg?x-oss-process=image%2Fresize%2Cw_416%2Ch_234

🏆【Alibaba 中间件技术系列】「RocketMQ 技术专题」让我们一起探索一下 DefaultMQPullConsumer 的实现原理及源码分析

用户头像
洛神灬殇
2021-11-23

在RocketMQ中一般有两种获取消息的方式,一个是拉(pull,消费者主动去broker拉取),一个是推(push,主动推送给消费者),在上一章节中已经介绍到了相关的Push操作,接下来的章节会介绍Pull操作方式的消费机制体系。

https://static001.geekbang.org/infoq/a5/a5c0eba38f60c0d0c5d432b833cd436f.jpeg?x-oss-process=image%2Fresize%2Cw_416%2Ch_234

🏆【Alibaba 中间件技术系列】「RocketMQ 技术专题」让我们一起探索一下 DefaultMQPushConsumer 的实现原理及源码分析

用户头像
洛神灬殇
2021-11-22

RocketMQ开源是使用文件作为持久化工具,阿里内部未开源的性能会更高,使用oceanBase作为持久化工具。在RocketMQ1.x和2.x使用zookeeper管理集群,3.x开始使用nameserver代替zk,更轻量级,此外RocketMQ的客户端拥有两种的操作方式:DefaultMQPushConsumer

https://static001.geekbang.org/infoq/a5/a5c0eba38f60c0d0c5d432b833cd436f.jpeg?x-oss-process=image%2Fresize%2Cw_416%2Ch_234

🏆【Alibaba 中间件技术系列】「RocketMQ 技术专题」让我们一起实践 RocketMQ 的服务搭建及配置操作

用户头像
洛神灬殇
2021-11-21

RocketMQ是一款分布式、队列模型的消息中间件,具有以下特点 1、能够保证严格的消息顺序 2、提供丰富的消息拉取模式 3、高效的订阅者水平扩展能力 4、实时的消息订阅机制 5、亿级消息堆积能力

https://static001.geekbang.org/infoq/1d/1d62763215e718de4fcc6ede63c579aa.png?x-oss-process=image%2Fresize%2Cw_416%2Ch_234

从消息到数据湖:看 Apache RocketMQ、Hudi、Kyuubi 最新进展

上海的开发者小伙伴们,12 月 18 号,Apache RocketMQ & Apache Hudi & Apache Kyuubi (Incubating)三社区 Meetup 来了,打造最强消息传输、实时计算、数据入湖一体化解决方案专场。

Apache RocketMQ_Apache RocketMQ技术文章_InfoQ写作社区