标签：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……
- 1
- 2
