RocketMQ主要由 Producer、Broker、Consumer 三部分组成，其中Producer 负责生产消息，Consumer 负责消费消息，Broker 负责存储消息。Broker 在实际部署过程中对应一台服务器，每个 Broker 可以存储多个Topic的消息，每个Topic的消息也可以分片存储于不同的 Broker。Message Queue 用于存储消息的物理地址，每个Topic中的消息地址存储于多个 Message Queue 中。ConsumerGroup 由多个Cons

由于rocketmq不支持java11的新特性，在启动的时候会出现各种错误，按照这个基础做数据的更新， 支持 java 11的rocketmq版本，基于 4.7.1做的更改，下载后直接下载使用就可以了