RocketMQ4.x本地源码部署

DBC 1.6K 0

安装JDK,放到对应文件夹

下载jdk-8u331-linux-x64.tar.gz

简单配置

jdk安装

解压:tar -zxvf jdk-8u331-linux-x64.tar.gz
重命名:mv jdk1.8.0_291 jdk8
vim /etc/profile
加入
export JAVA_HOME=/www/wwwroot/jdk8
export PATH=$JAVA_HOME/bin:$PATH
export CLASSPATH=.:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jar
export JAVA_HOME PATH CLASSPATH
使用 source /etc/profile 让配置立刻生效

下载Maven
温馨提示

解压:tar -zxvf apache-maven-3.8.1-bin.tar.gz
重命名: mv apache-maven-3.8.1 maven
vim /etc/profile
export PATH=/www/wwwroot/maven/bin:$PATH

立刻生效:source /etc/profile

下载RocketMq4.x
放到对应文件,直接解压

unzip rocketmq-all-4.4.0-source-release
来到目录下:cd rocketmq-all-4.4.0-source-release
安装:mvn -Prelease-all -DskipTests clean install -U
来到目录下:cd distribution/target/rocketmq-4.4.0
NameServer内存不够怎么处理

找到 runserver.sh 修改 JAVA_OPT
报错问题如下
[root@iZwz94sw188z3yfl7lpmmsZ apache-rocketmq]# sh bin/mqnamesrv
Java HotSpot(TM) 64-Bit Server VM warning: Using the DefNew young collector with the CMS collector is deprecated and will likely be removed in a future release
Java HotSpot(TM) 64-Bit Server VM warning: UseCMSCompactAtFullCollection is deprecated and will likely be removed in a future release.
Java HotSpot(TM) 64-Bit Server VM warning: INFO: os::commit_memory(0x00000006ec800000, 2147483648, 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 2147483648 bytes for committing reserved memory.
# An error report file with more information is saved as:
# /usr/local/software/rocketmq-all-4.4.0/distribution/target/apache-rocketmq/hs_err_pid8993.log

解决如下 编辑 bin/runserver.sh:
JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn256m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"

启动:nohup sh bin/mqnamesrv &
Broker内存不足
修改内存:
RocketMQ4.x本地源码部署插图

常见错误一

org.apache.rocketmq.remoting.exception.RemotingTooMuchRequestException:
sendDefaultImpl call timeout

原因:阿里云存在多网卡,rocketmq都会根据当前网卡选择一个IP使用,当你的机器有多块网卡时,很有可能会有问题。比如,我遇到的问题是我机器上有两个IP,一个公网IP,一个私网IP, 因此需要配置broker.conf 指定当前的公网ip, 然后重新启动broker
新增配置:conf/broker.conf (属性名称brokerIP1=broker所在的公网ip地址 )
新增这个配置:brokerIP1=120.76.62.13
启动命令:nohup sh bin/mqbroker -n localhost:9876 -c ./conf/broker.conf  &

如图所示:

RocketMQ4.x本地源码部署插图2

温馨提示
    • 上传源码包-》解压-》进入rocketmq-console目录-》 编译打包 mvn clean package -Dmaven.test.skip=true务必修改下面两个,再进行编译打包
      • 修改 pom.xml 版本号 (官方bug)  删除掉,不知道新版有没有解决这个问题!
      • RocketMQ4.x本地源码部署插图4
      • RocketMQ4.x本地源码部署插图6
      • 修改application.xml里面的nameserver地址
      • RocketMQ4.x本地源码部署插图8

 

  • 进入target目录 ,启动 java -jar rocketmq-console-ng-1.0.0.jar
  • 守护进程方式启动 nohup java -jar rocketmq-console-ng-1.0.0.jar &
  • RocketMQ4.x本地源码部署插图10

 

发表评论 取消回复
表情 图片 链接 代码

分享