正文
RocketMQ在linx安装及其有关问题解决
小程序:扫一扫查出行
【扫一扫了解最新限行尾号】
复制小程序
【扫一扫了解最新限行尾号】
复制小程序
Linx安装和使用:
rocketmq官网:http://rocketmq.apache.org/
- 首先安装JDK(推荐使用JDK1.8),并配置环境变量
- 下载rocketmq压碎包并解压到指定目录
- 在bin目录下修改runbroker.sh配置文件(根据服务器内存修改成相匹配的内存大小,否则启动 mqborker会出错)
RocketMQ使用时相关错误以及解决办法
1.启动sh mqnamesrv 时如果出现一下错误
解决方法:JDK版本过高,使用JDK1.8版本进行配置环境变量即可
2.Exception in thread "main" org.apache.rocketmq.client.exception.MQClientException: Send [1] times, still failed, cost [4008]ms, Topic: topic1, BrokersSent: [localhost.localdomain]
Caused by: org.apache.rocketmq.remoting.exception.RemotingConnectException: connect to <172.17.0.1:10911> failed
启动生产者producer时出现以上报错一般为rocketmq命名服务器对外暴露的端口IP连接不上
解决办法: 1.检查代码
检查此处配置的IP是否和rocketmq所在服务器中的IP相同
2.在recoketmq目录下的conf文件下创建一个broker.properties在里面添加 brokerIP1=(服务器的IP地址),启动 加上配置文件:sh mqbroker -c broker.properties
3.Exception in thread "main" org.apache.rocketmq.client.exception.MQClientException: CODE: 1 DESC: The broker does not support consumer to filter message by SQL92
当启动consumer时出现以上错误,首先时在接收消息时开启了消息过滤,rocketmq默认不支持sql语法形式的过滤
解决方法:在conf目录下的 borker.conf文件中添加 enablePropertyFilter=true 即可。