安装步骤是这些: Prerequisite The following softwares are assumed installed: 64bit OS, Linux/Unix/Mac is recommended; 64bit JDK 1.8+; Maven 3.2.x; Git; 4g+ free disk for Broker server Download Build from Release Clickhereto download
安装步骤是这些:
Prerequisite
The following softwares are assumed installed:
- 64bit OS, Linux/Unix/Mac is recommended;
- 64bit JDK 1.8+;
- Maven 3.2.x;
- Git;
- 4g+ free disk for Broker server
Download & Build from Release
Click here to download the 4.4.0 source release. Also you could download a binary release from here.
Now execute the following commands to unpack 4.4.0 source release and build the binary artifact.
> unzip rocketmq-all-4.4.0-source-release.zip > cd rocketmq-all-4.4.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
No route info of this topic, TopicTest。
nohup sh bin/mqbroker -n localhost:9876 & 需要改成 nohup sh mqbroker -n localhost:9876 autoCreateTopicEnable=true &
还是不行,查原因是防火墙没关,systemctl status firewalld 查看状态。systemctl stop firewalld.
问题4:RemotingTooMuchRequestException: sendDefaultImpl call timeout 发送失败
namesrver 要改成自己的IP。启动namesrver:
nohup sh bin/mqnamesrv -n "200.200.3.38:9876" &
启动broker ,强制加上本机ip:> 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
问题1:我yum install java 安装了1.8 默认openJDK,坑啊!
问题2:安装好启动的时候一直起不来,发现打了栈信息,查了很久发现内在最小8G以上,我的机器才2G(最低配置就8G吗)
问题3:测试的时候报
echo ‘brokerIP1=200.200.3.38‘ > conf/broker.properties
nohup sh bin/mqbroker -n localhost:9876 -c conf/broker.properties autoCreateTopicEnable=true &
感觉一点没有rabbitMq好用,不能再多爱了!!!