开发者学堂课程【RocketMQ知识精讲与项目实战(第一阶段):RocketMQ安装】学习笔记,与课程紧密联系,让用户快速学习知识
课程地址:https://developer.aliyun.com/learning/course/702/detail/12363
RocketMQ安装
内容介绍:
一、RocketMQ简介
二、准备工作
三、安装RocketMQ
四、目录介绍
五、总结
一、RocketMQ简介
RocketMQ 是使用 Java 语言开发,在阿里内部,RocketMQ 承接了例如“双十一”等高并发的场景消息流转,能处理万亿级别以上的消息。
二、准备工作
安装环境要求
第一步是准备安装环境。安装的环境为Linux环境,首先需要准备一台Linux的服务器,可以安装在本地的讯机当中(如下图),或者购买一个云上环境(例如阿里云)
第二步点击“下载地址”(如下图),会发现跳转到APACHE页面,因为阿里已经
将此产品贡献给了APEACHE基金会,现在成为了APECHE下的子项目。
跳转到下图:
第三步,点击“download”,之后点击发行版,目前最新的发行版为4.5.1。点进download之后界面为下图所示:
下载版本有两种,第一种为二进制版本,第二种是下载源码,下载源码需要手动进
行安装。此次课程下载的是二进制版本。
本次提供了4.0版本的资源,其中的rocketmq-master是源码,里面还提供了一个JDK的安装包,因为安装Rocket-MQ需要用到Java环境。目前4.4.0-4.5要求的JDK
版本为1.8。
若已经安装好JDK,则需要配置环境变量。先返回至目录当中,如下图:
三、安装RocketMQ
先把下载好的安装包上传到Lindux服务器,可以使用FileZila的服务器进行上传。
首先进行解压,进行解压之后进入里面的目录
四、目录介绍
目录里面含有benchmark,放入了一些demon,方便直接运行使用较多的是b目录,进入b目录后,里面是可执行文件。
另一个使用较多的是conf,意为configuration,
里面提供有视力配置文件,搭配集群结构的时候会用到双组双重的文件去进行搭
建。
Conf下面的文件名为lab文件,里面含有所运用到的依赖的架包,为解压之后的目录,将MQ安装到usr/local里面:
先创建一个文件夹: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。