频道

  • Flutter

更新时间不可用

频道是 RTM 实时网络中一种数据传输的管理机制,任何订阅或加入频道的用户都可以在 100 毫秒内接收到频道中传输的消息和事件,RTM 允许客户端订阅数百甚至数千个频道。大多数 RTM API 都将以频道为基础进行发送、接收、加密等行为。

基于声网的能力,RTM 的频道分成三种类型以匹配不同的应用场景:

  • Message Channel:遵循行业标准的 Pub/Sub (发布/订阅)模式,频道无需提前创建,订阅频道即可在频道内收发消息。频道内的发布者和订阅者数量没有上限。
  • User Channel:基于 Pub/Sub (发布/订阅)模式的点对点消息收发。用户无需订阅频道操作,可以直接指定用户 ID 发送消息,接收消息也只需监听 message 事件。
  • Stream Channel:遵循行业类似观察者模式的 Room (房间)概念,用户需要创建并加入频道才能在频道内收发消息。频道中允许创建不同的 Topic,消息通过 Topic 进行组织和管理。

想要了解 Message Channel 和 Stream Channel 的更多用法及适用场景,可以查看:

subscribe

接口描述

RTM 提供消息、状态等事件通知能力。通过设置事件监听,你可以接收已订阅频道中的消息和事件。关于如何添加和设置事件监听,详见事件监听章节。

通过调用 subscribe 方法,客户端可以订阅 Message Channel 并开始接收频道中的消息和事件通知。成功调用该方法后,订阅该频道且开启 Presence 事件监听的用户会收到 remoteJoinChannel 类型的 presence 事件,详见事件监听。

信息

该方法仅适用于 Message Channel。

接口方法

你可以通过以下方式调用 subscribe 方法:

Dart
Future<(RtmStatus, SubscribeResult?)> subscribe(
    String channelName,
    {
        bool withMessage = true,
        bool withMetadata = false,
        bool withPresence = true,
        bool withLock = false,
        bool beQuiet = false
    }
);
参数类型必填默认值描述
channelNameString必填-频道名称。
withMessagebool选填true是否订阅此频道中的消息事件通知。
withMetadatabool选填false是否订阅此频道中的 Storage 事件通知。
withPresencebool选填true是否订阅此频道中的 Presence 事件通知。
withLockbool选填false是否订阅此频道中的 Lock 事件通知。
beQuietbool选填false

是否静默订阅频道。该参数设置为 true 时表示静默订阅频道,表现如下:

  • 不影响你接收频道内其他用户的事件通知。
  • 频道内其他用户不会收到你订阅/取消订阅频道、设置/获取/删除临时状态的事件通知。
  • 调用 whoNow 方法查询不到自己。
  • 调用 whereNow 方法查询不到自己静默订阅的频道。
表格内容超出当前宽度,可横向滚动查看更多列。

基本用法

Dart
var (status,response) = rtmClient.subscribe("myChannel", withPresence:true, beQuiet:true);
if (status.error == true) {
    print(status);
} else {
    print(response);
}

返回值

调用此方法,会返回 Future<(RtmStatus, SubscribeResult?)> 类型的元组数据。

  • 无论该方法是否调用成功,元组的第一项都会返回一个 RtmStatus 类型的数据,其中字段定义如下:
Dart
class RtmStatus {
    bool error;                   // 本次操作是否出错。
    String errorCode;             // 本次操作错误码。
    String operation;             // 本次操作的 API。
    String reason;                // 本次操作错误原因简述。
}

你可以通过检索 errorCode 字段的错误码了解错误原因,并找到对应的解决方法。

  • 如果该方法调用成功,元组的第二项将返回一个 SubscribeResult 类型的数据,定义如下:

    Dart
    class SubscribeResult {
        final String channelName;       // 当前操作的频道
    }

unsubscribe

接口描述

如果你不再需要关注某个频道,可调用 unsubscribe 方法取消订阅该频道。成功取消订阅该频道后,其他订阅该频道并开启事件监听的用户会收到 remoteLeaveChannel 类型的 presence 事件通知,详见事件监听。

信息

该方法仅适用于 Message Channel。

接口方法

你可以通过以下方式调用 unsubscribe 方法:

Dart
Future<(RtmStatus, UnsubscribeResult?)> unsubscribe(String channelName);
参数类型必填默认值描述
channelNameString必填-频道名称。
表格内容超出当前宽度,可横向滚动查看更多列。

基本用法

Dart
var (status,response) = rtmClient.unsubscribe("myChannel");
if (status.error == true) {
    print(status);
} else {
    print(response);
}

返回值

调用此方法,会返回 Future<(RtmStatus, UnsubscribeResult?)> 类型的元组数据。

  • 无论该方法是否调用成功,元组的第一项都会返回一个 RtmStatus 类型的数据,其中字段定义如下:
Dart
class RtmStatus {
    bool error;                   // 本次操作是否出错。
    String errorCode;             // 本次操作错误码。
    String operation;             // 本次操作的 API。
    String reason;                // 本次操作错误原因简述。
}

你可以通过检索 errorCode 字段的错误码了解错误原因,并找到对应的解决方法。

  • 如果该方法调用成功,元组的第二项将返回一个 UnsubscribeResult 类型的数据,定义如下:

    Dart
    class UnsubscribeResult {
        final String channelName;           // 当前操作的频道
    }

createStreamChannel

接口描述

在使用 Stream Channel 之前,你需要先调用 createStreamChannel 方法创建 StreamChannel 实例。成功创建实例后,你可以调用其相关方法,例如:加入频道、离开频道、发送 Topic 消息、订阅 Topic 消息等。

信息

该方法仅适用于 Stream Channel。

接口方法

你可以通过以下方式调用 createStreamChannel 方法:

Dart
Future<(RtmStatus, StreamChannel?)> createStreamChannel(String channelName);
参数类型是否必填默认值描述
channelNameString必填-频道名称。
表格内容超出当前宽度,可横向滚动查看更多列。

基本用法

Dart
var (status, stChannel) = await rtmClient.createStreamChannel("myStChannel");
if (status.error == true) {
    print(status);
} else {
    print("create Stream Channel Success!");
}

返回值

调用此方法,会返回 Future<(RtmStatus, StreamChannel?)> 类型的元组数据。

  • 无论该方法是否调用成功,元组的第一项都会返回一个 RtmStatus 类型的数据,其中字段定义如下:
Dart
class RtmStatus {
    bool error;                   // 本次操作是否出错。
    String errorCode;             // 本次操作错误码。
    String operation;             // 本次操作的 API。
    String reason;                // 本次操作错误原因简述。
}

你可以通过检索 errorCode 字段的错误码了解错误原因,并找到对应的解决方法。

  • 如果该方法调用成功,元组的第二项将返回一个 StreamChannel 实例对象,用户后续调用 StreamChannel 的相关接口 API。

join

接口描述

成功创建 Stream Channel 后,你可以调用 join 方法加入 Stream Channel。

加入频道后,你才能进行频道相关操作。此时,订阅该频道并添加事件监听的用户会收到如下事件通知:

  • 本地用户:
    • snapshot 类型的 presence 事件通知。
    • snapshot 类型的 topic 事件通知。
  • 远端用户:remoteJoinChannel 类型的 presence 事件通知。

信息

该方法仅适用于 Stream Channel。

接口方法

你可以通过以下方式调用 join 方法:

Dart
Future<(RtmStatus, JoinResult?)> join({
    String? token,
    bool withMetadata = false,
    bool withPresence = true,
    bool withLock = false,
    bool beQuiet = false
    }
);
参数类型必填默认值描述
tokenString选填-

加入 Stream Channel 的 Token。

  • 如果你的项目开启了 Token 鉴权,你可以填入 RTC 临时 Token 或 Token 服务器生成的 RTC 正式 Token。
  • 如果你的项目未开启 Token 鉴权,你可以填入空字符串或开通了 RTC 和 RTM 服务的项目 App ID。
withMetadatabool选填false是否订阅此频道中的 Storage 事件通知。
withPresencebool选填true是否订阅此频道中的 Presence 事件通知。
withLockbool选填false是否订阅此频道中的 Lock 事件通知。
beQuietbool选填false

是否静默加入频道。该参数设置为 true 时表示静默加入频道,表现如下:

  • 不影响你接收频道内其他用户的事件通知。
  • 频道内其他用户不会收到你加入/离开频道、设置/获取/删除临时状态的事件通知。
  • 调用 whoNow 方法查询不到自己。
  • 调用 whereNow 方法查询不到自己静默加入的频道。
表格内容超出当前宽度,可横向滚动查看更多列。

基本用法

Dart
var (status,response) = await stChannel.join(token:"myToken", withPresence:true);
if (status.error == true) {
    print(status);
} else {
    print(response);
}

返回值

调用此方法,会返回 Future<(RtmStatus, JoinResult?)> 类型的元组数据。

  • 无论该方法是否调用成功,元组的第一项都会返回一个 RtmStatus 类型的数据,其中字段定义如下:
Dart
class RtmStatus {
    bool error;                   // 本次操作是否出错。
    String errorCode;             // 本次操作错误码。
    String operation;             // 本次操作的 API。
    String reason;                // 本次操作错误原因简述。
}

你可以通过检索 errorCode 字段的错误码了解错误原因,并找到对应的解决方法。

  • 如果该方法调用成功,元组的第二项将返回一个 JoinResult 类型的数据,定义如下:

    Dart
    class JoinResult {
        final String channelName;           // 当前操作的频道
        final String userId;                // 当前操作用户 User ID
    }

leave

接口描述

如果你不再需要待在某个频道中,你可以调用 leave 方法离开该频道。离开后你将不再会接收到此频道中的任何消息、状态及事件通知,你在该频道中创建的 Topic 发布者的角色及你与所有 Topic 的订阅关系都将自动解除。如果想再次恢复之前的发布者角色和订阅关系,你需要调用 join 方法再次进入该频道并自行调用 joinTopic 和 subscribeTopic 方法进行设置。

成功离开频道后,频道中的远端用户会收到 remoteLeaveChannel 类型的 presence 事件通知,详见事件监听。

信息

该方法仅适用于 Stream Channel。

接口方法

你可以通过以下方式调用 leave 方法:

Dart
Future<(RtmStatus, LeaveResult?)> leave();

基本用法

Dart
var (status,response) = await stChannel.leave();
if (status.error == true) {
    print(status);
} else {
    print(response);
}

返回值

调用此方法,会返回 Future<(RtmStatus, LeaveResult?)> 类型的元组数据。

  • 无论该方法是否调用成功,元组的第一项都会返回一个 RtmStatus 类型的数据,其中字段定义如下:
Dart
class RtmStatus {
    bool error;                   // 本次操作是否出错。
    String errorCode;             // 本次操作错误码。
    String operation;             // 本次操作的 API。
    String reason;                // 本次操作错误原因简述。
}

你可以通过检索 errorCode 字段的错误码了解错误原因,并找到对应的解决方法。

  • 如果该方法调用成功,元组的第二项将返回一个 LeaveResult 类型的数据,定义如下:

    Dart
    class LeaveResult {
        final String channelName;           // 当前操作的频道
        final String userId;                // 当前操作用户 User ID
    }

release

接口描述

如果你不再需要某个频道,你可以调用 release 方法销毁对应的 Stream Channel 实例以释放资源。调用 release 方法销毁 Stream Channel 实例不会销毁该频道,后续可通过再次调用 createStreamChannel 和 join 重新加入该频道。

信息

  • 该方法仅适用于 Stream Channel。如果不先调用 leave 离开频道而直接调用 release 销毁频道实例,SDK 会自动调用 leave 并触发对应的事件。
  • release 需要在非回调内的子线程调用,避免在回调中执行。

接口方法

你可以通过以下方式调用 release 方法:

Dart
Future<RtmStatus> release();

基本用法

Dart
var status = await stChannel.release();
if (status.error == true) {
    print(status);
} else {
    print(response);
}

返回值

无论该方法是否调用成功,都会返回一个 RtmStatus 类型的数据,其中字段定义如下:

无论该方法是否调用成功,元组的第一项都会返回一个 RtmStatus 类型的数据,其中字段定义如下:

Dart
class RtmStatus {
    bool error;                   // 本次操作是否出错。
    String errorCode;             // 本次操作错误码。
    String operation;             // 本次操作的 API。
    String reason;                // 本次操作错误原因简述。
}

你可以通过检索 errorCode 字段的错误码了解错误原因,并找到对应的解决方法。