RocketMQ-

第一课

下载源码并编译安装

这个broker对应的jar包启动时，传入到启动方法中的JVM参数

可以看到默认broker的最大内存和最小内存就是8G，如果虚拟机的内存不足8G，那么./mqBroker启动broker就会报错。所以需要把这几个参数值改小一点

提示找不到node-01这个主机名对应的ip地址

默认不加参数，就是启动broker，并直接在本机中找nameserver进行注册，我们也可以在启动时制定往哪台nameserver上连接

测试发送和接收消息

数据发送失败，提示找不到这个topic（就是因为当前要发送消息的broker，没有注册到nameserver上去）

通过启动broker，并注册到指定的nameserver后

此时，client端发送数据就成功了，可以看到发送的数据的topic就是TopicTest

消费者消费消息

rocketmq-console

像rocketmq-4.6.1-master这个里面就有pom文件，rocketmq-4.6.1-master目录下有namesrv、brokker、client、等等，master目录中有pom文件，所以这就是一个聚合项目，可以整个使用一次mvn命令进行编译

这里编译完成以后，是生成一个springboot框架的控制台项目jar包，我们需要通过jar -jar来启动这个控制台项目

正常java项目打包出来就是jar包，我们需要通过jar -jar来启动项目，就如当前的rocketmq-console项目，而上面的rocketmq-master可以通过./mqbroker启动项目，是因为写了runborker.sh的shell脚本文件，runborker.sh的shell脚本文件中就配置了很多JVM的启动参数等

这就是这个springboot项目的配置文件

或者，因为这是一个springboot项目，所以我们可以在jar -jar启动springboot项目的jar，在后面跟上一些参数

这个springboot写的控制台项目就启动起来了

可以看到有broker TOP 10的展示，说明RocketMQ生来就是为了多集群多broker，大数据量的存储而生的