一、准备工作
在创建新的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。