StreamChannel 类
该类为 Stream Channel 频道相关接口，使用户在频道内进行创建频道，加入频道，离开频道，销毁频道，发送消息，订阅消息等操作。频道类型，频道限制等更多频道相关信息详见 Channels。
方法
join
接口描述
public abstract int join(JoinChannelOptions options);加入频道。
调用该方法会触发 onJoinResult 事件回调。成功加入频道后，SDK 会触发 onPresenceEvent 事件回调：
- 加入频道的用户本人会收到
RTM_PRESENCE_TYPE_SELF_JOIN_CHANNEL事件。 - 频道中的其他用户会收到
RTM_PRESENCE_TYPE_REMOTE_JOIN_CHANNEL事件。
注意：
- 单次调用该方法只能加入一个频道，如需加入多个频道，你需要多次调用该方法。单个客户端可以同时加入最多 100 个频道。
- 用户需要收到成功加入频道的
onJoinResult回调才能继续进行频道相关的操作。
| 参数 | 描述 |
|---|---|
options |
（选填）加入频道时的配置选项，详见 JoinChannelOptions。 |
基本用法
加入频道
待补充
返回值
0：调用成功。- <
0：调用失败。
getChannelName
接口描述
public abstract String getChannelName();获取当前频道名称。
返回值
频道名称。
leave
接口描述
public abstract int leave();离开频道。
调用该方法会触发 onLeaveResult 事件回调。成功离开频道后，频道中的其他用户会收到 onPresenceEvent 中的 RTM_PRESENCE_TYPE_REMOTE_LEAVE_CHANNEL 事件。
基本用法
离开频道
待补充
返回值
0：调用成功。- <
0：调用失败。
release
接口描述
public abstract int release();销毁一个 StreamChannel 类型实例。
如果你不再需要某个频道，可以调用该方法销毁对应的 StreamChannel 实例以释放资源。调用该方法销毁 StreamChannel 实例不会销毁此频道，后续可通过再次调用 createStreamChannel 和 join 重新加入该频道。
注意：如果不先调用
leave离开频道而直接调用release销毁频道实例，SDK 会自动调用leave并触发对应的事件回调。
基本用法
离开频道
待补充
返回值
0：调用成功。- <
0：调用失败。
joinTopic
接口描述
public abstract int joinTopic(String topicName, JoinTopicOptions options);加入一个 Topic。
只有加入 Topic 才能执行发送 Topic 消息的操作。
调用该方法会触发 onJoinTopicResult 事件回调。成功加入 Topic 后频道中的其他用户会收到 onPresenceEvent 中的 RTM_PRESENCE_TYPE_REMOTE_JOIN_TOPIC 事件通知。
注意：
- 请在加入频道后调用该方法。
- 同一个客户端最多只能同时加入 8 个 Topic，超出数量会报错。
| 参数 | 描述 |
|---|---|
topicName |
Topic 名称，同一个频道内相同的 Topic 名称属于同一个 Topic。Topic 名称可设为 16 字节以内的字符串，单个频道下 Topic 名唯一，即你可以在一个频道中使用另一个频道已经存在的 Topic 名称。 |
options |
（选填）加入 Topic 时的配置选项，详见 JoinTopicOptions |
基本用法
待补充
返回值
0：调用成功。- <
0：调用失败。
leaveTopic
接口描述
public abstract int leaveTopic(String topicName);离开一个 Topic。
当客户端加入的 Topic 达到上限时，需要调用 leaveTopic 离开某些不再需要的 Topic 以释放资源。
调用该方法会触发 onLeaveTopicResult 事件回调。成功离开 Topic 后频道中的其他用户会收到 onPresenceEvent 中的 RTM_PRESENCE_TYPE_REMOTE_LEAVE_TOPIC 事件通知。
| 参数 | 描述 |
|---|---|
topicName |
Topic 名称，同一个频道内相同的 Topic 名称属于同一个 Topic。Topic 名称可设为 16 字节以内的字符串，单个频道下 Topic 名唯一，即你可以在一个频道中使用另一个频道已经存在的 Topic 名称。 |
基本用法
待补充
返回值
0：调用成功。- <
0：调用失败。
publishTopicMessage
接口描述
public abstract int publishTopicMessage(String topicName, byte[] message);在指定 Topic 中发送文本消息。消息在传输的过程中默认已经被 SSL/TLS 加密，以保证数据链路层安全。
成功调用该方法后，频道中订阅该 Topic 且订阅该消息发布者的用户会收到 onMessageEvent 事件回调。
注意：
- 调用该方法前需先调用
joinTopic加入 Topic。- 不支持同时向多个 Topic 发送同一条消息。
- 以下做法可有效提升消息收发的可靠性：
- 在调用
joinTopic时可将qos字段配置为RTM_MESSAGE_QOS_ORDERED以开启该 Topic 的消息保序能力。- 以串行的方式发送消息。
- 消息负载不要超过 1 KB，否则发送会失败。
- 单个客户端在单个 Topic 中发送消息的速率上限为 60 QPS，如果发送速率超限，将会有部分消息被丢弃。在满足要求的情况下，速率越低越好。
| 参数 | 描述 |
|---|---|
topicName |
Topic 名称，同一个频道内相同的 Topic 名称属于同一个 Topic。Topic 名称可设为 16 字节以内的字符串，单个频道下 Topic 名唯一，即你可以在一个频道中使用另一个频道已经存在的 Topic 名称。 |
message |
消息负载，长度在 1024 字节以内。 |
基本用法
向 Topic 中发送消息
待补充
返回值
0：调用成功。- <
0：调用失败。
subscribeTopic
接口描述
public abstract int subscribeTopic(String topicName, TopicOptions options);订阅 Topic 及 Topic 中的消息发布者。
subscribeTopic 为增量方法。例如，第一次调用该方法时，订阅消息发布者列表为 [UserA,UserB], 第二次调用该方法时，订阅消息发布者列表为 [UserB,UserC]，则最后成功订阅的结果是 [UserA，UserB,UserC]。你可以通过 getSubscribedUserList 查询当前已经订阅的消息发布者名单列表。
频道中单个 Topic 的消息发布者的数量没有上限，但对于 Topic 订阅者，目前最多只能同时订阅 50 个 Topic，每个 Topic 中最多只能订阅 64 个消息发布者。
如果用户网络连接出现问题，RTM 2 将自动尝试重新连接，但在断连期间的消息会丢失。
调用该方法会触发 onTopicSubscribed 回调。
| 参数 | 描述 |
|---|---|
topicName |
Topic 名称，同一个频道内相同的 Topic 名称属于同一个 Topic。Topic 名称可设为 16 字节以内的字符串，单个频道下 Topic 名唯一，即你可以在一个频道中使用另一个频道已经存在的 Topic 名称。 |
options |
（选填）订阅 Topic 时的配置选项，详见 TopicOptions。如果不填写该字段，SDK 将随机订阅该 Topic 中 64 个消息发布者。 |
基本用法
订阅指定用户
待补充
返回值
0：调用成功。- <
0：调用失败。
unsubscribeTopic
接口描述
public abstract int unsubscribeTopic(String topicName, TopicOptions options);取消订阅某 Topic 或取消对该 Topic 中指定的消息发布者的订阅。
调用该方法会触发 onTopicUnsubscribed 回调。
| 参数 | 描述 |
|---|---|
topic |
Topic 名称，同一个频道内相同的 Topic 名称属于同一个 Topic。Topic 名称可设为 16 字节以内的字符串，单个频道下 Topic 名唯一，即你可以在一个频道中使用另一个频道已经存在的 Topic 名称。 |
options |
（选填）取消订阅 Topic 时的配置选项，详见 TopicOptions。你可以指定想要取消订阅的消息发布者。
|
基本用法
取消订阅指定用户
待补充
取消订阅 Topic
待补充
返回值
0：调用成功。- <
0：调用失败。
getSubscribedUserList
接口描述
public abstract int getSubscribedUserList(String topicName, UserList users);查询指定 Topic 中已订阅的消息发布者列表。
注意：请在加入频道后调用该方法。
| 参数 | 描述 |
|---|---|
topicName |
Topic 名称，同一个频道内相同的 Topic 名称属于同一个 Topic。Topic 名称可设为 16 字节以内的字符串，单个频道下 Topic 名唯一，即你可以在一个频道中使用另一个频道已经存在的 Topic 名称。 |
users |
UserList 对象的引用，用于返回已订阅的用户列表。详见 UserList。 |
基本用法
查询指定 Topic 已订阅消息发布者名单
待补充
返回值
0：调用成功。- <
0：调用失败。
Class
JoinChannelOptions
public class JoinChannelOptions {
public String token;
}加入频道时的配置选项。
| 参数 | 描述 |
|---|---|
token |
(选填） 用于鉴权的 RTM Token。 |
JoinTopicOptions
public class JoinTopicOptions {
public RtmMessageQos messageQos;
public String topicMeta;
}加入 Topic 的配置选项。
| 参数 | 描述 |
|---|---|
messageQos |
指定后续发送 Topic 消息时的 QoS 保障，详见 RtmMessageQos。默认值为 RTM_MESSAGE_QOS_ORDERED ：开启消息保序。 |
topicMeta |
（选填）Topic 的元数据。 |
TopicOptions
public class TopicOptions {
public ArrayList<String> users;
}订阅或取消订阅 Topic 时的配置选项。
| 参数 | 描述 |
|---|---|
users |
（选填）该 Topic 中想要订阅或取消订阅的消息发布者列表，消息发布者数量不能超过 64 个。 |
UserList
public class UserList {
public ArrayList<String> users;
};用户列表。
| 参数 | 描述 |
|---|---|
users |
用户 ID 列表。 |
Enum
RtmMessageQos
public enum RtmMessageQos {
RTM_MESSAGE_QOS_UNORDERED(0),
RTM_MESSAGE_QOS_ORDERED(1);
}消息保序配置。
| 枚举值 | 描述 |
|---|---|
RTM_MESSAGE_QOS_UNORDERED |
0: 不开启消息保序。 |
RTM_MESSAGE_QOS_ORDERED |
1: 开启消息保序。 |
