文档章节

linux安装rocketmq

o
 osc_wws45aot
发布于 2019/08/21 18:24
字数 1113
阅读 27
收藏 0

「深度学习福利」大神带你进阶工程师,立即查看>>>

1RocketMQ简介

RocketMQ是一款分布式、队列模型的消息中间件,具有以下特点:

能够保证严格的消息顺序

提供丰富的消息拉取模式

高效的订阅者水平扩展能力

实时的消息订阅机制

亿级消息堆积能力

官网介绍:https://yq.aliyun.com/articles/624207?utm_content=m_1000012577

2 准备工作

本次安装选择在可连外网的本地虚拟机执行第2步,第3步,将编译好的结果(在SVN安装介质有)copy到服务器配置一下即可

2.1安装jdk

https://blog.csdn.net/Shiloh_My/article/details/82911878

https://www.cnblogs.com/pu20065226/p/10730506.html

2.2安装maven

下载源码包

wget http://mirror.bit.edu.cn/apache/maven/binaries/apache-maven-3.2.2-bin.tar.gz

tar -zxvf apache-maven-3.2.2-bin.tar.gz

2.3配置环境变量

以root用户修改/etc/profile,追加

export JAVA_HOME=/usr/local/java/jdk1.8.0_201
export CLASSPATH=.:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jar
export ROCKETMQ_HOME=/home/ap/testapp/software/rocketmq-all-4.2.0/distribution/target/apache-rocketmq
MAVEN_HOME=/usr/local/maven/apache-maven-3.6.1
PATH=$MAVEN_HOME/bin:$JAVA_HOME/bin:$PATH
export MAVEN_HOME PATH

 

配置生效:

source /etc/profile

 

2.4配置maven镜像

注:保证服务器可以连外网

 在镜像连阿里云

[testapp@k8s-node1 /usr/local/maven/apache-maven-3.6.1/conf]$ pwd
/usr/local/maven/apache-maven-3.6.1/conf
[testapp@k8s-node1 /usr/local/maven/apache-maven-3.6.1/conf]$ cat settings.xml 
......
<mirrors>
 <mirror>
      <id>alimaven</id>
      <name>aliyun maven</name>
      <url>http://maven.aliyun.com/nexus/content/groups/public/</url>
      <mirrorOf>central</mirrorOf>        
    </mirror>
  </mirrors>

 

验证maven:

 

 

3RocketMQ下载编译

3.1下载rocketmq4.2.0

https://github.com/apache/rocketmq/archive/release-4.2.0.zip下载zip包并上传

或者wget -P /software https://github.com/apache/rocketmq/archive/release-4.2.0.zip -O rocketmq-all-4.2.0-source-release.zip

Wget命令说明-P表示目录没有就创建,-O表示重命名

免编译版本(本文未用):http://mirror.bit.edu.cn/apache/rocketmq/4.2.0/rocketmq-all-4.2.0-bin-release.zip

3.2编译

unzip rocketmq-all-4.2.0-source-release.zip

cd rocketmq-all-4.2.0

 

[testapp@k8s-node1 ~/software/rocketmq-all-4.2.0]$ ll
总用量 64
-rw-r--r-- 1 root root  2917 12月 13 2017 1
drwxr-xr-x 4 root root    46 8月  20 19:38 broker
-rw-r--r-- 1 root root   997 12月 13 2017 BUILDING
drwxr-xr-x 4 root root    46 8月  20 19:38 client
drwxr-xr-x 4 root root    46 8月  20 19:37 common
-rw-r--r-- 1 root root  1997 12月 13 2017 CONTRIBUTING.md
-rw-r--r-- 1 root root   271 12月 13 2017 DEPENDENCIES
drwxr-xr-x 2 root root    34 12月 13 2017 dev
drwxr-xr-x 6 root root   157 8月  20 19:39 distribution
drwxr-xr-x 4 root root    46 8月  20 19:38 example
drwxr-xr-x 4 root root    46 8月  20 19:38 filter
drwxr-xr-x 4 root root    46 8月  20 19:38 filtersrv
-rw-r--r-- 1 root root 11365 12月 13 2017 LICENSE
drwxr-xr-x 4 root root    46 8月  20 19:38 logappender
drwxr-xr-x 4 root root    46 8月  20 19:38 namesrv
-rw-r--r-- 1 root root   168 12月 13 2017 NOTICE
drwxr-xr-x 4 root root    46 8月  20 19:38 openmessaging
-rw-r--r-- 1 root root 23353 12月 13 2017 pom.xml
-rw-r--r-- 1 root root  1524 12月 13 2017 PULL_REQUEST_TEMPLATE.md
-rw-r--r-- 1 root root  2426 12月 13 2017 README.md
drwxr-xr-x 4 root root    46 8月  20 19:37 remoting
drwxr-xr-x 4 root root    46 8月  20 19:38 srvutil
drwxr-xr-x 4 root root    46 8月  20 19:38 store
drwxr-xr-x 3 root root    74 12月 13 2017 style
drwxr-xr-x 4 root root   167 8月  20 19:37 target
drwxr-xr-x 4 root root    46 8月  20 19:38 test
drwxr-xr-x 4 root root    46 8月  20 19:38 tools
[testapp@k8s-node1 ~/software/rocketmq-all-4.2.0]$

[testapp@k8s-node1 ~/software/rocketmq-all-4.2.0]$ pwd
/home/ap/testapp/software/rocketmq-all-4.2.0

 

mvn -Prelease-all -DskipTests clean install -U

时间会比较长,要去下载相关依赖包

 

 

 

 

4安装步骤

保证2.3 ROCKETMQ_HOME变量以root用户添加并生效,第4步可以不用root用户如softwareapp

 

4.1拷贝编译后的文件至服务器

 

 

 

4.2   启动namesrv

nohup sh bin/mqnamesrv &

如果这条命令报错,请使用 nohup sh bin/mqnamesrv  >/dev/null 2>&1 &

tail -f ~/logs/rocketmqlogs/namesrv.log

4.3启动broker

nohup sh bin/mqbroker -n localhost:9876 &

tail -f ~/logs/rocketmqlogs/broker.log

5.验证

在发送/接收消息之前,我们需要告诉客户名称服务器的位置。RocketMQ 提供了多种方法来实现这一点。为了简单起见,我们使用环境变量NAMESRV_ADDR

5.1发送

export NAMESRV_ADDR=localhost:9876

sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer

5.2 接收

sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer

 

6.关闭服务器

sh bin/mqshutdown broker    //停止 broker

sh bin/mqshutdown namesrv   //停止 nameserver

 

7.修改内存配置

默认配置太大,top命令下消耗内存太多,可按需求更改

cd /software/rocketmq-all-4.2.0/distribution/target/apache-rocketmq/bin

使用vim xxx.sh命令进行JVM参数配置修改:
将runbroker.sh的第一个JAVA_OPT改成JAVA_OPT="${JAVA_OPT} -server -Xms256m -Xmx256m -Xmn128m"
将runserver.sh的第一个JAVA_OPT改成JAVA_OPT="${JAVA_OPT} -server -Xms128m -Xmx256m -Xmn256m -XX:MetaspaceSize=128m -XX:MaxMetaspaceSize=320m"

 

8.常用命令

查看集群情况 ./mqadmin clusterList -n 192.168.102.84:9876

查看 broker 状态 ./mqadmin brokerStatus -n 192.168.102.84:9876 -b 192.168.102.84:10911 (注意换成你的 broker 地址)

查看 topic 列表 ./mqadmin topicList -n 192.168.102.84:9876

查看 topic 状态 ./mqadmin topicStatus -n 192.168.102.84:9876 -t MyTopic (换成你想查询的 topic)

查看 topic 路由 ./mqadmin topicRoute -n 192.168.102.84:9876 -t MyTopic

 

o
粉丝 0
博文 500
码字总数 0
作品 0
私信 提问
加载中
请先登录后再评论。
记一次失败的Perl + Nginx + FastCGI 配置过程

这两天心血来潮,不知道为什么和 Perl + Nginx + FastCGI 配置 耗上了。但是失败了,记录如下: 1)安装Nginx 1.4.3 ,我的是WINDOWS 7 系统,修改配置文件如下: location ~ .(pl|cgi|perl)?...

通吃岛-低手哥
2013/10/27
1.7K
7
我的架构演化笔记 功能1: 基本的用户注册

“咚咚”,一阵急促的敲门声, 我从睡梦中惊醒,我靠,这才几点,谁这么早, 开门一看,原来我的小表弟放暑假了,来南京玩,顺便说跟我后面学习一个网站是怎么做出来的。 于是有了下面的一段...

强子哥哥
2014/05/31
976
3
树莓派(Raspberry Pi):完美的家用服务器

自从树莓派发布后,所有在互联网上的网站为此激动人心的设备提供了很多有趣和具有挑战性的使用方法。虽然这些想法都很棒,但树莓派( RPi )最明显却又是最不吸引人的用处是:创建你的完美家用...

异次元
2013/11/09
7.1K
8
Linux 反汇编工具--LDasm

LDasm (Linux 反汇编工具) 是一个基于 Perl/TK 的 objdump/binutils 图形化工具,试图模仿 W32Dasm 工具的外观。可搜索相互参照,将代码从 GAS 转换成 MASM 风格代码等等。...

匿名
2013/01/22
5.6K
1
Steam Installer for Wheezy

Linux游戏最近因为Valve旗下Steam平台的支持而获得快速增长。最初Steam只承诺支持最流行的桌面发行版Ubuntu,但最近它已向其它流行发行版开放了大门。但如果你使用的是不那么流行的发行版呢?...

匿名
2013/03/06
893
0

没有更多内容

加载失败,请刷新页面

加载更多

SQL 语句大全

点击上方“掌上编程”,选择“置顶或者星标” 优质文章第一时间送达! 一、基础 「1、说明:创建数据库」 CREATE DATABASE database-name    「2、说明:删除数据库」 drop database ...

GeneralMa
昨天
0
0
山东创睦网络科技有限公司:使用Python爬取全球新冠肺炎疫情数据

使用Python爬取全球新冠肺炎疫情数据 导入所需库包 获取实时数据的url 正式编写程序 查看输出结果 导入所需库包 在获取数据之前,我们需要先安装好所需的包requests和pandas: 1.如果是使用p...

osc_qv1fwke0
16分钟前
0
0
如何1年获得别人3年的工作经验(深度好文)

最近有同学问我,为什么你的工作年限不长,技术却这么厉害,我笑了笑,啥也没说。 我不是不想回答,是不知道怎么回答。在他们的定位可能就是,每方面都懂一点,遇到问题能够快速解决,就是比...

zhang_rick
今天
0
0
新基建带动行业

什么是“新基建”? 什么是“新基建”? 根据央视发布的信息来看,其涵盖了5G基站建设、新能源汽车充电桩、大数据中心、人工智能、工业互联网,特高压,城际以及城轨交通,涉及了七大领域和相...

osc_anefoz50
16分钟前
0
0
怕入错行?这群技术人写了本“择业指南”

计算机专业好找工作吗?哪些方向是当前的主流和热门方向呢? 计算机专业的你是不是还在为职业发展纠结犹豫呢? 刚经历完高考选专业的你是不是还在迷茫徘徊呢? 那么福利来啦! 《软件技术职业...

阿里云云栖号
16分钟前
0
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部