当前位置： 首页 > news >正文

RocketMQ系列开篇

news 2026/2/10 10:35:25

RocketMQ系列开篇

今天开始学习RocketMQ相关系列源码。我会带着自己的目的去学习源码。所以不会像一般的技术博客一样，写一个完整的流程，介绍每一步干了啥。而是提出一个问题，然后去看代码里面是怎么实现的。说明一下，本次系列我选的是roketMQ的5.0.0版本，不同版本肯定代码都是有不同出入的，但是思想是一样的，大家可以借鉴。下面开始正题。

首先clone源码。然后就是本地运行了。

模块介绍

首先先介绍一下主要的模块

nameserv.其实就是一个注册中心。接收broker的注册，保存broker的路由地址，以供消费者和生产者查询。

broker。就是保存数据的地方。

comsumer和producter就不用说了，生产者和消费者。

只要有个简单的认识就可以了，后续我们会对每个模块进行解析。

本地运行

这里就只跑一个最简单的例子。

启动 nameserv

首先启动nameserv。找到nameserv这个模块下面的NamesrvStartup这个类，启动后会发现报错说没有roketmq_Home。所以在启动类里面加上环境变量。

ROCKETMQ_HOME=D:/project/ideaPorject/myProject/rocketmq/distribution

启动broker

找到broker模块下面的BrokerStartup，加上和上面同样的ROCKETMQ_HOME的环境变量，然后启动

启动comsumer和producer

在example模块下面有个quickstart目录，里面有消费者和生产者。他们的group不一样，我们先改成一样。然后先启动comsumer，再启动producer。就会发现控制台有消费和打印出来了。

至此，我们的项目就启动完成了。

相关文章：

RocketMQ系列开篇

RocketMQ系列开篇 今天开始学习RocketMQ相关系列源码。我会带着自己的目的去学习源码。所以不会像一般的技术博客一样，写一个完整的流程，介绍每一步干了啥。而是提出一个问题，然后去看代码里面是怎么实现的。说明一下，本次系列我…...

编程日记 2023/4/21 8:59:12

logback无法删除太久远的日志文件？logback删除日志文件源码分析

logback无法删除太久远的日志文件？logback删除日志文件源码分析 最近发现logback配置滚动日志，但是本地日志文件甚至还有2年前的日志文件，服务器是却是正常的！ 网上搜索了一波没有发现，只找到说不能删除太久远的旧日志…...

编程日记 2023/4/21 8:58:53

【MyBatis-Plus】基于@Version注解的乐观锁实现

引入mybatis-plus依赖，注意这里的版本要求 since 3.4.0；（3.4.1,3.4.2已测） 3.2.0肯定是不支持的，无法引入MybatisPlusInterceptor； 乐观锁 当要更新一条记录的时候，希望这条记录没有被别人更新…...

编程日记 2023/4/21 8:58:35

ubuntu20.04搭建detectron2环境

Ubuntu22.04安装Cuda11.3 Linux下驱动安装 # 以下命令按顺序执行 sudo apt update && sudo apt upgrade -y # or sudo apt update # 查看显卡信息 ubuntu-drivers devices sudo ubuntu-drivers autoinstall # or sudo apt install nvidia-driver-510 reboot nvidia-s…...

编程日记 2023/4/21 8:58:20

Navicate远程连接Linux上docker安装的MySQL容器

Navicate远程连接Linux上docker安装的MySQL容器失败 来自：https://bluebeastmight.github.io/ 问题描述：windows端的navicat远程连接不上Linux上docker安装的mysql（5.7版本）容器，错误代码10060 标注： 1、…...

编程日记 2023/4/21 8:58:01

基于Jetson NX的模型部署

系统安装 系统安装过程分为3步： 下载必要的软件及镜像 Jetson Nano Developer Kit SD卡映像 https://developer.nvidia.com/jetson-nano-sd-card-image Windows版SD存储卡格式化程序 https://www.sdcard.org/downloads/formatter_4/eula_windows/ 镜像烧录工具…...

编程日记 2023/4/21 8:57:45

【PaddlePaddle onnx】PaddlePaddle导出ONNX及模型可视化教程

文章目录1 背景介绍2 实验环境3 paddle.onnx.export函数简介4 代码实操4.1 PaddlePaddle与ONNX模型导出4.2 ONNX正确性验证4.3 PaddlePaddle与ONNX的一致性检查4.4 多输入的情况5 ONNX模型可视化6 ir_version和opset_version修改7 致谢原文来自于地平线开发者社区，未…...

编程日记 2023/4/24 20:33:23

虹科案例 | 如何可持续的对变压器进行温度监控？

为了延长变压器的使用寿命，需要一个测量系统来监测内部整个绕组区域的温度。它必须明确温度升高发生的位置及其强度。您可以在此处了解为什么会这样以及如何在实践中实施? PART 1 变压器多点测温问题 变压器的工作温度越高，使用寿命越短。这里主要存在…...

编程日记 2023/4/24 20:33:22

Go之入门（特性、变量、常量、数据类型）

一、Go语言特性 语法简单并发性。Go语言引入了协程goroutine，实现了并发编程内存分配。Go语言为了解决高并发下内存的分配和管理，选择了tcmalloc进行内存分配（为了并发设计的高性能内存分配组件，使用cache为当前线程提供无锁分配…...

编程日记 2023/3/9 3:55:09

第九届省赛——8等腰三角形(找规律)

题目：本题目要求你在控制台输出一个由数字组成的等腰三角形。具体的步骤是：1. 先用1,2,3，...的自然数拼一个足够长的串2. 用这个串填充三角形的三条边。从上方顶点开始，逆时针填充。比如，当三角形高度是8时&#xff1a…...

编程日记 2023/3/9 3:54:05

【产品设计】ToB 增删改查显算传

入职培训时技术leader说：“我不需要你们太聪明，做好基础的增删改查就可以了。”看似很简单的活，要做好并不容易。基础的坑在哪里呢？ 一、 增（新增、创建、导入） 1. 明确表字段类型 新增的业务是由不同类型…...

编程日记 2023/4/22 3:44:55

MySQL(二)视图、锁、存储过程、触发器、锁以及常用工具

MySQL进阶视图检查选项视图的更新存储过程存储过程基本语法变量系统变量用户自定义变量局部变量if判断参数casewhile循环repeat循环loop循环cursor游标handler条件处理程序存储函数触发器锁全局锁表级锁表锁元数据锁意向锁行级锁行锁间隙锁&临键锁InnoDB引擎逻辑存储结构事…...

编程日记 2023/4/22 3:44:38

CorelDRAW Graphics Suite2023更新内容介绍

懂设计的职场人都知道这款软件，CorelDRAW是一款非常高效的矢量图形设计软件。CorelDRAW操作界面简洁易懂，能够为用户提供精确地创建物体的尺寸和位置的功能，减少点击步骤，提高设计效率，节省设计时间。功能比普通的美图…...

编程日记 2023/4/18 7:14:28

2021牛客OI赛前集训营-提高组（第三场） T1变幻

2021牛客OI赛前集训营-提高组&#xff08;第三场&#xff09; 题目大意 对于一个大小为nnn的数组aaa的任意一点iii&#xff0c;若满足ai−1>aia_{i-1}>a_iai−1​>ai​且ai<ai1a_i<a_{i1}ai​<ai1​&#xff0c;则称iii为山谷点。111和nnn不可能为山谷点。…...

编程日记 2023/4/20 6:23:20

你还在使用if-else写代码吗，今天带你领略下策略模式的魅力！

1、什么是策略模式 策略模式其实也是在解耦&#xff0c;把策略的定义、创建、使用这三个部分解耦开来&#xff0c;因为本身策略模式也是基于接口编程&#xff0c;这样其实可以简单的理解客户端调用使用接口进行编程&#xff0c;可以通过工厂方法创建对应的策略模式&#xff0c…...

编程日记 2023/4/20 9:41:42

Leetcode. 21 合并两个有序列表

尾插 核心思路&#xff1a;依次比较 &#xff0c;取经过比较后较小值进行尾插 cur1 指向list1 ,cur 2指向list2 ,当cur1走完list1 或者cur2 走完list2 后停止 如果cur1走完list1 ,可以将cur2 整个拿下来尾插 如果cur2走完list2 ,可以将cur1 整个拿下来尾插 特殊情况 &#xff1…...

编程日记 2023/4/20 9:41:29

使用 Wall 教你搭建 照片墙 和 视频墙

下载 Github:https://github.com/super-tongyao/wall 国内仓库&#xff08;不推荐&#xff0c;只做加速访问&#xff0c;无编译包和发行版&#xff0c;以github仓库为准&#xff09;&#xff1a;https://gitee.com/Super_TongYao/wall 推荐github仓库&#xff0c;下载最新版…...

编程日记 2023/4/20 9:41:15

0103 MySQL06

1.事务 1.一个事务其实就是一个完整的业务逻辑 如&#xff1a;转账&#xff0c;从A账户向B账户转账10000&#xff0c;将A账户的钱减去10000&#xff08;update&#xff09;&#xff0c;将B账户的钱加上10000&#xff08;update&#xff09;&#xff0c;这就是一个完整的业务逻…...

编程日记 2023/4/20 9:40:59

【UE4 RTS游戏】04-摄像机运动_鼠标移动到视口边缘时移动Pawn

效果可以看到当鼠标移动到视口边缘时&#xff0c;Pawn就会向这个方向移动。步骤打开项目设置&#xff0c;添加两个操作映射打开“CameraPawnController”&#xff0c;在事件图表中添加两个浮点型变量&#xff0c;一个为公有一个为私有。分别命名为“ZoomSensitivity”、“MaxAr…...

编程日记 2023/4/20 9:40:45

147597-66-8，p-SCN-Bn-NOTA，NOTA-P-苯-NCS新型双功能螯合剂

p-SCN-Bn-NOTA | NOTA-P-苯-NCS | CAS&#xff1a;147597-66-8 | 纯度&#xff1a;95%1.p-SCN-Bn-NOTA试剂信息&#xff1a;CAS号&#xff1a;147597-66-8外观&#xff1a;白色固体分子量&#xff1a;C20H26N4O6S分子式&#xff1a;448.4928溶解性&#xff1a;溶于有机溶剂&…...

编程日记 2023/4/20 9:40:31

龙虎榜——20250610

上证指数放量收阴线&#xff0c;个股多数下跌&#xff0c;盘中受消息影响大幅波动。 深证指数放量收阴线形成顶分型&#xff0c;指数短线有调整的需求&#xff0c;大概需要一两天。 2025年6月10日龙虎榜行业方向分析 1. 金融科技 代表标的&#xff1a;御银股份、雄帝科技 驱动…...

编程新知 2026/2/8 15:03:06

Linux应用开发之网络套接字编程(实例篇)

服务端与客户端单连接 服务端代码 #include <sys/socket.h> #include <sys/types.h> #include <netinet/in.h> #include <stdio.h> #include <stdlib.h> #include <string.h> #include <arpa/inet.h> #include <pthread.h> …...

编程新知 2026/2/9 16:57:53

国防科技大学计算机基础课程笔记02信息编码

1.机内码和国标码 国标码就是我们非常熟悉的这个GB2312,但是因为都是16进制&#xff0c;因此这个了16进制的数据既可以翻译成为这个机器码&#xff0c;也可以翻译成为这个国标码&#xff0c;所以这个时候很容易会出现这个歧义的情况&#xff1b; 因此&#xff0c;我们的这个国…...

编程新知 2026/2/8 4:37:15

Qt/C++开发监控GB28181系统/取流协议/同时支持udp/tcp被动/tcp主动

一、前言说明 在2011版本的gb28181协议中&#xff0c;拉取视频流只要求udp方式&#xff0c;从2016开始要求新增支持tcp被动和tcp主动两种方式&#xff0c;udp理论上会丢包的&#xff0c;所以实际使用过程可能会出现画面花屏的情况&#xff0c;而tcp肯定不丢包&#xff0c;起码…...

编程新知 2026/2/5 4:23:49

23-Oracle 23 ai 区块链表（Blockchain Table）

小伙伴有没有在金融强合规的领域中遇见&#xff0c;必须要保持数据不可变&#xff0c;管理员都无法修改和留痕的要求。比如医疗的电子病历中&#xff0c;影像检查检验结果不可篡改行的&#xff0c;药品追溯过程中数据只可插入无法删除的特性需求&#xff1b;登录日志、修改日志…...

编程新知 2026/2/10 8:01:46

【位运算】消失的两个数字（hard）

消失的两个数字&#xff08;hard&#xff09; 题⽬描述&#xff1a;解法&#xff08;位运算&#xff09;&#xff1a;Java 算法代码&#xff1a;更简便代码 题⽬链接&#xff1a;⾯试题 17.19. 消失的两个数字 题⽬描述&#xff1a; 给定⼀个数组&#xff0c;包含从 1 到 N 所有…...

编程新知 2025/11/15 16:18:24

Go 语言接口详解

Go 语言接口详解 核心概念 接口定义 在 Go 语言中&#xff0c;接口是一种抽象类型&#xff0c;它定义了一组方法的集合&#xff1a; // 定义接口 type Shape interface {Area() float64Perimeter() float64 } 接口实现 Go 接口的实现是隐式的&#xff1a; // 矩形结构体…...

编程新知 2026/1/4 5:19:25

1.3 VSCode安装与环境配置

进入网址Visual Studio Code - Code Editing. Redefined下载.deb文件&#xff0c;然后打开终端&#xff0c;进入下载文件夹&#xff0c;键入命令 sudo dpkg -i code_1.100.3-1748872405_amd64.deb 在终端键入命令code即启动vscode 需要安装插件列表 1.Chinese简化 2.ros …...

编程新知 2026/1/29 3:35:37

【配置 YOLOX 用于按目录分类的图片数据集】

现在的图标点选越来越多&#xff0c;如何一步解决&#xff0c;采用 YOLOX 目标检测模式则可以轻松解决 要在 YOLOX 中使用按目录分类的图片数据集&#xff08;每个目录代表一个类别&#xff0c;目录下是该类别的所有图片&#xff09;&#xff0c;你需要进行以下配置步骤&#x…...

编程新知 2026/1/30 4:52:56

【论文阅读28】-CNN-BiLSTM-Attention-（2024）

本文把滑坡位移序列拆开、筛优质因子&#xff0c;再用 CNN-BiLSTM-Attention 来动态预测每个子序列&#xff0c;最后重构出总位移&#xff0c;预测效果超越传统模型。 文章目录 1 引言2 方法2.1 位移时间序列加性模型2.2 变分模态分解 (VMD) 具体步骤2.3.1 样本熵&#xff08;S…...

编程新知 2026/2/2 3:06:53