RocketMQ 快速搭建与控制台搭建

一、下载资料及环境准备

这里 下载路径 可以下载对应的版本,本文以 4.9.5 为例:下载这里的Binary 为Linux 安装文件,Source 也下载,方便后续使用。

在这里插入图片描述
将下载后的包进行解压:
在这里插入图片描述
由于RockerMQ 的建议运行环境较大,但平时自己的服务器没有这么大,所以进行内存调整 。前提是将解压后的文件夹放入 /app/rocketmq,且Linux 虚拟机已安装jdk。现修改 runserver.sh 文件的内存大小:

cd /app/rocketmq/rocketmq-all-4.9.5-bin-release/bin
vim runserver.sh

输入/MaxMetaspaceSize 找到对应修改的地方 ,将这一行改为:

JAVA_OPT="${JAVA_OPT} -server -Xms512m -Xmx512m -Xmn256m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"

同样调整 runbroker.sh 文件中的内存:

JAVA_OPT="${JAVA_OPT} -server -Xms8g -Xmx8g"

修改为:

JAVA_OPT="${JAVA_OPT} -server -Xms1g -Xmx1g"

查看本机已安装的jdk信息及环境变量:(此处将不介绍如何安装及配置环境变量,网上资料很多)
在这里插入图片描述

二、启动、停止 RocketMQ,消息收发

RocketMQ 的后端服务分为 nameserver 和 broker 两个服务。

1、后台启动 nameserver 服务

cd /app/rocketmq/rocketmq-all-4.9.5-bin-release/nohup bin/mqnamesrv &

在这里插入图片描述

Clone session 复制一个连接会话用来跟踪日志:

cd /app/rocketmq/rocketmq-all-4.9.5-bin-release/
ll # 查看目录文件
tail -fn 500 nohup.out 

查看日志,可以看到 Name server 启动成功的日志输出:
在这里插入图片描述
也可以 jps 查看Java 进程(看到 NamesrvStartup 就是刚才启动的进程):
在这里插入图片描述

2、后台启动 broker 服务

启动 broker 之前先要修改配置:conf/broker.confautoCreateTopicEnable=true

cd /app/rocketmq/rocketmq-all-4.9.5-bin-release/conf/vim broker.conf

改好后保存即可:
在这里插入图片描述
后台启动 broker:

 cd /app/rocketmq/rocketmq-all-4.9.5-bin-release/nohup bin/mqbroker &  

同样查看 nohup.out 的日志,如显示以下则表示成功启动:
在这里插入图片描述
同样使用 jps 指令可以检查服务的启动状态。使用 jsp 指令后,可以看到一个名为 BrokerStartup 的进程,则表示 broker 服务启动完成:
在这里插入图片描述

3、配置 MQ 相关的环境变量

vim /etc/profile# 加入对应的环境变量
export ROCKETMQ_HOME=/app/rocketmq/rocketmq-all-4.9.5-bin-release
export PATH=$PATH:${ROCKETMQ_HOME}/bin
export NAMESRV_ADDR=localhost:9876

配置完成后退出并保存,使用 source /etc/profile 使环境变量生效。
后期可以直接使用 mqnamesrvmqbroker 指令,具体可以参考下图使用:
在这里插入图片描述
在这里插入图片描述

4、在当前窗口启动MQ服务

配置了上述环境变量就可以快捷使用mq 命令启动(当前窗口):
1、启动 namesrv 如下

mqnamesrv start

在这里插入图片描述

2、启动 broker 如下:

 mqbroker start

在这里插入图片描述

5、停止MQ 服务

1、停止 namesrv 服务 :

mqshutdown namesrv  

2、停止 broker 服务:

mqshutdown broker 

使用 jps 查看 namesrvbroker 的服务 已经停止:
在这里插入图片描述

6、使用自带测试类,实现消息收发

1、 生产者发送消息:

 tools.sh org.apache.rocketmq.example.quickstart.Producer 

这个指令默认往RocketMQ中发送1000条消息。在命令行窗口可以看到发送消息的日志:
在这里插入图片描述
2、消费者消费消息:

tools.sh org.apache.rocketmq.example.quickstart.Consumer

消费者启动完成后,可以看到消费到的消息:
在这里插入图片描述

注意:Consumer消费者的指令并不会主动结束,他会继续挂起,等待消费新的消息。我们可以使用CTRL+C停止该进程。

三、搭建RocketMQ Dashboard

在 下载链接 的底部可以找到 RocketMQ Dashboard 后下载:在这里插入图片描述
解压后使用开发工具打开,配置好maven 工具,然后修改配置 rocketmq.config.namesrvAddr
在这里插入图片描述

使用 maven 插件进行打包:
在这里插入图片描述
在Linux 系统中执行以下命令启动 rocketmq-dashboard

java -jar rocketmq-dashboard-1.0.1-SNAPSHOT.jar

使用ip + 端口号进行访问: http://192.168.217.130:8080/#/
在这里插入图片描述

在这里插入图片描述
至此RocketMQ 的namesrv 和 broker 、dashboard 就搭建好啦!

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

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

相关文章

Cyber RT学习笔记 --- 1.Cyber RT框架介绍

1.Cyber RT框架介绍 1.1 Cyber RT简介 Apollo Cyber是首个专为自动驾驶定制的高性能且开源的实时通信框架,于2019年与Apollo 3.5开放平台同期发布,它主要解决了自动驾驶系统的高并发、低延迟、高吞吐、任务调度等问题,同时还提供了多种通信…

【C++】STL-函数对象 + 谓词

1.函数对象使用 #include <iostream> using namespace std;//STL-函数对象&#xff08;仿函数&#xff09;class MyAdd { public:int operator()(int v1, int v2){return v1 v2;} }; //1、函数对象在使用时&#xff0c;可以像普通函数那用调用&#xff0c;可以有参数&am…

恒运资本:沪指涨逾1%,金融、地产等板块走强,北向资金净买入超60亿元

4日早盘&#xff0c;两市股指盘中强势上扬&#xff0c;沪指、深成指涨超1%&#xff0c;上证50指数涨近2%&#xff1b;两市半日成交约5500亿元&#xff0c;北向资金大举流入&#xff0c;半日净买入超60亿元。 截至午间收盘&#xff0c;沪指涨1.12%报3168.38点&#xff0c;深成指…

iKeyPrime完美解4G信号,可以登录iCloud,有消息通知,支持最新iOS16.6。

iKeyPrime是一款绕过激活锁界面的解锁工具&#xff0c;可以激活所有iPhone苹果手机&#xff0c;二网/三网恢复信号&#xff0c;并且支持插卡接打电话、收发短信、4G流量上网&#xff0c;支持iCloud登录&#xff0c;有消息通知&#xff0c;支持iPhone5S~X的所有型号&#xff0c;…

linux并发服务器 —— linux网络编程(七)

网络结构模式 C/S结构 - 客户机/服务器&#xff1b;采用两层结构&#xff0c;服务器负责数据的管理&#xff0c;客户机负责完成与用户的交互&#xff1b;C/S结构中&#xff0c;服务器 - 后台服务&#xff0c;客户机 - 前台功能&#xff1b; 优点 1. 充分发挥客户端PC处理能力…

【二等奖方案】大规模金融图数据中异常风险行为模式挖掘赛题「冀科数字」解题思路

第十届CCF大数据与计算智能大赛&#xff08;2022 CCF BDCI&#xff09;已圆满结束&#xff0c;大赛官方竞赛平台DataFountain&#xff08;简称DF平台&#xff09;正在陆续释出各赛题获奖队伍的方案思路&#xff0c;欢迎广大数据科学家交流讨论。 本方案为【大规模金融图数据中…

机器学习笔记之最优化理论与方法(六)无约束优化问题——最优性条件

机器学习笔记之最优化理论与方法——无约束优化问题[最优性条件] 引言无约束优化问题无约束优化问题最优解的定义 无约束优化问题的最优性条件无约束优化问题的充要条件无约束优化问题的必要条件无约束优化问题的充分条件 引言 本节将介绍无约束优化问题&#xff0c;主要介绍无…

Spring Boot 整合 Shiro(后端)

1 Shiro 什么是 Shiro 官网&#xff1a; http://shiro.apache.org/ 是一款主流的 Java 安全框架&#xff0c;不依赖任何容器&#xff0c;可以运行在 Java SE 和 Java EE 项目中&#xff0c;它的主要作用是对访问系统的用户进行身份认证、 授权、会话管理、加密等操作。 …

avue实现用户本地保存自定义配置字段属性及注意事项(基于tj-vue2-tools)

avue实现用户本地保存自定义配置字段属性及注意事项&#xff08;基于tj-vue2-tools&#xff09; tj-vue2-tools项目地址&#xff1a;https://www.npmjs.com/package/tj-vue2-tools 文档请看项目官方 依赖js-base64 安装依赖 npm install js-base64安装 npm install tj-vue2-t…

Python综合案例(基本地图使用)

一、基本地图的使用 基本代码&#xff1a; """ 演示地图可视化的基本使用 """ from pyecharts.charts import Map from pyecharts.options import VisualMapOpts# 准备地图对象 map Map() # 准备数据 data [("北京", 99),("…

02-Flask-对象初始化参数

对象初始化参数 前言对象初始化参数import_namestatic_url_pathstatic_foldertemplate_floder 前言 本篇来学习Flask中对象初始化参数 对象初始化参数 import_name Flask程序所在的包(模块)&#xff0c;传__name__就可以 _name_ 是一个标识 Python 模块的名字的变量&#x…

网络协议从入门到底层原理学习(一)—— 简介及基本概念

文章目录 网络协议从入门到底层原理学习&#xff08;一&#xff09;—— 简介及基本概念一、简介1、网络协议的定义2、网络协议组成要素3、广泛的网络协议类型网络通信协议网络安全协议网络管理协议 4、网络协议模型对比图 二、基本概念1、网络互连模型2、计算机之间的通信基础…