技术

安装_CENTOS_ROCKET_MQ

文档

安装

1
2
3
4
5
6
7
8
9
10
# 64bit OS, Linux/Unix/Mac is recommended
# install 64bit JDK 1.8+
# install Maven 3.2.x

yum install git

cd /opt/software
git clone -b release-4.2.0 https://github.com/apache/rocketmq.git
cd rocketmq
mvn -Prelease-all -DskipTests clean install -U
  • 环境变量
    1
    vi /etc/profile
1
2
3
4
5
6
7
8
9
10
11
12
13
# ROCKETMQ_HOME
ROCKETMQ_HOME=/opt/software/rocketmq/distribution/target/apache-rocketmq

# MAVEN_HOME
MAVEN_HOME=/opt/software/apache-maven-3.5.3

# JAVA_HOME START
JAVA_HOME=/opt/software/sdks/jdk/jdk1.8.0_162
JRE_HOME=$JAVA_HOME/jre
CLASS_PATH=.:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jar:$JRE_HOME/lib
PATH=$PATH:$JAVA_HOME/bin:$JRE_HOME/bin:$MAVEN_HOME/bin:$ROCKETMQ_HOME:$ROCKETMQ_HOME/bin
export JAVA_HOME JRE_HOME CLASS_PATH PATH
# JAVA_HOME END
1
source /etc/profile

Start Name Server

1
2
3
4
> cd /opt/software/rocketmq/distribution/target/apache-rocketmq
> nohup sh bin/mqnamesrv &
> tail -f ~/logs/rocketmqlogs/namesrv.log
The Name Server boot success...

Start Broker

1
2
3
4
> cd /opt/software/rocketmq/distribution/target/apache-rocketmq
> nohup sh bin/mqbroker -n localhost:9876 &
> tail -f ~/logs/rocketmqlogs/broker.log 
The broker[%s, 172.30.30.233:10911] boot success...

Shutdown Servers

1
2
3
4
5
6
7
8
> cd /opt/software/rocketmq/distribution/target/apache-rocketmq
> 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

Send & Receive Messages

1
2
3
4
5
6
7
8
> cd /opt/software/rocketmq/distribution/target/apache-rocketmq
> export NAMESRV_ADDR=localhost:9876
> sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
SendResult [sendStatus=SEND_OK, msgId= ...

> cd /opt/software/rocketmq/distribution/target/apache-rocketmq
> sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
ConsumeMessageThread_%d Receive New Messages: [MessageExt...

防火墙

1
# 开放 9876 端口

遇到的问题

  • 启动 Name Server 和 Broker 的时候 报内存不足

    1
    “VM warning: INFO: OS::commit_memory(0x00000006c0000000, 2147483648, 0) faild; error=’Cannot allocate memory’ (errno=12)”

  • 解决方案：修改/RocketMQ/devnev/bin/ 下的服务启动脚本 runserver.sh 、runbroker.sh 中对于内存的限制，​改成如下示例：

    1
    JAVA_OPT="${JAVA_OPT} -server -Xms128m -Xmx128m -Xmn128m -XX:PermSize=128m -XX:MaxPermSize=128m"