文档章节

rocketMQ安装中遇到的坑

o
 osc_w9s1w4o0
发布于 2019/03/29 11:49
字数 459
阅读 25
收藏 0

精选30+云产品,助力企业轻松上云!>>>

安装步骤是这些:

Prerequisite

The following softwares are assumed installed:

  1. 64bit OS, Linux/Unix/Mac is recommended;
  2. 64bit JDK 1.8+;
  3. Maven 3.2.x;
  4. Git;
  5. 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

> 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:测试的时候报
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:
echo 'brokerIP1=200.200.3.38' > conf/broker.properties
nohup sh bin/mqbroker -n localhost:9876 -c conf/broker.properties autoCreateTopicEnable=true &
 
   问题5:安装 rocketmq-console-ng 界面 包的时候,maven  pom.xml 的 rocketmq.version 竟然用得是SNAPSHOT 的包,完全编译不了!!!
 
 最后去了maven 官网去找的版本包编译。
 
感觉一点没有rabbitMq好用,不能再多爱了!!!




 



o
粉丝 0
博文 500
码字总数 0
作品 0
私信 提问
加载中
请先登录后再评论。
rocketmq遇到的坑

记录下搭建rocketmq过程中遇到的坑:(集群机子代号这里列为:mq-a,mq-b,mq-a-s, mq-b-s) rocketmq搭建的是 双主双从 模式。三台机器,机器 a 、b 分别安装 双主,机器c 安装 双从 。启动...

猫狗熊
06/03
5
0
RocketMQ踩坑记

一、前言 现在的主流消息队列基本都是kafka、RabbitMQ和RocketMQ,只有了解各自的优缺点才能在不同的场景选择合适的MQ,对比图如下: MQ对比图 本篇文章主要介绍我自己在跑官方demo时遇到的一...

osc_3qfoc6mk
2019/10/01
1
0
【Rocketmq】通过 docker 快速搭建 rocketmq 环境

安装 Namesrv 拉取镜像 启动容器 注意事项   {RmHome} 要替换成你的宿主机想保存 MQ 的日志与数据的地方,通过 docker 的 -v 参数使用 volume 功能,把你本地的目录映射到容器内的目录上。...

K1W1
2019/09/19
61
0
RocketMQ 在联想大数据中的应用简析

http://casaveneziausa.com/lenovo-logo/ 众所周知,RocketMQ 作为一款分布式、队列模型的消息中间件,具有以下特点: 在复杂的应用场景中,将 RocketMQ 作为技术解耦的消息中间件,可以简化...

ngcloud
2019/06/25
0
0
【入门篇】Spring Boot整合RocketMQ

因为新公司的消息队列使用RocketMQ,所以趁今天没什么事,就在本地玩了一把Spring Boot整合RocketMQ,把整合过程的步骤还有踩坑记分享下。 一、预备环境 jdk8+ maven 二、win 搭建RocketMQ环...

Stephen_Qu
2019/03/29
317
0

没有更多内容

加载失败,请刷新页面

加载更多

Linux系统检查用户账户到期时间

如果你在 Linux 上启用了密码策略。密码必须在到期前进行更改,并且登录到系统时会收到通知。如果你很少使用自己的帐户,那么可能由于密码过期而被锁定。在许多情况下,这可能会在无需密码登...

老孟的Linux私房菜
43分钟前
13
0
关于南京哪里有开餐饮费发票?

关于南京哪里有开餐饮费发票?聚焦餐饮行业,谈话〖18 7一電一7 5 3 8一徴一3331〗研究院昨发布数据显示,今年上半年,全国餐饮行业招聘需求增长46.18%,平均月薪6387元.随着餐饮行业的快速...

点击fojewio
今天
7
0
android studio 4.0 打开DDMS

1、先找到AndroidStudio配置的SDK路径; 2、在SDK的/tools/路径下有个monitor.bat 的批处理文件; 3、鼠标连续点击两下monitor.bat这个批处理文件,在屏幕上会打开一个类似CMD的命令行中输入...

chenhongjiang
今天
10
0
如何在Android中使用SharedPreferences来存储,获取和编辑值

问题: Closed . 已关闭 。 This question needs to be more focused. 这个问题需要更加集中。 It is not currently accepting answers. 它当前不接受答案。 Learn more . 了解更多 。 Want...

fyin1314
今天
6
0
【JDK1.8】LinkedList源码分析

LinkedList的特性 LinkedList内部使用双向链表作为存储结构,LinkedList可以理解为链表的扩展对象,封装了常用的和非常用的操作链表的方法。以及在通过索引获取元素时的简单优化,通常Linke...

XuePeng77
今天
40
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部