创建RocketMQ Topic
Topic,即消息主题,消息发送与接收的基本单元。购买RocketMQ实例成功后,需要手动创建Topic,然后才能进行生产消息和消费消息。
前提条件
已购买RocketMQ实例。
创建Topic
- 登录管理控制台。
- 在管理控制台左上角单击,选择区域。
请选择RocketMQ实例所在的区域。
- 在管理控制台左上角单击,选择“应用中间件 > 分布式消息服务RocketMQ版”,进入分布式消息服务RocketMQ专享版页面。
- 单击RocketMQ实例的名称,进入实例详情页面。
- 在左侧导航栏,单击“Topic管理”,进入“Topic管理”页面。
- 单击“创建Topic”,弹出“创建Topic”页面。
- 参考表1或表2,填写Topic名称和配置信息。
图1 创建Topic(RocketMQ实例4.8.0版本)
图2 创建Topic(RocketMQ实例5.x版本)
表1 Topic参数说明(RocketMQ实例4.8.0版本) 参数
说明
Topic名称
您可以自定义Topic名称,用于区分不同的Topic。
Topic名称命名规则如下:- 长度为3~64个字符。
- 只能由英文字母、数字、百分号、竖线、中划线、下划线组成。
- 不能以“rmq_sys_”开头。
- 不能和以下字符串相同:
- TBW102
- SCHEDULE_TOPIC_XXXX
- BenchmarkTest
- RMQ_SYS_TRANS_HALF_TOPIC
- RMQ_SYS_TRACE_TOPIC
- RMQ_SYS_TRANS_OP_HALF_TOPIC
- TRANS_CHECK_MAX_TIME_TOPIC
- SELF_TEST_TOPIC
- OFFSET_MOVED_EVENT
Topic名称不能设置为相同,否则会创建失败。
创建Topic后不能修改名称。
说明:如果Topic名称中包含“%”或“|”,在云监控中会将“%”或“|”转换为“_”显示,例如Topic名称为“test%01”,在云监控中Topic名称显示为“test_01”。
权限
Topic的权限,包括发布+订阅、发布和订阅。
关联代理
选择在某个代理上创建Topic,并设置Topic的队列个数。
如果实例部署在多个代理上,单击“添加关联代理”,可以在其他代理上创建Topic,并设置Topic的队列个数。
如果需要新增关联代理,则需要先扩容代理个数,具体操作请参见变更RocketMQ实例规格。扩容代理个数后,用户可以创建的最大Topic数也会增加。例如扩容前实例的代理数为1,每个代理的最大Topic数为4000;扩容后实例的代理数为2,则2个代理的最大Topic数为8000。
描述
Topic的描述信息。
取值长度为0~200个字符。
表2 Topic参数说明(RocketMQ实例5.x版本) 参数
说明
Topic名称
您可以自定义Topic名称,用于区分不同的Topic。
Topic名称命名规则如下:- 长度为3~64个字符。
- 只能由英文字母、数字、百分号、竖线、中划线、下划线组成。
- 不能以“rmq_sys_”开头。
- 不能和以下字符串相同:
- TBW102
- SCHEDULE_TOPIC_XXXX
- BenchmarkTest
- RMQ_SYS_TRANS_HALF_TOPIC
- RMQ_SYS_TRACE_TOPIC
- RMQ_SYS_TRANS_OP_HALF_TOPIC
- TRANS_CHECK_MAX_TIME_TOPIC
- SELF_TEST_TOPIC
- OFFSET_MOVED_EVENT
Topic名称不能设置为相同,否则会创建失败。
创建Topic后不能修改名称。
说明:如果Topic名称中包含“%”或“|”,在云监控中会将“%”或“|”转换为“_”显示,例如Topic名称为“test%01”,在云监控中Topic名称显示为“test_01”。
消息类型
选择消息的类型,支持的消息类型:普通、顺序、定时和事务。
- 普通消息:没有特殊功能的消息,区别于定时消息、顺序消息和事务消息。
- 定时消息:生产者生产消息到分布式消息服务RocketMQ版后,消息不会立即被消费,而是延迟到特定时间后才会发送给消费者进行消费。
- 顺序消息:消费者按照消息发送的顺序来消费消息。
- 事务消息:提供类似X/Open XA的分布事务功能,通过事务消息能达到分布式事务的最终一致。
描述
Topic的描述信息。
取值长度为0~200个字符。
- 配置完成后,单击“确定”,完成Topic的创建。