2024/12/05 18:34:58
消息负载结构化
消息负载的结构应该具备易读性和可扩展性,以减少程序的构建和维护成本,以及在未来版本升级时新老版本可以更容易地兼容。由于通过 RTM 发送的消息只能为字符串(String)或二进制(Binary)类型,RTM 无法直接提供可解析、可扩展的消息数据结构。但你可以根据业务需求自行构建结构化消息负载,并使用 customType
参数来标识和解析它。
你在业务流程中可能会涉及到以下类型的消息:
- 纯文本消息
- 文本消息:包含有图片、文件等附件的 URL。
- 视频文件消息:包含文本说明、视频地址和缩略图地址等。
- 问卷调查、答题消息:可能包含预先设置的答案选项。
- 邀请消息:例如邀请其他用户参加私聊或者群聊。
- 信令消息:例如发起视频或音频聊天的邀请指令。
- 指令消息:例如平行驾驶或者 IoT 应用中向设备下发控制指令消息或传感器上传的设备状态消息。
- 状态同步消息:例如元宇宙或游戏中玩家的位置、视角或当前状态消息。
假设你收到以下三条消息负载:
"This is a Message!"
{ message: "https://cdn.agora.io/assets/avatar.png"}
{ message: { x =1 0, y = 100, z = 55 } }
当你收到这些消息负载时,你很难快速判断这是一条带有图片地址的消息或是一条包含位置信息的消息。即便可以扫描所有消息,检查文本中是否包含 jpg
字符串或含有 x,y,z
字符,这个方法也会随着 App 用户和消息类型的增加而变得困难。
为了解决这类问题,你可以在消息负载结构中引入预定义的字段,通过结构化消息负载增加可解析性和扩展性。例如,在上面的例子中,我们在消息结构中引入 type
字段,改动如下:
原消息结构 | 结构化消息结构 |
---|---|
"Hello, This is a Message!" | {type: "text", message: "Hello, This is a Message!"} |
{message: "https://cdn.agora.io/assets/avatar.png"} | {type: "image", url: "https://cdn.agora.io/assets/avatar.png"} |
{message: { x =1 0, y = 100, z = 55 }} | {type: "position", coordinate: { x: 10, y: 100, z: 55 }} |
现在你可以根据接收到消息负载中的 type
字段来解析消息格式和数据,并对不同消息类型进行不同的处理。你也可以充分利用 publish
方法中的 customType
字段将你自定义的附加信息随着消息一起发送给接收端。用户接收到 Message Event 后可以通过 customType
字段来解析出数据。详见:消息负载序列化。
Dart
import 'dart:convert';
final channelName = 'chat_room';
var message = {
type: 'image',
asset_url: 'https://my.app/image.png',
thumb_url: 'https://my.app/thumbnail/image.png',
mentionedUsers: ['Tony','Lily'],
sender: 'Max'
}
// Message string serialization
var payload = jsonEncode(message);
// Send message with customType set
try {
var (status, response) = await rtmClient.publish(
channelName,
payload,
customType: 'image');
if (status.error == true ){
print('${status.operation} failed, errorCode: ${status.errorCode}, due to ${status.reason}');
} else {
print('${status.operation} success!');
}
} catch (e) {
print('something went wrong: $e');
}
// When receiving a message, use the custom Type field to parse the message type。
// Handle message event
rtm.addListener( message: (MessageEvent event) {
if (event.customType == "image" ) {
print("It is a image message!");
Map<String, dynamic> data = jsonDecode(utf8.decode(event.message!));
}
});
推荐消息负载结构
本节列举了一些应用场景中经常用到的可解析、可扩展的消息结构示例,你可以根据自己的实际业务场景进行修改。
文本消息
JSON
{
type: "text",
message: "This is a message",
mentionedUsers: ["Tony","Lily"],
sender: "Max"
}
多语言消息
JSON
{
type: "translation",
message: {
"zh": "你好",
"en": "Hello",
"jp": "こんにちは"
},
mentionedUsers: ["Tony","Lily"],
sender: "Max"
}
图片附件消息
JSON
{
type: "attachment",
text: "Here is a image below!"
attachments: [
{
type: "image",
asset_url: "https://bit.ly/2K74TaG",
thumb_url: "https://bit.ly/2Uumxti",
myCustomField: 123
}
],
mentionedUsers: ["Tony","Lily"],
sender: "Max"
}
图片消息
JSON
{
type: "image",
asset_url: "https://my.app/image.png",
thumb_url: "https://my.app/thumbnail/image.png",
mentionedUsers: ["Tony","Lily"],
sender: "Max"
}
视频消息
JSON
{
type: "video",
asset_url: "https://my.app/video.mp4",
thumb_url: "https://my.app/thumbnail/video.png"
mentionedUsers: ["Tony","Lily"],
sender: "Max"
}
动作提示消息
JSON
{
type: "action",
event: "正在输入",
sender: "Max"
}
聊天邀请消息
JSON
{
type: "chatInvite",
channel: "this is the channel you are being invited too",
message: "Hi Tony, welcome to the team!"
}
视频呼叫消息
JSON
{
type: "chatInvite",
session: "your_video_session",
message:"Hi Tony, welcome to the video chat!",
sender: "Max"
}
问卷消息
JSON
{
type: "poll",
question: "Which option is right?",
answers: {
A: "Apple",
B: "Banana",
C: "Blackberry"
},
sender: "Max"
}
状态同步消息
JSON
{
type: "position",
data: {
coordinate: { x: 10, y: 100, z: 55 },
direction: {pitch: 30, roll : 90, yaw: 80}
}
mentionedUsers: ["Tony","Lily"],
sender: "Max"
}