快速入门
RocketMQ 是阿里主导开发的分布式开源消息队列系统,是一个低延迟、高并发、高可用、高可靠的分布式消息中间件。
部署 Websoft9 提供的 RocketMQ 之后,请参考下面的步骤快速入门。
准备
- 在云控制台获取您的 服务器公网IP地址
- 在云控制台安全组中,确保 Inbound(入)规则 下的 TCP:9003 端口已经开启
- 在服务器中查看 RocketMQ 的 默认账号和密码
- 若想用域名访问 RocketMQ ,务必先完成 域名五步设置 过程
RocketMQ 初始化向导
详细步骤
-
使用 SSH 登录到 RocketMQ 所在服务器后,运行如下命令,检查 RocketMQ 服务状态
sudo systemctl status mqnamesrv
sudo systemctl status mqbroker -
使用本地浏览器访问可视化工具 RocketMQ-Console,进一步验证。
出现问题?
若碰到问题,请第一时刻联系 技术支持。也可以先参考下面列出的问题定位或 FAQ 尝试快速解决问题。
RocketMQ 使用入门
下面以 使用 RocketMQ 发送(生产者)和接受消息(消费者) 作为一个任务,帮助用户快速入门:
建议开始下面的步骤之前,先花5分钟时间阅读由通俗易懂的 物流系统与 消息队列
-
对实验所需准备的工具或程序做出说明
- 发送人(本实验对应的是一个程序):/data/rocketmq/bin/tools.sh
- 接收人(本实验对应的是一个程序):/data/rocketmq/bin/tools.sh
- 消息信件:示例代码生成
org.apache.rocketmq.example.quickstart.Producer
(Java 类) - 消息存储地: RabbitMQ Broker
- 消息订单处理中心:NAMESRV_ADDR 用于根据消息存储地资源情况进行消息的动态分配
-
使用 SSH 登录到 RocketMQ 服务器,运行下面命令,以发件人的身份发送消息
export NAMESRV_ADDR=localhost:9876
cd /data/rocketmq/bin
sh tools.sh org.apache.rocketmq.example.quickstart.Producer -
发送成功会收到 SendResult [sendStatus=SEND_OK, msgId= ... 之类的反馈结果
-
在运行下面的命令,以收件人的身份接受消息
cd /data/rocketmq/bin
sh tools.sh org.apache.rocketmq.example.quickstart.Consumer -
接受成功会收到 ConsumeMessageThread_%d Receive New Messages: [MessageExt... 之类的反馈结果
-
登录到可视化界面 RocketMQ-Console 中可更直观的查看运行结果
需要了解更多 RocketMQ 的使用,请参考官方文档:RocketMQ Documentation
RocketMQ 常用操作
收发消息示例
对于如何发送消息以及接受消息,本文档章节:RocketMQ 使用入门 中有详细的讲解。
可视化工具 RocketMQ-Console-NG
RocketMQ 扩展项目中提供了管理和监控 RocketMQ 的可视化工具:RocketMQ-Console-NG :
-
使用本地电脑浏览器访问:http://服务器公网IP:9003, 进入登陆页面
-
输入账号密码(不知道账号密码?),成功登录到 RocketMQ 后台
-
设置自己喜欢的语言