RocketMQ安装|学习笔记

简介: 快速学习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一站式入门使用
从源码编译、部署broker、部署namesrv,使用java客户端首发消息等一站式入门RocketMQ。
消息队列 MNS 入门课程
1、消息队列MNS简介 本节课介绍消息队列的MNS的基础概念 2、消息队列MNS特性 本节课介绍消息队列的MNS的主要特性 3、MNS的最佳实践及场景应用 本节课介绍消息队列的MNS的最佳实践及场景应用案例 4、手把手系列:消息队列MNS实操讲 本节课介绍消息队列的MNS的实际操作演示 5、动手实验:基于MNS,0基础轻松构建 Web Client 本节课带您一起基于MNS,0基础轻松构建 Web Client
相关文章
|
29天前
|
消息中间件 编解码 Java
RocketMQ安装和使用
RocketMQ安装和使用
48 1
|
3月前
|
消息中间件 存储 JSON
RocketMQ-初体验RocketMQ(05)_RocketMQ架构解读
RocketMQ-初体验RocketMQ(05)_RocketMQ架构解读
40 0
|
10天前
|
消息中间件 存储 算法
RocketMQ学习笔记
RocketMQ学习笔记
53 0
|
8月前
|
消息中间件 Java Maven
RocketMQ 入门使用
RocketMQ 入门使用
177 1
|
9月前
|
消息中间件 存储 Java
RocketMQ极简入门-MQ概述&RocketMQ安装
1.MQ是什么 MQ全称为Message Queue,即消息队列 ,是一种提供消息队列服务的中间件,也称为消息中间件,是一套提供了消息生 产、存储、消费全过程的软件系统,遵循FIFO原则。在高并发的分布式系统中使用居多。
233 0
|
9月前
|
消息中间件 存储 Java
一.RocketMQ极简入门-MQ概述&RocketMQ安装
RocketMQ极简入门-MQ概述&RocketMQ安装
|
11月前
|
消息中间件 运维 网络协议
RocketMQ-初体验RocketMQ(02)_单节点RocketMQ的安装
RocketMQ-初体验RocketMQ(02)_单节点RocketMQ的安装
247 0
|
11月前
|
消息中间件 存储 Oracle
RocketMQ-初体验RocketMQ(01)_RocketMQ初体验
RocketMQ-初体验RocketMQ(01)_RocketMQ初体验
124 0
|
消息中间件 RocketMQ 索引
Rocketmq学习一
首先从github中拉取Rocketmq的代码,进行运行。 1.由于rocketmq需要依赖nameServer,类似于zookeeper。首先启动时,配置好NamesrvStartup的环境变量信息,也即rocketmq的ROCKEMQ_HOME与你的项目对应。接着就可以启动了。
262 2
Rocketmq学习一
|
消息中间件 RocketMQ
rocketmq学习2
前面我们已经通过quickstrat可以看到nameServer的启动:从启动类中,我们看到:首先创建NamesrvConfig、nettyServerConfig,设置监听端口,将8888改成9876。填充NamesrvConfig、NettyServerConfig、BrokerConfig,获取namesrvAddr,创建Controller,注册钩子函数,启动start。 NamesrvController的属性信息、构造函数:
87 2
rocketmq学习2