RocketMQ–导读
原文链接 译者：小村长
最近两个项目中用到了RocketMQ消息中间件，每次都是在网上找几个Demo，而没有去看它的官方文档。年前面试某大型互联网企业。RocketMQ多有提及。今借此机会翻译一篇RocketMQ的官方文档。希望能够对大家的工作和学习有所帮助。
由于RocketMQ是互联网企业解耦常用的消息中间件，希望大家在使用的时候也多多思考几个问题：
第一，RocketMQ由几部分组成以及每个组件的作用。
第二，RocketMQ消息怎么保证可靠性以及高可用性。
第三，RocketMQ消息种类以及怎么保证消息有序。
最后，我还是建议有能力的童鞋能够自己去Apache RocketMQ官方看看。
快速开始
前置条件
假定安装了以下软件:
从发布版下载并构建
点击 这里 下载4.2.0发行版源代码. 你也可以点击 这里下载二进制发行版.
现在执行以下命令来解压4.2.0源版本并构建.
> unzip rocketmq-all-4.2.0-source-release.zip
> cd rocketmq-all-4.2.0/
> mvn -Prelease-all -DskipTests clean install -U
> cd distribution/target/apache-rocketmq
启动 Name Server服务
> nohup sh bin/mqnamesrv &
> tail -f ~/logs/rocketmqlogs/namesrv.log
The Name Server boot success...
启动Broker
> 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 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原创文章，作者：ItWorker，如若转载，请注明出处：https://blog.ytso.com/93865.html