rocketmq4.2的安装及快速入门

 

 

 

官网快速入门地址：http://rocketmq.apache.org/docs/quick-start/

rocketmq4.2下载地址：https://www.apache.org/dyn/closer.cgi?path=rocketmq

http://mirror.bit.edu.cn/apache/rocketmq/4.2.0/

 

须要安装maven和jdk8 linux系统须要64位（32位的不行）

 

 建立目录/opt/rocketmq4.2

 

[root@bogon opt]# pwd
/opt
[root@bogon opt]# ls
ipvsadm kafka10 keepalived1.2.18 maven3.5 mongodb3.2.1 mysql nginx1.6.2 redis4 rh tomcat8
[root@bogon opt]# mkdir rocketmq4.2
[root@bogon opt]# cd rocketmq4.2/
[root@bogon rocketmq4.2]# pwd
/opt/rocketmq4.2
[root@bogon rocketmq4.2]#

 

上传文件rocketmq-all-4.2.0-source-release.zip

 

 

 解压

[root@bogon rocketmq4.2]# unzip rocketmq-all-4.2.0-source-release.zip

 

 

编译mvn -Prelease-all -DskipTests clean install -U

 

 

 

 

 

cd distribution/target/apache-rocketmq

Start Name Server

> nohup sh bin/mqnamesrv &
  > tail -f ~/logs/rocketmqlogs/namesrv.log
  The Name Server boot success...

若是服务器内存不够，能够修改runserver.sh脚本（mqnamesrv文件中经过runserver.sh脚本调用Name Server的主函数com.alibaba.rocketmq.namesrv.NamesrvStartup启动Name Server）中的JAVA_OPT参数

 JAVA_OPT="-server -Xms4g -Xmx4g -Xmn2g -XX:PermSize=128m -XX:MaxPermSize=320m"  

 

Start Broker

> nohup sh bin/mqbroker -n localhost:9876 &
  > tail -f ~/logs/rocketmqlogs/broker.log 
  The broker[%s, 172.30.30.233:10911] boot success...

 

若是服务器内存不够，能够修改runbroker.sh脚本（mqbroker文件中经过runbroker.sh脚本调用Broker的主函数com.alibaba.rocketmq.broker.BrokerStartup启动Broker）的JAVA_OPT参数

 

JAVA_OPT_="-server -Xms4g -Xmx4g -Xmn2g -XX:PermSize=128m -XX:MaxPermSize=320m"  

 

 

 

 

Quick Start

This quick start guide is a detailed instruction of setting up RocketMQ messaging system on your local machine to send and receive messages.

 ON THIS PAGE

• PREREQUISITE
• DOWNLOAD & BUILD FROM RELEASE
• START NAME SERVER
• START BROKER
• SEND & RECEIVE MESSAGES
• SHUTDOWN SERVERS

Prerequisite

The following softwares are assumed installed:

1. 64bit OS, Linux/Unix/Mac is recommended;
2. 64bit JDK 1.8+;
3. Maven 3.2.x
4. Git

Download & Build from Release

Click here to download the 4.2.0 source release. Also you could download a binary release from here.

Now execute the following commands to unpack 4.2.0 source release and build the binary artifact.

> unzip rocketmq-all-4.2.0-source-release.zip
  > cd rocketmq-all-4.2.0/ > mvn -Prelease-all -DskipTests clean install -U > cd distribution/target/apache-rocketmq 

Start Name Server

> nohup sh bin/mqnamesrv &
  > tail -f ~/logs/rocketmqlogs/namesrv.log
  The Name Server boot success...

Start Broker

> nohup sh bin/mqbroker -n localhost:9876 &
  > tail -f ~/logs/rocketmqlogs/broker.log 
  The broker[%s, 172.30.30.233:10911] boot success...

Send & Receive Messages

Before sending/receiving messages, we need to tell clients the location of name servers. RocketMQ provides multiple ways to achieve this. For simplicity, we use environment variable NAMESRV_ADDR

> export NAMESRV_ADDR=localhost:9876 > sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer SendResult [sendStatus=SEND_OK, msgId= ... > sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer ConsumeMessageThread_%d Receive New Messages: [MessageExt... 

Shutdown Servers

> sh bin/mqshutdown broker The mqbroker(36695) is running... Send shutdown request to mqbroker(36695) OK > sh bin/mqshutdown namesrv The mqnamesrv(36664) is running... Send shutdown request to mqnamesrv(36664) OK

 

 

 

 

Quick Start

This quick start guide is a detailed instruction of setting up RocketMQ messaging system on your local machine to send and receive messages.

 ON THIS PAGE

• PREREQUISITE
• DOWNLOAD & BUILD FROM RELEASE
• START NAME SERVER
• START BROKER
• SEND & RECEIVE MESSAGES
• SHUTDOWN SERVERS

Prerequisite

The following softwares are assumed installed:

1. 64bit OS, Linux/Unix/Mac is recommended;
2. 64bit JDK 1.8+;
3. Maven 3.2.x
4. Git

Download & Build from Release

Click here to download the 4.2.0 source release. Also you could download a binary release from here.

Now execute the following commands to unpack 4.2.0 source release and build the binary artifact.

> unzip rocketmq-all-4.2.0-source-release.zip
  > cd rocketmq-all-4.2.0/ > mvn -Prelease-all -DskipTests clean install -U > cd distribution/target/apache-rocketmq 

Start Name Server

> nohup sh bin/mqnamesrv &
  > tail -f ~/logs/rocketmqlogs/namesrv.log
  The Name Server boot success...

Start Broker

> nohup sh bin/mqbroker -n localhost:9876 &
  > tail -f ~/logs/rocketmqlogs/broker.log 
  The broker[%s, 172.30.30.233:10911] boot success...

Send & Receive Messages

Before sending/receiving messages, we need to tell clients the location of name servers. RocketMQ provides multiple ways to achieve this. For simplicity, we use environment variable NAMESRV_ADDR

> export NAMESRV_ADDR=localhost:9876 > sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer SendResult [sendStatus=SEND_OK, msgId= ... > sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer ConsumeMessageThread_%d Receive New Messages: [MessageExt... 

Shutdown Servers

> sh bin/mqshutdown broker The mqbroker(36695) is running... Send shutdown request to mqbroker(36695) OK > sh bin/mqshutdown namesrv The mqnamesrv(36664) is running... Send shutdown request to mqnamesrv(36664) OK