theluyuan/linux-tutorial
1
0
Fork 0
mirror of https://github.com/dunwu/linux-tutorial.git synced 2024-04-15 19:55:24 +08:00
Code Issues Projects Releases Wiki Activity

📝 Writing docs.

Browse Source
This commit is contained in:
Zhang Peng 2018-07-17 09:49:47 +08:00
parent 6bc9734ad6
commit 018fec7212
1 changed files with 52 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

52
docs/deploy/tool/rocketmq/install-rocketmq.md
View File

@ -8,6 +8,9 @@
- [启动 Broker](#启动-broker)
- [收发消息](#收发消息)
- [关闭服务器](#关闭服务器)
- [FAQ](#faq)
- [connect to <172.17.0.1:10909> failed](#connect-to-172170110909-failed)
- [资料](#资料)
<!-- /TOC -->
@ -42,7 +45,7 @@ The Name Server boot success...
## 启动 Broker
```sh
> nohup sh bin/mqbroker -n localhost:9876 &
> nohup sh bin/mqbroker -n localhost:9876 -c conf/broker.conf &
> tail -f ~/logs/rocketmqlogs/broker.log
The broker[%s, 172.30.30.233:10911] boot success...
```
@ -71,3 +74,50 @@ Send shutdown request to mqbroker(36695) OK
The mqnamesrv(36664) is running...
Send shutdown request to mqnamesrv(36664) OK
```
## FAQ
### connect to <172.17.0.1:10909> failed
启动后，生产者客户端连接 RocketMQ 时报错：
```java
org.apache.rocketmq.remoting.exception.RemotingConnectException: connect to <172.17.0.1:10909> failed
at org.apache.rocketmq.remoting.netty.NettyRemotingClient.invokeSync(NettyRemotingClient.java:357)
at org.apache.rocketmq.client.impl.MQClientAPIImpl.sendMessageSync(MQClientAPIImpl.java:343)
at org.apache.rocketmq.client.impl.MQClientAPIImpl.sendMessage(MQClientAPIImpl.java:327)
at org.apache.rocketmq.client.impl.MQClientAPIImpl.sendMessage(MQClientAPIImpl.java:290)
at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendKernelImpl(DefaultMQProducerImpl.java:688)
at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.sendSelectImpl(DefaultMQProducerImpl.java:901)
at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:878)
at org.apache.rocketmq.client.impl.producer.DefaultMQProducerImpl.send(DefaultMQProducerImpl.java:873)
at org.apache.rocketmq.client.producer.DefaultMQProducer.send(DefaultMQProducer.java:369)
at com.emrubik.uc.mdm.sync.utils.MdmInit.sendMessage(MdmInit.java:62)
at com.emrubik.uc.mdm.sync.utils.MdmInit.main(MdmInit.java:2149)
```
原因：RocketMQ 部署在虚拟机上，内网 ip 为 10.10.30.63，该虚拟机一个 docker0 网卡，ip 为 172.17.0.1。RocketMQ broker 启动时默认使用了 docker0 网卡，生产者客户端无法连接 172.17.0.1，造成以上问题。
解决方案
（1）干掉 docker0 网卡或修改网卡名称
（2）停掉 broker，修改 broker 配置文件，重启 broker。
修改 conf/broker.conf，增加两行来指定启动 broker 的 IP：
```
namesrvAddr = 10.10.30.63:9876
brokerIP1 = 10.10.30.63
```
启动时需要指定配置文件
```sh
nohup sh bin/mqbroker -n localhost:9876 -c conf/broker.conf &
```
## 资料
- [RocketMQ 官方 Quick Start](https://rocketmq.apache.org/docs/quick-start/)
- [RocketMQ 搭建及刨坑](http://laciagin.me/2017/12/07/RocketMQ%E6%90%AD%E5%BB%BA%E5%8F%8A%E5%88%A8%E5%9D%91/)