rocketmq4.x快速入门指南
2024-08-21 23:43:25
以下采用的是apache rocketmq 4.2.0
版本 相关文档如下
- 快速体验: http://blog.seoui.com/2018/07/24/rocketmqinstall/
- rocketmq简单消息发送: http://blog.seoui.com/2018/07/24/rocketmq_simple_message/
- rocketmq有序消息: http://blog.seoui.com/2018/07/24/rocketmq_ordered_message/
- rocketmq广播消息: http://blog.seoui.com/2018/07/24/rocketmq_broadcast_message/
- rocketmq延时消息: http://blog.seoui.com/2018/08/01/rocketmq_delay_message/
- rocketmq批量消息: http://blog.seoui.com/2018/08/02/rocketmq_batch_message/
下载源码并编译
wget http://mirrors.hust.edu.cn/apache/rocketmq/4.2.0/rocketmq-all-4.2.0-source-release.zip
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
目录 distribution/target/apache-rocketmq
是编译后的产出 可复制这个目录安装MQ的机器上,这里复制到/usr/local/
共享一份编译后的文件方便以后再次使用
https://pan.baidu.com/s/1ZyUOKFm-t8cJDQuH68QydQ
启动NameServer
cd /usr/local/apache-rocketmq
nohup sh bin/mqnamesrv &
查看日志tail -f ~/logs/rocketmqlogs/namesrv.log
启动成功后打印The Name Server boot success…
启动Broker
这里需要注意一下就是 如果当前机器上有多张网卡的情况,最好指定一个IP
, 有可能消费端正好就和MQ选择的网卡不通
vim conf/broker.conf
指定IP 访问多网卡的情况 并配置好nameserver的地址 也可以使用mqbroker启动参数-n
指定nameserver地址
brokerIP1=192.168.1.2
namesrvAddr=192.168.1.3:9876
启动broker -c
参数指定配置文件
nohup sh bin/mqbroker -c config/broker.properties &
查看一下集群列表
sh bin/mqadmin clusterList -n localhost:9876
发送/接收消息
Producer
export NAMESRV_ADDR=localhost:9876
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
能发送表示OK
Consumer
export NAMESRV_ADDR=localhost:9876
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer
能接收到之前发送的消息表示OK
关闭MQ
sh bin/mqshutdown broker
sh bin/mqshutdown namesrv
最新文章
- [LeetCode] Remove Duplicate Letters 移除重复字母
- vmware中两台虚拟机互相访问
- Configure Visual Studio 2013 for debugging .NET framework
- java正则随笔
- Ogre 1.9 Android移植
- JDBC连接属性
- .Net程序员面试试题
- 异步获取CMD命令行输出内容
- Thinking in Java 第二章学习笔记
- Tensorflow会话Session
- 获取电脑系统唯一GUID
- 011_如何decode url及图片转为base64文本编码总结
- linux中使用ifconfig命令查看网卡信息时显示为eth1,但是在network-scripts中只有ifcfg-eth0的配置文件,并且里面的NAME=";eth0";。
- Redis 队列好处
- Ansible安装及配置
- Luogu
- python中str相关函数
- Android - 富文本编辑器
- lwip Packet buffers (PBUF) API 操作 集合
- 【HTML5游戏开发】简单的《找不同汉字版》,来考考你的眼力吧
热门文章
- 如何使用JS来开发室内地图商场停车场车位管理系统
- Redis数据结构和常用API
- 设计模式之外观模式——Java语言描述
- UiPath针对SAP的输入技巧
- ArcGIS JS Api 4.x修改三维球背景技巧
- arcgis画矢量图
- Git默认用户名和密码设置
- MySQL数据库Inception工具学习与测试 笔记
- ORA-39127: 调用 ";WMSYS";.";LT_EXPORT_PKG";.";SCHEMA_INFO_EXP"; 时发生意外错误
- SSIS-导入Excel文件时记录行号