在什么网站可以做外贸出口劳保鞋,建设租车网站,企业培训网,提交网站的入口地址一、准备工作
从RockitMQ官网下载 | RocketMQ下载最新的release包。我这里下载的版本是v5.2.0 解压到本地目录#xff0c;bin目录下存放可运行的脚本。 二、RocketMQ基本结构
在动手开发之前#xff0c;我们需要了解一下RocketMQ的基本结构 如上图所示#xff0c;一个正常…一、准备工作
从RockitMQ官网下载 | RocketMQ下载最新的release包。我这里下载的版本是v5.2.0 解压到本地目录bin目录下存放可运行的脚本。 二、RocketMQ基本结构
在动手开发之前我们需要了解一下RocketMQ的基本结构 如上图所示一个正常工作的RocketMQ包括四个部分。
NameServer 基于高可用设计产生的用于服务发现和路由。正式应用时通常采用集群部署。Broker实现队列机制负责消息存储和转发。正式应用时也采用集群部署。Producer消息生产者生成消息并发送到RocketMQ中生产者通常是我们自己实现的应用程序。Consumer消息消费者从RocketMQ中接收消息并进行业务处理。这部分也通常是我们自己实现的。 这里并不打算深入讲解RocketMQ的架构和特性因为我觉得针对于初学者太早地深入知识细节会让人感到迷惘学习起来吃力。为了避免浪费时间以上的知识己经能满足本文后面要实践的内容。随着实践我们会慢慢加深对RocketMQ的理解再回过头来一点点深入了解。 以上的知识都来源于RocketMQ官网的参考文档需要更多细节的同学 可以打开https://rocketmq.apache.org/docs/quickStart/01quickstart/ 自行阅读。 三、Windows环境下启动最小应用
从上面的图可以了解到RocketMQ自身分为 NameServer 和 Broker 两个部分因此用作本机开发调试用的最小应用应该分别启动一个NameServer和一个Broker节点。
RocketMQ默认提供了 windows环境 和 linux环境 下的启动脚本。脚本位于bin目录下windows的脚本以.cmd为文件名后缀linux环境的脚本以.sh为文件名后缀。
第一步、配置JAVA_HOME 和 ROCKETMQ_HOME 环境变量
JAVA_HOME 的配置已经是老生常谈这里不再赘述不懂的话请自行百度。
ROCKETMQ_HOME 应指向解压后的Readme.md文件所在目录。 第二步启动 NameServer
bin目录下直接双击mqnamesrv.cmd脚本启动NameServer 看到 The Name Server boot success 字样表示NameServer己启动成功。 windows环境下可以在目录%USERPROFILE%\logs\rocketmqlogs下找到NameServer的启动日志。文件名为namesrv.log。 第三步启动 Broker
Broker的启动脚本是mqbroker.cmd脚本启动之前要指定 NameServer的地址。
启动方式一修改mqbroker.cmd脚本增加NameServer的地址。
rem 添加此行指定NameServer的地址
set NAMESRV_ADDRlocalhost:9876rem 在此行之前添加NameServer的地址
call %ROCKETMQ_HOME%\bin\runbroker.cmd org.apache.rocketmq.broker.BrokerStartup %*
双击mqbroker.cmd脚本启动Broker。
启动方式二不修改mqbroker.cmd脚本直接使用cmd命令启动
先进入rocketmq安装目录的bin目录下面然后执行下面命令启动broker
start mqbroker.cmd -n 127.0.0.1:9876 autoCreateTopicEnabletrue 看到 The broker ... boot success 字样表示Broker己启动成功 与NameServer类似可以在目录%USERPROFILE%\logs\rocketmqlogs下找到Broker的启动日志。文件名为broker.log。 四、使用RocketMQ仪表盘
RocketMQ Dashboard是一个Web界面应用程序用于管理和监控Apache RocketMQ消息中间件的运行状态。RocketMQ Dashboard提供了一系列的监控指标和管理功能包括Broker配置、集群概览、主题状态、消费者状态、生产者状态和消息跟踪等。
https://github.com/apache/rocketmq-dashboard直接下载源码到本地部署
用idea打开修改配置文件application.yml
rocketmq:config:namesrvAddrs:- 192.168.10.100:9876- 192.168.10.101:9876namesrvAddrs地址就是服务的地址192.168.10.100是我虚拟主机的ip如果是window环境下改成localhost或者127.0.0.1
然后启动程序访问http://localhost:8080/#/
