Java SDK 接入

本文介绍如何以 Java SDK 的方式在服务端接入数据同步服务。

引入 jar 包

完成 Maven 配置后，在主控 pom.xml 文件中引入如下依赖：

<dependency>
  <groupId>com.aliyun</groupId>
  <artifactId>aliyun-java-sdk-mpaas</artifactId>
    <version>1.0.0.0</version>
</dependency>
<dependency>
<groupId>com.aliyun</groupId>
  <artifactId>aliyun-java-sdk-core</artifactId>
  <optional>true</optional>
  <version>[4.3.2,5.0.0)</version>
</dependency>

接口说明

单数据同步接口

单数据同步接口是指同步数据到指定的用户或者设备。

参数说明

业务参数信息如下：

单条数据同步结果码

代码示例

public static void main(String[] args) {
        //请求信息，除 AccessKey ID  AccessKey Secret 外固定即可
        DefaultProfile.addEndpoint("cn-hangzhou", "mpaas", "mpaas.cn-hangzhou.aliyuncs.com");
        // 创建 DefaultAcsClient 实例并初始化
        DefaultProfile profile = DefaultProfile.getProfile(
            "cn-hangzhou", // 地域 ID
            "xxxxxx",   // RAM 账号的 AccessKey ID
            "xxxxxx");  // RAM 账号的 AccessKey Secret
        IAcsClient client = new DefaultAcsClient(profile);
       CreateOpenSingleDataRequest singleRequest = constuctSingleRequest();
        CreateOpenSingleDataResponse singleDataResponse;
        try {
            singleDataResponse = client.getAcsResponse(singleRequest);
            System.out.println("singleDataResponse:" +
                ToStringBuilder
                    .reflectionToString(singleDataResponse, ToStringStyle.SHORT_PREFIX_STYLE));
        } catch (ServerException e) {
            e.printStackTrace();
        } catch (ClientException e) {
            e.printStackTrace();
        } catch (com.aliyuncs.exceptions.ClientException e) {
            e.printStackTrace();
        } catch (Throwable throwable) {
            throwable.printStackTrace();
        }
    }
    private static CreateOpenSingleDataRequest constuctSingleRequest() {
        CreateOpenSingleDataRequest singleRequest
            = new CreateOpenSingleDataRequest();
        //*************必要属性*************/
        //mPaaS 控制台获取的 APPID
        singleRequest.setAppId("xxxxxxx");
        //mPaaS 控制台获取的 WorkspaceId
        singleRequest.setWorkspaceId("xxxxxxxx");
        //mPaaS 控制台移动同步中配置的同步标识
        singleRequest.setBizType("TEST-SYNC");
        //需要推送的用户 ID 或者设备 ID（UTDID）
        singleRequest.setLinkToken("testUserId");
        //实际业务消息体，自定义长度不超过 4096
        singleRequest.setPayload("testPayload");
         //业务 ID，保证唯一，长度不超过 100
        singleRequest.setThirdMsgId("test_third_msg_id_" + System.currentTimeMillis());
        //************非必要属性*************/
        //推送目标设备的操作系统 iOS 或 Android 为空时不限制操作系统
        singleRequest.setOsType("IOS");
        //持的最小客户端版本号，如：8.6.0.0.9999 ，可为空，为空将不限制最小版本号
        singleRequest.setAppMinVersion("0.0.0.0");
        //支持的最大客户端版本号，如：9.0.0.0.9999，可为空，为空将不限制最大版本号
        singleRequest.setAppMaxVersion("100.100.100.100");
        //有效期开始，可为空，为空时不限制有效起始时间
        singleRequest.setValidTimeStart(System.currentTimeMillis());
        //有效期结束，可为空，为空时不限制有效结束时间 最长有效期为 30 天
        singleRequest.setValidTimeEnd(System.currentTimeMillis() + (1000 * 3600));
        return singleRequest;
    }

全局（网）数据同步接口

全局（网）数据同步是指同步数据到所有设备。

参数说明

业务参数信息如下：

全局（网）数据同步结果码

代码示例

public static void main(String[] args) {
        //请求信息，除 AccessKey ID  AccessKey Secret 外固定即可
        DefaultProfile.addEndpoint("cn-hangzhou", "mpaas", "mpaas.cn-hangzhou.aliyuncs.com");
        // 创建 DefaultAcsClient 实例并初始化
        DefaultProfile profile = DefaultProfile.getProfile(
            "cn-hangzhou", // 地域 ID
            "xxxxxx",   // RAM 账号的 AccessKey ID
            "xxxxxx");  // RAM 账号的 AccessKey Secret
        IAcsClient client = new DefaultAcsClient(profile);
        CreateOpenGlobalDataRequest globalDataRequest = constuctGlobelRequest();
        CreateOpenGlobalDataResponse globalDataResponse;
        try {
            globalDataResponse = client.getAcsResponse(globalDataRequest);
            System.out.println("globalDataResponse:" +
                ToStringBuilder
                    .reflectionToString(globalDataResponse, ToStringStyle.SHORT_PREFIX_STYLE));
        } catch (ServerException e) {
            e.printStackTrace();
        } catch (ClientException e) {
            e.printStackTrace();
        } catch (com.aliyuncs.exceptions.ClientException e) {
            e.printStackTrace();
        } catch (Throwable throwable) {
            throwable.printStackTrace();
        }
    }
 private static CreateOpenGlobalDataRequest constuctGlobelRequest() {
        CreateOpenGlobalDataRequest globalRequest
            = new CreateOpenGlobalDataRequest();
        //************必要属性*************/
        //mPaaS 控制台获取的 APPID
        globalRequest.setAppId("BE9C457161429");
        //mPaaS 控制台获取的 WorkspaceId
        globalRequest.setWorkspaceId("sit");
        //mPaaS 控制台移动同步中配置的同步标识
        globalRequest.setBizType("test-global");
        //实际业务消息体，自定义长度不超过 4096
        globalRequest.setPayload("testtestata");
        //业务 ID，保证唯一，长度不超过 100
        globalRequest.setThirdMsgId("test_third_msg_id_" + System.currentTimeMillis());
        //************非必要属性*************/
        //推送目标设备的操作系统 iOS 或 Android 为空时不限制操作系统
        globalRequest.setOsType("IOS");
        //持的最小客户端版本号，如：8.6.0.0.9999 ，可为空 为空将不限制最小版本号
        globalRequest.setAppMinVersion("0.0.0.0");
        //支持的最大客户端版本号，如：9.0.0.0.9999，可为空 为空将不限制最大版本号
        globalRequest.setAppMaxVersion("100.100.100.100");
        //最大 Uid
        globalRequest.setMaxUid(Long.valueOf(99));
        //最小 Uid
        globalRequest.setMinUid(Long.valueOf(1));
        //需要推送的灰度 Uid 00~99,字符串数组
        globalRequest.setUids("01,02,99");
        globalRequest.setValidTimeStart(System.currentTimeMillis());
        globalRequest.setValidTimeEnd(System.currentTimeMillis() + (1000 * 3600));
        return globalRequest;
    }