1.前言

本篇主要讲解使用java语言对消息中间件进行消息的产生和消费，用来方便理解rocketmq的价值和使用。该工作主要是面对系统开发人员，运维人员加以了解，以便在实际运维工作中更加顺畅。

2.向rocketmq中生产消息

2.1向集群中创建 Topic

发送消息前，需要确保目标主题已经被创建和初始化。可以利用 RocketMQ Admin 工具创建目标 Topic 。 相关命令如下： sh bin/mqadmin updateTopic –n 192.168.11.101:9876;192.168.11.102:9876 –c MyCluster –t TopicTest

备注：RocketMQ 部署安装包默认开启了 autoCreateTopicEnable 配置，会自动为发送的消息创建 Topic，但该特性仅推荐在初期测试时使用。生产环境强烈建议管理所有主题的生命周期，关闭自动创建参数，以避免生产集群出现大量无效主题，无法管理和回收，造成集群注册压力增大，影响生产集群的稳定性。

2.2添加客户端依赖

该步骤是为了引入相关依赖包，不然缺少依赖类和方法