需要访问旧版文档站？前往旧版文档官网首页。 (在新标签页打开)
声网文档中心

使用 Topic

  • Android

更新时间不可用

了解如何在实时消息 RTM 中主题，包括适用场景、配置步骤、实现要点和注意事项。

Topic 的相关操作主要有加入、离开、订阅和取消订阅，可以归纳为以下两种行为：

  • 消息发布者行为：加入 Topic 的目的在于注册成为该 Topic 的消息发布者，从而让用户具备发送消息的能力。同理，离开 Topic 是为了取消对该 Topic 消息发布者的注册，从而让用户失去发送消息的能力。
  • 消息订阅者行为：订阅 Topic 的目的在于订阅 Topic 中的消息，从而让用户具备接收消息的能力。同理，取消订阅 Topic 是为了取消订阅 Topic 中的消息，从而让用户失去接收消息的能力。

上述两类行为之间相互独立，即你对某个 Topic 中消息发布者的行为并不会影响你对该 Topic 中消息订阅者的行为。

加入 Topic

在 Topic 中发送消息的前提条件是加入 Topic。当前 RTM 支持单个客户端在同一个频道内同时加入不超过 8 个 Topic。加入 Topic 时，你可以设置一些预定义的属性，这将影响到后续通过此 Topic 发送消息的行为，包括消息是否保序、消息优先级、是否与共频道传输的音视频数据保持同步传输等。详细设置可以参考 API 文档及发送消息。

成功加入频道后，SDK 会触发 REMOTE_JOIN 类型的 onTopicEvent 事件，频道中所有开启 Topic 事件监听的用户都会收到此事件通知。

示例代码如下：

Java
var options = new JoinTopicOptions();
options.messageQos = RtmMessageQos.ORDERED;
mStreamChannel.joinTopic("topic_name", options, new ResultCallback<Void>() {
    @Override
    public void onSuccess(Void responseInfo) {
        log(CALLBACK, "join topic success");
    }

    @Override
    public void onFailure(ErrorInfo errorInfo) {
        log(ERROR, errorInfo.toString());
    }
});

离开 Topic

当你不再需要向某个 Topic 发送消息，或者同时加入的 Topic 超出数量限制时，你可以离开某个 Topic 以释放资源。成功离开 Topic 后，SDK 会触发 REMOTE_LEAVE 类型的 onTopicEvent 事件，频道中所有开启 Topic 事件监听的用户都会收到此事件通知。

示例代码如下：

Java
mStreamChannel.leaveTopic("Motion", new ResultCallback<Void>() {
    @Override
    public void onSuccess(Void responseInfo) {
        log(CALLBACK, "leave topic success");
    }

    @Override
    public void onFailure(ErrorInfo errorInfo) {
        log(ERROR, errorInfo.toString());
    }
});

订阅 Topic

加入 Topic 并不代表你能接收到该 Topic 中传输的消息，你需要订阅此 Topic 并指定消息发布者才能实现消息的接收。在单个频道中，你可以同时订阅不超过 50 个 Topic，每个 Topic 中你可以同时订阅不超过 64 个消息发布者。该限制主要是为了平衡端侧带宽和性能。

订阅 Topic 中消息发布者需要填写消息发布者列表（users）参数。假设第一次订阅消息发布者列表为 [UserA,UserB]，第二次订阅消息发布者列表为 [UserB,UserC]，则最后成功订阅的结果是 [UserA,UserB,UserC]。

如果你在订阅 Topic 时，不填写消息发布者列表，则默认随机订阅不超过 64 个用户：

  • 如果 Topic 中的用户不超过 64 人则全部订阅。
  • 如果 Topic 中的用户超过 64 人则随机订阅 64 人。

示例代码如下：

Java
TopicOptions options = new TopicOptions();
options.users = new ArrayList<>(Arrays.asList("user_name"));

mStreamChannel.subscribeTopic("Motion", options, new ResultCallback<SubscribeTopicResult>() {
    @Override
    public void onSuccess(SubscribeTopicResult responseInfo) {
        log(CALLBACK, "subscribe topic success");
    }

    @Override
    public void onFailure(ErrorInfo errorInfo) {
        log(ERROR, errorInfo.toString());
    }
});

取消订阅

当你对 Topic 中某个消息发布者不再感兴趣，或者对整个 Topic 不再关注，你可以通过取消订阅停止接收相关消息。如果你在取消订阅 Topic 时不填写消息发布者列表，则默认取消对整个 Topic 的订阅。

示例代码如下：

Java
var topicName = "Motion";
var options = new TopicOptions();
options.users = new ArrayList<>(Arrays.asList("Tony"));

mStreamChannel.unsubscribeTopic(topicName.toString(), options, new ResultCallback<Void>() {
    @Override
    public void onSuccess(Void responseInfo) {
        log(CALLBACK, "unsubscribe topic success");
    }

    @Override
    public void onFailure(ErrorInfo errorInfo) {
        log(ERROR, errorInfo.toString());
    }
});

咨询电话

400 632 6626

上海声网科技有限公司

Copyright © 2026 声网保留所有权利