rocketmq 启动_016【windows版Rocketmq】小白学习Rocketmq单机部署

以前都是听说MQ，或者在别人搭建好的基础上去使用，没有自己动手搭建过，就没有更深入去理解。现在机会来啦.啦啦.啦啦啦......

234d6e9913bdbe0aa254bf0be17e638e.png

引用自己的CSDN文章

href="https://blog.csdn.net/chenzhong2010/article/details/106699590

或点击左下角“阅读原文”来支持我...φ(0￣*)啦啦啦_φ(*￣0￣)>

一、安装配置

1.1、下载
下载地址是http://rocketmq.apache.org/release_notes/release-notes-4.2.0/
打开后显示如图：

02190d8d5b7c2ea6cba2d6cf30e02752.png

点击上图zip进行下载。1.2、安装下载完成后解压该zip文件，并移动到对应的目录下，如：

cad1fcc0f9457980c42c38b8ca59a265.png

1.3、配置环境变量

右键“我的电脑”->“属性”->“高级属性”->“环境变量”，新增环境变量

ROCKETMQ_HOME

D:\04_work_installed\01_java_tools\34_Rocketmq_4_2_0\rocketmq-all-4.2.0-bin-release

0b0e0feb7ea815b3bc435dbcd64606ab.png

二、启动NAMESERVER

打开cmd命令窗口，输入命令：

start mqnamesrv.cmd

80ff204e721eed5fa4987d3db2a1f09a.png

如上图所述，说明环境变量是正确的，并且NAMESERVER启动成功，此框请不要关闭。

三、启动BROKER

另外打开一个cmd命令窗口，输入命令：

start mqbroker.cmd -n 127.0.0.1:9876 autoCreateTopicEnable=true

后续查询broker名称是tiannanIT，名称就是本地电脑名称：

c34273f98eb83c0ec7b745726a65fb91.png

或者

启动带有配置文件的，启动broker时需要加载配置文件，执行命令：

start mqbroker.cmd -n 127.0.0.1:9876 autoCreateTopicEnable=true -c D:\04_work_installed\01_java_tools\34_Rocketmq_4_2_0\rocketmq-all-4.2.0-bin-release\conf\broker.conf

后续查询broker名称是broker-a，名称就是broker.conf里面配置的：

7d0e6313aaf9bb9683fab9007a554522.png

配置文件broker.conf默认内容如：

brokerClusterName = DefaultClusterbrokerName = broker-abrokerId = 0deleteWhen = 04fileReservedTime = 48brokerRole = ASYNC_MASTERflushDiskType = ASYNC_FLUSH

cmd运行brocker后：

96be0c6772496e37307e31cd7c98de59.png

奇怪，只是弹出了个框，却没有成功提示，不过这样已经是启动broker成功了，此框勿关闭。

【备注】如果光标没有闪烁，而是回到命令行，那意思就是brocker启动失败，需要把c:/user/你的用户名/store文件夹里面的所有文件全部删除，再启动，成功。

四、查看连接到nameserver上的broker

mqadmin clusterList -n localhost:9876

25b88b1e6eab4d3d58ab5060a76f0ea0.png

五、下载RocketMQ插件(管理控制台)

通过git命令下载以下链接对应的源码

git clone https://gitee.com/mirrors/RocketMQ-Externals.git

进入D:\04_work_installed\01_java_tools\34_Rocketmq_4_2_0\rocketmq-externals_git_resource\rocketmq-externals**rocketmq-console**目录，清除并打包(如果有自己的maven私服，最好启动)：

mvn clean package -Dmaven.test.skip=true

507ff76887fb9cf5fb79ea565c87c33d.png

进入到编译包下cd D:\04_work_installed\01_java_tools\34_Rocketmq_4_2_0\rocketmq-externals_git_resource\rocketmq-externals\rocketmq-console\target\

执行启动该jar：

java -jar rocketmq-console-ng-1.0.1.jar

应用访问：http://127.0.0.1:9980

bd92471e9effa794e30d0eb269464c33.png

六、创建主题topic

mqadmin updateTopic -n localhost:9876 -b localhost:10911 -t tx-mq-TOPIC

a3558d5b1a54c712b4b09d477540f26d.png

mqadmin updateTopic -c DefaultCluster -n localhost:9876 -t threezto-test -r 12 -w 12

a15c886b34024de73f1582c0bc1a34c4.png

显示刚刚已经创建的两个topic：

78e82654894d24385d0b6c65cdc93e0a.png

然后可以查看一些自定义主题、系统主题等等：

35b2ca1113485798ecfdc46008a67530.png

七、控制台创建主题

通过菜单：主题->新增/更新，就弹出框来填写对应的信息，并提交。

d33358a79b5b2448551c897974021558.png

八、启动消费者

打开cmd命令窗口，执行以下命令：

set NAMESRV_ADDR=127.0.0.1:9876 tools.cmd org.apache.rocketmq.example.quickstart.Consumer

e8273504d3fe620f73af0c67d64f3778.png

以上，消费者启动成功。

九、启动生产者

打开cmd命令窗口，执行以下命令：

set NAMESRV_ADDR=127.0.0.1:9876tools.cmd org.apache.rocketmq.example.quickstart.Producer

11df987b15bd4a1ee2d453f243baec2f.png

使用topic是TopicTest。

这时候消费者窗口正在消费消息：

十、查看控制台

de03bdd50813c3e1e3f33f20d466d75a.png

查看消费者：

e008b8f6a6a9c76a68563e61d35b085f.png

查看集群：

39bc18cae1a4cb2e892cb4be9956db87.png

查看主题TopicTest的各项信息：

4a09f947c86a14e9257c3545f9585161.png

状态：

01d4b02e17e0430e2044376ce6f3ecf9.png

路由：

dfd1591e6508ac945297aab25812aa38.png

CONSUMER管理：

5eb57e290eaf76b85b570675a66a39cb.png

TOPIC配置：

3605976edd217b967c2ef6d52a3b12b0.png

查看消息：

d3ec6cd23aaf60c76a143cdf7b08add1.png

2f0ac0a25d922a4e66ab6942a1050a5e.png

可以查到，
Topic：TopicTest
Tag：TagA
consumerGroup：please_rename_unique_group_name_4

十一、其他命令

1)删除主题

mqadmin deleteTopic -n localhost:9876 -c DefaultCluster -t zto-example

十二、数据文件配置

12.1 查看数据存储
rocketmq的数据默认都是存放到该目录下

eb1c07bbc789f5bb9242dc6e2e081438.png

查询属性，发现文件实在太大了，想迁移该文件到其他地方，为c盘腾空间

58254514e6e9d672d50975ae2b92d52a.png

打开broker.conf配置文件，增加以下配置(注意：需要使用 \\，\是无效的)：

#存储路径storePathRootDir=D:\\04_work_installed\\01_java_tools\\34_Rocketmq_4_2_0\\rocketmq-all-4.2.0-bin-release\\store#commitLog 存储路径storePathCommitLog=D:\\04_work_installed\\01_java_tools\\34_Rocketmq_4_2_0\\rocketmq-all-4.2.0-bin-release\\store\\commitlog#消费队列存储路径存储路径storePathConsumeQueue=D:\\04_work_installed\\01_java_tools\\34_Rocketmq_4_2_0\\rocketmq-all-4.2.0-bin-release\\store\\consumequeue#消息索引存储路径storePathIndex=D:\\04_work_installed\\01_java_tools\\34_Rocketmq_4_2_0\\rocketmq-all-4.2.0-bin-release\\store\\index#checkpoint 文件存储路径storeCheckpoint=D:\\04_work_installed\\01_java_tools\\34_Rocketmq_4_2_0\\rocketmq-all-4.2.0-bin-release\\store\\checkpoint#abort 文件存储路径abortFile=D:\\04_work_installed\\01_java_tools\\34_Rocketmq_4_2_0\\rocketmq-all-4.2.0-bin-release\\store\\abort

首先将C:\Users\tiannan\store里所有文件迁移出来(否则brocker运行失败)，然后重新运行：

start mqbroker.cmd -n 127.0.0.1:9876 autoCreateTopicEnable=true -c D:\04_work_installed\01_java_tools\34_Rocketmq_4_2_0\rocketmq-all-4.2.0-bin-release\conf\broker.conf

运行成功后，你会发现rocketmq安装目录下生成store文件夹，里面还有生成一些文件，如：

6d31457c92b585602f2214c59d70c07f.png

关闭broker后，再将之前的备份拷贝回来：

701bed4d12f520899e735e790cb1c2ce.png

最好重新重启broker，打开rocketmq控制台，又可以看见之前生成的topic等信息了。

在上述配置的内容来看，rocketmq的各端配置、以及消息都是存储在store里面的，需要保护好该目录数据。

12.2 查看日志存储

2f330e28ba43596b03a7beadf120fdf7.png

默认存储在C:\Users\tiannan\logs\rocketmqlogs文件夹里面，这个日志文件夹以及里面的日志文件，是以下日志配置进行配置的：

85a8b535716caeffa69dd5c74be6e677.png

xml文件里面都是设置父目录是 ${user.home}/logs/rocketmqlogs ，所以可以在对应的xml文件里面修改日志存储位置。

十三、修改mqnamesrv和mqbroker的jvm内存

mqnamesrv.cmd -> runserver.cmd
打开runserver.cmd文件，找到以下内容修改：

set "JAVA_OPT=%JAVA_OPT% -server -Xms2g -Xmx2g -Xmn1g -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"##修改为set "JAVA_OPT=%JAVA_OPT% -server -Xms512m -Xmx512m -Xmn256m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"

mqbroker.cmd -> runbroker.cmd打开runbroker.cmd文件，找到以下内容修改：

set "JAVA_OPT=%JAVA_OPT% -server -Xms2g -Xmx2g -Xmn1g"##修改为set "JAVA_OPT=%JAVA_OPT% -server -Xms512m -Xmx512m -Xmn256m"

或者修改成你需要的内存大小即可。

挺简单的，对你来说，已经学会了拉32d64461378da417cdded8cc8cb79e72.png32d64461378da417cdded8cc8cb79e72.png32d64461378da417cdded8cc8cb79e72.png32d64461378da417cdded8cc8cb79e72.png32d64461378da417cdded8cc8cb79e72.png32d64461378da417cdded8cc8cb79e72.png23f38c9582342608c202dcc66e9d09b6.png。 

关注我，下期继续！！！

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/260246.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

WPF WebBrowser 加载 html ，出现安全警告， 运行 脚本和 activeX 控件，

WPF WebBrowser 加载 html ，出现安全警告， 运行 脚本和 activeX 控件，

对于你的问题&#xff0c;只需要在你的HTML首行添加如下代码即可隐藏安全提示条&#xff1a; <!-- saved from url(0014)about:internet --> 还有一个可选方案是使用Winform的WebBrowser控件&#xff0c;不需要更改HTML代码&#xff0c;也不会出现安全提示&#xff0c;需…
阅读更多...
资料下载资源网站

资料下载资源网站

脚本之家&#xff1a;www.jb51.net 转载于:https://www.cnblogs.com/dreammyle/p/3850250.html
阅读更多...
php异步处理下载文件,异步处理Excel文件导入【流程图+PHP示例】

php异步处理下载文件,异步处理Excel文件导入【流程图+PHP示例】

面向管理后台的系统中&#xff0c;经常会有文件导入的需求。常规的做法就是同步等待&#xff0c;但在业务关系复杂(多表数据校验)、数据量较大的情况下&#xff0c;管理人员只能等结果&#xff0c;也可能会等到超时。使用异步的话&#xff0c;将导入数据的功能与后端接口解耦&a…
阅读更多...
tcp client.cs

tcp client.cs

public class stateobject { public socket worksocket null; public const int Buffer_Size2048; public byte[] buffer new byte[Buffer_size]; public stringbuilder sb new stringbuilder(); } 转载于:https://www.cnblogs.com/neumik/archive/2012/11/15/2771024.ht…
阅读更多...
[python] 之 常用内建函数

[python] 之 常用内建函数

本博客仅列举了一些常用的内建函数&#xff0c;欢迎大家补充&#xff01; 1. dir([obj]) 显示对象的属性&#xff0c;若果没有提供参数&#xff0c;则显示全局变量的名字 2. help([obj]) 以一种整齐美观的方式&#xff0c;显示对象的文档字符串&#xff1b;如果没有提供任何参数…
阅读更多...
python查询模块所有类_python 小技巧(import模块、查询类继承关系、安装包)

python查询模块所有类_python 小技巧(import模块、查询类继承关系、安装包)

作者&#xff1a;Vamei 出处&#xff1a;http://www.cnblogs.com/vamei 欢迎转载&#xff0c;也请保留这段声明。谢谢&#xff01;在这里列举一些我使用Python时积累的小技巧。这些技巧是我在使用Python过程中经常使用的。之前很零碎的记在笔记本中&#xff0c;现在整理出来&am…
阅读更多...
4.2 access函数实例

4.2 access函数实例

int access(const char *filenpath, int mode); 功 能: 确定文件或文件夹的访问权限。 mode&#xff0c;要判断的模式在头文件unistd.h中的预定义如下&#xff1a;#define R_OK 4 /* Test for read permission. */#define W_OK 2 /* Test for write permission. */#define X_OK…
阅读更多...
php 简易 blog,PHP实现简易blog的制作

php 简易 blog,PHP实现简易blog的制作

最近&#xff0c;有时间看了点PHP的代码。参考PHP100教程做了简单的blog&#xff0c;这里面简单的记录一下。首先是集成环境&#xff0c;这里选用的WAMP&#xff1a;http://www.wampserver.com/en/首先通过&#xff0c;phpMyAdmin创建一张blog表。纯界面操作&#xff0c;过程比…
阅读更多...
jquery 事件对象属性小结

jquery 事件对象属性小结

jquery 事件对象属性小结 使用事件自然少不了事件对象. 因为不同浏览器之间事件对象的获取, 以及事件对象的属性都有差异, 导致我们很难跨浏览器使用事件对象. jQuery中统一了事件对象, 当绑定事件处理函数时, 会将jQuery格式化后的事件对象作为唯一参数传入: $("#testDiv…
阅读更多...
ABP文档 - Mvc 视图

ABP文档 - Mvc 视图

文档目录 本节内容&#xff1a; 简介AbpWebViewPage 基类简介 ABP通过nuget包Abp.Web.Mvc集成到Mvc视图里&#xff0c;你可以像往常那样创建常规的视图。 AbpWebViewPage 基类 ABP也提供了AbpWebViewPage&#xff0c;它定义了一些有用的属性和方法&#xff0c;如果你使用启动模…
阅读更多...
ThinkPad L440 FN键设置

ThinkPad L440 FN键设置

刚入手了ThinkPad L440&#xff0c;用起来相当不错&#xff0c;嘿嘿&#xff01; L440系统默认&#xff08;F1-F12&#xff09;键盘为系统默认功能键&#xff0c;主要控制音量、亮度、连接投影仪等。 因为编写程序需要调试&#xff0c;经常用到F10&#xff0c;F11等键&#xff…
阅读更多...
离散数学反对称关系_《离散数学》学习记录 - 集合论

离散数学反对称关系_《离散数学》学习记录 - 集合论

来源&#xff1a;北京大学《离散数学》公开课地址&#xff1a;https://www.bilibili.com/video/av18896337/?p122.1 有序对和卡氏积有序对<a,b>&#xff1a;有顺序&#xff0c;类似于数组&#xff0c;可以用集合定义。性质&#xff1a;有序对内元素对应相等卡氏积AB&…
阅读更多...
收集的博客列表

收集的博客列表

前端&#xff1a; ———————————————————— 宅居 - 裸: http://otakustay.com/ 转载于:https://www.cnblogs.com/ccdc/archive/2012/11/21/2780879.html
阅读更多...
php创建表并插入数据,php数据库操作-创建库和表以及插入数据

php创建表并插入数据,php数据库操作-创建库和表以及插入数据

以上我们正确连接到了mysql数据库&#xff0c;本文将进一步创建数据库&#xff0c;表&#xff0c;在表中填充数据。大家知道连接上数据库才能进行操作&#xff0c;同样的代码搬过来/** 数据库操作*(创建数据库&#xff0c;表&#xff0c;插入数据&#xff0c;插入多条数据)** T…
阅读更多...
C#配置及使用log4net

C#配置及使用log4net

首先从官方网站http://logging.apache.org/log4net/下载最近版本的log4net组件。在程序中添加对log4net.dll的引用&#xff0c;就可以在程序中使用了。 下一步&#xff0c;编写配置文件&#xff0c;内容如下 <?xml version"1.0" encoding"utf-8" ?>…
阅读更多...
ORACLE EBS常用表及查询语句（最终整理版）

ORACLE EBS常用表及查询语句（最终整理版）

建议去看参考二 参考一&#xff1a; call fnd_global.APPS_INITIALIZE(1318,50583,401) select fnd_profile.VALUE(ORG_ID) FROM DUAL select * from hr_operating_units hou where hou.organization_id204 --fn…
阅读更多...
mysql触发器 当记录的指定字段发生变化时，更新表中的另外一个字段，或者更新另外一张关联表中关联记录的字段...

mysql触发器 当记录的指定字段发生变化时，更新表中的另外一个字段，或者更新另外一张关联表中关联记录的字段...

2019独角兽企业重金招聘Python工程师标准>>> 注意&#xff1a;语句中出现的old&#xff0c;new&#xff0c;now&#xff08;&#xff09;&#xff0c;都为数据库自带的关键字&#xff0c;此处不做解释。 两种情况&#xff1a; 第一种&#xff1a;一张表中&#xff0…
阅读更多...
通用无线设备对码软件_珞光全新发布国产通用软件无线电平台 ：USRP-LW N310！珞光品牌已实现国产替代...

通用无线设备对码软件_珞光全新发布国产通用软件无线电平台 ：USRP-LW N310！珞光品牌已实现国产替代...

USRP-LW N310是一种网络的软件定义无线电&#xff08;SDR&#xff09;&#xff0c;它提供了部署大规模的可靠的和容错性的分布式无线系统。USRP-LW N310通过引入远程执行任务的能力简化了对SDR系统的控制和管理&#xff0c;如更新软件&#xff0c;重新启动&#xff0c;工厂复位…
阅读更多...
手把手玩转win8开发系列课程（2）

手把手玩转win8开发系列课程（2）

对win8开发&#xff0c;上一节我们对win8进行了简单的介绍&#xff0c;这一节我们来瞧一瞧他的开发环境搭建。 前奏。 这里所讲的win8开发&#xff0c;主要是指Windows8 app store 上开发&#xff0c;及metro ui或叫morden ui 程序的开发。传统桌面应用程序&#xff0c;网站应…
阅读更多...
python通过什么来区分不同语句块_Python语言通过

python通过什么来区分不同语句块_Python语言通过

【填空题】小块【填空题】离开;出发(n.)【填空题】好人啊中的 “ 啊 ” 读( )【填空题】“ 洁癖 ” 的正确读音是( )【单选题】The article suggests that when a person ________ under unusual stress he should be especially careful to have a well-balanced diet. (CET20…
阅读更多...
最新文章

Copyright @ 2022~2023