单机RocketMq搭建

柔光的暖阳◎ 2023-02-09 14:06 30阅读 0赞

### 环境搭建 ###

> 需要的环境：  
> 64bit OS, Linux/Unix/Mac is recommended;  
> 64bit JDK 1.8+;  
> Maven 3.2.x;  
> Git;  
> 4g+ free disk for Broker server

###### 1、安装JDK ######

由于系统已有JDK环境，这里不在演示

###### 2、安装Maven ######

参考：https://www.cnblogs.com/killer21/p/11670706.html
    1、安装wget命令（如果已有则不需要安装）
    yum -y install wget
    
    2、下载maven安装包
    wget http://mirrors.cnnic.cn/apache/maven/maven-3/3.5.4/binaries/apache-maven-3.5.4-bin.tar.gz
    
    3、解压maven安装包
    tar -zxvf apache-maven-3.5.4-bin.tar.gz
    
    4、配置maven
     vim /etc/profile
    
    在配置文件配置
    export MAVEN_HOME=/opt/apache-maven-3.5.4
    export PATH=$MAVEN_HOME/bin:$PATH
    
    配置文件生效
    source /etc/profile
    
    5、查看maven
    mvn -version

###### 3、安装GIT ######

参考：https://git-scm.com/download/linux
    
    1、安装命令
    yum install git
    
    2、查看安装是否成功
    git --version

###### 4、安装RocketMQ ######

参考：http://rocketmq.apache.org/docs/quick-start/
    
    1、下载安装包
    下载地址：
    https://archive.apache.org/dist/rocketmq/4.3.1/rocketmq-all-4.3.1-source-release.zip
    
    2、解压安装包
    unzip rocketmq-all-4.3.1-source-release.zip 
    
    3、打包RocketMQ源码
    cd rocketmq-all-4.3.1
    mvn -Prelease-all -DskipTests clean install -U
    cd distribution/target/apache-rocketmq
    
    4、启动NameServer
    nohup sh bin/mqnamesrv -n 119.23.245.18:9876 &
    
    查看启动日志：
    tail -f ~/logs/rocketmqlogs/namesrv.log
    
    如遇启动报错（内存不足）：
    Native memory allocation (mmap) failed to map 2147483648 bytes for committing reserved memory.
    
    找到runserver.sh和runbroker.sh，编辑 
    #JAVA_OPT="${JAVA_OPT} -server -Xms8g -Xmx8g -Xmn4g" (默认需要内存空间)
    
    改为如下：
    JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn125m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"
    
    
    5、 启动Broker
    nohup sh bin/mqbroker -n 119.23.245.18:9876 &
    
    查看启动日志
    tail -f ~/logs/rocketmqlogs/broker.log
    
    6、Send & Receive Messages
    设置环境变量：
    export NAMESRV_ADDR=localhost:9876
    
    Send Message:
    sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
    
    Receive Message: 
    sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
    
    7、Shutdown Servers
    Shutdown Broker:
    sh bin/mqshutdown broker
    
    Shutdown NameServer:
    sh bin/mqshutdown namesrv

###### 5、安装RocketMQ控制台 ######

1、下载源码
    git clone https://github.com/apache/rocketmq-externals.git
    
    2、修改配置文件
    修改application.properties
    
    server.port : 服务器端口（修改为了8088）
    rocketmq.config.namesrvAddr ： mq地址（localhost:9876）
    
    3、打包源码
    mvn clean package
    
    4、运行jar文件
    nohup java -jar rocketmq-console-ng-1.0.1.jar & tail -f nohup.out
    
    5、打开控制台
    浏览器中输入IP:PORT(例如127.0.0.1:8088)