您的位置:首页 > 其它

RocketMQ 入门部署

2016-09-04 23:24 405 查看
通过RocketMQ 项目主页的Quick start了解RocketMQ的安装部署(Linux下)。

一、必备条件

64bit OS, best to have Linux/Unix/Mac;
64bit JDK 1.6+;
Maven 3.x
Git
Screen

二、基本安装步骤

1、进入你的安装目录:

我这里是/usr/local/development/rocketmq

cd    /usr/local/development/rocketmq

2、clone和编译

git clone https://github.com/alibaba/RocketMQ.git
cd RocketMQ

bash install.sh

3、设置环境变量

vi /etc/profile  在最后加上

#set rocket enviroment

export ROCKETMQ_HOME=/usr/local/development/rocketmq/RocketMQ/devenv

source /etc/profile  使环境变量生效

4、启动

进入bin目录:cd   /usr/local/development/rocketmq/RocketMQ/bin

启动nameserv: screen bash mqnamesrv

当看到“The Name Server boot success. serializeType=JSON” 时表示name server启动成功了

然后按  Ctrl + A  Ctrl + D

启动broker :screen bash mqbroker -n localhost:9876

同样当看到相应的提示信息“*******  register broker to name server localhost:9876 OK”就表示broker启动成功

至此,一个name server 一个 broker 启动完成。

5、测试

Quick Start最后一部分是发送和接收消息的测试用例。

首先是设置name server 地址到环境变量,以便测试用例找到name server的地址。RocketMQ有多种配置方式令客户端找到name server:①在代码中指定 ②在java 启动参数中指定 ③在环境变量中指定 ④HTTP静态服务器寻址。(详见 RocketMQ Developer Guid.pdf  网络上可下载)

export NAMESRV_ADDR=localhost:9876

然后,运行Producer:

bash tools.sh com.alibaba.rocketmq.example.quickstart.Producer

然后,运行Consumer:

bash tools.sh com.alibaba.rocketmq.example.quickstart.Consumer

当看到打印出发送、消费消息的日志记录就表明测试用例运行成功了。

PS:  RocketMQ Developer Guid 上 12.2  Broker 集群搭建 指明了几种broker集群的搭建方式。在conf目录下已经提供了一些搭建形式的配置文件,比如:

2m-2s-async          //2个master2个slave,异步复制

2m-2s-sync            //2个master2个slave,同步双写

2m-noslave           //2个master无slave
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: