一,环境搭建

1 启动nameServer

1.启动存在问题

启动类

报错

需要进行2,3

2.添加配置

在项目下创建文件conf,并拷贝配置文件到该目录下

配置文件在哪找

3.配置环境变量

为什么添加:让系统找到2步骤中配置

name 上面报错中有提示:ROCKETMQ_HOME

value 源码路径

2 启动broker

1.修改broker配置文件,添加数据保存路径,不添加保存在默认位置

自定义文件生成路径

添加配置,如下图

-c D:\rocketmq\conf\broker.conf   -c  broker.conf路径

2.注意

namesrvAddr=127.0.0.1:9876  配置

启动成功

The broker[broker-a, 192.168.96.*:10911] boot success. serializeType=JSON and name server is 127.0.0.1:9876

3.调试

生产者与消费者,启动可以看消息发送与消费

二,nameServer

1.架构设计

2.NameServer作用
主要作用为消息生产者和消息消费者提供关于topic路由信息,维护存储,注册,删除路由信息,管理broker节点。

3.启动

4.路由管理

RouteInfoManager

路由元数据

路由注册,broker启动向nameServer注册

发送心跳,通过定时任务,broker每隔30s向nameServer发送注册信息

处理心跳

路由删除

nameServer120检查broker信息是否存在,删除

路由发现

小结:

三,生产者

主要方法

属性

启动

DefaultMQProducer

启动生产者具体实现

DefaultMQProducerImpl

四,消费消息

rocketmq源码调试相关推荐

  1. 6、RocketMQ 源码解析之 Broker 启动(上)

    上面一篇我们介绍了 RocketMQ 的元数据管理,它是通过自定义一个 KV 服务器.并且其它服务在 NameServer 注册服务信息的时候都是全量注册.如果 RocketMQ 的拓扑图当中有多台 ...

  2. RocketMQ 源码分析 —— 集成 Spring Boot

    点击上方"芋道源码",选择"设为星标" 做积极的人,而不是积极废人! 源码精品专栏 原创 | Java 2020 超神之路,很肝~ 中文详细注释的开源项目 RP ...

  3. mq消费者组_「架构师MQ进阶」RocketMQ源码分析(四)- 源代码包结构分析

    在前面第一篇中已经将源代码下载到本地了,本篇主要是介绍代码中相关模块到作用.036.Rocket-MQ-Source-code-cover.png 一.源码结构 RocketMQ源码组织方式基于Mav ...

  4. Android FrameWork学习(二)Android系统源码调试

    点击打开链接 通过上一篇 Android FrameWork学习(一)Android 7.0系统源码下载\编译 我们了解了如何进行系统源码的下载和编译工作. 为了更进一步地学习跟研究 Android ...

  5. 在Eclipse中进行HotSpot的源码调试--转

    原文地址:http://www.linuxidc.com/Linux/2015-05/117250.htm 在阅读OpenJDK源码的过程中,经常需要运行.调试程序来帮助理解.我们现在已经可以编译出一 ...

  6. webuploader 怎么在react中_另辟蹊径搭建阅读React源码调试环境支持所有React版本细分文件断点调试...

    引言(为什么写这篇文章) 若要高效阅读和理解React源码,搭建调试环境是必不可少的一步.而常规方法:使用react.development.js和react-dom.development.js调试 ...

  7. 使用vs2005进行(wince)DLL源码调试

    调试Dll也需要进到源码里面,进行单步调试.下面是使用vs2005进行wince DLL源码调试的步骤(可能我的方法麻烦了). ------------------------------------ ...

  8. Mac下下载android4.2源码,进行源码调试

    星期天在家研究了一下如何在mac下下载android4.2的源码并通过eclipse进行源码级别调试来更清晰的研究一下android的运行原理,具体步骤如下: 最后下下来了,但是我进行编译却没有通过, ...

  9. 探秘RocketMQ源码——Series1:Producer视角看事务消息

    简介:探秘RocketMQ源码--Series1:Producer视角看事务消息 1. 前言 Apache RocketMQ作为广为人知的开源消息中间件,诞生于阿里巴巴,于2016年捐赠给了Apach ...

  10. iOS之深入解析WKWebView的WebKit源码调试与分析

    一.前言 移动互联网时代,网页依旧是内容展示的重要媒介,这离不开 WebKit 浏览内核技术的支持与发展.在 iOS 平台下开发者们需要通过 WKWebView 框架来与 WebKit 打交道. 虽然 ...

最新文章

  1. Linux桌面资源监视器,rsmo-linux下与桌面相嵌的系统资源监视器(转)
  2. Kubernetes CRD开发汇总
  3. hive中实现行转列_漫谈数据仓库之拉链表(原理、设计以及在Hive中的实现)
  4. linux进程如何挂起自己,Linux Server HTTP进程每天挂起服务器
  5. Java方法实现是什么意思_Java中实现可调用的最佳方法是什么,需要一段时间才能完成...
  6. FreeRTOS源码分析与应用开发04:消息队列
  7. groupadd 命令
  8. UVM的factory机制
  9. anaconda下载 (清华镜像)
  10. 实现发送邮件动态html内容的几种思路
  11. 2021肿瘤早筛行业研究报告
  12. 基于PyQt5与opencv制作的证件照尺寸变换应用程序
  13. springboot快速开发框架,适合二次开发(一)
  14. photoshop 抠图
  15. 怎么实现微信公众号生成专属二维码推广来源统计
  16. 基于springboot+vue个人博客搭建
  17. 从零开始学架构——架构基础
  18. 牛客练习赛72-Abrz的杯子brz的雪糕
  19. java线程池的参数设置
  20. 高仿人人车 范围选择器

热门文章

  1. worldcloud库的使用
  2. PSVR透露下一步计划,不做内容改做声控
  3. WAF Bypass数据库特性(Oracle探索篇)
  4. 编写可执行程序,其它程序调用,并返回数据,C#
  5. 冒泡排序(普通,加强对比)
  6. html5 postMessage解决跨域、跨窗口消息传递[转载]
  7. 视频直播、视频会议、视频点播三者有何区别
  8. leetcode:Longest Common Prefix【Python版】
  9. Oracle数据泵对已经存在的表加载索引
  10. linux中的输出格式化,Linux column使用(格式化输出)