RocketMQ源码学习(一)-概述

godlong_X 发布于2019-08-16 10:41 / 751人阅读

摘要：每个与集群中的所有节点建立长连接，定时注册信息到所有。完全无状态，可集群部署。本系列源码解析主要参照原理简介来追寻其代码实现虽然版本不太一致但这也是能找到的最详细的资料了接下来根据其模块来源码阅读目录如下

为什么选择读RocketMQ?

对MQ的理解一直不深,上周看了,还是觉得不够深入,找个成熟的产品来学习吧,RabbitMQ是erLang写的,Kafka是Scala写的,非Java写的看起来还需要补充很多知识,ActiveMQ虽然是Java,但是各方面略显老旧,最终选择了RocketMQ(4.1.0-incubating release)来学习.

吐槽下RocketMQ

　　　作为阿里巴巴捐给Apache的项目,官网上有用的资源太少了,到处都只说性能的数据,还有简单例子,详细的使用文档竟然没有了,怪不得没有kafka流行呢,dubbo的文档都比这强很多,话说开源产品不是摆来看和吹牛的,让更多的人方便使用起来才是开源的核心思想吧,另外源码中的注释也实在太少了,还不如我司的项目的注释齐全呢,跟JDK,Spring比起来差太多了,不过好在名字起的不错,编码也规范,看起来还能继续下去.

概览

如图所示RocketMQ的使用由命名服务，生产者，消费者，中转服务器组成．

Name Server 是一个几乎无状态节点，可集群部署，节点之间无任何信息同步

Broker 部署相对复杂，Broker 分为 Master 与 Slave，一个 Master 可以对应多个 Slave，但是一个 Slave 只能对应一个 Master，Master 与 Slave 的对应关系通过指定相同的 BrokerName，不同的 BrokerId 来定义，BrokerId为 0 表示 Master，非 0 表示 Slave。Master 也可以部署多个。每个 Broker 与 Name Server 集群中的所有节点建立长连接，定时注册 Topic 信息到所有 Name Server。

Producer 与 Name Server 集群中的其中一个节点(随机选择)建立长连接，定期从 Name Server 取 Topic 路由信息，并向提供 Topic 服务的 Master 建立长连接，且定时向 Master 发送心跳。Producer 完全无状态，可
集群部署。

Consumer 与 Name Server 集群中的其中一个节点(随机选择)建立长连接，定期从 Name Server 取 Topic 路
由信息，并向提供 Topic 服务的 Master、Slave 建立长连接，且定时向 Master、Slave 发送心跳。Consumer 既可以从 Master 订阅消息，也可以从 Slave 订阅消息，订阅规则由 Broker 配置决定。

本系列源码解析主要参照来追寻其代码实现,虽然版本不太一致,但这也是能找到的最详细的资料了.接下来根据其模块来源码阅读
目录如下:
1.　Name Server
2.　Producer
3.　Broker
4.　Consumer

GPU云服务器云服务器深度学习概述机器学习概述深度学习的概述第一源码网

文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。

转载请注明本文地址：https://www.ucloud.cn/yun/70243.html

RocketMQ源码学习(六)-Name Server

摘要：完全无状态，可集群部署与集群中的其中一个节点随机选择建立长连接，定期从取路由信息，并向提供服务的建立长连接，且定时向发送心跳。既可以从订阅消息，也可以从订阅消息，订阅规则由配置决定。问题列表: Name Server 的作用是什么? Name Server 存储了Broker的什么信息? Name Server 为Producer的提供些什么信息? Name Server 为Co...

Joyven 2019-08-16 10:44 评论0 收藏0
jvm原理

摘要：在之前，它是一个备受争议的关键字，因为在程序中使用它往往收集器理解和原理分析简称，是后提供的面向大内存区数到数多核系统的收集器，能够实现软停顿目标收集并且具有高吞吐量具有更可预测的停顿时间。 35 个 Java 代码性能优化总结优化代码可以减小代码的体积，提高代码运行的效率。从 JVM 内存模型谈线程安全小白哥带你打通任督二脉 Java使用读写锁替代同步锁应用情景前一阵有个做...

lufficc 2019-08-15 13:54 评论0 收藏0
让你看懂的RocketMQ事务消息源码分析(干货)

摘要：但是服务器又确实是收到了这条消息的，只是给客户端的响应丢失了，所以导致的结果就是扣款失败，成功发货。所有的半消息都会写在为的半消息队列里，并且每条半消息，在整个链路里会被写多次，如果并发很大且大部分消息都是事务消息的话，可靠性会存在问题。前言得益于MQ削峰填谷，系统解耦，操作异步等功能特性，在互联网行业，可以说有分布式服务的地方，MQ都往往不会缺席。由阿里自研的RocketMQ更是...

zsirfs 2019-08-16 18:34 评论0 收藏0
一定能看懂的RocketMQ事务消息源码分析(干货)

摘要：但是服务器又确实是收到了这条消息的，只是给客户端的响应丢失了，所以导致的结果就是扣款失败，成功发货。既然消息的发送不能和本地事务写在一起，那如何来保证其整体具有原子性的需求呢答案就是今天我们介绍的主角事务消息。前言得益于MQ削峰填谷，系统解耦，操作异步等功能特性，在互联网行业，可以说有分布式服务的地方，MQ都往往不会缺席。由阿里自研的RocketMQ更是经历了多年的双十一高并发挑战...

myshell 2019-08-16 18:33 评论0 收藏0
写这么多系列博客，怪不得找不到女朋友

摘要：前提好几周没更新博客了，对不断支持我博客的童鞋们说声抱歉了。熟悉我的人都知道我写博客的时间比较早，而且坚持的时间也比较久，一直到现在也是一直保持着更新状态。 showImg(https://segmentfault.com/img/remote/1460000014076586?w=1920&h=1080); 前提好几周没更新博客了，对不断支持我博客的童鞋们说声：抱歉了！。自己这段时...

JerryWangSAP 2019-08-16 11:11 评论0 收藏0