【Linux】Linux环境下安装RocketMQ(图文解说详细版)

这篇具有很好参考价值的文章主要介绍了【Linux】Linux环境下安装RocketMQ(图文解说详细版)。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

一、简介

消息队列中间件是分布式系统中的重要组件,主要解决应用耦合、流量削峰等问题,目前主流的 MQ 主要是:RocketMQ、kafka、RabbitMQ等。

RocketMQ 相较于其它 MQ 的优势:

  • 支持事务型消息(消息发送和 DB 操作保持两方的最终一致性,RabbitMQ 和 Kafka 不支持)
  • 支持结合 RocketMQ 的多个系统之间数据最终一致性(多方事务,二方事务是前提)
  • 支持 18 个级别的延迟消息(Kafka 不支持)
  • 支持指定次数和时间间隔的失败消息重发(Kafka 不支持,RabbitMQ 需要手动确认)
  • 支持 Consumer 端 Tag 过滤,减少不必要的网络传输(即过滤由MQ完成,而不是由消费者完成。RabbitMQ 和 Kafka 不支持)
  • 支持重复消费(RabbitMQ 不支持,Kafka 支持)

RocketMQ主要有四大核心组成部分:NameServer、Broker、Producer以及Consumer四部分

linux按照rocketmq,Linux,java-rocketmq,linux,rocketmq

二、MQ 下载

官网下载:下载链接

进入是这样子的,这里是 rocketMq 最新版本的下载链接
linux按照rocketmq,Linux,java-rocketmq,linux,rocketmq
linux按照rocketmq,Linux,java-rocketmq,linux,rocketmq

如果你想下载旧版本的 rocketMq 的话,只需要改网址上的的版本就行,比如说把 4.9.3 改成 4.4.0
linux按照rocketmq,Linux,java-rocketmq,linux,rocketmq

三、JAVA 环境配置

rocketmq 需要 Linux 上安装JDK,版本 1.8 以上,如果你 Linux 上已经配置了 Java 环境可跳过。

Linux 上配置 JAVA 环境可参见博客:Linux安装Java环境(OpenJDK)

linux按照rocketmq,Linux,java-rocketmq,linux,rocketmq

四、MQ 安装

将下载好的安装包上传至服务器
linux按照rocketmq,Linux,java-rocketmq,linux,rocketmq

rz 命令直接上传安装包 (这里我提前在 linux 上创建了一个文件夹 mkdir /soft/rocketmq 来存放管理的软件)
linux按照rocketmq,Linux,java-rocketmq,linux,rocketmq

上传至 Linux 之后再解压
命令:unzip rocketmq-all-4.4.0-bin-release.zip

linux按照rocketmq,Linux,java-rocketmq,linux,rocketmq

它的目录结构:

  • benchmark:这里面就是一些可以直接运行,进行测试的 sh 文件
  • bean:该目录是比较常用的,里面是一些可执行文件
  • conf:这里面就是一些配置文件
  • lib:就是 mq 所依赖的第三方 jar 包

五、启动 MQ

  1. 启动 NameServer
    进入 bin 目录 cd bin/
    后台启动 nohup sh mqnamesrv & 或者 nohup ./mqnamesrv &
    linux按照rocketmq,Linux,java-rocketmq,linux,rocketmq

可以查看日志,看 mq 是否启动成功

tail -f ~/logs/rocketmqlogs/namesrv.log

linux按照rocketmq,Linux,java-rocketmq,linux,rocketmq

或者通过端口号查看

netstat -an | grep 9876

linux按照rocketmq,Linux,java-rocketmq,linux,rocketmq

  1. 启动 Broker
    在启动之前先修改两个配置
vim runserver.sh

linux按照rocketmq,Linux,java-rocketmq,linux,rocketmq

mq 默认需要的内存是比较大的,根据自己 Linux 的内存大小去设置,我这里就改成 256 256 128 了

JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"

vim runbroker.sh
linux按照rocketmq,Linux,java-rocketmq,linux,rocketmq

这里也修改成 256 256 128

JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m"

启动 broker

nohup ./mqbroker -n localhost:9876 &

查看日志检测是否启动成功

tail -f ~/logs/rocketmqlogs/broker.log

linux按照rocketmq,Linux,java-rocketmq,linux,rocketmq

又看到日志打印这个就说明启动成功了,注意:不要把它给关了

六、测试

开了两个窗口,都在 mq 的 bin 目录下,一个用于发送消息,一个用于接收消息
linux按照rocketmq,Linux,java-rocketmq,linux,rocketmq

  1. 发送消息
# 声明一个 namesrv 的地址
export NAMESRV_ADDR=localhost:9876
# 发送消息
./tools.sh org.apache.rocketmq.example.quickstart.Producer

PS:如果报错了,可能出现的原因:

  • 防火墙没关

可以关闭掉防火墙

# 关闭防火墙
systemctl stop firewalld.service 
# 查看防火墙的状态
firewall-cmd --state 
# 禁止firewall开机启动
systemctl disable firewalld.service

或者让防火墙开放 MQ 相关的端口

# 开放name server默认端口
firewall-cmd --remove-port=9876/tcp --permanent
# 开放master默认端口
firewall-cmd --remove-port=10911/tcp --permanent
# 开放slave默认端口 (当前集群模式可不开启)
firewall-cmd --remove-port=11011/tcp --permanent 
# 重启防火墙
firewall-cmd --reload
  • 查下 broker 关掉了

把 nameServer 和 Broker 重新启动,这里我就说 broker 关掉引起的

  1. 接收消息
# 声明一个 namesrv 的地址
export NAMESRV_ADDR=localhost:9876
# 发送消息
./tools.sh org.apache.rocketmq.example.quickstart.Consumer

linux按照rocketmq,Linux,java-rocketmq,linux,rocketmq

七、运行

#新建目录用来存放rocketmq-console的文件
mkdir /usr/local/rocketmq-console

cp target/rocketmq-console-ng-2.0.0.jar /usr/local/rocketmq-console/

#运行jar包
cd /usr/local/rocketmq-console/
java -jar rocketmq-console-ng-2.0.0.jar

运行成功在浏览器输入 http://127.0.0.1:8080 即可看到运行界面,账号密码: admin/admin
linux按照rocketmq,Linux,java-rocketmq,linux,rocketmq

  • 配置账号密码
    我们开启了登录验证的功能,但是没有设置账户密码,这里默认的账户密码为 admin/admin。我们修改下这个密码。
    在 rocketmq-console的数据目录下新建账户文件 users.properties 。
vim /usr/local/rocketmq-console/data/users.properties
  • 设置账号密码
# 该文件支持热修改,即添加和修改用户时,不需要重新启动console
# 格式, 每行定义一个用户, username=password[,N]  #N是可选项,可以为0 (普通用户); 1 (管理员)  

#定义管理员 
admin=123456,1

#定义普通用户
#user1=user1
#user2=user2

然后我们杀进程,重启这个jar包即可。
linux按照rocketmq,Linux,java-rocketmq,linux,rocketmq

八、关闭 MQ

进入 bin 目录下
关闭 NameServer

sh mqshutdown namesrv

关闭 Broker文章来源地址https://www.toymoban.com/news/detail-597731.html

sh mqshutdown broker

到了这里,关于【Linux】Linux环境下安装RocketMQ(图文解说详细版)的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

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

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

相关文章

  • M1 Mac如何安装CentOS7虚拟机(图文详细解说)

    目录 Linux镜像下载网址: 一、虚拟机安装  1、下载相应的文件   2、打开VMware Fusion pro进行安装 3、 输入许可证密钥​编辑 4、 将CentOS-7拖入“从光盘或映像中安装”中 5、点击继续​编辑 6、选择其他--其他64位ARM--继续   7、进行自定设置​编辑  8、这里更改名为“Centos7”

    2024年02月14日
    浏览(63)
  • RedHat8(RHEL8)超详细安装教程--图文解说版

    目录 一、RHEL8介绍 二、产品地址 三、安装   1.【文件】-----【新建虚拟机】(快捷键:Ctrl+N)   2. 这里我们选择【自定义】即可----【下一步】  3. 【兼容性】保持默认---【下一步】  4.【稍后安装】---【下一步】  5. 选择【Linux】操作系统---【RHEL8】版本---【下一步】  6

    2024年02月01日
    浏览(63)
  • Centos7-Linux环境中下载安装Git2.3超详细图文教程(亲测有效)

    Git — The stupid content tracker, 傻瓜内容跟踪器。Linus Torvalds 是这样给我们介绍 Git 的。 Git 是用于 Linux内核开发的版本控制工具。与常用的版本控制工具 CVS, Subversion 等不同,它采用了分布式版本库的方式,不必服务器端软件支持(wingeddevil注:这得分是用什么样的服务端,使用

    2023年04月15日
    浏览(69)
  • Linux环境下配置安装RocketMQ

    官网下载:下载链接 根据需要下载自己需要的版本、本文使用下载的是:4.7.0版本 创建目录,使用ftp工具上传下载的包到上面创建的目录下。 注意 :rocketmq 需要 Linux 上安装JDK,版本 1.8 以上,如果你 Linux 上已经配置了 Java 环境可跳过,未安装请自行安装。 上传之后进行解压

    2024年02月12日
    浏览(56)
  • Linux环境搭建Jenkins(详细图文)

    目录 简介Jenkins 特点 一、环境准备 1.jdk环境准备 2.maven环境准备 3.git环境准备  二、安装部署Jenkins(采用war包方式) 1.下载Jenkins ​2.启动war包 1)将下载好的Jenkins的war包上传到服务器上 2)编辑启动脚本,方便 3)启动Jenkins的war 3.浏览器访问 4.插件安装  5.创建管理员账号 6

    2024年02月21日
    浏览(38)
  • Linux系统配置Node.js环境详细教程(图文讲解)

    前言:在使用Jenkins部署Vue项目的时候,如果没有安装Node.js环境的话,Jenkins会无法对Vue项目进行构建,所以本期出了一篇关于在Linux系统如何配置Node.js环境的讲解,以博客的方式记录一下我详细的配置流程和踩过的坑,特此分享! 博主的其他部署教程: 1、Jenkins部署前后端分

    2024年02月11日
    浏览(51)
  • Linux环境安装Jdk图文步骤

    准备工作: a、jdk安装包:百度网盘 请输入提取码,提取码:jdk8 b、远程工具,xshell,,electerm,,MobaXterm,,fxp,docker,宝塔等等很多的 安装步骤: 1、将jdk-8u221-linux-x64.tar.gz上传到/usr/local目录下(fxp或者其他远程工具);  2、解压文件,解压命令:tar -xvf jdk-8u221_linux-x6

    2024年02月09日
    浏览(39)
  • RocketMQ的windos/linux/docker超详细安装及简单入门!

    本文若有不当之处欢迎提出pr/issue 主要内容: 初识MQ RocketMQ简介 RocketMQ安装 RocketMQ快速入门 SpringBoot集成RocketMQ 最后 1.1.同步和异步通讯 微服务间通讯有同步和异步两种方式: 同步通讯:就像打电话,需要实时响应。 异步通讯:就像发邮件,不需要马上回复。 两种方式各有

    2024年02月03日
    浏览(38)
  • Linux安装JDK详细教程(图文教程)

    1、 下载Linux版本的 JDK (注意看自己安装的Linux系统是什么位数) 查看本机位数命令:sudo uname --m  JDK官网下载地址:https://www.oracle.com/java/technologies/downloads 2、使用工具远程进入Linux系统,查看Linux是否有安装JDK 以root用户登录输入命令:Java-version 3、 卸载安装的JDK(有JDK的情况

    2024年02月16日
    浏览(51)
  • 【Linux】安装Tomcat详细教程(图文教程)

    目录 一、简介 1.1 Tomcat 是什么 1.2Tomcat 重要目录 1.3 web 工程发布目录结构 二、安装 2.1 下载Tomcat 2.2 配置环境变量 2.3 修改默认的端口启动两个 Tomcat 1、Tomcat1 2、Tomcat2        Tomcat 服务器是一个免费的开放源代码的Web 应用服务器,属于轻量级应用服务器,在中小型系统和并

    2024年02月07日
    浏览(45)

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

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

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

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

二维码1

领取红包

二维码2

领红包