RocketMQ、Dashboard部署以及安全设置

这篇具有很好参考价值的文章主要介绍了RocketMQ、Dashboard部署以及安全设置。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

一、启动RocketMQ

1.1 下载RocketMQ

RocketMQ安装包下载地址:https://rocketmq.apache.org/download

RocketMQ、Dashboard部署以及安全设置,RocketMQ,rocketmq

在/opt文件夹下建立rocketmq文件夹,存放rocketmq相关文件

cd /opt
mkdir rocketmq
cd rocketmq/

复制RocketMQ下载路径

RocketMQ、Dashboard部署以及安全设置,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

下载成功

RocketMQ、Dashboard部署以及安全设置,RocketMQ,rocketmq

使用unzip解压

unzip rocketmq-all-5.1.3-bin-release.zip

如果没有unzip,则先安装

yum install -y unzip zip

查看结果

RocketMQ、Dashboard部署以及安全设置,RocketMQ,rocketmq

修改文件夹名字(文件夹名字太长,看着不舒服)

mv rocketmq-all-5.1.3-bin-release rocketmq-5.1.3

RocketMQ、Dashboard部署以及安全设置,RocketMQ,rocketmq

至此,RocketMQ相关文件准备工作已完成

1.2 修改配置文件

由于RocketMQ默认配置比较高,我们要根据自己的机器配置调整相关参数。(如果机器配置比较高,可以直接调到1.3 启动章节)

1.2.1 修改nameServer Jvm内存配置

/opt/rocketmq/rocketmq-5.1.3/bin
vim  runserver.sh

修改-Xms4g -Xmx4g -Xmn2g,三个参数

RocketMQ、Dashboard部署以及安全设置,RocketMQ,rocketmq

  • Xms 为jvm启动时分配的内存,比如-Xms512m,表示分配512M
  • Xmx 为jvm运行过程中分配的最大内存,比如-Xms512m,表示jvm进程最多只能够占用512M内存
  • Xmn 堆内新生代的大小,-Xmn256m代表新生代大小为256M

在这边,根据自己的配置,调整为以下参数:

RocketMQ、Dashboard部署以及安全设置,RocketMQ,rocketmq

1.2.2 修改broker参数

vim runbroker.sh

RocketMQ、Dashboard部署以及安全设置,RocketMQ,rocketmq

  • -Xms -Xmx 上面已经说明了
  • -XX:MaxDirectMemorySize 用于设置直接内存的最大大小。

根据机器配置,修改为以下:

RocketMQ、Dashboard部署以及安全设置,RocketMQ,rocketmq

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. serializeType=JSON, 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_ADDR=localhost:9876
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer

成功示例:

RocketMQ、Dashboard部署以及安全设置,RocketMQ,rocketmq

1.3.3.2 测试消息接收
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer

成功示例:

RocketMQ、Dashboard部署以及安全设置,RocketMQ,rocketmq

1.3.3.3 Java程序发送消息

注意linux服务器要开放对应的端口!

Maven项目引入依赖

<dependency>
  <groupId>org.apache.rocketmq</groupId>
  <artifactId>rocketmq-client</artifactId>
  <version>5.1.1</version>
</dependency>

测试类

public class ASimpleTest {
  public static void main(String[] args)  throws Exception{
    // 创建一个生产者(指定一个组名)
    DefaultMQProducer producer = new DefaultMQProducer("test-producer-group");
    // 连接namersrv
    producer.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();
  }
}

输出:

RocketMQ、Dashboard部署以及安全设置,RocketMQ,rocketmq

1.3.4 关闭NameServer和broker

# 关闭broker
sh bin/mqshutdown broker
# 关闭namesrv
sh bin/mqshutdown namesrv

1.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下载地址

RocketMQ、Dashboard部署以及安全设置,RocketMQ,rocketmq

下载到本地或者Linux环境(因为我只有本地有Maven,所以下载到Windows环境)

RocketMQ、Dashboard部署以及安全设置,RocketMQ,rocketmq

2.2 Maven打包

解压后,进入文件夹

RocketMQ、Dashboard部署以及安全设置,RocketMQ,rocketmq

执行Maven命令,打出对应jar包

mvn clean package

2.3 上传到Linux服务器

target文件夹底下的rocketmq-dashboard-1.0.0.jar上传到服务器

RocketMQ、Dashboard部署以及安全设置,RocketMQ,rocketmq

RocketMQ、Dashboard部署以及安全设置,RocketMQ,rocketmq

2.4 启动Dashboard

启动dashboard,指定Dashboard端口为18001,NameServer地址为127.0.0.1:9876

nohup java -jar rocketmq-dashboard-1.0.0.jar  --server.port=18001 --rocketmq.config.namsrvAddr=127.0.0.1:9876 > dashboard.log 2>&1 &

2.5 访问面板

RocketMQ、Dashboard部署以及安全设置,RocketMQ,rocketmq

至此,RocketMQ面板启动完成。但是在实际使用中,还会对RocketMQ的访问增加密码限制,接下来,进行密码设置

三、设置密码

3.1 RocketMQ配置密码

3.1.1 开启acl控制

conf/broker.conf中开启aclEnable=true

vim conf/broker.conf

在最底下追加

RocketMQ、Dashboard部署以及安全设置,RocketMQ,rocketmq3.1.2 配置账号密码

修改conf/plain_acl.yml

RocketMQ、Dashboard部署以及安全设置,RocketMQ,rocketmq

重启NameServer和Broker

重新访问面板,发现报错了

RocketMQ、Dashboard部署以及安全设置,RocketMQ,rocketmq

3.2 配置面板中的密码

3.2.1 在dashboard.jar包同级目录创建config文件夹

RocketMQ、Dashboard部署以及安全设置,RocketMQ,rocketmq

3.2.2 上传application.properties

将项目底下的application.properties上传到config文件夹下

RocketMQ、Dashboard部署以及安全设置,RocketMQ,rocketmq

RocketMQ、Dashboard部署以及安全设置,RocketMQ,rocketmq

3.2.3 修改application.properties

将注释放开,设置对应的账号密码

RocketMQ、Dashboard部署以及安全设置,RocketMQ,rocketmq

结果:

RocketMQ、Dashboard部署以及安全设置,RocketMQ,rocketmq

3.2.4 重启dashboard

具体操作,参考文章:SpringBoot jar包部署

重新访问面板,发现可正常访问

3.3 面板开启账号密码

当前,已经为RocketMQ设置了密码,但是,还存在问题,操作面板没有设置密码,操作面板没有设置密码,在实际应用中,也是很危险的。下面讲解面板设置密码:

3.3.1 开启账号密码访问

修改application.properties

RocketMQ、Dashboard部署以及安全设置,RocketMQ,rocketmq

修改为:

rocketmq.config.loginRequired=true

重新访问,发现需要账号密码

RocketMQ、Dashboard部署以及安全设置,RocketMQ,rocketmq

账号密码配置文件为:users.properties

路径:

RocketMQ、Dashboard部署以及安全设置,RocketMQ,rocketmq

说明:

RocketMQ、Dashboard部署以及安全设置,RocketMQ,rocketmq

得知,管理员默认账号为admin,密码为admin.

3.3.2 修改账号密码

users.properties上传到config目录,修改内容为

RocketMQ、Dashboard部署以及安全设置,RocketMQ,rocketmq

3.3.3 修改默认用户配置文件路径

修改application.properties

vim application.properties

RocketMQ、Dashboard部署以及安全设置,RocketMQ,rocketmq

将其修改为:

rocketmq.config.dataPath=./config

3.3.4 重启dashboard

重启后,使用账号zhangsan,密码:123 登录成功。

RocketMQ、Dashboard部署以及安全设置,RocketMQ,rocketmq

至此,RocketMQ部署已经完毕

参考文章:RocketMQ官网快速开始文章来源地址https://www.toymoban.com/news/detail-652247.html

到了这里,关于RocketMQ、Dashboard部署以及安全设置的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • Linux系统下消息中间件RocketMQ下载、安装、搭建、配置、控制台rocketmq-dashboard的安装保姆级教程 rocketmq ui

    这里给出我使用的 RocketMQ 版本(5.1.3)、RocketMQ-Dashboard 版本的百度网盘链接: 链接:https://pan.baidu.com/s/1HaKBBDGWZ0WKLGgVwIG9pw 提取码:1234 1、注意:有两种资源下载:Source表示源码、Binary是二进制包(我们下载这个):二进制包是已经编译完成后可以直接运行的,源码包是需要

    2024年02月12日
    浏览(62)
  • linux下构建rocketmq-dashboard多架构镜像——筑梦之路

    接上篇:linux上构建任意版本的rocketmq多架构x86 arm镜像——筑梦之路-CSDN博客 这里来记录下构建rocketmq-dashboard多架构镜像的方法步骤。 当前rocketmq-dashboard只有一个版本,源码地址如下: https://dist.apache.org/repos/dist/release/rocketmq/rocketmq-dashboard/1.0.0/rocketmq-dashboard-1.0.0-source-release

    2024年02月06日
    浏览(39)
  • RocketMQ 单机源码部署 自定义配置文件和端口以及acl权限配置解析

    1、我们首先配置完 namesrv和broker和acl认证的配置文件,然后直接使用-c指定配置文件来启动程序,就会非常明了,用户名密码要大于6,第一个用户我测试着不知道为什么始终有最高权限,大家尽量不要吧第一个用户给别人用。 ​ 1、创建 conf/namesrv.conf 文件 ​ 2、修改 conf/br

    2024年02月13日
    浏览(44)
  • 【RocketMQ】005-Docker 部署 RocketMQ

    MQ 镜像 可视化平台镜像 创建 nameserver 挂载目录 创建 broker 目录 创建 broker 配置文件目录 目录:/home/zibo/docker/rocketmq/data/conf vim broker.conf 启动 nameserver docker run : 这是Docker命令,用于创建和管理Docker容器。 -d : 这是一个选项,指示Docker在后台运行容器。 --restart=always : 这是一个

    2024年02月16日
    浏览(41)
  • rocketMq消息队列原生api使用以及rocketMq整合springboot

    使用RocketMQ的原生API开发是最简单也是目前看来最牢靠的方式。这里用SpringBoot来搭建一系列消息生产者和消息消费者,来访问之前搭建的RocketMQ集群。 首先创建一个基于Maven的SpringBoot工程,引入如下依赖: RocketMQ的官网上有很多经典的测试代码,这些代码虽然依赖的版本比较

    2024年02月12日
    浏览(48)
  • 【RocketMQ】RocketMQ 5.1.0版本Proxy集群模式部署实践

    为了支持长远的云原生发展,RocketMQ引入了一个全新的模块:Proxy,官方对RocketMQ客户端提供了独立的开源项目:https://github.com/apache/rocketmq-clients,如果要使用这个新的客户端,必须要使用Proxy作为endpoint。 Proxy有两种搭建方式: LOCAL:本地模式,顾名思义,通过追加参数,在

    2024年02月01日
    浏览(55)
  • Apache RocketMQ之集成RocketMQ_MQTT 安装部署协议

    Apache RocketMQ 安装说明 安装步骤 参考快速开始 https://rocketmq.apache.org/zh/docs/quickStart/01quickstart 安装可视化rocketmq_dashboard下载地址 https://rocketmq.apache.org/zh/docs/4.x/deployment/03Dashboard/ 安装rocketmq_mqtt https://rocketmq.apache.org/zh/docs/4.x/mqtt/01RocketMQMQTTOverview broker.conf配置文件中添加参数,开

    2024年02月13日
    浏览(33)
  • RocketMQ快速实战以及集群架构详解

    MQ:MessageQueue,消息队列。是在互联网中使用非常广泛的一系列服务中间件。 这个词可以分两个部分来看,一是Message:消息。消息是在不同进程之间传递的数据。这些进程可以部署在同一台机器上,也可以分布在不同机器上。二是Queue:队列。队列原意是指一种具有FIFO(先进

    2024年02月03日
    浏览(47)
  • 22道常见RocketMQ面试题以及答案

    面试宝典到手,搞定面试,不再是难题,系列文章传送地址,请点击本链接。 1、RocketMQ是什么? 2、RocketMQ有什么作用? 3、RoctetMQ的架构 4、RoctetMQ的优缺点 8、消息过滤,如何实现? 9、消息去重,如果由于网络等原因,多条重复消息投递到了Consumer端,你怎么进行消息去重? 1

    2024年02月10日
    浏览(47)
  • RocketMQ 源码编译部署包

    1. 版本 Java 版本: 1.8.0_201 RocketMQ 版本: 5.1.3 2.打包 git clone https://github.com/apache/rocketmq.git git checkout release-5.1.3 cd rocketmq

    2024年02月16日
    浏览(39)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包