• -------------------------------------------------------------
  • ====================================

标签:RocketMQ

CentOS 7.9下RocketMQ 4.9安装和配置手册

1. 安装前的准备1.1 安装环境1.1.1 操作系统内核版本[root@localhost ~]# uname -aLinux localhost.localdomain 3.10.0-1160.el7.x86_64 #1 SMP Mon Oct 19 16:18:59 UTC 2020 x86_64 x86_64 x86_64 GNU/Linux……

RocketMq 实际案例–普通消息的发送

RocketMq 实际案例–普通消息的发送@(消息中间件)[RocketMq 实例]学习 rocketMq 最根本的是要先学会用嘛,在创建 rocketMq 的第一个案例的时候,碰到很多坑,可以记录下。第一步:启动 namesrv 和 broker官方文档未告知的坑:问题 1: 如果在单机环境下,没有 Dock……

安装rocketmq-console

一、alibaba 版本使用 rocketmq 命令查看集群状态,查看 topic 信息时比较麻烦,而且不直观,这个时候可以使用一些 web 页面来管理 rocketmq。以前曾使用过一个老版本的工具,适用于 alibaba 版本(贡献至 apache 之前的版本),这里只共享一个安装包的百度网盘连接:https://pan.bai……

利用Rocketmq4.2版来实现分布式事务

花了点时间学了RocketMQ,下面是本人的一点点心得,如果觉的写的好就点个赞,但如果你要借鉴话,我还是劝你看下面参考资料里的视频(作者为阿里牛人),虽然他分享的视频是为了推销阿里云的 DRDS、ONS(RocketMQ阿里版),只是讲了个大概,没有细说,但是指明一个大的方向,让人非常的受益。借用阿里牛人视频中的 ppt:来说明单机事务拆分成分布式……

消息中间件 RocketMQ 源码解析:Filtersrv

本文主要基于 RocketMQ 4.0.x 正式版概述Filtersrv 注册到 Broker过滤类3.1 Consumer 订阅时设置 过滤类代码3.2 Consumer 上传 过滤类代码3.3 Filter 编译 过滤类代码过滤消息4.1 Consumer 从 Filtersrv 拉取消息4.2 Filtersrv 从 Broker ……

RocketMQ实战(一)

阿里巴巴有 2 大核心的分布式技术,一个是 OceanBase,另一个就是RocketMQ。在实际项目中已经领教过RocketMQ的强大,本人计划写一个RocketMQ实战系列,将涵盖RocketMQ的简介,环境搭建,初步使用、API 详解、架构分析、管理员集群操作等知识。What is RocketMQ?RocketMQ作为一款分布式的消……

说说 MQ 之 RocketMQ

RocketMQ 是出自 A 公司的开源产品,用 Java 语言实现,在设计时参考了 Kafka,并做出了自己的一些改进,消息可靠性上比 Kafka 更好,目前,RocketMQ 的文档仍然不够丰富 1 2,社区仍然无法与 Kafka 比肩,但 A 公司已经推出了基于 RocketMQ 的云产品 3,相信未来 RocketMQ……

RocketMQ初步应用架构理论

R写给RocketMQ架构应用入门,内容涉及它的设计机理以及推到出来的应用注意事项,入门人员请看。稍微涉及技术细节,留以我设计中间件时参考,将来整理深度文档时会抽取走,入门人员可以无视。以下RocketMQ简称为 RQ,理论部分采用版本为 3.2.4,测试部分采用版本为 3.2.6。MQ 的需求我们对 MQ 的需求,……

源码分析RocketMQ刷盘机制

刷盘机制支持同步刷盘和异步刷盘。为了了解其具体事项,我们以 Commitlog 的存储为例来说明RocketMQ是如何进行磁盘读写。Comitlog#putMessage 首先,主要是将消息写入到 MappedFile,内存映射文件。然后根据刷盘策略刷写到磁盘,入口:CommitLog#putMessage handleDiskFlushCommit……

RocketMQ 源码分析 —— Message 拉取与消费(上)

摘要: 原创出处 http://www.iocoder.cn/RocketMQ/message-pull-and-consume-first/ 「芋道源码」欢迎转载,保留摘要,谢谢!本文主要基于 RocketMQ 4.0.x 正式版1、概述2、ConsumeQueue 结构3、ConsumeQueue 存储ReputMe……