南城网站建设价格,域名搜索,出入库软件永久免费,手机站是什么意思RocketMQ、dashboard部署以及安全设置 一、启动RocketMQ1.1 下载RocketMQ1.2 修改配置文件1.2.1 修改nameServer Jvm内存配置1.2.2 修改broker参数 1.3 启动1.3.1 启动NameServer1.3.2 启动Broker1.3.3 测试是否启动成功1.3.3.1 测试消息发送1.3.3.2 测试消息接收1.3.3.3 Java程… RocketMQ、dashboard部署以及安全设置 一、启动RocketMQ1.1 下载RocketMQ1.2 修改配置文件1.2.1 修改nameServer Jvm内存配置1.2.2 修改broker参数 1.3 启动1.3.1 启动NameServer1.3.2 启动Broker1.3.3 测试是否启动成功1.3.3.1 测试消息发送1.3.3.2 测试消息接收1.3.3.3 Java程序发送消息 1.3.4 关闭NameServer和broker1.3.5 汇总启动脚本 二、启动RocketMQ Dashboard2.1 下载Dashboard源码2.2 Maven打包2.3 上传到Linux服务器2.4 启动Dashboard2.5 访问面板 三、设置密码3.1 RocketMQ配置密码3.1.1 开启acl控制image-202308142305488723.1.2 配置账号密码 3.2 配置面板中的密码3.2.1 在dashboard.jar包同级目录创建config文件夹3.2.2 上传application.properties3.2.3 修改application.properties3.2.4 重启dashboard 3.3 面板开启账号密码3.3.1 开启账号密码访问3.3.2 修改账号密码3.3.3 修改默认用户配置文件路径 3.3.4 重启dashboard 一、启动RocketMQ
1.1 下载RocketMQ
RocketMQ安装包下载地址https://rocketmq.apache.org/download 在/opt文件夹下建立rocketmq文件夹存放rocketmq相关文件
cd /opt
mkdir rocketmq
cd rocketmq/复制RocketMQ下载路径 以当前最新版5.1.3为例下载链接为https://dist.apache.org/repos/dist/release/rocketmq/5.1.3/rocketmq-all-5.1.3-bin-release.zip
使用wget直接下载到当前路径
wget https://dist.apache.org/repos/dist/release/rocketmq/5.1.3/rocketmq-all-5.1.3-bin-release.zip如果没有wget先进行安装
yum -y install wget下载成功 使用unzip解压
unzip rocketmq-all-5.1.3-bin-release.zip如果没有unzip则先安装
yum install -y unzip zip查看结果 修改文件夹名字文件夹名字太长看着不舒服
mv rocketmq-all-5.1.3-bin-release rocketmq-5.1.3至此RocketMQ相关文件准备工作已完成
1.2 修改配置文件
由于RocketMQ默认配置比较高我们要根据自己的机器配置调整相关参数。如果机器配置比较高可以直接调到1.3 启动章节
1.2.1 修改nameServer Jvm内存配置
/opt/rocketmq/rocketmq-5.1.3/bin
vim runserver.sh修改-Xms4g -Xmx4g -Xmn2g三个参数 Xms 为jvm启动时分配的内存比如-Xms512m表示分配512MXmx 为jvm运行过程中分配的最大内存比如-Xms512m表示jvm进程最多只能够占用512M内存Xmn 堆内新生代的大小-Xmn256m代表新生代大小为256M
在这边根据自己的配置调整为以下参数 1.2.2 修改broker参数
vim runbroker.sh-Xms -Xmx 上面已经说明了-XX:MaxDirectMemorySize 用于设置直接内存的最大大小。
根据机器配置修改为以下 1.2.3 修改broker配置
cd /opt/rocketmq/rocketmq-5.1.3/conf/1.3 启动
1.3.1 启动NameServer
# 启动NameServer
sh bin/mqnamesrv
# 查看日志
tail -f ~/logs/rocketmqlogs/namesrv.log日志中显示The Name Server boot success. serializeTypeJSON, address 0.0.0.0:9876 代表已经启动 1.3.2 启动Broker
# 在rocketmq-5.1.3目录启动Broker使用conf/broker.conf配置文件
nohup sh bin/mqbroker -c conf/broker.conf -n localhost:9876 # 查看日志
tail -f ~/logs/rocketmqlogs/proxy.log 1.3.3 测试是否启动成功
1.3.3.1 测试消息发送
export NAMESRV_ADDRlocalhost:9876
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer成功示例: 1.3.3.2 测试消息接收
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer成功示例 1.3.3.3 Java程序发送消息 注意linux服务器要开放对应的端口 Maven项目引入依赖
dependencygroupIdorg.apache.rocketmq/groupIdartifactIdrocketmq-client/artifactIdversion5.1.1/version
/dependency测试类
public class ASimpleTest {public static void main(String[] args) throws Exception{// 创建一个生产者指定一个组名DefaultMQProducer producer new DefaultMQProducer(test-producer-group);// 连接namersrvproducer.setNamesrvAddr(192.168.1.7:9876);// 启动producer.start();for (int i 0; i 10; i) {Message testTopic new Message(testTopic, 我是一个简单的消息.getBytes());SendResult send producer.send(testTopic);System.out.println(send.getSendStatus());}producer.shutdown();}
}输出 1.3.4 关闭NameServer和broker
# 关闭broker
sh bin/mqshutdown broker
# 关闭namesrv
sh bin/mqshutdown namesrv1.3.5 汇总启动脚本 结合前面的脚本汇总成一个统一的脚本 创建文件 vim restart.sh脚本内容
# 关闭broker
sh bin/mqshutdown broker
# 关闭namesrv
sh bin/mqshutdown namesrv
# 启动namersrv
sh bin/mqnamesrv
# 启动broker
nohup sh bin/mqbroker -c conf/broker.conf -n localhost:9876 之后只要执行sh restart.sh即可快速重启 至此RocketMQ的启动、测试是否启动以及关闭已经说明完毕 二、启动RocketMQ Dashboard
RocketMQ Dashboard是一个用于管理和监控Apache RocketMQ消息队列的Web界面。
2.1 下载Dashboard源码
RocketMq Dashboard下载地址 下载到本地或者Linux环境因为我只有本地有Maven所以下载到Windows环境 2.2 Maven打包
解压后进入文件夹 执行Maven命令打出对应jar包
mvn clean package2.3 上传到Linux服务器
将target文件夹底下的rocketmq-dashboard-1.0.0.jar上传到服务器 2.4 启动Dashboard
启动dashboard指定Dashboard端口为18001NameServer地址为127.0.0.1:9876
nohup java -jar rocketmq-dashboard-1.0.0.jar --server.port18001 --rocketmq.config.namsrvAddr127.0.0.1:9876 dashboard.log 21 2.5 访问面板 至此RocketMQ面板启动完成。但是在实际使用中还会对RocketMQ的访问增加密码限制接下来进行密码设置 三、设置密码
3.1 RocketMQ配置密码
3.1.1 开启acl控制
在conf/broker.conf中开启aclEnabletrue
vim conf/broker.conf在最底下追加
3.1.2 配置账号密码
修改conf/plain_acl.yml 重启NameServer和Broker
重新访问面板发现报错了 3.2 配置面板中的密码
3.2.1 在dashboard.jar包同级目录创建config文件夹 3.2.2 上传application.properties
将项目底下的application.properties上传到config文件夹下 3.2.3 修改application.properties
将注释放开设置对应的账号密码 结果 3.2.4 重启dashboard
具体操作参考文章SpringBoot jar包部署
重新访问面板发现可正常访问
3.3 面板开启账号密码
当前已经为RocketMQ设置了密码但是还存在问题操作面板没有设置密码操作面板没有设置密码在实际应用中也是很危险的。下面讲解面板设置密码
3.3.1 开启账号密码访问
修改application.properties 修改为
rocketmq.config.loginRequiredtrue重新访问发现需要账号密码 账号密码配置文件为users.properties
路径 说明 得知管理员默认账号为admin密码为admin.
3.3.2 修改账号密码
将users.properties上传到config目录修改内容为 3.3.3 修改默认用户配置文件路径
修改application.properties
vim application.properties将其修改为
rocketmq.config.dataPath./config3.3.4 重启dashboard
重启后使用账号zhangsan密码123 登录成功。 至此RocketMQ部署已经完毕 参考文章RocketMQ官网快速开始
