发送消息

发送消息是 RTM 的基本能力之一，本文主要介绍如何在不同类型的频道中发送消息。同时，你也可以查看实现收发消息快速构建一个示例程序并体验如何收发消息。

RTM 目前只支持字符串和二进制类型的消息数据格式。如果你的业务中使用了 JSON、Object 等其他数据类型，或者 protobuf 等第三方数据构建工具，那么你需要在发送消息之前对消息数据进行序列化。关于如何有效构建负载数据结构及推荐的序列化方式可以参考消息负载结构化。

Message Channel 中发送消息

在 Message Channel 中，你只需调用 publish 方法即可发送消息，无需提前订阅频道。该方法一次只能向一个频道发送消息，如需向多个频道发送消息，你需要多次调用该方法。RTM 并不限制你向多少个频道发送消息，也不限制有多少用户向一个频道发送消息，但是对你同时向一个频道发送消息的频率有一定的限制，详见 API 使用限制。

注意

publish 方法仅适用于 Message Channel，你无法使用该方法向 Stream Channel 发送消息。

发送字符串消息和二进制消息的示例代码如下：

JavaScript
// 发送字符串消息
const payload = "Hello Agora!";
const channelName = "chat_room";
const publishOptions = {
    customType: 'string',
};
try {
    const result = await rtm.publish(channelName, payload);
} catch (status) {
    const { operation, reason, errorCode } = status;
    console.log(`${operation} failed, the error code is ${errorCode}, because of: ${reason}.`);
}

JavaScript
// 发送二进制消息
const message = "Hello Agora!";
const payload = new TextEncode().encode(message);
const channelName = "chat_room";
try {
    const result = await rtm.publish(channelName, payload);
} catch (status) {
    const { operation, reason, errorCode } = status;
    console.log(`${operation} failed, the error code is ${errorCode}, because of: ${reason}.`);
}

方法调用成功后，RTM 会在 100 毫秒内将你的消息发送给订阅该频道的所有在线用户。同时，你会收到 PublishResponse 类型的返回值，虽然其中的内容是空的。

Stream Channel 中发送消息

与 Message Channel 不同，在 Stream Channel 中发送消息，你首先需要具备三个前提条件：

你需要创建一个 RTMStreamChannel 实例。
你需要调用 join 方法加入该频道。
你需要调用 joinTopic 方法注册成为指定 Topic 的消息发布者。

满足上述条件后，你就可以调用 publishTopicMessage 方法向指定的 Topic 发送消息了。该方法一次只能向一个 Topic 发送消息，如需向多个 Topic 发送消息，你可以多次调用该方法。

RTM 规定一个用户同时只能注册成为不超过 8 个 Topic 的消息发布者，即同时只能加入不超过 8 个 Topic ，但并不限制一个 Topic 可容纳的用户数量。你向一个 Topic 发送消息的频率可以达到 120 QPS，此特性在需要数据高频大并发的场景中十分有效，例如：元宇宙中的位置状态同步、协同办公中的画板应用、平行操控中的操作指令传输等。

发送字符串消息和二进制消息的示例代码如下：

JavaScript
// 发送字符串消息
const payload = "Hello Agora!";
const topicName = "chat_topic";
try {
    const result = await streamChannel.publishTopicMessage(topicName, payload);
} catch (status) {
    const { operation, reason, errorCode } = status;
    console.log(`${operation} failed, the error code is ${errorCode}, because of: ${reason}.`);
}

JavaScript
// 发送二进制消息
const message = "Hello Agora!";
const payload = new TextEncode().encode(message);
const topicName = "chat_topic";
try {
    const result = await streamChannel.publishTopicMessage(topicName, payload);
} catch (status) {
    const { operation, reason, errorCode } = status;
    console.log(`${operation} failed, the error code is ${errorCode}, because of: ${reason}.`);
}

成功向 Topic 发送消息后，RTM 会在 100 毫秒内将你的消息发送给订阅该 Topic 的所有在线用户。同时，你会收到 PublishTopicMessageResponse 类型的返回值，虽然当前其中的内容是空的。该消息和在 Message Channel 中发送的消息具备同样的延迟特性和 SLA 保障。

消息负载包体积限制

RTM 对每条消息负载包体积限制在 1 KB 以内（包括 1 KB），如果你需要更大的消息负载包体积，请联系声网 RTM 团队（rtm@agora.io）。

当你的消息负载包体积超过 1 KB 时，你会收到以下返回值：

RTM 对在 Message Channel 和 Stream Channel 中发送的消息负载包体积有限制，详见 API 使用限制。消息负载包体积包含消息负载自身加上 customType 字段大小。当消息负载包体积超出限制时，你会收到以下返回值：

JavaScript
// Status
{
    error = true;
    errorCode = -11010;
    Operation = "PublishTopicMessageOperation";   // Or "PublishOperation"
    Reason = "Publish too long message.";
}

为避免因为消息负载包体积超限而导致发送失败，你可以在消息发送之前对消息负载包体积进行检查。

Message Channel 中发送消息​

Stream Channel 中发送消息​

消息负载包体积限制​

Message Channel 中发送消息

Stream Channel 中发送消息

消息负载包体积限制