当前位置: 首页 > news >正文

RocketMQ单结点安装/Dashboard安装

目录

1.安装NameServer

2.安装Broker

3.使用自带工具测试数据发送

4.使用DashBoard进行查看

5.关闭相关设备


前置条件:两台虚拟机CentOS Linux release 7.5.1804(ps:当然也可以都部署在一台机器上)

RocketMq属于天生集群。需要同时启动nameServerBroker进行部署,在通过Dashboard进行监控,所以要安装三个东西。

官网:下载 | RocketMQ

当前在这之前还需要安装JDK

yum -y install java-1.8.0-openjdk-devel.x86_64
sudo cat >> /etc/profile <<-'EOF'
export JAVA_HOME=/usr/lib/jvm/java-1.8.0-openjdk
export JRE_HOME=$JAVA_HOME/jre
export CLASSPATH=$JAVA_HOME/lib:$JRE_HOME/lib:$CLASSPATH
export PATH=$JAVA_HOME/bin:$JRE_HOME/bin:$PATH
EOF
source /etc/profile
echo $JAVA_HOME

1.安装NameServer

下载压缩包后通过

#进行解压
unzip rocketmq-all-5.3.0-bin-release.zipcd 到对应解压压缩包内#修改runserver
sed -i 's/-Xms4g -Xmx4g -XX:MetaspaceSize=128m/-Xms1g -Xmx1g -XX:MetaspaceSize=128m/g' ./bin/runserver.sh#nameServer默认使用9876端口,如果使用虚拟机启动可以忽略这行
firewall-cmd --zone=public --add-port=9876/tcp --permanent
firewall-cmd --reload# 非后台启动
# sh ./bin/mqnamesrv
#后台启动并查看日志 
nohup sh ./bin/mqnamesrv > nqnamesrv.log &

查看启动日志cat nqnamesrv.log 如果输出结果是seccess则表示启动成功

2.安装Broker

在另外一台的虚拟机上,也需要

#进行解压
unzip rocketmq-all-5.3.0-bin-release.zipcd 到对应解压压缩包内#修runbroker
sed -i 's/-Xms8g -Xmx8g/-Xms1g -Xmx1g/g' ./bin/runbroker.sh#创建broker的的配置
cat > single-master.properties <<-'EOF'
#集群名称,同一个集群下的broker要求统一
brokerClusterName=DefaultCluster
#broker名称
brokerName=broker-a
#brokerId=0代表主节点,大于零代表从节点
brokerId=0
#删除日志文件时间点,默认凌晨 4 点
deleteWhen=04
#日志文件保留时间,默认 48 小时
fileReservedTime=48
#Broker 的角色
#- ASYNC_MASTER 异步复制Master
#- SYNC_MASTER 同步双写Master
brokerRole=SYNC_MASTER
#刷盘方式
#- ASYNC_FLUSH 异步刷盘,性能好宕机会丢数
#- SYNC_FLUSH 同步刷盘,性能较差不会丢数
flushDiskType=SYNC_FLUSH
#末尾追加,NameServer节点列表,使用分号分割
namesrvAddr=192.168.10.100:9876
autoCreateTopicEnable=true
EOF#防火墙设置
firewall-cmd --zone=public --add-port=10911/tcp --permanent
firewall-cmd --reload#启动日志
#sh ./bin/mqbroker -c ./single-master.properties
nohup sh ./bin/mqbroker -c ./single-master.properties > broker.log &

查看cat  broker.log ,如果为success则表示启动成功

3.使用自带工具测试数据发送

在nameServer端

export NAMESRV_ADDR=192.168.10.100:9876
sh tools.sh org.apache.rocketmq.example.quickstart.Producer

在broker端接收消息

export NAMESRV_ADDR=192.168.10.100:9876
sh tools.sh org.apache.rocketmq.example.quickstart.Consumer

4.使用DashBoard进行查看

https://github.com/apache/rocketmq-dashboard

仓库服务 (aliyun.com)   rocketmq-dashboard

默认启动是8080端口

nohup java -jar rocketmq-dashboard-1.0.0.jar > dashboard.log &

启动访问地址http://192.168.10.100:8080/#/

5.关闭相关设备

# 停止NameServer
sh bin/mqshutdown namesrv
# 停止Broker
sh bin/mqshutdown broker
#查看关闭是否成功,如果没有返回结果则表示关闭成功
ss -anp | grep 9876
ss -anp | grep 10911

6.启动脚本

虚拟机安装完之后每次启动都很麻烦,所以补充一个一件启动脚本

vim start_mq.sh#!/bin/bashnohup sh /home/nameSrv/bin/mqnamesrv > /home/nameSrv/nqnamesrv.log 2>&1 &
nohup sh /home/brokerSrv/bin/mqbroker -c /home/brokerSrv/single-master.properties > /home/brokerSrv/broker.log 2>&1 &
nohup java -jar /home/mq-dash.jar > /home/dashboard.log 2>&1 &chmod 777 start_mq.sh
#再次重启
sh ./路径/start_mq.sh 

相关文章:

RocketMQ单结点安装/Dashboard安装

目录 1.安装NameServer 2.安装Broker 3.使用自带工具测试数据发送 4.使用DashBoard进行查看 5.关闭相关设备 前置条件&#xff1a;两台虚拟机CentOS Linux release 7.5.1804(ps:当然也可以都部署在一台机器上) RocketMq属于天生集群。需要同时启动nameServer和Broker进行…...

【北京迅为】《i.MX8MM嵌入式Linux开发指南》-第二篇 Linux系统编程篇-第三十四章 进程基础

i.MX8MM处理器采用了先进的14LPCFinFET工艺&#xff0c;提供更快的速度和更高的电源效率;四核Cortex-A53&#xff0c;单核Cortex-M4&#xff0c;多达五个内核 &#xff0c;主频高达1.8GHz&#xff0c;2G DDR4内存、8G EMMC存储。千兆工业级以太网、MIPI-DSI、USB HOST、WIFI/BT…...

使用LVS+NGinx+Netty实现数据接入

数据接入 链接参考文档 LVSKeepalived项目 车辆数据上收&#xff0c;TBox通过TCP协议连接到TSP平台 建立连接后进行数据上传。也可借由该连接实现远程控制等操作。 通过搭建 LV—NGinx—Netty实现高并发数据接入 LVS&#xff1a;四层负载均衡&#xff08;位于内核层&#x…...

云手机结合自主ADB命令接口 提升海外营销效率

现在&#xff0c;跨境电商直播已经成为在线零售的重要渠道&#xff0c;在大环境下&#xff0c;确保直播应用的稳定性和用户体验至关重要。 云手机支持自主ADB命令接口&#xff0c;为电商直播营销提供了技术支持&#xff0c;使得应用开发、测试、优化和运维更加高效。 什么是A…...

【计算机视觉前沿研究 热点 顶会】CVPR 2024中与域适应、分布外目标检测相关的论文

测试时间线性分布外检测 分布外&#xff08; OOD&#xff09;检测旨在通过在输入样本显著偏离训练分布&#xff08;分布中&#xff09;时触发警报来解决神经网络的过度置信度预测&#xff0c;这表明输出可能不可靠。当前的 OOD 检测方法探索各种线索来识别 OOD 数据&#xff0…...

首次由国产8K摄像机服务巴黎奥运会8K公用信号

法国巴黎时间16日上午&#xff0c;中央广播电视总台“中国红”8K转播车穿越大半个地球&#xff0c;抵达法兰西体育场&#xff0c;顺利完成与奥林匹克转播公司(OBS)的交接。 &#xff08;1&#xff09;“中国红”8K转播车 作为适合户外露天项目的“移动制作域”&#xff0c;“…...

idea怎么配置gradle多个版本

1.背景 gradle版本很多,而且很多时候版本是不兼容的,我们希望拉取下来的代码就包含已经配置好的版本,而不是去配置本机的gradle版本..... 意思就是要实现项目A可以用6.X版本 项目B可以使用7.X版本 项目C可以用9.X版本..... 2.配置方式 步骤一:项目根路径下保留一个文件夹…...

SpringCloudAlibaba-Seata2.0.0与Nacos2.2.1

一、下载 ## 下载seata wget https://github.com/apache/incubator-seata/releases/download/v2.0.0/seata-server-2.0.0.tar.gz## 解压 tar zxvf seata-server-2.0.0.tar.gz二、执行sql文件 ## 取出sql文件执行 cd /seata/script/server/db/mysql ## 找个mysql数据库执行三、…...

【编程语言】C++和C的异同点

文章目录 相同点不同点cin和scanf()结构体struct指针&#xff1a;NULL、nullptr、void* 有一段时间没有发博客了&#xff0c;从笔记里摘录一些发两篇。 相同点 C有很多从C继承过来的东西&#xff0c;因此C书(《C Primer》、《C Primer Plus》)中有一些基础的东西讲的并没有C书…...

【日常记录】【插件】excel.js导出的时候给单元格设置下拉选择、数据校验等

文章目录 1. 代码基本结构2. 导出的excel 某单元格的值设置为下拉选择3. 如何把下拉选择项设置为动态4. 单元格设置校验、提示5. 在WPS上的设置 1. 代码基本结构 <!DOCTYPE html> <html lang"en"><head><meta charset"UTF-8"><…...

分布式 I/O 系统Modbus TCP 耦合器BL200

BL200 耦合器是一个数据采集和控制系统&#xff0c;基于强大的 32 位微处理器设计&#xff0c;采用 Linux 操作系统&#xff0c;可以快速接入现场 PLC、SCADA 以及 ERP 系统&#xff0c; 内置逻辑控制、边缘计算应用&#xff0c;支持标准 Modbus TCP 服务器通讯&#xff0c;以太…...

人工智能导论-机器学习

机器学习概述 概述 本章主要介绍的机器学习的概念、发展历程、发展趋势、相关应用&#xff0c;着重拓展机监督学习和无监督学习的相关知识。 重点&#xff1a;机器学习的定义和应用&#xff1b; 难点&#xff1a;机器学习算法及分类。 机器学习 - 重要性 MachineLeaning出…...

计算机网络——网络层(路由选择协议、路由器工作原理、IP多播、虚拟专用网和网络地址转换)

目录 路由选择协议 因特网的路由选择协议特点 路由信息协议RIP RIP衡量目的网络距离 RIP选择路由器的方式 RIP具有以下三个重要特点 RIP的基本工作流程 RIP的距离向量算法 ​编辑 ​编辑 RIP存在的问题——“坏消息传播得慢” RIP的封装 开放最短路径优先协议OSPF…...

对接企业微信API自建应用配置企业可信IP

前言 为了实现系统调用团队会议功能&#xff0c;组织发起企业微信会议&#xff0c;于是需要和企业微信做API对接。对接过程很难受&#xff0c;文档不清晰、没有SDK、没有技术支持甚至文档报文和实际接口报文都不匹配&#xff0c;只能说企业微信的API是从业以来见过的最难用的AP…...

Windows右键新建Markdown文件类型配置 | Typora | VSCode

&#x1f64b;大家好&#xff01;我是毛毛张! &#x1f308;个人首页&#xff1a; 神马都会亿点点的毛毛张 今天毛毛张分享的是如何在右键的新建菜单中添加新建MarkdownFile文件&#xff0c;这是毛毛张分享的关于Typora软件的相关知识的第三期 文章目录 1.前言&#x1f3dd;…...

PyTorch构建一个肺部CT图像分类模型来分辨肺癌

当你有5万个标注的肺部CT DICOM图像数据&#xff0c;并且希望使用PyTorch构建一个肺部CT图像分类模型来分辨肺癌&#xff0c;以下是详细的步骤和示例代码&#xff1a; 数据准备 首先&#xff0c;确保你的数据集被正确分为训练集、验证集和测试集&#xff0c;并且每个图像都有相…...

MySQL简介及数据库

mysql简介 mysql是一个轻量级关系型数据库管理系统&#xff0c;具有体积小&#xff0c;速度快&#xff0c;开源的优点 sql是一种结构化查询语言(Structured Query Language)&#xff0c;专门用来管理和处理关系型数据库的标准化编程语言&#xff0c;mysql实现了SQL标准&#xf…...

服务器基础1

服务器基础复习01 1.环境部署 系统&#xff1a;华为欧拉系统 网络简单配置nmtui 因为华为欧拉系统密码需要复杂度 所以我们可以进入后更改密码 echo 123 | passwd --stdin root也可以 echo "root:123" | chpasswd2.关闭防火墙&#xff0c;禁用SElinux 首先先关…...

<数据集>光伏板缺陷检测数据集<目标检测>

数据集格式&#xff1a;VOCYOLO格式 图片数量&#xff1a;2400张 标注数量(xml文件个数)&#xff1a;2400 标注数量(txt文件个数)&#xff1a;2400 标注类别数&#xff1a;4 标注类别名称&#xff1a;[Crack,Grid,Spot] 序号类别名称图片数框数1Crack8688922Grid8248843S…...

leetcode 513. 找树左下角的值

给定一个二叉树的 根节点 root&#xff0c;请找出该二叉树的 最底层 最左边 节点的值。 假设二叉树中至少有一个节点。 示例 1: 输入: root [2,1,3] 输出: 1示例 2: 输入: [1,2,3,4,null,5,6,null,null,7] 输出: 7提示: 二叉树的节点个数的范围是 [1,104]-231 < Node.val &…...

C++并发编程实战学习笔记

一、C的并发&#xff1a; 多进程并发&#xff1a; 将应用程序分为多个独立的进程&#xff0c;它们在同一时刻运行&#xff0c;就像同 时进行网页浏览和文字处理一样。独立的进程可以通过进程间常规的通信渠道传递讯息(信号、套接字、文件、管道等等)。不过&#xff0c;这种进程…...

【雷丰阳-谷粒商城 】【分布式高级篇-微服务架构篇】【25】【分布式事务】

持续学习&持续更新中… 守破离 【雷丰阳-谷粒商城 】【分布式高级篇-微服务架构篇】【25】【分布式事务】 本地事务事务的基本性质事务的隔离级别&#xff08;下面四个越往下&#xff0c;隔离级 别越高&#xff0c;并发能力越差&#xff09;事务的传播行为&#xff08;是否…...

HC05主从一体蓝牙模块的裸机使用——单片机<-->蓝牙模块

HC-05是一种常用的蓝牙模块&#xff0c;具有低功耗、低成本、易于使用的特点。它可以实现与其他蓝牙设备&#xff08;如手机、电脑等&#xff09;进行无线通信。HC-05蓝牙模块具有串口通信接口&#xff0c;可以通过串口与主控制器&#xff08;如Arduino、Raspberry Pi等&#x…...

“点点通“餐饮点餐小程序-计算机毕业设计源码11264

"点点通"餐饮点餐小程序 XXX专业XX级XX班&#xff1a;XXX 指导教师&#xff1a;XXX 摘要 随着中国经济的飞速增长&#xff0c;消费者的智能化水平不断提高&#xff0c;许多智能手机和相关的软件正在得到更多的关注和支持。其中&#xff0c;微信的餐饮点餐小程序更…...

C#知识|账号管理系统-账号信息管理界面[1]:账号分类选择框、Panel面板设置

哈喽,你好啊,我是雷工! 前一节实现了多条件查询后端代码的编写, 接下来继续学习账号信息管理界面的功能编写,本节主要记录账号分类选择框和Panel的设置, 以下为学习笔记。 01 功能说明 本节实现以下功能: ①:账号分类选择框只能选择,无法自由输入; ②:账号分类框默认…...

Meta即将推出4000亿的Llama 3 超级AI模型,或将改写大语言模型竞争格局!|TodayAI

2024年4月&#xff0c;科技巨头Meta发布了其最新的AI大型语言模型——Llama 3&#xff0c;该模型基于一个至少比前代产品Llama 2大七倍的数据集&#xff0c;展现出前所未有的性能。在最初发布时&#xff0c;Llama 3提供了8B和70B两种参数规模的版本&#xff0c;并迅速超越了Goo…...

数据挖掘新技能:Python爬虫编程指南

Python爬虫的优势 Python之所以成为数据爬取的首选语言&#xff0c;主要得益于其丰富的库和框架支持。以下是一些常用的库&#xff1a; Requests&#xff1a;用于发送HTTP请求&#xff0c;简单易用&#xff0c;是Python爬虫的基础库。BeautifulSoup&#xff1a;用于解析HTML文…...

object-C 解答算法:移动零(leetCode-283)

移动零(leetCode-283) 题目如下图:(也可以到leetCode上看完整题目,题号283) 解题思路: 本质就是把非0的元素往前移动,接下来要考虑的是怎么移动,每次移动多少? 这里需要用到双指针,i 记录每次遍历的元素值, j 记录“非0元素值”需要移动到的位置; 当所有“非0元素值”都移…...

靖江美食元宇宙

关于“靖江美食元宇宙”的具体信息&#xff0c;搜索结果中并未提供直接相关的详细描述。不过&#xff0c;搜索结果显示了有关元宇宙在食品领域的应用和探索&#xff0c;例如食品元宇宙的概念、不同品牌尝试进入元宇宙市场的例子等。这些信息表明&#xff0c;元宇宙技术正在被用…...

模板方法设计模式

模板方法设计模式: 模板方法设计模式&#xff1a;解决方法中存在重复代码的问题。 模板方法设计模式的写法&#xff1a; 1、定义一个抽象类 2、在里面定义2个方法 ​ 一个是模板方法&#xff1a;把相同代码放里面去 ​ 一个是抽象方法&#xff1a;具体实现交给子类完成 建议使用…...

建站之星(sitestar)网站建设系统/百度关键词优化企业

终于抽时间学习了linux的网络编程&#xff0c;以前只是对socket有个字面上的了解&#xff0c;具体的机制和用法一无所知。正好项目要用&#xff0c;学习下&#xff0c;做个笔记。 在linux上&#xff0c;任何都可以当做文件来对待。获得一个文件描述符&#xff0c;就可以对它进行…...

亿网通官网/seo排名点击 seo查询

https://blog.csdn.net/DepressedPrince/article/details/80909636 https://blog.csdn.net/chjunjun/article/details/80698710转载于:https://www.cnblogs.com/jianxingjianyuan/p/10815550.html...

dw做网站如何让用户可编辑/广东河源最新疫情

随着 Elastic 扩展我们的 Elasticsearch Service Cloud 产品和自动上线&#xff0c;我们已经将 Elastic Stack 的受众范围从完整的运营团队扩展到了数据工程师&#xff0c;安全团队和顾问。作为 Elastic 支持团队的代表&#xff0c;我喜欢与更多用户背景甚至更广泛的用例进行交…...

互联业务登录页 网站/百度网址大全设为主页

空姐梅梅入住酒店&#xff0c;意外发现房间内装有针孔摄像头。梅梅认为自己的个人隐私被严重侵犯&#xff0c;要求酒店担责&#xff0c;但酒店却称并不知情&#xff0c;而且摄像头早已陈旧损坏&#xff0c;并没有实际摄录功能。近日&#xff0c;法院经审理认定酒店方侵权&#…...

住房和成乡建设部网站/推广联盟平台

Scala的变量分为两种&#xff1a;val和var。val跟java的final变量类似&#xff0c;一旦初始化就不能被重新赋值。而var则不同&#xff0c;类似于Java的非final变量&#xff0c;在整个生命周期内var可以被重新赋值。 val msg"Hello";var msg:String "hello"…...

国内做网站公司哪家好/抚顺网站seo

● 把电脑的第一启动项设为USB设备启动以往用光盘装系统&#xff0c;必须调整启动项为光驱启动&#xff0c;而现在我们要用U盘装系统&#xff0c;所以要调整为U盘启动。关于这个&#xff0c;不同电脑不同版本的bios有不同的设置方法&#xff0c;不过都大同小异&#xff0c;目的…...