在线直播教育的场景通常会涉及多个直播间，且每个直播间中也会有多名成员。本文以单直播间、一名老师、两名学生的场景为例，说明如何使用微消息队列MQTT版实现直播互动消息、禁言、成员上下线通知以及系统消息通知，其中，老师和学生的客户端以HTML网页为例，后端应用以Java为例。
背景信息
使用微消息队列MQTT版需与后端存储队列绑定，目前仅支持消息队列RocketMQ版，详细信息，请参见MQTT与RocketMQ的消息结构映射。
使用微消息队列MQTT版的客户端收发消息时，服务端会根据MQTT客户端设置的Username和Password参数来进行鉴权。针对不同的权限验证场景，Username和Password参数具备不同的含义。在此场景下，Token鉴权模式更加适用。详细信息，请参见Token鉴权概述。
文中提及的名词概念，请参见下文中的名词解释。
场景详情
四个场景均以一名老师和两名学生的在线教育场景为例。老师和学生使用不同的MQTT客户端，通过不同的Group ID分组，不同的老师和学生通过Device ID区分。同一直播间的客户端发送和订阅消息的Topic需分开创建和使用，以免消息队列RocketMQ版形成消费死循环。具体示例如下。
例如，一个在线教育直播间中有三名成员，一名老师和两名学生。学生A在直播间发文字消息，直播间所有成员全部可见。您可以将一个直播间与一个MQTT的Topic对应，例如客户端发送消息使用的Topic为roomSend/message，订阅消息使用的Topic为room/message/123456，其中：
- roomSend为直播间所有客户端发送消息使用的父级Topic，需要在微消息队列MQTT版控制台创建。
- room为直播间所有客户端订阅的父级Topic，需要在微消息队列MQTT版控制台创建。
- /message为自定义的二级Topic，无需在微消息队列MQTT版控制台创建，本示例中其含义为文字消息。
- /123456为自定义的三级Topic，无需在微消息队列MQTT版控制台创建，本示例中其含义为直播间的ID。
同一个直播间的所有成员都订阅room/message/123456 Topic。具体消息流向如下图所示。
流程说明如下：
- 学生A通过客户端发送一条消息至微消息队列MQTT版。消息示例如下：
topic: "roomSend/message"，body: "{ 'peer': 'xxx', 'roomId': '123456', 'msg': 'xxx' }"
说明：HTML网页客户端发送的消息格式为JSON。
- 微消息队列MQTT版将消息转发至消息队列RocketMQ版。
- 订阅了消息队列RocketMQ版Topic的后端应用消费该消息以实现业务处理，例如内容审核。
- 后端应用将处理后的消息再次发送至消息队列RocketMQ版的Topic。
- 消息队列RocketMQ版将该消息转发至微消息队列MQTT版。
- 微消息队列MQTT版将该消息推送至所有网页客户端，涉及成员老师、学生A以及学生B。
此场景是使用微消息队列MQTT版P2P消息收发功能的典型场景，老师禁止某位同学在直播间发言的指令消息会被发送至需要禁言的学生客户端上实现禁言效果。同时，服务端也会添加禁言名单用于业务校验和消息过滤。老师的客户端需将消息发送至roomSend/command Topic，其中：
- roomSend为直播间所有客户端发送消息使用的父级Topic，需要在微消息队列MQTT版控制台创建。
- command为自定义二级Topic，无需在微消息队列MQTT版控制台创建，command与message二级Topic作区分，表示指令类的消息。
说明：P2P消息无需订阅，此场景下示例值为room/p2p/GID_student@@@002。
具体消息流向如下图所示。
流程说明如下：
- 老师通过客户端发送一条禁言指令消息至微消息队列MQTT版。
- 微消息队列MQTT版将消息转发至消息队列RocketMQ版。
- 订阅了消息队列RocketMQ版Topic的后端应用接收到该条指令消息后，进行必要检验处理并保存禁言名单用于后续过滤被禁言学生的消息。同时发送一条P2P消息（room/p2p/GID_student@@@002）给学生B的客户端，使学生B的客户端显示禁言效果。
通过微消息队列MQTT版的客户端状态异步通知功能，已在直播间的所有成员都可以收到其他成员上下线的通知消息。此场景下，所有的客户端都需订阅room/status Topic，其中：
- room为父级Topic，需要在微消息队列MQTT版控制台创建。
- status为自定义二级Topic，无需在微消息队列MQTT版控制台创建，本示例中表示与客户端状态相关的消息。
每个MQTT客户端都订阅该Topic后，当某个客户端上下线时，MQTT服务都会触发一条事件消息到消息队列RocketMQ版。具体消息流向如下图所示。
流程说明如下：
- 微消息队列MQTT版将学生A进入直播间的上线事件消息发送至消息队列RocketMQ版。
- 订阅了消息队列RocketMQ版Topic的后端应用消费该消息以实现业务处理，例如考勤记录。
- 后端应用将处理后的消息再次发送至消息队列RocketMQ版的Topic。
- 消息队列RocketMQ版将该消息转发至微消息队列MQTT版。
- 微消息队列MQTT版将该消息广播至所有客户端，涉及成员老师、学生A以及学生B。
此场景使用微消息队列MQTT版的消息收发功能，系统的更新通知都会发送到直播间的所有成员。此场景下，所有的客户端都需订阅room/system Topic，其中：
- room为父级Topic，需要在微消息队列MQTT版控制台创建。
- system为自定义二级Topic，无需在微消息队列MQTT版控制台创建，本示例中表示系统发送的消息。
具体消息流向如下图所示。
流程说明如下：
- 后端应用更新消息发送至消息队列RocketMQ版的Topic。
- 消息队列RocketMQ版将该消息转发至微消息队列MQTT版。
- 微消息队列MQTT版将该消息推送至所有客户端，涉及成员老师、学生A和学生B。
操作流程
在线直播教育所涉及的四个场景的流程如下所示，各个场景所使用的微消息队列MQTT版功能各不相同，因此使用的SDK客户端代码有所差异，请以每个场景的具体描述为准。
操作步骤
名词解释
MQTT
一个基于订阅/发布的长连接双向通信模型，订阅方便灵活，非常适合直播消息互动场景。微消息队列MQTT版基于标准的MQTT协议，广泛服务于终端应用场景。
MQTT服务器
微消息队列MQTT版提供的MQTT协议交互的服务端节点，用于完成与MQTT客户端和消息队列RocketMQ版各自的消息收发。
MQTT客户端
用于和MQTT服务器交互的移动端节点，本文直播互动场景主要是手机或PC电脑。
父级Topic（Parent Topic）
MQTT协议基于Pub/Sub模型，因此任何消息都属于一个Topic。根据MQTT协议，Topic存在多级，定义第一级Topic为父级Topic，使用微消息队列MQTT版前，需先在控制台创建该父级Topic，可以在微消息队列MQTT版控制台创建，或者直接在消息队列RocketMQ版的控制台创建。
子级Topic（Subtopic）
MQTT的二级Topic，甚至三级Topic都是父级Topic下的子类。使用时，直接在代码里设置，无需创建。需要注意的是微消息队列MQTT版限制父级Topic和子级Topic的总长度为64个字符，如果超出长度限制将会导致客户端异常。
Client ID
微消息队列MQTT版的Client ID是每个客户端的唯一标识，要求全局唯一，使用相同的Client ID连接微消息队列MQTT版服务会被拒绝。
Client ID由两部分组成，组织形式为 <GroupID>@@@<DeviceID>。Client ID的长度限制为64个字符，不允许使用不可见字符。详细信息，请参见使用限制。
Group ID
用于指定一组逻辑功能完全一致的节点共用的组名，代表一类相同功能的设备。Group ID需要在微消息队列MQTT版的控制台创建，创建后方可使用。
Device ID
每个设备独一无二的标识，由业务方自己指定。需要保证全局唯一，例如每个传感器设备的序列号。
P2P消息
微消息队列MQTT版在标准的MQTT协议基础上提供的一种特殊消息，该类型消息无需普通的订阅关系匹配，便可直接发送给指定的单个目标MQTT客户端。详细信息，请参见P2P消息收发模式（MQTT）。
音视频通信RTC
阿里云覆盖全球的实时音视频开发平台，依托核心音视频编解码、信道传输、网络调度技术，提供高可用、高品质、超低延时的音视频通信服务，让用户快速搭建多端实时应用，适用于在线教育、视频会议、互动娱乐、音视频社交等场景。
直播场景需要传输流媒体服务，详细信息，请参见音视频通信RTC。本文只涉及MQTT互动消息收发内容。