操作场景
在使用 TCP 协议的 SDK 收发消息前,您需要在消息队列 RocketMQ 控制台中创建集群、Topic 等资源,运行客户端时需要配置相关的资源信息。
前提条件
操作步骤
步骤1:新建集群
2. 单击新建集群,集群类型可以选择虚拟集群,填写好集群名称和说明,单击确定,创建一个集群。
3. 在集群列表页面,单击创建好的集群ID,在集群基本信息页面的网络模块,可以查看到集群的接入点信息。
步骤2:创建命名空间
1. 在集群列表页面,单击步骤1创建好的集群的“ID”,进入集群基本信息页。
2. 选择顶部的命名空间页签,单击新建,设置好命名空间名称和描述信息,创建一个命名空间。
步骤3:创建角色并授权
1. 在左侧导航栏选择角色管理,单击新建,创建一个角色。
2. 在集群管理页面,单击步骤1创建好的集群的“ID”,进入集群详情页面。
3. 在页面上方选择命名空间页签,找到刚刚创建的命名空间,单击操作栏的配置权限。
4. 在配置权限页面,单击添加角色,为刚刚创建的角色添加生产消费权限。
步骤4:创建 Topic
1. 在命名空间列表页,选择顶部的 Topic 页签,进入 Topic 列表页。
2. 选择 步骤3 创建好的命名空间,单击新建,填写好 Topic 名称,消息类型选择普通消息,单击确定,创建一个 Topic。 说明:
本文以收发普通消息为例进行说明,因此,您参考上述步骤创建的普通消息的Topic,不能用于收发其他类型的消息。
步骤5:创建 Group
1. 在 Topic 列表页,选择顶部的 Group 页签,进入 Group 列表页。
2. 选择刚刚创建好的命名空间,单击新建,填写好 Group 名称,协议类型选择 TCP,单击确定,创建一个 Group。
说明:
消息队列 RocketMQ 版支持 HTTP 协议和 TCP 协议,因此,建议您分别为两种协议创建对应类型的 Group,若多个消费者使用同一个 Group 消费消息,其中部分消费者使用 TCP 协议,部分消费者使用 HTTP 协议,可能会导致消费失败、部分消息重复或丢失。
本页内容是否解决了您的问题?