RocketMQ基础

组成结构

1.Prodecer Cluster：消息生产者群；负责发送消息，一般由业务系统负责产生消息。
2.Consumer Cluster：消息消费者群；负责消费消息，一般是后台系统负责异步消费。
3.NameServer：名称服务器；收集关于broker的信息；相当于broker的注册中心，不负责处理消息。
4.Broker：消息服务器；MQ核心，负责消息的接收存储发送等。需要定时更新状态发送到NameServer中。

RocketMQ初步测试(windows系统)
1.解压MQ压缩包
2.更改bin目录下的配置(调整默认内存大小)
runserver.cmd:-server -Xms512m -Xmx512m -Xmn512m -XX:MetaspaceSize=128m XX:MaxMetaspaceSize=320m
runbroker.cmd:-server -server -Drocketmq.broker.diskSpaceWarningLevelRatio=0.98 -Xms512m Xmx512m -Xmn512m
3.启动NameServer;

4.启动broker。需要制定nameServer的地址
进入cmd窗口，执行命名行bin/mqbroker.cmd -n 127.0.0.1:9876
5.测试
发送消息：
(1)设置nameserver地址，set NAMESRV_ADDR=127.0.0.1:9876
(2)发送消息，tools.cmd org.apache.rocketmq.example.quickstart.Producer

接收消息：
(1)设置nameserver地址，set NAMESRV_ADDR=127.0.0.1:9876
(2)接收消息，tools.cmd org.apache.rocketmq.example.quickstart.Consumer

安装可视化管理端
1.解压UI压缩包(maven项目)

2.修改配置
修改rocketmq-console\src\main\resources\application.properties

3.打包
进入rocketmq-console目录下，执行cmd语句mvn clean package -Dmaven.test.skip=true

4.启动(运行jar包的形式)
进入/rocketmq-console/target，执行cmd命令，java -jar rocketmq-console-ng-1.0.1.jar --server.port=9877 --rocketmq.config.namesrvAddr=127.0.0.1:9876

5.访问http://127.0.0.1:9877