RocketMq介绍

目录

简介

官方网站（以前有中文的，现在都是英文的了）

GIT

RocketMQ 编译安装

JDK要求

在linux上安装maven

配置java环境变量

修改maven环境变量

rocketmq-console 编译安装

首先是阿里推出的一个MQ，在Apache里进行孵化。

语言来说比较友好，是java开发的。另外两个mq都不是java写的。

在技术选型上

• 如果只是一个消息中间件的 特别简单的使用的话 我会使用redis或者activemq 因为api特别的简单，也是使用的jms的那么一套标准
• 当消息比较大和多的时候就比较推荐rocketmq了，本身就面向集群的。

官方网站（以前有中文的，现在都是英文的了）

Apache RocketMQ

GIT

• English：rocketmq/docs/en at master · apache/rocketmq · GitHub
• 中文：rocketmq/docs/cn at master · apache/rocketmq · GitHub

RocketMQ 编译安装

JDK要求

Version	Client	Broker	NameServer
4.0.0-incubating	>=1.7	>=1.8	>=1.8
4.1.0-incubating	>=1.6	>=1.8	>=1.8
4.2.0	>=1.6	>=1.8	>=1.8
4.3.x	>=1.6	>=1.8	>=1.8
4.4.x	>=1.6	>=1.8	>=1.8
4.5.x	>=1.6	>=1.8	>=1.8
4.6.x	>=1.6	>=1.8	>=1.8
4.7.x	>=1.6	>=1.8	>=1.8
4.8.x	>=1.6	>=1.8	>=1.8
4.9.x	>=1.6	>=1.8	>=1.8

在linux上安装maven

wget https://mirrors.tuna.tsinghua.edu.cn/apache/maven/maven-3/3.6.3/binaries/apache-maven-3.6.3-bin.tar.gz
tar -zxf apache-maven-3.6.3-bin.tar.gz 
mv apache-maven-3.6.3 /usr/local/maven
cd /usr/local/maven/conf
vi setting.xml

    aliyunmaven
    central
    aliyun maven
    https://maven.aliyun.com/repository/public 

下载maven，解压，移位重命名。修改阿里镜像。

配置java环境变量

export JAVA_HOME="/usr/java/jdk1.8.0_181=amd64"
export CLASS_PATH="$JAVA_HOME/lib"
export PATH=".$PATH:$JAVA_HOME/bin"

修改maven环境变量

/etc/profile
//在最后几行加入
export M2_HOME=/usr/local/maven
export PATH=$PATH:$M2_HOME/bin
//修改完后刷新
source etc/profile

等你把rocketmq 下好过后

首先解压

如果没有解压可以先下载解压

yum install -y unzip
unzip rocket-master.zip

进去rocketmq主目录编译项目

mvn -Prelease-all -DskipTests clean install -u

回车开始编译(确定有pom文件)

cd distribution/target/rocketmq-4.6.1/bin

需要启动两个东西

mqbroker

mqnamesrv

./mqnamesrv 启动 相当于一个注册中心
./mqbroker -n localhost:9876 启动

测试使用

vi tools.sh
export NAMESRV_ADDR=localhost:9876
./tools.sh org.apache.rocketmq.example.quickstart.Producer

pom.xml依赖

    org.apache.rocketmq
    rocketmq-client
    4.6.1

rocketmq-console 编译安装

https://github.com/apache/rocketmq-externals 可以查看rocketmq相关的额外

进入rocketmq-console 目录(看到有pom文件)

mvn clean package -Dmaven.test.skip=true

cd target/

java -jar rocketmq-console-ng-1.0.1.jar --127.0.0.1:9876

启动过后 访问启动地址就好了.

消息队列

是《数据结构》中先进先出的一种数据结构，在当前的架构中，作为中间件提供服务。

消息中间件功能

应用解耦

流量削峰

大数据处理

跨语言