RocketMQ
解读 RocketMQ 5.0 全新的高可用设计
RocketMQ v5 版本融合了上述方案的优势，提出 DLedger Controller 作为管控节点（中间部分所示），将选举逻辑插件化并优化了数据复制的实现。 ......
SpringCloud之Stream消息驱动RocketMQ讲解
[toc] # 1 Stream消息驱动 本文是以 `RocketMQ` 为例讲解，[点击此处了解SpringBoot整合RocketMQ](https://jingzh.blog.csdn.net/article/details/130554340) ## 1.1 简介 ### 1.1.1 定义 ......
容器化部署RocketMQ4.9.4集群
## 容器化部署RocketMQ4.9.4集群 - 背景： 生产环境单机的MQ不具有高可用，所以我们应该部署成集群模式，这里给大家部署一个**双主双从异步复制的Broker集群** ### 一、安装docker ```sh yum install -y docker systemctl enable ......
RocketMQ安装教程
RocketMQ是阿里巴巴在2012年开发的分布式消息中间件，专为万亿级超大规模的消息处理而设计，具有高吞吐量、低延迟、海量堆积、顺序收发等特点。它是阿里巴巴双十一购物狂欢节和众多大规模互联网业务场景的必备基础设施。在同一年，阿里巴巴正式开源了RocketMQ的第一个版本。 2015年，Rocket ......
Apache RocketMQ EventBridge：构建下一代事件驱动引擎
事件驱动，这个词在部分人印象中，它是一个过时的技术——没什么新意。从时间上看，确实也是这样，上世纪 60 年代，事件驱动就已经被正式提出，经常会被在 GUI 编程中。但是在有些人印象中，事件驱动又是一个非常陌生，非常新颖的技术。 ......
docker部署rocketmq
参考网址：https://www.cnblogs.com/MUQINGFENG123/p/17036619.html 一、拉镜像 docker pull foxiswho/rocketmq:server-4.7.0 （拉取镜像） docker pull foxiswho/rocketmq:broke ......
使用RocketMQ组件对请求做削峰处理
内容 rocketMQ基本介绍 使用MQ，将购票流程一分为二。目前系统的吞吐量低，用户从购买车票到拿到票花费的时间较长。 增加排队购票功能。排队提示loading。 购票时序图 目前的时序图，用户发送购票请求，服务端校验验证码，拿令牌，拿锁，然后选座购票，结束流程才会返回。服务器执行时间太长。 增加 ......
必知必会：RocketMQ
1.优点： 应用解耦、异步处理、流量削峰。 2.消息模型： 发布-订阅模型。 一个消息可以被多个消费组消费； 一个消费组中包含多个消费者，同一个消费组的每个消费者负责一部分消息。 3.消息模式： 有两种，集群消息和广播消息，默认是集群消息。 集群消息：一个消费组共同消费一个主题的多个队列，每个队列只 ......
docker 安装rocketmq
1 启动NameServer docker pull rocketmqinc/rocketmq mkdir -p /docker/rocketmq/nameserver/logs /docker/rocketmq/nameserver/store docker run -d --restart=al ......
SpringBoot整合RocketMQ
前提是必须已经安装了RocketMQ并配置好相关的环境变量（自行百度） 第一步： 第二步： 第三步： 第四步： ......
rocketmq集群配置简介
RocketMQ天生对集群的支持非常好，它有以下一些模式： （1）单Master 优点：除了配置简单没什么优点 缺点：不可靠，该机器重启或者宕机，将要导致整个服务不可用 （2）多Master 优点：配置简单，性能最高 缺点：可能会有少量消息丢失（配置相关），单台机器重启或宕机期间，该机器下未被消费的 ......
RocketMQ 从入门到实战
扫一扫加入作者公众号 扫一扫关注 中间件兴趣圈 RocketMQ 官微 扫一扫关注【阿里巴巴云原生】公众号 阿里云开发者“藏经阁” 获取第一手技术干货 海量免费电子书下载作者简介 作者简介 丁威，《RocketMQ 技术内幕》作者，RocketMQ 官方社区优秀布道师，荣获 CSDN2020 博客之 ......
rocketmq-client-go
关注几个配置项: topic groupName tag 按需配置即可。 关于producer和consumer的入口启动略去，客户端层面，关于producer和consumer可以按照自己业务特点，进行配置。 以下为simple样例。 生产者 1 package producer 2 3 impo ......
rocketmq-dashboard
安装文档地址: https://www.cnblogs.com/supermarx/p/16207077.html . ____ _ __ _ _ /\\ / ___'_ __ _ _(_)_ __ __ _ \ \ \ \ ( ( )\___ | '_ | '_| | '_ \/ _` | \ \ ......
rocketMQ消息队列简介及其实例
一、RocketMQ 核心的四大组件： Producer：就是消息生产者，可以集群部署。它会先和 NameServer 集群中的随机一台建立长连接，得知当前要发送的 Topic 存在哪台 Broker Master上，然后再与其建立长连接，支持多种负载平衡模式发送消息。 Consumer：消息消费者 ......
单机下RocketMq安装-多Master模式
版本：5.1.1 官方下载地址：https://rocketmq.apache.org/zh/download jdk版本：jdk1.8.0_201 在指定目录下新建文件夹rocketmq，并下载安装包到目录下 cd /usr/localmkdir rocketmqwget https://dist ......
基于 AIGC，RocketMQ 学习社区探索开源软件学习新范式
AIGC 持续火爆全球，越来越多的场景开始接入并体现非凡的价值。其中应用广泛的场景之一就是智能知识问答，它改变了人们学习的方式，从阅读式到问答式，让知识的获取更加精准有效。开源软件拥有着广泛的求知群体，AIGC+ 社区的结合是学习型社区未来演进方向上的一个新颖的尝试，今天我们结合 RocketMQ ... ......
RocketMQ消费暂停问题分析
一、背景 客经使用rocketMq批量推送数据到pcr执行次贷策略引擎和互斥决策引擎，pcr将决策结果推送到前置路由。 二、问题现象描述 在客经推数据时，pcr-updateBorrowState消息积压越来越多，从日志上看，pcr不拉取消息，重启服务器后可以消费消息，过一会又消费变慢，不断重启才让 ......
RocketMQ保证高可用性
RocketMQ分布式集群是通过Master和Slave的配合达到高可用性的。Master和Slave的区别： 在Broker的配置文件中，参数brokerId的值为0表明这个Broker是Master， 大于0表明这个Broker是Slave， brokerRole参数也说明这个Broker是Ma ......
RocketMQ 学习社区重磅上线！AI 互动，一秒了解 RocketMQ 功能源码
为了进一步帮助你全方位的了解 RocketMQ 相关的知识，同时可以更好的在实际生产环境中使用 RocketMQ，RocketMQ 学习社区重磅上线。 ......
rocketmq
## rocketmq ```java 在 RocketMQ 中，msgId 和 offsetMsgId 是两个不同的概念。 msgId 是消息唯一标识符。具有全局唯一性，由 RocketMQ 在消息发送时自动生成。当消息被成功发送到 Broker 端后，msgId 会随着消息一起存储在 commi ......
万字长文讲透 RocketMQ 4.X 消费逻辑
RocketMQ 是笔者非常喜欢的消息队列，4.9.X 版本是目前使用最广泛的版本，但它的消费逻辑相对较重，很多同学学习起来没有头绪。 这篇文章，笔者梳理了 RocketMQ 的消费逻辑，希望对大家有所启发。  消息，重启pod 优点：操作简单，无需新增资源，在原有资源上扩容 缺点：只完成当前升级，最大只能升级到4C 8G，后续业务量起来有可能还需要升级（升级硬件） 操作： 1. 摘除写入流量 brokerPermission=2 ......
RocketMQ 多级存储设计与实现
随着 RocketMQ 5.1.0 的正式发布，多级存储作为 RocketMQ 一个新的独立模块到达了 Technical Preview 里程碑：允许用户将消息从本地磁盘卸载到其他更便宜的存储介质，可以用较低的成本延长消息保留时间。本文详细介绍 RocketMQ 多级存储设计与实现。 ......
ROCKETMQ
# 配置环境变量（**ROCKETMQ_HOME**） # 修改runserver.cmd 1、进入bin目录下找到runserver.cmd文件，用编辑器打开，因为RocketMQ默认需要2g运行内存，做为测试用，就只要最低配置就好了，注释原有的NameServer 的配置，在其前面加上rem 注 ......
RocketMQ使用实例
下面是一个使用Java实现的RocketMQ示例代码，用于发送和消费消息： 首先，您需要下载并安装RocketMQ，并启动NameServer和Broker。 接下来，您可以使用以下示例代码来发送和消费消息： Producer.java文件： ```java import org.apache.ro ......
详解RocketMQ 顺序消费机制
摘要：顺序消息是指对于一个指定的 Topic ，消息严格按照先进先出（FIFO）的原则进行消息发布和消费，即先发布的消息先消费，后发布的消息后消费。 本文分享自华为云社区《RocketMQ 顺序消费机制》，作者： 勇哥java实战分享 。 顺序消息是指对于一个指定的 Topic ，消息严格按照先进先 ......
RocketMQ4.9.5集群部署
## RocketMQ集群部署 - 背景： 生产环境单机的MQ不具有高可用，所以我们应该部署成集群模式，这里给大家部署一个**双主双从异步复制的Broker集群** ### 一、单机部署、部署前提参考 ```sh https://www.cnblogs.com/hsyw/p/17428530.htm ......