今天来聊一聊 RocketMQ 的灰度方案。
灰度发布是指在黑与白之间,平滑过渡的一种发布方式。在大流量的系统中,如果一次升级改造范围比较大,或者影响内容不太确定,一般会采用切量的方式进行升级,这样可以减少生产变更带来的影响。
2025年05月28日
今天来聊一聊 RocketMQ 的灰度方案。
灰度发布是指在黑与白之间,平滑过渡的一种发布方式。在大流量的系统中,如果一次升级改造范围比较大,或者影响内容不太确定,一般会采用切量的方式进行升级,这样可以减少生产变更带来的影响。
2025年05月28日
京东大佬问我,SpringBoot中如何做延迟队列?单机如何做?分布式如何做呢?并给出案例与代码分析。
嗯,用户问的是在SpringBoot中如何实现延迟队列,单机和分布式环境下分别怎么做。这个问题其实挺常见的,延迟队列在任务调度、订单超时处理这些场景里用得很多。首先得理清楚延迟队列的基本概念和实现方式,然后再考虑单机和分布式环境下的不同解决方案。
2025年05月28日
大家好,我是小郭,今天主要来和大家聊一聊RocketMQ中的线程池是如何创建的,如何设置线程池数量,同时也可以从中去学习到一些线程池的实践和需要注意的一些细节。
在RocketMQ中存在了大量的对线程池的使用,从消息的生产到投递Broker中,到最后的消息消费每一个环节中都大量使用到线程池的地方,下面我们拿出几个不同类型的线程池来看一看。
2025年05月28日
今年双十一大促中,消息中间件 RocketMQ 发生了以下几个方面的变化:
2025年05月28日
RocketMQ是阿里开发的基于消息队列的通用消息中间件产品,能集成分布式事务,也继承了RabbitMQ的优点。
2025年05月28日
Apache Kafka 是一款开源的 分布式流处理平台,最初由 LinkedIn开发,用于处理实时数据管道和流式分析。其核心设计目标是 高吞吐、低延迟、持久化存储 和
2025年05月28日
RocketMQ的Binary版是一些编译好的jar和辅助的shell脚本,可以直接从官网找到下载链接(http://rocketmq.apache.org/dowloading/releases/),也可以下载源码自己编译。 系统要求:64bit的Linux、Unix或Mac。Java版本大于等于JDK1.8。如果需要从GitHub上下载源码和编译的话,需要安装Maven 3.2.x和Git。 RocketMQ当前的最新版本是4.2.0,下面以Binary版本为例说明如何快速使用:
2025年05月28日
这里引用:
https://hub.docker.com/r/leixuewen/rocketmq
2025年05月28日
一 RocketMQ基础
1.1 介绍
MQ是一种提供消息队列服务的中间件,也称为消息中间件,是一套提供了消息生产、存储、消费全过程API的软件系统。
RocketMQ是使用Java语言开发的一款MQ产品,经过数年阿里双11的考验,性能与稳定性非常高,其没有遵循任何常见的MQ协议,而是使用自研协议。