RocketMQ安装|学习笔记

本文涉及的产品
日志服务 SLS,月写入数据量 50GB 1个月
简介: 快速学习RocketMQ安装

开发者学堂课程【RocketMQ知识精讲与项目实战(第一阶段)RocketMQ安装】学习笔记,与课程紧密联系,让用户快速学习知识

课程地址:https://developer.aliyun.com/learning/course/702/detail/12363


RocketMQ安装


内容介绍:

一、RocketMQ简介

二、准备工作

三、安装RocketMQ

四、目录介绍

五、总结

 

一、RocketMQ简介

RocketMQ 是使用 Java 语言开发,在阿里内部,RocketMQ 承接了例如“双十一”等高并发的场景消息流转,能处理万亿级别以上的消息。

 

二、准备工作

安装环境要求

第一步是准备安装环境。安装的环境为Linux环境,首先需要准备一台Linux的服务器,可以安装在本地的讯机当中(如下图),或者购买一个云上环境(例如阿里云)

第二步点击“下载地址”(如下图),会发现跳转到APACHE页面,因为阿里已经

将此产品贡献给了APEACHE基金会,现在成为了APECHE下的子项目。

跳转到下图:

image.png

第三步,点击“download”,之后点击发行版,目前最新的发行版为4.5.1。点进download之后界面为下图所示:

image.png

下载版本有两种,第一种为二进制版本,第二种是下载源码,下载源码需要手动进

行安装。此次课程下载的是二进制版本。

本次提供了4.0版本的资源,其中的rocketmq-master是源码,里面还提供了一个JDK的安装包,因为安装Rocket-MQ需要用到Java环境。目前4.4.0-4.5要求的JDK

版本为1.8。

若已经安装好JDK,则需要配置环境变量。先返回至目录当中,如下图:


image.pngimage.png


三、安装RocketMQ

先把下载好的安装包上传到Lindux服务器,可以使用FileZila的服务器进行上传。

首先进行解压,进行解压之后进入里面的目录

 

四、目录介绍

目录里面含有benchmark,放入了一些demon,方便直接运行使用较多的是b目录,进入b目录后,里面是可执行文件。

另一个使用较多的是conf,意为configuration,

里面提供有视力配置文件,搭配集群结构的时候会用到双组双重的文件去进行搭

建。

Conf下面的文件名为lab文件,里面含有所运用到的依赖的架包,为解压之后的目录,将MQ安装到usr/local里面:

image.png

先创建一个文件夹:rocket-MQ:

将解压的安装包copy进入文件夹内:

第一步,回到最开始的usr/soft/

第二步,通过mv的命令rocket-MQ

第三步,移动到usr/local下面的rocket-MQ

 

五:启动Rocket-MQ

1. 启动NameServer

1  # 1.启动NameServer

2  nohup sh bin/mqnamesrv &

3  # 2.查看启动日志

4  tail -f ~/logs/rocketmqlogs/namesrv.1og

2. 启动Broker

1  # 1.启动Broker

2  nohup sh bin/mqbroker  -n localhost:9876 &

3  # 2.查看启动日志

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

3. 正式启动

1.启动第一步

在bin目录进行启动,清除标记,使用后台方式的进程进行启动,

在bin目录中,存在NameServer,进行启动。

输入命令tail  -f ~/logs/rocketmqlogs/broker.log去查看

后面加上命令/namesrv.log查看是否启动成功。

如果看到“the name server boos success”,则说明启动成功。

查看lindux文件,第一种方式是通过lindux命令的方式去查看。

第二种方式是通过高级记事本连接上lindux服务器,通过远程下载的方式去查看。

第二种方式是需要用到notepad中,

下载一个插件:nppFTP

点击show nppTFP window后

配置的方法,点击齿轮形状的图标,后点击general settings。

接下来可以配置想要的lindux服务器,通过sftp的协议进行连接。

配置好之后,点击“192.168.25.135后,出现目录。

之后进入root目录,进行rocketmq查看

综上为启动步骤的第一步过程。

2.启动第二步——启动broker

在rocketmq的bin目录之下,执行 nohup sh bin/mqbroker  -n localhost:9876 &的命令

如果未启动成功,则可以在Java当中查看,因为Java中有一个命令可以查看启动的命令进程

图中可知,nameserver启动成功,broker启动失败。原因是默认的Java讯机的内存较大,需要将内存改小。

在bin目录下编辑俩个文件

1  编辑runbroke.sh和runserver.sh修改默认为JVM大小

2  vi  runbroker.sh

3  vi  runbroker.sh

修改默认内存,输入命令:

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

修改完内存之后,再次执行 nohup sh bin/mqbroker  -n localhost:9876 &的命令,此时如果发现还没有启动成功,则将nameserver一起进行重启。

1  #1.关闭nameserver

2  sh bin/nqshutdown namesrv

3  # 2.关闭Broker

4  sh bin/mqshutdown broker

执行完上述命令后,此时已经全部关闭,接下来进行重新启动:

1  # 1.启动NameServer

2  nohup sh bin/mqnamesrv &

3  # 2.查看启动日志

4  tail -f ~/logs/rocketmqlogs/namesrv.1og

1  # 1.启动Broker

2  nohup sh bin/mqbroker  -n localhost:9876 &

3  # 2.查看启动日志

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

执行完上述命令后

查看完之后,如果出现broker start up 则表示启动成功

接下里查看日志文件是否产生,进行刷新后,文件已产生。

启动的信息也能够显示出来,综上启动的全过程基本上完成。


六、总结

在启动的过程中,首先需要准备一个二进制的安装包,进行解压安装,接下里进入bin目录下进行启动,首先启动nameserver,在启动broker。

相关实践学习
消息队列RocketMQ版:基础消息收发功能体验
本实验场景介绍消息队列RocketMQ版的基础消息收发功能,涵盖实例创建、Topic、Group资源创建以及消息收发体验等基础功能模块。
消息队列 MNS 入门课程
1、消息队列MNS简介 本节课介绍消息队列的MNS的基础概念 2、消息队列MNS特性 本节课介绍消息队列的MNS的主要特性 3、MNS的最佳实践及场景应用 本节课介绍消息队列的MNS的最佳实践及场景应用案例 4、手把手系列:消息队列MNS实操讲 本节课介绍消息队列的MNS的实际操作演示 5、动手实验:基于MNS,0基础轻松构建 Web Client 本节课带您一起基于MNS,0基础轻松构建 Web Client
相关文章
|
6月前
|
消息中间件 编解码 Java
RocketMQ安装和使用
RocketMQ安装和使用
171 1
|
6月前
|
消息中间件 存储 JSON
RocketMQ-初体验RocketMQ(05)_RocketMQ架构解读
RocketMQ-初体验RocketMQ(05)_RocketMQ架构解读
71 0
|
6月前
|
消息中间件 Java RocketMQ
RocketMQ实战教程之RocketMQ安装
这是一篇关于RocketMQ安装的实战教程,主要介绍了在CentOS系统上使用传统安装和Docker两种方式安装RocketMQ。首先,系统需要是64位,并且已经安装了JDK 1.8。传统安装包括下载安装包,解压并启动NameServer和Broker。Docker安装则涉及安装docker和docker-compose,然后通过docker-compose.yaml文件配置并启动服务。教程还提供了启动命令和解决问题的提示。
|
3月前
|
消息中间件 存储 Java
分享一下rocketmq入门小知识
分享一下rocketmq入门小知识
50 0
分享一下rocketmq入门小知识
|
6月前
|
消息中间件 存储 算法
RocketMQ学习笔记
RocketMQ学习笔记
155 0
|
消息中间件 Java Maven
RocketMQ 入门使用
RocketMQ 入门使用
220 1
|
消息中间件 存储 Java
RocketMQ极简入门-MQ概述&RocketMQ安装
1.MQ是什么 MQ全称为Message Queue,即消息队列 ,是一种提供消息队列服务的中间件,也称为消息中间件,是一套提供了消息生 产、存储、消费全过程的软件系统,遵循FIFO原则。在高并发的分布式系统中使用居多。
280 0
|
消息中间件 存储 Java
一.RocketMQ极简入门-MQ概述&RocketMQ安装
RocketMQ极简入门-MQ概述&RocketMQ安装
|
消息中间件 存储 Oracle
RocketMQ-初体验RocketMQ(01)_RocketMQ初体验
RocketMQ-初体验RocketMQ(01)_RocketMQ初体验
158 0
|
消息中间件 运维 网络协议
RocketMQ-初体验RocketMQ(02)_单节点RocketMQ的安装
RocketMQ-初体验RocketMQ(02)_单节点RocketMQ的安装
321 0
下一篇
无影云桌面