一、安装
[root@master opt]# ls
alibaba-rocketmq-3.2.6.tar.gz grafana-2.5.0.linux-x64.tar.gz httpd-2.2.23.tar.gz memcached-1.4.25.tar.gz nagios-3.4.3.tar.gz php-5.4.10.tar.gz
cacti-0.8.8b.tar.gz hadoop libevent-1.4.14b-stable mongodb nagios-plugins-1.4.13 tomcat
flume1.6 hadoop_data libevent-1.4.14b-stable.tar.gz mongodb-linux-x86_64-1.6.3.tgz nagios-plugins-1.4.13.tar.gz
grafana-2.5.0 httpd-2.2.23 memcached nagios php-5.4.10
[root@master opt]# tar -zxvf alibaba-rocketmq-3.2.6.tar.gz
[root@master opt]# cd alibaba-rocketmq
[root@master alibaba-rocketmq]# ls
benchmark bin conf issues lib LICENSE.txt test wiki
[root@master alibaba-rocketmq]# cd bin/
[root@master bin]# ls
mqadmin mqadmin.xml mqbroker.exe mqbroker.numanode1 mqbroker.numanode3 mqfiltersrv mqfiltersrv.xml mqnamesrv.exe mqshutdown play.sh runbroker.sh startfsrv.sh
mqadmin.exe mqbroker mqbroker.numanode0 mqbroker.numanode2 mqbroker.xml mqfiltersrv.exe mqnamesrv mqnamesrv.xml os.sh README.md runserver.sh tools.sh
[root@master bin]# cd ../conf/
[root@master conf]# ls
2m-2s-async 2m-2s-sync 2m-noslave logback_broker.xml logback_filtersrv.xml logback_namesrv.xml logback_tools.xml
[root@master conf]#
[root@master bin]# ls
mqadmin mqadmin.xml mqbroker.exe mqbroker.numanode1 mqbroker.numanode3 mqfiltersrv mqfiltersrv.xml mqnamesrv.exe mqshutdown play.sh runbroker.sh startfsrv.sh
mqadmin.exe mqbroker mqbroker.numanode0 mqbroker.numanode2 mqbroker.xml mqfiltersrv.exe mqnamesrv mqnamesrv.xml os.sh README.md runserver.sh tools.sh
[root@master bin]# sh play.sh
Start Name Server and Broker Successfully, 192.168.1.107:9876
[root@master bin]# ifconfig
eth0 Link encap:Ethernet HWaddr 00:0C:29:03:CF:7F
inet addr:192.168.1.103 Bcast:192.168.1.255 Mask:255.255.255.0
inet6 addr: fe80::20c:29ff:fe03:cf7f/64 Scope:Link
UP BROADCAST RUNNING MULTICAST MTU:1500 Metric:1
RX packets:8900 errors:0 dropped:0 overruns:0 frame:0
TX packets:1625 errors:0 dropped:0 overruns:0 carrier:0
collisions:0 txqueuelen:1000
RX bytes:12509126 (11.9 MiB) TX bytes:154496 (150.8 KiB)
Base address:0x2000 Memory:c9020000-c9040000
lo Link encap:Local Loopback
inet addr:127.0.0.1 Mask:255.0.0.0
inet6 addr: ::1/128 Scope:Host
UP LOOPBACK RUNNING MTU:16436 Metric:1
RX packets:39 errors:0 dropped:0 overruns:0 frame:0
TX packets:39 errors:0 dropped:0 overruns:0 carrier:0
collisions:0 txqueuelen:0
RX bytes:3572 (3.4 KiB) TX bytes:3572 (3.4 KiB)
[root@master bin]# hostname -i
192.168.1.107
[root@master bin]# sh mqadmin
The most commonly used mqadmin commands are:
updateTopic Update or create topic
deleteTopic Delete topic from broker and NameServer.
updateSubGroup Update or create subscription group
deleteSubGroup Delete subscription group from broker.
updateBrokerConfig Update broker's config
topicRoute Examine topic route info
topicStatus Examine topic Status info
brokerStatus Fetch broker runtime status data
queryMsgById Query Message by Id
queryMsgByKey Query Message by Key
queryMsgByOffset Query Message by offset
printMsg Print Message Detail
producerConnection Query producer's socket connection and client version
consumerConnection Query consumer's socket connection, client version and subscription
consumerProgress Query consumers's progress, speed
consumerStatus Query consumer's internal data structure
cloneGroupOffset clone offset from other group.
clusterList List all of clusters
topicList Fetch all topic list from name server
updateKvConfig Create or update KV config.
deleteKvConfig Delete KV config.
wipeWritePerm Wipe write perm of broker in all name server
resetOffsetByTime Reset consumer offset by timestamp(without client restart).
updateOrderConf Create or update or delete order conf
cleanExpiredCQ Clean expired ConsumeQueue on broker.
startMonitoring Start Monitoring
checkMsg Check Message Store
statsAll Topic and Consumer tps stats
syncDocs Synchronize wiki and issue to github.com
See 'mqadmin help <command>' for more information on a specific command.
[root@master bin]#
二、Send & Receive Messages
Before sending/receiving messages, we need to tell clients where name servers are located. RocketMQ provides multiple ways to achieve this. For simplicity, we use environment variable NAMESRV_ADDR
生产消息窗口
export NAMESRV_ADDR=localhost:9876
Now we are ready to send/receive messages.
sh tools.sh com.alibaba.rocketmq.example.quickstart.Producer
You will see a few hundred messages are sent to brokers.
消息消息窗口
export NAMESRV_ADDR=localhost:9876
To consume messages you just sent in the previous step,
sh tools.sh com.alibaba.rocketmq.example.quickstart.Consumer
相关推荐
该资源为在购买了阿里云中间件产品rocketmq消息队列之后,使用的连接rocketmq的demo工程,该程序以 Java 为例,包括普通消息、事务消息、定时消息的测试代码,以及相关 Spring 的配置示例,同时提供tcp连接的程序。
使用阿里中间件RocketMQ、Tair、jstorm对双十一实时交易进行实时计算 使用阿里中间件RocketMQ、Tair、jstorm对双十一实时交易进行实时计算 使用阿里中间件RocketMQ、Tair、jstorm对双十一实时交易进行实时计算 使用...
阿里版 rocketmq-console,下载编译打包即可。。。。。。。。。。。。
阿里巴巴 rocketmq阿里巴巴 rocketmq阿里巴巴 rocketmq阿里巴巴 rocketmq
阿里分布式消息中间件RocketMQ-深入解析.docx
阿里RocketMQ资料,包括整体设计、使用注意点经验总结等等
阿里Apache RocketMQ事务消息介绍.pdf
(最新) 阿里云消息 RocketMQ开发手册,加入最新的规则
保姆级(详细操作步骤)kettel+阿里云rocketMQ大批量数据推送
阿里RocketMQ用户指南V3.2.4阿里RocketMQ用户指南V3.2.4阿里RocketMQ用户指南V3.2.4.pdf
RocketMQ-介绍.pptx Rocketmq使用.docx RocketMQ-原理简介.pdf 阿里RocketMQ_用户指南_V3.2.4_最新版本.pdf
rocketMq主要引用于在项目中的消息队列实现,可异步处理数据
本文档旨在描述RocketMQ如何使用,以及服务集群的部署方式。
阿里的分布式系统应用到的消息服务框架,Rocketmq3.1.1
很好用的消息队列,新版Rocketmq4.2, RocketMQ是一款分布式、队列模型的消息中间件
阿里 rocketmq 文档
rocketMQ
springboot整合activeMQ案例代码,服务是发布在阿里云上的,本案例详细讲解了rocketmq的基本使用
spring-boot-mq-rocketmq 一套大通rocketmq 有注释 打开可运行 妈妈再也不用担心你的rocketmq
阿里RocketMQ_用户指南_V3.2.4_最新版本.pdf benchmark.pdf Metaq在JDk 7下的异常及解决方案.docx mqvsmq.pdf RocketMQ_原理简介.pdf RocketMQ_admin.pdf RocketMQ_benchmark.pdf RocketMQ_calvinzhan - 类图.pdf ...