linux安装RocketMQ

rocketMQ | 2020-03-06 16:25:47

RocketMQ之前是阿里基于ActiveMQ 5.x的分布式消息传递中间件,RocketMQ最早是阿里巴巴开源的MQ中间件,在阿里集团被广泛应用在订单,交易,充值,流计算,消息推送,日志流式处理,binglog分发等场景。现已捐献给Apache,目前是Apache下的顶级项目。

官网:http://rocketmq.apache.org/

安装RocketMQ需要安装的环境:

1.建议使用64位操作系统,Linux / Unix / Mac; 参考:U盘安装linux centOS 7

2.64位JDK 1.8+; 参考:linux centos 安装java jdk及环境变量配置

3.Maven 3.2.x. 参考:linux安装maven及配置环境变量

4.git(可以不需要)




一 从发布下载和构建

单击此处下载4.3.0源代码版本。您也可以从这里下载二进制版本

现在执行以下命令来解压缩4.3.0源代码版本并构建二进制工件。

  > unzip rocketmq-all-4.3.0-source-release.zip  > cd rocketmq-all-4.3.0/  > mvn -Prelease-all -DskipTests clean install -U
  > cd distribution/target/apache-rocketmq

二 启动命名服务器

  > nohup sh bin/mqnamesrv &  > tail -f ~/logs/rocketmqlogs/namesrv.log
  The Name Server boot success...

三 启动代理

  > nohup sh bin/mqbroker -n localhost:9876 &  > tail -f ~/logs/rocketmqlogs/broker.log 
  The broker[%s, 172.30.30.233:10911] boot success...

四 发送和接收消息

在发送/接收消息之前,我们需要告诉客户端名称服务器的位置。RocketMQ提供了多种方法来实现这一目标。为简单起见,我们使用环境变量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...

五 关服务器

> sh bin/mqshutdown brokerThe mqbroker(36695) is running...Send shutdown request to mqbroker(36695) OK> sh bin/mqshutdown namesrvThe mqnamesrv(36664) is running...Send shutdown request to mqnamesrv(36664) OK


登录后即可回复 登录 | 注册
    
关注编程学问公众号