#安装maven

wget http://mirrors.hust.edu.cn/apache/maven/maven-3/3.5.3/binaries/apache-maven-3.5.3-bin.tar.gz

/bin/cp apache-maven-3.5.3-bin.tar.gz  /usr/local/

cd /usr/local

tar -xvf apache-maven-3.5.3-bin.tar.gz

# 创建软连接(将软连接上maven工程,保证以后改变apache不用改环境变量的配置)

ln -s apache-maven-3.5.3/ maven

#设置maven环境变量

vi /etc/profile

export M2_HOME=/usr/local/maven

export PATH=${PATH}:${M2_HOME}/bin

source /etc/profile

#安装git

yum install -y git

#安装jdk

rpm -ivh jdk-9.0.4_linux-x64_bin.rpm

vi /etc/profile

JAVA_HOME=/usr/java/default

PATH=$JAVA_HOME/bin:$PATH

source /etc/profile

#安装rocketmq

git clone https://github.com/apache/incubator-rocketmq.git

cd incubator-rocketmq

mvn -Prelease-all -DskipTests clean install -U

cd distribution/target/

cp -r apache-rocketmq /usr/local/rocketmq

cd /usr/local/rocketmq

mkdir logs

#设置path

vim /etc/profile

#rocketmq
export ROCKETMQ_HOME=/usr/local/rocketmq
export PATH=$PATH:$ROCKETMQ_HOME/bin
export NAMESRV_ADDR=127.0.0.1:9876

#设置namesrv启动内存

vim bin/runserver.sh

JAVA_OPT="${JAVA_OPT} -server -Xms2g -Xmx3g -Xmn3g ... -Xms 的值一定要比 -Xmx  要小不让,也会报错.

#设置broker启动内存 

vim bin/runbroker.sh

JAVA_OPT="${JAVA_OPT} -server -Xms2g -Xmx3g -Xmn3g ... -Xms 的值一定要比 -Xmx  要小不让,也会报错.

#启动nameserver

nohup bin/mqnamesrv > logs/namesrv.log 2>&1 &

nohup bin/mqbroker -n 127.0.0.1:9876 > logs/broker.log 2>&1 &

#查看启动日志

tail -f /usr/local/rocketmq/logs/broker.log


关闭RcocketMQ相关服务

bin/mqshutdown namesrv
bin/mqshutdown broker

向MQ发送和接收消息

# 在bin目录下面执行,将服务器地址引入到环境变量中
export NAMESRV_ADDR=127.0.0.1:9876
# 通过java代码实现的案例生产者生产消息
bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
# 通过java代码实现案例消费者消费消
bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer

监控MQ

# 调用命令监控在target的bin目录
bin/mqadmin clusterList -n 127.0.0.1:9876


-----------------------

消息中间件RocketMQ的安装与部署

____________

git clone https://github.com/apache/incubator-rocketmq-externals.git

cd incubator-rocketmq-externals/

mvn -Prelease-all -DskipTests clean install -U


签名:这个人很懒,什么也没有留下!
最新回复 (0)
返回