一、准备工作
在创建新的RocketMQ Topic之前，我们必须先准备好以下内容：
1. RocketMQ服务的IP地址以及端口号。
2. 互联网连接（也称为服务凭据），这是访问RocketMQ服务的用户名和密码。
在准备好了以上内容之后，我们就可以开始创建新的RocketMQ Topic了。
二、创建新的RocketMQ Topic
要创建新的RocketMQ Topic，我们需要使用RocketMQ提供的命令工具。
1. 首先打开命令行终端（Windows下为CMD，Linux下为Terminal）：
$ cd /usr/local/rocketmq/bin/ $ ./mqadmin updateTopic -n localhost:9876 -t new_topic -c DefaultCluster -r 1 -o true
2. 然后执行以下命令进行创建，其中-n参数表示RocketMQ服务的IP地址以及端口号，-t参数表示新Topic的名称，-c参数表示新Topic所属的Cluster名称，-r参数表示新Topic的初始队列数量，-o参数表示是否自动创建Broker的配置文件。
执行成功后，会返回类似下面这种格式的消息：
update topic success. -n localhost:9876 -c DefaultCluster
这就说明我们已经成功创建了新的RocketMQ Topic了。
三、查看RocketMQ Topic列表
如果我们想要查看已经存在的RocketMQ Topic列表，可以使用以下命令：
$ ./mqadmin topicList -n localhost:9876
执行成功后，会返回RocketMQ服务上已存在的Topic列表，例如：
new_topic test_topic test_topic2
四、修改RocketMQ Topic配置
如果我们需要修改已经存在的RocketMQ Topic的配置，可以使用以下命令：
$ ./mqadmin updateTopic -n localhost:9876 -t new_topic -o false
执行成功后，会返回类似下面这种格式的消息：
update topic success. -n localhost:9876
这里我们将new_topic的自动创建Broker配置改为了false。
五、删除RocketMQ Topic
如果我们需要删除一个RocketMQ Topic，可以使用以下命令进行删除：
$ ./mqadmin deleteTopic -n localhost:9876 -t new_topic
执行成功后，会返回类似下面这种格式的消息：
delete topic by name[new_topic] success.
这里我们成功删除了名为new_topic的RocketMQ Topic。
原创文章，作者：小蓝，如若转载，请注明出处：https://www.506064.com/n/201178.html
微信扫一扫 
支付宝扫一扫 