程序员经验分享-hwhale

(一)调试RocketMq源码

2023-11-11

一.启动NameServer

1.1namesrv模块找到NamesrvStartup.java

修改Environment variables 新增ROCKETMQ_HOME
在这里插入2图片描述

1.2修改配置文件目录

Rocketmq主目录新建conf logs storedata三个文件夹,将distribution的broker.conf logback_broker.xml,logback_namesrv.xml复制到conf,修改日志目录,和增加broker.conf

brokerClusterName = DefaultCluster
brokerName = broker-a
brokerId = 0
deleteWhen = 04
fileReservedTime = 48
brokerRole = ASYNC_MASTER
flushDiskType = ASYNC_FLUSH

namesrvAddr=127.0.0.1:9876
storePathRootDir=/Library/Java/MySpace/rocketmq/storedata
storePathCommitLog=/Library/Java/MySpace/rocketmq/storedata/commitLog
storePathConsumeQueue=/Library/Java/MySpace/rocketmq/storedata/consumequeue
storePathIndex=/Library/Java/MySpace/rocketmq/storedata/index
storeCheckpoint=/Library/Java/MySpace/rocketmq/storedata/checkpoint
abortFile=/Library/Java/MySpace/rocketmq/storedata/abort

1.3启动NamesrvStartup.java

正确输出

The Name Server boot success. serializeType=JSON

二.配置Broker

2.1配置BrokerStartup.java

在这里插入图片描述

2.2启动BrokerStartup.java

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

broker.log的日志信息
在这里插入图片描述

三.启动producer和consumer

org.apache.rocketmq.example.quickstart.Producer
org.apache.rocketmq.example.quickstart.Consumer
先修改NameServer地址 然后启动观察日志
如果出现以下问题,需要在broker.conf配置brokerIP1=外网ip
在这里插入图片描述

本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)

消息队列

(一)调试RocketMq源码 的相关文章

  • 堆叠注入--攻防世界CTF赛题学习

    在一次联系CTF赛题中才了解到堆叠注入 在这里简单介绍一下 堆叠注入的原理什么的一搜一大堆 我就不引用百度了 直接进入正题 这个是攻防世界的一道CTF赛题 采用寻常思路来寻找sql注入漏洞 payload 1 and 1 1 利用paylo

随机推荐

  • 汽配企业为什么需要MES管理系统解决方案

    众所周知 汽配组装是汽车制造的关键环节 而汽配行业变革以精益为终极目标 制造业要想脱颖而出 就需要采用MES生产管理系统 以实现制造 物流 质量的精益化管理 在快速的流水线节拍生产下 汽配MES管理系统不仅提高了产品的质量 降低了生产成本

  • Java入门——编程案例（1）

    案例01 买飞机票 机票价格按照淡季旺季 头等舱和经济舱收费 输入机票原价 月份和头等舱或者经济舱 机票最终优惠价格的计算方案如下 旺季 5 10月 头等舱9折 经济舱8 5折 淡季 11月到来年4月 头等舱7折 经济舱6 5折 impor

  • 4. 文件系统 (FILE SYSTEM)

    所有的应用都需要存储和检索信息 当进程运行时 它可以存储有限数量的信息到自己的地址空间中 然而 其存储能力受限于虚拟地址空间的大小 对一些应用来说 虚拟地址空间并不能满足其存储需求 将信息保存在进程的地址空间的第二个问题是 当进程结束时信息

  • 科技之光-激光器知识普及

    前几天在一处看到比较好的文章记录一下

  • 建立完善的区块链游戏新生态——HTML5区块链游戏大会在京举行

    5月19日 由白鹭科技和Egretia共同主办的 2018 HTML5区块链游戏大会 HBGS 在京隆重举办 大会首次向全球发布了HTML5区块链游戏完整开发工作流 并举办HTML5区块链游戏行业联盟成立仪式 来自海内外互联网科技创新企业创

  • python缩进说法_每天一道Python选择题--python缩进

    一 开胃菜 以下代码是否正确 age 3 if age lt 6 print 不能上小学 else print 可以 A 正确 B 错误 答案 B else 语句下的 print 可以 没有缩进 程序运行报错 选B 错误 历年是个二级考点

  • c++指针之间类型转换的坑

    c 指针之间类型转换的坑 c中指针类型的转换 c 中指针类型的转换 c中指针类型的转换 C风格可以把不同类型的指针进行转换 c 中指针类型的转换 C风格可以把不同类型的指针进行转换 C 不可以 需要借助void 使用空指针 然后将空指针转换

  • Linux高阶命令：编译和反编译

    一 编译和反编译 1 编译单个C语言源文件 命令格式 gcc 文件名 c o 输出文件名 命令解释 使用gcc编译器编译源文件 并指定生成的可执行文件名 例子 在Ubuntu下 先建立并编辑一个简单的C语言程序 nano test c 使用

  • 查看Android打包时签名文件keystore的MD5值

    有些SDK提供方需要我们提供打包APK时使用的包名和签名文件 xxxxxx jks这个文件 MD5值 然后SDK服务端应该会进行比对保证商户调用的合法性 不然光靠包名是可以伪造的 怎么获取签名文件的MD5值 方法一 原先通过命令keytoo

  • cuda三维纹理内存的使用

    有时候需要使用cuda处理多帧的图像 需要把多帧时间序列的图像传入到显存中 这个时候就可以把保存图像的全局内存绑定到二维纹理内存 核函数通过纹理拾取来访问输入的图像数据 不过二维纹理内存的宽是有限制的 cudaChannelFormatDe

  • 【OpenCV】 级联分类器训练模型

    目录 一 OpenCV级联分类器概念 二 OpenCV级联分类器操作步骤 三 样本采集工作原理分析一 四 样本采集工作原理分析二 五 创建自己的级联分类器 5 1 创建自己的级联分类器第一步 5 2 创建自己的级联分类器第二步 5 3 创建

  • CTF-信息收集篇

    这里是参考了CTFSHOW中的web入门中的题目 来学习关于CTF中的信息收集上的知识点 目录 web 1 web 2 web 3 web 4 web 5 web 6 web 7 web 8 web 9 web 10 web 11 web

  • 记第一次学习搭建web渗透靶场(vulhub)

    一个非常适合小白使用的靶场 valhub官网 https vulhub org github地址 https github com vulhub vulhub 二 只需要在Linux环境下安装即可 最好是Ubuntu 官网推荐的是克隆模式

  • 巡检服务

    巡检管理服务是指服务商对客户的IT应用系统 业务系统及相关设备进行周期性 主动性的健康检查服务 旨在及时发现已有或潜在问题 提出改进建议和措施 防止故障的发生 围绕巡检服务管理的目标进行巡检服务规划 组建巡检服务团队 监理巡检服务管理制度及

  • 如何查看Jetson TX1/2 CPU和GPU性能使用状态

    如何查看Jetson TX1 2 CPU和GPU性能使用状态 官方给了一个脚本文件 我们使用超级权限运行即可 sudo tegrastats 效果如下 RAM 4634 7854MB lfb 2x512kB cpu 0 1112 off o

  • Java 集合之Collection

    首先我们看下Collection的结构图 从结构图上我们可以看到Collection集合下面有3个比较大的实现 Set List Queue在日常开放过程中我们比较常用的是Set与List 针对Queue我在之前的博客中也有所介绍 在这里不

  • 登录界面设计测试---适合背诵

    主要从功能 易用性 性能 安全 兼容 一 功能测试 1 7 case 主要体现 用户名和密码 账号问题 8 12 case 主要体现 验证 图片或短信 13 20 case 主要体现 特别场景 1 输入已注册的用户名和正确的密码 验证是否成

  • Window的Java环境安装

    一 Window的Java环境安装 1 下载百度网盘的Java环境jdk 8u131 windows x64 exe 2 点击jdk 8u131 windows x64 exe 下一步 3 更改Java你想安装位置 点击下一步 4 Java

  • MATLAB反三角函数arcsecx, arccscx, arctanx, arccotx, arcsinx, arccosx绘图表示

    matlab源代码 依次为 arcsecx arccscx arctanx arccotx arcsinx arccosx figure 1 x 0 0 01 pi y sec x plot y x title arcsecx set gc

  • (一)调试RocketMq源码

    文章目录 一 启动NameServer 1 1namesrv模块找到NamesrvStartup java 1 2修改配置文件目录 1 3启动NamesrvStartup java 二 配置Broker 2 1配置BrokerStartup

热门标签