RocketMQ入门介绍

in 网站建设
关注公众号【好便宜】( ID:haopianyi222 ),领红包啦~
阿里云,国内最大的云服务商,注册就送数千元优惠券:https://t.cn/AiQe5A0g
腾讯云,良心云,价格优惠: https://t.cn/AieHwwKl
搬瓦工,CN2 GIA 优质线路,搭梯子、海外建站推荐: https://t.cn/AieHwfX9

一,安装

1,Rocketmq 安装

1,下载rocketmqzip包,地址

2,执行命令进行安装

unzip rocketmq-all-4.6.0-source-release.zip  
cd rocketmq-all-4.6.0/  
mvn -Prelease-all -DskipTests clean install -U  
cd distribution/target/apache-rocketmq

3,启动NameServer

# 启动NameServer  
nohup sh bin/mqnamesrv &  
# 查看日志  
tail -f ~/logs/rocketmqlogs/namesrv.log
//启动日志  
2019-12-19 13:48:44 INFO main - The Name Server boot success. serializeType=JSON  
2019-12-19 13:48:44 INFO NettyEventExecutor - NettyEventExecutor service started  
2019-12-19 13:49:36 INFO NettyServerCodecThread_1 - NETTY SERVER PIPELINE: channelRegistered 192.168.60.201:60218  
2019-12-19 13:49:36 INFO NettyServerCodecThread_1 - NETTY SERVER PIPELINE: channelActive, the channel[192.168.60.201:60218]

4,启动Broker

# 启动Broker  
nohup sh bin/mqbroker -n localhost:9876 &  
# 查看Broker启动日志  
tail -f ~/logs/rocketmqlogs/broker.log
2019-12-19 13:49:34 INFO main - load /home/qianjiangtao/store/config/subscriptionGroup.json OK  
2019-12-19 13:49:34 INFO main - load [/home/qianjiangtao/store/config/consumerFilter.json] OK  
2019-12-19 13:49:34 INFO main - load [/home/qianjiangtao/store/config/delayOffset.json] OK  
2019-12-19 13:49:36 INFO main - Set user specified name server address: 192.168.60.201:9876  
2019-12-19 13:49:36 INFO PullRequestHoldService - PullRequestHoldService service started  
2019-12-19 13:49:37 INFO main - register broker to name server 192.168.60.201:9876 OK  
2019-12-19 13:49:37 INFO main - The broker[localhost.localdomain, 192.168.60.201:10911] boot success. serializeType=JSON and name server is 192.168.60.201:9876

2,Rocketmq监控工具安装

1,下载rocketmq-console, 下载地址

2,修改配置文件application.propertiesnamesrvAddr

# 到resource目录中  
cd rocketmq-console/src/main/resources  
# 修改application配置  
server.contextPath=/rocketmq  
server.port=9888  
spring.application.name=rocketmq-console  
spring.http.encoding.charset=UTF-8  
spring.http.encoding.enabled=true  
spring.http.encoding.force=true  
logging.config=classpath:logback.xml  
# 指定namesrvAddr地址  
rocketmq.config.namesrvAddr=192.168.60.201:9876  
rocketmq.config.dataPath=/tmp/rocketmq-console/data  
rocketmq.config.enableDashBoardCollect=true

3,解压直接作为spring boot运行

mvn clean package -Dmaven.test.skip=true  
java -jar target/rocketmq-console-ng-1.0.1.jar

4,访问rocketmq-console web界面,地址
1576737383982.png
image.png

3,消息测试

测试rocketmq发送消息和消费消息,rocketmq自带测试工具直接运行就可以简单的测试消息的发送和消费

export NAMESRV_ADDR=localhost:9876  
# 消息发送默认发送1000条消息  
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Producer
//发送日志  
SendResult [sendStatus=SEND_OK, msgId=C0A83CC9284C28D93B305FDDBBBA03E1, offsetMsgId=C0A83CC900002A9F000000000005C0D4,messageQueue=MessageQueue 
[topic=TopicTest, brokerName=localhost.localdomain, queueId=2], queueOffset=498]  
......
# 消息消费  
sh bin/tools.sh org.apache.rocketmq.example.quickstart.Consumer

通过web监控界面也可以查看消息的发送和消费情况
image.png

二,角色介绍

RocketMQ架构上主要分为四部分,如下图所示:
image.png

1,Producer

消息发布的角色,支持分布式集群方式部署。Producer通过MQ的负载均衡模块选择相应的Broker集群队列进行消息投递,投递的过程支持快速失败并且低延迟。

2,Consumer

消息消费的角色,支持分布式集群方式部署。支持以push推,pull拉两种模式对消息进行消费。同时也支持集群方式和广播方式的消费,它提供实时消息订阅机制,可以满足大多数用户的需求。

3,NameServer

一个非常简单的Topic路由注册中心,支持Broker的动态注册与发现。主要包括两个功能:

4,BrokerServer

Broker主要负责消息的存储、投递和查询以及服务高可用保证,为了实现这些功能,Broker包含了以下几个重要子模块。

image.png

关注公众号【好便宜】( ID:haopianyi222 ),领红包啦~
阿里云,国内最大的云服务商,注册就送数千元优惠券:https://t.cn/AiQe5A0g
腾讯云,良心云,价格优惠: https://t.cn/AieHwwKl
搬瓦工,CN2 GIA 优质线路,搭梯子、海外建站推荐: https://t.cn/AieHwfX9
扫一扫关注公众号添加购物返利助手,领红包
Comments are closed.

推荐使用阿里云服务器

超多优惠券

服务器最低一折,一年不到100!

朕已阅去看看