rocketMQ基础环境

Posted zhimingxin

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了rocketMQ基础环境相关的知识,希望对你有一定的参考价值。

 

一、安装:

http://rocketmq.apache.org/dowloading/releases/

https://www.apache.org/dyn/closer.cgi?path=rocketmq/4.5.1/rocketmq-all-4.5.1-bin-release.zip

启动

1.3.2 启动消患队列服务

启动单机的消息队列服务比较简单,不需要写配置文件,只需要依次启动

本机的NameServer 和B roker 即可

启动NameServer:

> nohup sh bin/mqnamesrv &

> tail - f ~/Logs / rocketmqLogs / namesrv . Log

The Name Server boot success . ..

启动B roker :

> nohup sh bin/mqbroker n localhost : 9876&

> tail -f ~/ Logs/rocketmqLogs/broker . Log

The broker[%s, 192.168.0.233 : 10911] boot success .. .

1.3.3 用命令行发送和接收消息

为了快速展示发送和接收消息,本节展示的是用命令行发送和接收消息,

实际上就是运行写好的demo 程序,后续我们可以参考这些demo 来写自己的发

送和接收程序

运行示例程序,发送和接收消息:

>export NAMESRV ADDR=localhost : 9876

> sh bin/tools . sh org .apache .roc ketmq.example . quickstart.Producer

SendResult [sendStatus=SEND OK, msgid=

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

ConsumeMessageThread 主d Receive New Messages : [MessageExt . ..

1.3.4 关闭消息队列

消息队列被启动后,如果不主动关闭, 会一直在后台运行,占用系统资

。我们有专门用来关闭NameServ er 和Broker 的命令

 

关闭NameServer 和Broker:

> sh bin/mqshutdown broker

The mqbroker (36695) i s running ...

Send shutdown request to mqbroker (36695 ) OK

> sh bin/mqshutdown namesrv

The mqnames r v (36664 ) is runn 工口g ...

Send shutdown request t o mqnamesrv (36664) OK

喜,现在你已经能够使用RocketMQ 发送并接收消息了,使用消息队列

基本功能就是这么简单

 

 

相关资料

Mac下查看已安装的jdk版本及其安装目录:

在Mac中如何正确地设置JAVA_HOME

https://blog.csdn.net/a158123/article/details/79684499

rocketmq4.2.0 - 服务安装, web管理界面安装 

https://blog.csdn.net/changerzhuo_319/article/details/81513821

以上是关于rocketMQ基础环境的主要内容,如果未能解决你的问题,请参考以下文章

RocketMQ 可视化环境搭建和基础代码使用

技术专栏 | RocketMQ基础与实战——RocketMq下载与安装

RocketMQ 4.5.1 双主双从异步复制环境搭建

生产环境kafka日志集群400W/tps就扛不住了

生产环境kafka日志集群400W/tps就扛不住了

生产环境kafka日志集群400W/tps就扛不住了