2.安装

2.1.源码安装

2.1.1.安装maven
上传解压
Mkdir /home/maven
Cd /home/maven
Rz D:\javasoftware\maven\apache-maven-3.5.2-bin.tar.gz
Tar -zxf apache-maven-3.5.2-bin.tar.gz

配置环境变量
Vim /etc/profile，添加
export PATH=/home/maven/apache-maven-3.5.2/bin:$PATH

:wq，保存
Source /etc/profile，重启

测试
Mvn -v

2.1.2.安装rocketmq
下载源码包rocketmq-all-4.2.0-source-release.zip
上传到服务器

Unzip rocketmq-all-4.2.0-source-release.zip

cd rocketmq-all-4.2.0/

mvn -Prelease-all -DskipTests clean install -U，安装
这一步要下载很多jar包，安装十几个模块，装了半个小时，太费时间了。

Distribution模块多了target目录，
[root@localhost rocketmq-all-4.2.0]# cd distribution/
[root@localhost distribution]# ll
total 56
drwxr-xr-x. 2 root root 4096 Dec 13 22:12 benchmark
drwxr-xr-x. 2 root root 4096 Dec 13 22:12 bin
drwxr-xr-x. 5 root root 4096 Dec 13 22:12 conf
-rw-r–r--. 1 root root 17336 Dec 13 22:12 LICENSE-BIN
-rw-r–r--. 1 root root 1337 Dec 13 22:12 NOTICE-BIN
-rw-r–r--. 1 root root 4885 Dec 13 22:12 pom.xml
-rw-r–r--. 1 root root 2133 Dec 13 22:12 release-client.xml
-rw-r–r--. 1 root root 2990 Dec 13 22:12 release.xml
drwxr-xr-x. 6 root root 4096 Apr 25 17:38 target
[root@localhost distribution]# cd target/
[root@localhost target]# ll
total 17768
drwxr-xr-x. 6 root root 4096 Apr 25 17:38 apache-rocketmq
-rw-r–r--. 1 root root 9058025 Apr 25 17:38 apache-rocketmq.tar.gz
-rw-r–r--. 1 root root 9098504 Apr 25 17:38 apache-rocketmq.zip
drwxr-xr-x. 2 root root 4096 Apr 25 17:36 archive-tmp
-rw-r–r--. 1 root root 87 Apr 25 17:38 checkstyle-cachefile
-rw-r–r--. 1 root root 6066 Apr 25 17:38 checkstyle-checker.xml
-rw-r–r--. 1 root root 83 Apr 25 17:38 checkstyle-result.xml
drwxr-xr-x. 2 root root 4096 Apr 25 17:36 effective-pom
drwxr-xr-x. 3 root root 4096 Apr 25 17:36 maven-shared-archive-resources
[root@localhost target]# cd apache-rocketmq
[root@localhost apache-rocketmq]# ll
total 44
drwxr-xr-x. 2 root root 4096 Apr 25 17:38 benchmark
drwxr-xr-x. 2 root root 4096 Apr 25 17:38 bin
drwxr-xr-x. 5 root root 4096 Dec 13 22:12 conf
drwxr-xr-x. 2 root root 4096 Apr 25 17:38 lib
-rw-r–r--. 1 root root 17336 Dec 13 22:12 LICENSE
-rw-r–r--. 1 root root 1337 Dec 13 22:12 NOTICE
-rw-r–r--. 1 root root 2426 Dec 13 22:12 README.md
cd distribution/target/apache-rocketmq/bin

2.2.二进制解压包安装

Rz rocketmq-all-4.2.0-bin-release.zip
unzip rocketmq-all-4.2.0-bin-release.zip -d rocketmq-all-4.2.0-bin-release
Unzip默认把里面内容解压到当前文件夹，-d，解压到指定文件夹。
cd rocketmq-all-4.2.0-bin-release/bin

2.3.启动

2.3.1.启动name server

默认内存太大了
cat mqnamesrv

内部调用runserver.sh

cat runserver.sh

修改成

nohup sh mqnamesrv &，不好，按下enter才会输入下一个命令。
nohup sh mqnamesrv > /dev/null 2>&1 &，这个好，可以直接输入其他命令。
在当前目录，多出来nohup.out文件，
在~/logs/rocketmqlogs/多出来namesrv.log文件，

tail -f ~/logs/rocketmqlogs/namesrv.log
The Name Server boot success…

Jps，发现进程NamesrvStartup
[root@localhost bin]# jps
2285 NamesrvStartup
2302 Jps

2.3.2.启动broker

nohup sh mqbroker -n localhost:9876 &

Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00000005c0000000, 8589934592, 0) failed; error='Cannot allocate memory' (errno=12)
#
# There is insufficient memory for the Java Runtime Environment to continue.
# Native memory allocation (mmap) failed to map 8589934592 bytes for committing reserved memory.
# An error report file with more information is saved as:
# /home/rocketmq/rocketmq-all-4.2.0/distribution/target/apache-rocketmq/bin/hs_err_pid4813.log

内存需要8G，没搞错吧。

分析原因：
Cat mqbroker

内部调用runbroker.sh，

Cat runbroker.sh

初始内存8G，

修改成
-Xms256m -Xmx256m -Xmn128m"

再次启动就成功了，
[root@localhost bin]# nohup sh mqbroker -n localhost:9876 &
[2] 2313
nohup: ignoring input and appending output to `nohup.out’

Jps，发现进程BrokerStartup
[root@localhost bin]# jps
2320 BrokerStartup
2377 Jps
2285 NamesrvStartup

tail -f ~/logs/rocketmqlogs/broker.log
The broker[%s, 172.30.30.233:10911] boot success…

2.3.3.收发消息

在首发消息之前，需要设置name server的值，
export命令用于将shell变量输出为环境变量，或者将shell函数输出为环境变量。

export NAMESRV_ADDR=localhost:9876

./tools.sh org.apache.rocketmq.example.quickstart.Producer
SendResult [sendStatus=SEND_OK, msgId=AC112A010963330BEDB48860DA700000, offsetMsgId=AC112A0100002A9F00000000000230F0, messageQueue=MessageQueue [topic=TopicTest, brokerName=localhost, queueId=0], queueOffset=199]
死循环发送消息，ctrl+c终止。

./tools.sh org.apache.rocketmq.example.quickstart.Consumer
ConsumeMessageThread_16 Receive New Messages: [MessageExt [queueId=2, storeSize=180, queueOffset=185, sysFlag=0, bornTimestamp=1524724087840, bornHost=/192.168.5.128:35493, storeTimestamp=1524724087849, storeHost=/172.17.42.1:10911, msgId=AC112A0100002A9F0000000000020828, commitLogOffset=133160, bodyCRC=1996742104, reconsumeTimes=0, preparedTransactionOffset=0, toString()=Message [topic=TopicTest, flag=0, properties={MIN_OFFSET=0, MAX_OFFSET=200, CONSUME_START_TIME=1524800117986, UNIQ_KEY=AC112A010E09330BEDB483D9C8200065, WAIT=true, TAGS=TagA}, body=18]]]
死循环发送消息，ctrl+c终止。

2.3.4.关闭

先关闭broker，后关闭namesrv。
[root@localhost bin]# sh mqshutdown broker
The mqbroker(2364) is running…
Send shutdown request to mqbroker(2364) OK

[root@localhost bin]# sh mqshutdown namesrv
The mqnamesrv(2247) is running…
Send shutdown request to mqnamesrv(2247) OK
[2]+ Exit 143 nohup sh mqbroker -n localhost:9876
[root@localhost bin]#

Rocketmq介绍和安装相关推荐

RocketMQ 介绍与安装
1. RocketMQ介绍 RocketMQ文档:https://github.com/apache/rocketmq/tree/master/docs/cn 1.1 RocketMQ的使用场景应用 ...
RocketMQ介绍与云服务器安装
RocketMQ 介绍与概念在github上的说法来看: Apache RocketMQ是一个分布式消息传递和流媒体平台,具有低延迟,高性能和可靠性,万亿级容量和灵活的可扩展性.它提供了多种功能: ...
RocketMQ单机版本安装(windows环境)
本文说下windows环境中如何安装单机版的RocketMQ 文章目录概述资源下载 RocketMQ安装配置环境变量启动NAMESERVER 启动BROKER 本文小结概述简介本文主要介 ...
RocketMQ简介及安装使用详解(未完待续)
1.RocketMQ介绍 2.RocketMQ安装 3.RocketMQ集群搭建 4.集群监控平台搭建 5.各种消息发送代样例 6.RocketMQ实现案例
Scrapy-Splash的介绍、安装以及实例
scrapy-splash的介绍在前面的博客中,我们已经见识到了Scrapy的强大之处.但是,Scrapy也有其不足之处,即Scrapy没有JS engine, 因此它无法爬取JavaScrip ...
Springlake-01 介绍功能安装
Springlake-01 介绍&功能&安装 1. 简介与功能 1)Springlake 是一个企业内容平台SECP 2)是一个可配置的系统,80%内容可以配置 3)允许建立和配置垂直 ...
Kafka系列一之架构介绍和安装
Kafka架构介绍和安装写在前面还是那句话,当你学习一个新的东西之前,你总得知道这个东西是什么?这个东西可以用来做什么?然后你才会去学习它,使用它.简单来说,kafka既是一个消息队列,如今,它也 ...
SharpWebMail介绍和安装(转)
SharpWebMail介绍和安装什么是:SharpWebMail SharpWebMail是一款C#开发的基于WEB应用程序的多语言的WEB邮件服务.它允许我们使用SMTP或IMAP服务来完成发送 ...
Linux系统Vi/Vim编辑器的简单介绍、安装/卸载、常用命令
Linux系统Vi/Vim编辑器的简单介绍.安装/卸载.常用命令 1.介绍 vi(Visual Interface)编辑器是Linux和Unix上最基本的文本编辑器,工作在字符模式下.由于不需要图形界 ...

Rocketmq介绍和安装