Storage

  • Android

更新时间不可用

RTM 的 Storage 功能提供了一套动态数据库机制,可以让开发者动态设置、存储、更新、删除 Channel Metadata 和 User Metadata 等数据。

setChannelMetadata

接口描述

setChannelMetadata 方法可以为频道(Message Channel 或 Stream Channel)设置 Channel Metadata。一个频道只能有一组 Metadata,但每组 Metadata 可以有一个或多个 Metadata Item。如果多次调用该方法,SDK 会依次检索 Metadata Item 的 key 值,并按如下规则处理:

  • 如果设置的 Metadata Item key 值不同,则会根据调用顺序依次增加。
  • 如果设置的 Metadata Item key 值相同,则最后一次设置的 Metadata Item 的 value 会覆盖之前的值。

成功设置 Channel Metadata 后,订阅该频道且开启事件监听的用户会收到 CHANNEL 类型的 onStorageEvent 事件通知。详见事件监听。

Channel Metadata 同时也引进了版本控制逻辑 CAS(Compare And Set),该方法提供两种独立的版本控制字段,你可以根据实际业务场景设置任意一种或多种:

  • 通过 Metadata 中的 majorRevision 属性开启整组 Channel Metadata 的版本号校验。
  • 通过 MetadataItem 中的 revision 属性开启某个 Metadata Item 的版本号校验。

设置 Channel Metadata 或 Metadata Item 时,配合版本属性可以控制本次调用是否开启版本号校验,逻辑如下:

  • 版本属性默认为 -1 ,本次调用不开启 CAS 验证。如果 Channel Metadata 或 Metadata Item 已存在,则该值会被最新值覆盖;如果 Channel Metadata 或 Metadata Item 不存在,则 SDK 会创建该值。
  • 版本属性为正整数时,本次调用开启 CAS 验证。如果 Channel Metadata 或 Metadata Item 已存在,则 SDK 会在版本号验证成功后更新对应的值;否则 SDK 会返回错误码。

接口方法

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

Java
void setChannelMetadata(
    String channelName,
    RtmChannelType channelType,
    Metadata data,
    MetadataOptions options,
    String lockName,
    ResultCallback<Void> resultCallback
);
参数类型是否必填默认值描述
channelNameString必填-频道名称。
channelTypeRtmChannelType必填-频道类型。详见 RtmChannelType。
dataMetadata必填-Metadata Item。详见 Metadata 。
optionsMetadataOptions必填-Channel Metadata 配置选项。
lockNameString必填-Lock 名称。设置后,只有调用 acquireLock 方法获取该锁的用户才能执行操作。
resultCallbackResultCallback<Void>必填-

调用结果回调:

  • 调用成功:执行 onSuccess 方法。
  • 调用失败:执行 onFailure 方法。
表格内容超出当前宽度,可横向滚动查看更多列。

MetadataOptions 数据类型包含以下属性:

属性类型是否必填默认值描述
recordTsboolean选填false是否记录编辑的时间戳。
recordUserIdboolean选填false是否记录编辑者的用户 ID。
表格内容超出当前宽度,可横向滚动查看更多列。

基本用法

Java
// Create a metadata instance
Metadata metadata = new Metadata();
// Set the Major Revision
metadata.setMajorRevision(174298270);
// Add metadata item
ArrayList<MetadataItem> items = new ArrayList<MetadataItem>();
items.add(new MetadataItem("Apple", "100", 174298200));
items.add(new MetadataItem("Banana", "200", 174298100));
metadata.setItems(items);
// Record who and when set the metadata
MetadataOptions options = new MetadataOptions();
options.setRecordTs(true);
options.setRecordUserId(true);

rtmClient.getStorage().setChannelMetadata("channelName", RtmChannelType.MESSAGE, metadata, options, "lockName", new ResultCallback<Void>() {
    @Override
    public void onSuccess(Void responseInfo) {
        log(CALLBACK, "set channel metadata success");
    }

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

getChannelMetadata

接口描述

getChannelMetadata 方法可以获取指定频道的 Metadata。

接口方法

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

Java
void getChannelMetadata(
    String channelName,
    RtmChannelType channelType,
    ResultCallback<Metadata> resultCallback
);
参数类型是否必填默认值描述
channelNameString必填-频道名称。
channelTypeRtmChannelType必填-频道类型。详见 RtmChannelType。
resultCallbackResultCallback<Metadata>必填-

调用结果回调:

  • 调用成功:执行 onSuccess 方法并返回 Metadata 查询结果。
  • 调用失败:执行 onFailure 方法。
表格内容超出当前宽度,可横向滚动查看更多列。

接口方法

Java
rtmClient.getStorage().getChannelMetadata("channelName", RtmChannelType.MESSAGE, new ResultCallback<Metadata>() {
    @Override
    public void onSuccess(Metadata data) {
        log(CALLBACK, "get channel metadata success");
        log(INFO, "metadata major revision: " + data.getMajorRevision());
        for (MetadataItem item : data.getItems()) {
            log(INFO, item.toString);
        }
    }

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

removeChannelMetadata

接口描述

removeChannelMetadata 方法可以删除 Channel Metadata 或 Channel Metadata Item 数组。

删除时,配合版本属性可以控制本次调用是否开启版本号校验,逻辑如下:

  • 版本属性默认为 -1 ,本次调用不开启 CAS 验证。如果 Channel Metadata 或 Metadata Item 已存在,则 SDK 会删除该值;如果 Channel Metadata 或 Metadata Item 不存在,则 SDK 会返回错误码。
  • 版本属性为正整数时,本次调用开启 CAS 验证。如果 Channel Metadata 或 Metadata Item 已存在,则 SDK 会在版本号验证成功后删除对应值;否则 SDK 会返回错误码。

成功删除 Channel Metadata 或 Metadata Item 后,订阅该频道且开启事件监听的用户会收到 CHANNEL 类型的 onStorageEvent 事件通知。详见事件监听。

接口方法

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

Java
void removeChannelMetadata(
    String channelName,
    RtmChannelType channelType,
    Metadata data,
    MetadataOptions options,
    String lockName,
    ResultCallback<Void> resultCallback
);
参数类型是否必填默认值描述
channelNameString必填-频道名称。
channelTypeRtmChannelType必填-频道类型。详见 RtmChannelType。
dataMetadata必填-Metadata Item。详见 Metadata 。
optionsMetadataOptions必填-Channel Metadata 配置选项。
lockNameString必填-Lock 名称。设置后,只有调用 acquireLock 方法获取该锁的用户才能执行操作。
resultCallbackResultCallback<Void>必填-

调用结果回调:

  • 调用成功:执行 onSuccess 方法。
  • 调用失败:执行 onFailure 方法。
表格内容超出当前宽度,可横向滚动查看更多列。

MetadataOptions 数据类型包含以下属性:

属性类型是否必填默认值描述
recordTsboolean选填false是否记录编辑的时间戳。
recordUserIdboolean选填false是否记录编辑者的用户 ID。
表格内容超出当前宽度,可横向滚动查看更多列。

接口方法

Java
// Create a metadata instance
Metadata metadata = new Metadata();
// Set the Major Revision
metadata.setMajorRevision(174298270);
// Add a metadata item
MetadataItem item = new MetadataItem();
item.setKey("Apple");
item.setRevision(174298200);
metadata.getItems().add(item);
//Record who and when set the metadata
MetadataOptions options = new MetadataOptions();

rtmClient.getStorage().removeChannelMetadata("channelName", RtmChannelType.MESSAGE, metadata, options, "", new ResultCallback<Void>() {
    @Override
    public void onSuccess(Void responseInfo) {
        log(CALLBACK, "remove channel metadata success");
    }

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

updateChannelMetadata

接口描述

updateChannelMetadata 方法可以更新已有的 Channel Metadata。每次调用该方法,你可以更新一个 Channel Metadata,也可以更新一个或多个 Channel Metadata Item 数组。

成功更新后,订阅该频道且开启事件监听的用户会收到 CHANNEL 类型的 onStorageEvent 事件通知。详见事件监听。

信息

该方法不能对不存在的 Metadata Item 进行操作。

接口方法

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

Java
void updateChannelMetadata(
    String channelName,
    RtmChannelType channelType,
    Metadata data,
    MetadataOptions options,
    String lockName,
    ResultCallback<Void> resultCallback
);
参数类型是否必填默认值描述
channelNameString必填-频道名称。
channelTypeRtmChannelType必填-频道类型。详见 RtmChannelType。
dataMetadata必填-Metadata Item。详见 Metadata 。
optionsMetadataOptions必填-Channel Metadata 配置选项。
lockNameString必填-Lock 名称。设置后,只有调用 acquireLock 方法获取该锁的用户才能执行操作。
resultCallbackResultCallback<Void>必填-

调用结果回调:

  • 调用成功:执行 onSuccess 方法。
  • 调用失败:执行 onFailure 方法。
表格内容超出当前宽度,可横向滚动查看更多列。

options 参数包含以下属性:

属性类型是否必填默认值描述
recordTsboolean选填false是否记录编辑的时间戳。
recordUserIdboolean选填false是否记录编辑者的用户 ID。
表格内容超出当前宽度,可横向滚动查看更多列。

基本用法

Java
// Create a metadata instance
Metadata metadata = new Metadata();
// Set the Major Revision
metadata.setMajorRevision(174298270);
// Add metadata item
ArrayList<MetadataItem> items = new ArrayList<MetadataItem>();
items.add(new MetadataItem("Apple", "120", 174298200));
items.add(new MetadataItem("Banana", "220", 174298100));
metadata.setItems(items);

rtmClient.getStorage().updateChannelMetadata("channelName", RtmChannelType.MESSAGE, metadata, new MetadataOptions(true, true), "lockName", new ResultCallback<Void>() {
    @Override
    public void onSuccess(Void responseInfo) {
        log(CALLBACK, "update channel metadata success");
    }

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

setUserMetadata

接口描述

setUserMetadata 方法可以设置 User Metadata。如果多次调用该方法时,SDK 会依次检索 User Metadata Item 的 key 值,并按如下规则处理:

  • 如果设置的 Metadata Item key 值不同,则会根据调用顺序依次增加。
  • 如果设置的 Metadata Item key 值相同,则最后一次设置的 Metadata 的 value 会覆盖之前的值。

成功设置 User Metadata 后,订阅该用户 Metadata 且开启事件监听的用户会收到 USER 类型的 onStorageEvent 事件通知。详见事件监听。

User Metadata 同时也引进了版本控制逻辑 CAS,该方法提供两种独立的版本控制字段,你可以根据实际业务场景设置任意一种或多种:

  • 通过 Metadata 中的 majorRevision 属性开启整组 Channel Metadata 的版本号校验。
  • 通过 MetadataItem 中的 revision 属性开启某个 Metadata Item 的版本号校验。

设置 User Metadata 时,配合版本属性可以控制本次调用是否开启版本号校验,逻辑如下:

  • 版本属性为 -1 时,本次调用不开启 CAS 验证。如果 User Metadata 或 Metadata Item 已存在,则该值会被最新值覆盖;如果 User Metadata 或 Metadata Item 不存在,则会创建该值。
  • 版本属性为正整数时,本次调用开启 CAS 验证。如果 User Metadata 或 Metadata Item 已存在,则 SDK 会在版本号验证成功后更新对应的值;如果 User Metadata 或 Metadata Item 不存在,则 SDK 会返回错误码。

接口方法

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

Java
void setUserMetadata(
    String userId,
    Metadata data,
    MetadataOptions options,
    ResultCallback<Void> resultCallback
);
参数类型是否必填默认值描述
userIdString必填-用户 ID。
dataMetadata必填-Metadata Item。详见 Metadata 。
optionsMetadataOptions必填-Channel Metadata 配置选项。
resultCallbackResultCallback<Void>必填-

调用结果回调:

  • 调用成功:执行 onSuccess 方法。
  • 调用失败:执行 onFailure 方法。
表格内容超出当前宽度,可横向滚动查看更多列。

options 参数包含以下属性:

属性类型是否必填默认值描述
recordTsboolean选填false是否记录编辑的时间戳。
recordUserIdboolean选填false是否记录编辑者的用户 ID。
表格内容超出当前宽度,可横向滚动查看更多列。

基本用法

Java
// Create a metadata instance
Metadata metadata = new Metadata();
// Set the Major Revision
metadata.setMajorRevision(174298270);
// Add metadata item
ArrayList<MetadataItem> items = new ArrayList<MetadataItem>();
items.add(new MetadataItem("Name", "Tony", 174298200));
items.add(new MetadataItem("Mute", "true", 174298100));
metadata.setItems(items);

rtmClient.getStorage().setUserMetadata("userName", metadata, new MetadataOptions(true, true), new ResultCallback<Void>() {
    @Override
    public void onSuccess(Void responseInfo) {
        log(CALLBACK, "set user metadata success");
    }

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

getUserMetadata

接口描述

getUserMetadata 方法可以获取指定用户的 Metadata 和 User Metadata Item。

接口方法

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

Java
void getUserMetadata(
    String userId,
    ResultCallback<Metadata> resultCallback
);
参数类型是否必填默认值描述
userIdString必填-用户 userId。
resultCallbackResultCallback<Metadata>必填-

调用结果回调:

  • 调用成功:执行 onSuccess 方法并返回 Metadata 查询结果。
  • 调用失败:执行 onFailure 方法。
表格内容超出当前宽度,可横向滚动查看更多列。

基本用法

Java
rtmClient.getStorage().getUserMetadata("userName", new ResultCallback<Metadata>() {
    @Override
    public void onSuccess(Metadata data) {
        log(CALLBACK, "get user metadata success");
        log(INFO, "major revision: " + data.getMajorRevision());
        for (MetadataItem item : data.getItems()) {
            log(INFO, item.toString());
        }
    }

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

removeUserMetadata

接口描述

removeUserMetadata 方法可以删除 User Metadata 或某几个 User Metadata Item。

成功删除后,订阅该用户 Metadata 且开启事件监听的用户会收到 USER 类型的 onStorageEvent 事件通知。详见事件监听。

接口方法

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

Java
void removeUserMetadata(
    String userId,
    Metadata data,
    MetadataOptions options,
    ResultCallback<Void> resultCallback
);
参数类型是否必填默认值描述
userIdString必填-用户 ID。
dataMetadata必填-Metadata Item。详见 Metadata 。
optionsMetadataOptions必填-Channel Metadata 配置选项。
resultCallbackResultCallback<Void>必填-

调用结果回调:

  • 调用成功:执行 onSuccess 方法。
  • 调用失败:执行 onFailure 方法。
表格内容超出当前宽度,可横向滚动查看更多列。

options 参数包含以下属性:

属性类型是否必填默认值描述
recordTsboolean选填false是否记录编辑的时间戳。
recordUserIdboolean选填false是否记录编辑者的用户 ID。
表格内容超出当前宽度,可横向滚动查看更多列。

基本用法

Java
// Create a metadata instance
Metadata metadata = new Metadata();
// Set the Major Revision
metadata.setMajorRevision(174298270);
// Add metadata item
MetadataItem item = new MetadataItem();
item.setKey("Mute");
item.setRevision(174298100);
metadata.getItems().add(item);
// Record who and when set the metadata
MetadataOptions options = new MetadataOptions();

rtmClient.getStorage().removeUserMetadata("Tony", metadata, options, new ResultCallback<Void>() {
    @Override
    public void onSuccess(Void responseInfo) {
        log(CALLBACK, "remove user metadata success");
    }

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

updateUserMetadata

接口描述

updateUserMetadata 方法可以更新已有的 User Metadata 或 Metadata Item。成功更新后,订阅该 User Metadata 且开启事件监听的用户会收到 USER 类型的 onStorageEvent 事件通知。详见事件监听。

信息

该方法不能对不存在的 Metadata Item 进行操作。

接口方法

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

Java
void updateUserMetadata(
    String userId,
    Metadata data,
    MetadataOptions options,
    ResultCallback<Void> resultCallback
);
参数类型是否必填默认值描述
userIdString必填-用户 ID。
dataMetadata必填-Metadata Item。详见 Metadata 。
optionsMetadataOptions必填-Channel Metadata 配置选项。
resultCallbackResultCallback<Void>必填-

调用结果回调:

  • 调用成功:执行 onSuccess 方法。
  • 调用失败:执行 onFailure 方法。
表格内容超出当前宽度,可横向滚动查看更多列。

MetadataOptions 数据类型包含以下属性:

属性类型是否必填默认值描述
recordTsboolean选填false是否记录编辑的时间戳。
recordUserIdboolean选填false是否记录编辑者的用户 ID。
表格内容超出当前宽度,可横向滚动查看更多列。

基本用法

Java
// Create a metadata instance
Metadata metadata = new Metadata();
// Set the Major Revision
metadata.setMajorRevision(174298270);
// Add a metadata item
metadata.getItems().add(new MetadataItem("Name", "Tony", 174298200));
// Record who and when set the metadata
MetadataOptions options = new MetadataOptions();
options.setRecordTs(true);
options.setRecordUserId(true);

rtmClient.getStorage().updateUserMetadata("Tony", metadata, options, new ResultCallback<Void>() {
    @Override
    public void onSuccess(Void responseInfo) {
        log(CALLBACK, "update user metadata success");
    }

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

subscribeUserMetadata

接口描述

subscribeUserMetadata 方法可以订阅指定用户的 Metadata。成功订阅且开启事件监听后,当该用户的 Metadata 发生变更时会收到 USER 类型的 onStorageEvent 事件通知。详见事件监听。

接口方法

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

Java
void subscribeUserMetadata(
    String userId,
    ResultCallback<Void> resultCallback
);
参数类型是否必填默认值描述
userIdString必填-用户 ID。
resultCallbackResultCallback<Void>必填-

调用结果回调:

  • 调用成功:执行 onSuccess 方法。
  • 调用失败:执行 onFailure 方法。
表格内容超出当前宽度,可横向滚动查看更多列。

基本用法

Java
rtmClient.getStorage().subscribeUserMetadata("Tony", new ResultCallback<Void>() {
    @Override
    public void onSuccess(Void responseInfo) {
        log(CALLBACK, "subscribe user metadata success");
    }

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

unsubscribeUserMetadata

接口描述

如果你不需要接收某个用户 User Metadata 的变更通知,调用 unsubscribeUserMetadata 方法取消订阅。

接口方法

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

Java
void unsubscribeUserMetadata(
    String userId,
    ResultCallback<Void> resultCallback
);
参数类型是否必填默认值描述
userIdString必填-用户 ID。
resultCallbackResultCallback<Void>必填-

调用结果回调:

  • 调用成功:执行 onSuccess 方法。
  • 调用失败:执行 onFailure 方法。
表格内容超出当前宽度,可横向滚动查看更多列。

基本用法

Java
rtmClient.getStorage().unsubscribeUserMetadata("Tony", new ResultCallback<Void>() {
    @Override
    public void onSuccess(Void responseInfo) {
        log(CALLBACK, "unsubscribe user metadata success");
    }

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

Metadata

设置和管理 Metadata 的数据结构。包含以下属性:

属性类型是否必填默认值描述
majorRevisionlong选填-1

设置版本控制开关:

  • -1: 关闭版本校验。
  • 0: 开启版本校验,只有目标版本号与此值相符才能执行操作。

itemsArrayList<MetadataItem>选填null设置 Metadata Item。
表格内容超出当前宽度,可横向滚动查看更多列。

MetadataItem 数据类型包含以下属性:

属性类型是否必填默认值描述
keyString选填-键。
valueString选填-值。
authorUserIdString选填-编辑者的用户 ID。该值为只读,不支持写入。
revisionlong选填-1
  • 在读取操作时作为真实版本号返回。
  • 在写入操作时作为版本控制开关:
    • -1: 关闭版本校验。
    • 0: 开启版本校验,只有目标版本号与此值相符才执行操作。

updateTslong选填0更新时间戳。该值为只读,不支持写入。
表格内容超出当前宽度,可横向滚动查看更多列。