方舟智能分析
产品功能SDK指南API
搜索
⌃K
Links
Comment on page

Java SDK

Java SDK使用说明
Java SDK 主要用于服务端 Java 应用，如 Java Web 应用的后台服务。集成前请先登录下载SDK。

1. 集成 SDK

1.1 JAR 包集成

以 Eclipse 为例：将需要的 jar 包拷贝到本地工程 libs 子目录下；在 Eclipse 中右键工程根目录，选择 Properties -> Java Build Path -> Libraries ，然后点击Add External JARs... 选择指向 jar 的路径，点击 OK，即导入成功。
说明：该版本 jar 包基于 JDK1.8 进行编译。
有两种 JAR 包供选择：
一种为带有依赖包和 SDK 的 jar 包（analysys-java-sdk-xxx-jar-withdependencies.jar）,只需要导入这一个 jar 包即可正常使用 JavaSDK。
一种为不带有依赖包的 jar 包（analysys-java-sdk-xxx.jar），这个 jar 包只包含 SDK，如果使用该 jar 包，则需要手动在项目中添加 Maven 依赖包：JavaSDK 依赖 httpclient4.5 以上版本和 jackson-databind2.9 以上版本包，Maven 依赖如下：
<dependency>
<groupId>org.apache.httpcomponents</groupId>
<artifactId>httpclient</artifactId>
<version>4.5.5</version>
</dependency>
<dependency>
<groupId>com.fasterxml.jackson.core</groupId>
<artifactId>jackson-databind</artifactId>
<version>2.9.4</version>
</dependency>

2. SDK 初始化

2.1 获取配置信息

需获取的配置信息为：
  • 数据接收地址：http://host:port

2.2 初始化接口

在程序启动时（如 public static void main(String[] args) 方法中），调用构造函数 new AnalysysJavaSdk(Collecter) 初始化 Java SDK 实例。如下：
final String APP_KEY = "APPKEY";
final String ANALYSYS_SERVICE_URL = "http://host:port";
AnalysysJavaSdk analysys = new AnalysysJavaSdk(new SyncCollecter(ANALYSYS_SERVICE_URL), APP_KEY);
  • APPKEY：网站获取的 Key
  • SyncCollecter：为实时事件收集器
事件收集器还提供批量收集器和本地落文件收集器，用户可以按照自己需求指定。

2.2.1 实时收集器

用户每触发一次上传，该收集器则立即上传数据至接收服务器：
public SyncCollecter(String serverUrl);
  • serverUrl：数据接收地址

2.2.2 批量收集器

用户触发上传，该收集器将先缓存数据，直到数量达到用户设置的阈值或者用户设置的等待时间，才会触发真正的上传：
public BatchCollecter(String serverUrl);
public BatchCollecter(String serverUrl, int batchNum);
public BatchCollecter(String serverUrl, int batchNum, long batchSec);
  • serverUrl：数据接收地址
  • batchNum：批量发送数量，默认值：20条
  • batchSec：批量发送等待时间(秒)，默认值：10秒

2.2.3 落地文件收集器

该收集器可以把用户触发的事件经过封装处理成标准的JSON写入本地文件中。支持多线程/多进程同时写入同一文件，默认为同步一条条写入文件，可以指定是否异步批量写入以及批量写入的条数和时间间隔。
public LogCollecter(String logFolder);
​
public LogCollecter(String logFolder, boolean async);
​
public LogCollecter(String logFolder, GeneralRule rule);
​
public LogCollecter(String logFolder, GeneralRule rule, boolean async);
​
public LogCollecter(String logFolder, GeneralRule rule, boolean async, int batchNum, long batchSec);
​
  • logFolder：数据保存的目录
  • async： 是否异步批量保存(默认为false，如果设置为true则默认20条或者10秒进行落地操作)
  • rule: 文件存储规则。当传值为"GeneralRule.DAY"时，文件按日写入数据（即每日生成一个文件），当传值为"GeneralRule.HOUR"时，文件按小时写入数据（即每小时生成一个文件）。默认规则为按小时
  • batchNum： 批量保存数量，默认值：20条
  • batchSec： 批量保存等待时间(秒)，默认值：10秒
至此 SDK初始化完成，调用 SDK 提供的接口已可正常采集用户数据了。需要注意：在多线程环境中时，推荐使用单例模式初始化 AnalysysJavaSdk，开发者可以在不同的线程间重复使用 AnalysysJavaSdk 实例用于记录数据。 说明：程序结束前需要调用 flush() 接口，该接口可以把本地缓存的尚未发送至数据接收服务器或未写入本地的数据发送到数据接收服务器或写入本地文件。

3. 基础接口介绍

3.1 Debug 模式

Debug 主要用于开发者测试，接口如下：
public void setDebugMode(DEBUG debug);
  • debug：debug 模式,枚举类型,默认关闭状态。有以下三种枚举值：
    • DEBUG.CLOSE：表示关闭 Debug 模式
    • DEBUG.OPENNOSAVE：表示打开 Debug 模式，但该模式下发送的数据仅用于调试，不计入平台数据统计
    • DEBUG.OPENANDSAVE：表示打开 Debug 模式，该模式下发送的数据可计入平台数据统计
    注意：发布版本时debug模式设置为`DEBUG.CLOSE`。

3.2 统计事件

事件跟踪，设置事件名称和事件详细信息。接口如下：
public void track(String distinctId, boolean isLogin, String eventName, Map<String, Object> properties, String platform) throws AnalysysException;
public void track(String distinctId, boolean isLogin, String eventName, Map<String, Object> properties, String platform, String xwhen) throws AnalysysException;
  • distinctId：自定义设备身份标识,长度大于 0 且小于 255字符
  • isLogin：用户 ID 是否是登录 ID
  • eventName：自定义事件ID标识，以字母开头的字符串，必须由字母、数字、下划线组成，$ 开头为预置事件/属性，不支持乱码、中文、空格等，长度范围1-99字符
  • properties: 自定义事件属性,最多包含 100条，且key是以字母开头的字符串，必须由字母、数字、下划线组成，字母不区分大小写，不支持乱码、中文、空格等，长度范围1-99字符；value 类型约束(String/Number/boolean/list/数组)，若为字符串,最大长度255字符
  • platform：平台类型,建议内容范围：JS、WeChat、Android、iOS, 并且支持自定义
  • xwhen: 用户自定义时间戳(带毫秒的13位时间戳)
示例：用户浏览商品
// 浏览商品
String distinctId = "1234";
boolean isLogin = false;
String eventName = "ViewProduct";
String platform = "Android";
Map<String, Object> trackPropertie = new HashMap<String, Object>();
trackPropertie.put("$ip", "112.112.112.112"); //IP地址
List<String> bookList = new ArrayList<String>();
bookList.add("Thinking in Java");
trackPropertie.put("productName", bookList); //商品列表
trackPropertie.put("productType", "Java书籍");//商品类别
trackPropertie.put("producePrice", 80); //商品价格
trackPropertie.put("shop", "xx网上书城"); //店铺名称
analysys.track(distinctId, isLogin, eventName, trackPropertie, platform);
// 或者也可以使用自定义的时间戳
String myxWhen = "1569859200000";
analysys.track(distinctId, isLogin, eventName, trackPropertie, platform, myxWhen);

3.3 用户关联

用户关联的主要作用是打通用户登录前后的行为，以及多屏登录后的行为。做过用户关联的用户在登录前后的行为在方舟系统里面会被认为是一个用户。方舟系统目前支持 一台设备只能绑定一个用户 ID，一个用户 ID 只能绑定一台设备。设备和用户 ID 绑定后，就无法再和其他用户或者设备进行绑定。例如一个用户的设备 ID 是 ABC 用户的登录 ID 是 123，绑定成功后会对应同一个 ID，这样在统计或者分析时会被认为是一个用户。如果注册成功或者登录事件在后端触发，后端 alias 接口的 distinctId 需要从前端获取匿名 ID 传给后端。建议埋点时观看下 方舟 SDK 接入视频 接口描述如下：
public void alias(String aliasId, String distinctId, String platform) throws AnalysysException;
public void alias(String aliasId, String distinctId, String platform, String xwhen) throws AnalysysException;
  • aliasId：用户注册 ID，长度大于 0，且小于 255字符
  • distinctId：自定义设备身份标识，长度大于 0，且小于 255字符
  • platform：平台类型,建议内容范围：JS、WeChat、Android、iOS, 并且支持自定义
  • xwhen: 用户自定义时间戳(带毫秒的13位时间戳)
示例：匿名用户浏览商品到注册会员
// 匿名ID
String distinctId = "1234567890987654321";
String platform = "Android";
...
...
...
//用户注册登录
String registerId = "ABCDEF123456789";
analysys.alias(registerId, distinctId, platform);
​
// 或者也可以使用自定义的时间戳
String myxWhen = "1569859200000";
analysys.alias(registerId, distinctId, platform, myxWhen);

3.4 用户属性设置

SDK提供以下接口供用户设置用户的属性，比如用户的年龄/性别等信息。
用户属性是一个标准的K-V结构，K和V均有相应的约束条件，如不符合则丢弃该次操作。 参数约束:
  • 属性名称
    以字母开头的字符串，必须由字母、数字、下划线组成，字母不区分大小写，$ 开头为预置事件/属性，不支持乱码、中文、空格等，长度范围1-99字符
  • 属性值
    支持部分类型：string/number/boolean/集合/数组; 若为字符串,则最大长度255字符; 若为数组或集合,则最多包含100条,且key约束条件与属性名称一致,value最大长度255字符
设置单个或多个属性，如用户所在城市，用户昵称，用户头像信息等。如果之前存在，则覆盖，否则，新创建。接口如下：
public void profileSet(String distinctId, boolean isLogin, Map<String, Object> properties, String platform) throws AnalysysException;
public void profileSet(String distinctId, boolean isLogin, Map<String, Object> properties, String platform, String xwhen) throws AnalysysException;
  • distinctId: 自定义设备身份标识,长度大于0且小于255字符
  • isLogin: 用户ID是否是登录 ID
  • properties: 事件属性
  • platform: 平台类型,建议内容范围：JS、WeChat、Android、iOS, 并且支持自定义
  • xwhen: 用户自定义时间戳(带毫秒的13位时间戳)
示例：用户注册后设置用户的注册信息属性
String registerId = "ABCDEF123456789";
boolean isLogin = true;
String platform = "Android";
//用户信息
Map<String, Object> profiles = new HashMap<String, Object>();
profiles.put("$city", "北京"); //城市
profiles.put("$province", "北京"); //省份
profiles.put("nickName", "昵称123");//昵称
profiles.put("userLevel", 0); //用户级别
profiles.put("userPoint", 0); //用户积分
List<String> interestList = new ArrayList<String>();
interestList.add("户外活动");
interestList.add("足球赛事");
interestList.add("游戏");
profiles.put("interest", interestList);//用户兴趣爱好
analysys.profileSet(registerId, isLogin, profiles, platform);
​
// 或者也可以使用自定义的时间戳
String myxWhen = "1569859200000";
analysys.profileSet(registerId, isLogin, profiles, platform, myxWhen);

4. 更多接口

4.1 用户属性

4.1.1 设置用户固有属性

只在首次设置时有效的属性。如：用户的注册时间。如果被设置的用户属性已存在，则这条记录会被忽略而不会覆盖已有数据，如果属性不存在则会自动创建。接口如下：
public void profileSetOnce(String distinctId, boolean isLogin, Map<String, Object> properties, String platform) throws AnalysysException;
public void profileSetOnce(String distinctId, boolean isLogin, Map<String, Object> properties, String platform, String xwhen) throws AnalysysException;
  • distinctId: 自定义设备身份标识,长度大于0且小于255字符
  • isLogin: 用户ID是否是登录 ID
  • properties: 事件属性
  • platform: 平台类型,建议内容范围：JS、WeChat、Android、iOS, 并且支持自定义
  • xwhen: 用户自定义时间戳(带毫秒的13位时间戳)
示例：要统计用户注册时间
String registerId = "ABCDEF123456789";
boolean isLogin = true;
String platform = "Android";
Map<String, Object> profile_age = new HashMap<String, Object>();
profile_age.put("registerTime", "20180101101010");
analysys.profileSetOnce(registerId, isLogin, profile_age, platform);
​
// 或者也可以使用自定义的时间戳
String myxWhen = "1569859200000";
analysys.profileSetOnce(registerId, isLogin, profile_age, platform, myxWhen);

4.1.2 设置用户属性相对变化值

设置用户属性的单个相对变化值(相对增加,减少)，只能对数值型属性进行操作，如果这个Profile之前不存在,则初始值为0。接口如下：
public void profileIncrement(String distinctId, boolean isLogin, Map<String, Object> properties, String platform) throws AnalysysException;
public void profileIncrement(String distinctId, boolean isLogin, Map<String, Object> properties, String platform, String xwhen) throws AnalysysException;
  • distinctId: 自定义设备身份标识,长度大于0且小于255字符
  • isLogin: 用户ID是否是登录 ID
  • properties: 事件属性
  • platform: 平台类型,建议内容范围：JS、WeChat、Android、iOS, 并且支持自定义
  • xwhen: 用户自定义时间戳(带毫秒的13位时间戳)
示例：用户注册初始积分为0，在用户购买商品后，用户的积分增加20，则调用该接口，用户的积分变为0+20=20了：
String registerId = "ABCDEF123456789";
boolean isLogin = true;
String platform = "Android";
Map<String,Object> profile = new HashMap<>();
profile.put("userPoint",20);
analysys.profileIncrement(registerId, isLogin, profile, platform);
​
// 或者也可以使用自定义的时间戳
String myxWhen = "1569859200000";
analysys.profileIncrement(registerId, isLogin, profile, platform, myxWhen);

4.1.3 增加列表类型的属性

为列表类型的属性增加一个或多个元素，如：用户新增兴趣爱好，接口如下：
public void profileAppend(String distinctId, boolean isLogin, Map<String, Object> properties, String platform) throws AnalysysException;
public void profileAppend(String distinctId, boolean isLogin, Map<String, Object> properties, String platform, String xwhen) throws AnalysysException;
  • distinctId: 自定义设备身份标识,长度大于0且小于255字符
  • isLogin: 用户ID是否是登录 ID
  • properties: 事件属性
  • platform: 平台类型,建议内容范围：JS、WeChat、Android、iOS, 并且支持自定义
  • xwhen: 用户自定义时间戳(带毫秒的13位时间戳)
示例：用户初始填写的兴趣爱好为["户外活动"，"足球赛事"，"游戏"]，调用该接口追加["学习"，"健身"]，则用户的爱好变为["户外活动"，"足球赛事"，"游戏"，"学习"，"健身"]
String registerId = "ABCDEF123456789";
boolean isLogin = true;
String platform = "Android";
Map<String,Object> profile = new HashMap<>();
List<String> interestList = new ArrayList<String>();
interestList.add("户外活动");
interestList.add("足球赛事");
interestList.add("游戏");
profile.put("interest", interestList);//用户兴趣爱好
analysys.profileAppend(registerId, isLogin, profile, platform);
​
// 或者也可以使用自定义的时间戳
String myxWhen = "1569859200000";
analysys.profileAppend(registerId, isLogin, profile, platform, myxWhen);

4.1.4 删除设置的属性值

删除设置的属性值。接口如下：
public void profileUnSet(String distinctId, boolean isLogin, String property, String platform) throws AnalysysException;
public void profileUnSet(String distinctId, boolean isLogin, String property, String platform, String xwhen) throws AnalysysException;
public void profileDelete(String distinctId, boolean isLogin, String platform) throws AnalysysException;
public void profileDelete(String distinctId, boolean isLogin, String platform, String xwhen) throws AnalysysException;
  • distinctId: 自定义设备身份标识,长度大于0且小于255字符
  • isLogin: 用户ID是否是登录 ID
  • propertie: 事件属性
  • platform: 平台类型,建议内容范围：JS、WeChat、Android、iOS, 并且支持自定义
  • xwhen: 用户自定义时间戳(带毫秒的13位时间戳)
示例1： 要删除已经设置的用户昵称这一用户属性
String registerId = "ABCDEF123456789";
boolean isLogin = true;
String platform = "Android";
// 删除单个用户属性
analysys.profileUnSet(registerId, isLogin, "nickName", platform);
​
// 或者也可以使用自定义的时间戳
String myxWhen = "1569859200000";
analysys.profileUnSet(registerId, isLogin, "nickName", platform, myxWhen);
示例2：要删除已经设置的所有用户属性
String registerId = "ABCDEF123456789";
boolean isLogin = true;
String platform = "Android";
// 清除所有属性
analysys.profileDelete(registerId, isLogin, platform);
​
// 或者也可以使用自定义的时间戳
String myxWhen = "1569859200000";
analysys.profileDelete(registerId, isLogin, platform, myxWhen);

4.2 通用属性

如果某个事件的属性，在所有事件中都会出现，则这个属性可以做为通用属性，通过 registerSuperProperties() 将该属性设置为事件通用属性，则设置后每次发送事件的时候都会带有该属性。比如用户浏览/购买商品过程中的用户等级就可以作为通用属性。
通用属性是一个标准的 K-V 结构，K 和 V 均有相应的约束条件，如不符合则丢弃该次操作。
约束条件如下:
  • 属性名称
    以字母开头的字符串，必须由字母、数字、下划线组成，字母不区分大小写，$ 开头为预置事件/属性，不支持乱码、中文、空格等，长度范围1-99字符
  • 属性值
    • 支持部分类型：string/number/boolean/集合/数组;
    • 若为字符串,则最大长度 255字符;
    • 若为数组或集合,则最多包含 100条,且 key 约束条件与属性名称一致,value 最大长度 255字符

4.2.1 注册通用属性

以用户浏览/购买商品的过程中发生的事件为例，用户的级别/积分就可以作为通用的属性，通过把用户级别/积分注册为通用属性，就可以避免在每次收集事件属性的时候都要手工设置该属性值。接口如下：
public void registerSuperProperties(Map<String, Object> params);
  • params：设置多个属性
示例：
// 设置多个通用属性
Map<String, Object> superPropertie = new HashMap<String, Object>();
superPropertie.put("userLevel", 0); //用户级别
superPropertie.put("userPoint", 0); //用户积分
analysys.registerSuperProperties(superPropertie);

4.2.2 删除通用属性

如果要删除某个通用属性或者删除全部的通用属性，可以分别调用 unregisterSuperProperty 或 clearSuperProperties 接口。具体接口定义如下：
public void unRegisterSuperProperty(String key);
public void clearSuperProperties();
  • key：属性名称
示例1：删除设置的用户积分属性
// 删除单个通用属性
analysys.unRegisterSuperProperty("userPoint");
示例2：清除所有已经设置的通用属性
// 清除所有通用属性
analysys.clearSuperProperties();

4.2.3 获取通用属性

由属性名称查询获取单条通用属性，或者获取全部的通用属性。接口如下：
public Object getSuperProperty(String key);
public Map<String, Object> getSuperProperties();
  • key：属性名称
示例1：查看已经设置的 userLevel 通用属性
// 获取单个通用属性
analysys.getSuperProperty("userLevel");
示例2：查看所有已经设置的通用属性
// 获取所有通用属性
analysys.getSuperProperties();

4.3 刷新缓存

立即发送所有收集的信息到服务器。
analysys.flush();

5. SDK 使用样例

final String APP_ID = "1234";
final String ANALYSYS_SERVICE_URL = "http://192.168.0.3:8089";
AnalysysJavaSdk analysys = new AnalysysJavaSdk(new SyncCollecter(ANALYSYS_SERVICE_URL), APP_ID);
try {
String distinctId = "1234567890987654321";
String platForm = "Android";
analysys.setDebugMode(DEBUG.CLOSE); //设置debug模式
//浏览商品
Map<String, Object> trackPropertie = new HashMap<String, Object>();
trackPropertie.put("$ip", "112.112.112.112"); //IP地址
List<String> bookList = new ArrayList<String>();
bookList.add("Thinking in Java");
trackPropertie.put("productName", bookList); //商品列表
trackPropertie.put("productType", "Java书籍"); //商品类别
trackPropertie.put("producePrice", 80); //商品价格
trackPropertie.put("shop", "xx网上书城"); //店铺名称
analysys.track(distinctId, false, "ViewProduct", trackPropertie, platForm);//用户注册登录
String registerId = "ABCDEF123456789";
analysys.alias(registerId, distinctId, platForm);//设置公共属性
Map<String, Object> superPropertie = new HashMap<String, Object>();
superPropertie.put("sex", "male"); //性别
superPropertie.put("age", 23); //年龄
analysys.registerSuperProperties(superPropertie);//用户信息
Map<String, Object> profiles = new HashMap<String, Object>();
profiles.put("$city", "北京"); //城市
profiles.put("$province", "北京"); //省份
profiles.put("nickName", "昵称123");//昵称
profiles.put("userLevel", 0); //用户级别
profiles.put("userPoint", 0); //用户积分
List<String> interestList = new ArrayList<String>();
interestList.add("户外活动");
interestList.add("足球赛事");
interestList.add("游戏");
profiles.put("interest", interestList);//用户兴趣爱好
analysys.profileSet(registerId, true, profiles, platForm);//用户注册时间
Map<String, Object> profile_age = new HashMap<String, Object>();
profile_age.put("registerTime", "20180101101010");
analysys.profileSetOnce(registerId, true, profile_age, platForm);//重新设置公共属性
analysys.clearSuperProperties();
superPropertie.clear();
superPropertie = new HashMap<String, Object>();
superPropertie.put("userLevel", 0); //用户级别
superPropertie.put("userPoint", 0); //用户积分
analysys.registerSuperProperties(superPropertie);//再次浏览商品
trackPropertie.clear();
trackPropertie.put("$ip", "112.112.112.112"); //IP地址
List<String> abookList = new ArrayList<String>();
abookList.add("Thinking in Java");
trackPropertie.put("productName", bookList); //商品列表
trackPropertie.put("productType", "Java书籍");//商品类别
trackPropertie.put("producePrice", 80); //商品价格
trackPropertie.put("shop", "xx网上书城"); //店铺名称
analysys.track(registerId, true, "ViewProduct", trackPropertie, platForm);//订单信息
trackPropertie.clear();
trackPropertie.put("orderId", "ORDER_12345");
trackPropertie.put("price", 80);
analysys.track(registerId, true, "Order", trackPropertie, platForm);//支付信息
trackPropertie.clear();
trackPropertie.put("orderId", "ORDER_12345");
trackPropertie.put("productName", "Thinking in Java");
trackPropertie.put("productType", "Java书籍");
trackPropertie.put("producePrice", 80);
trackPropertie.put("shop", "xx网上书城");
trackPropertie.put("productNumber", 1);
trackPropertie.put("price", 80);
trackPropertie.put("paymentMethod", "AliPay");
analysys.track(registerId, true, "Payment", trackPropertie, platForm);
} catch (AnalysysException e) {
e.printStackTrace();
analysys.flush();
}
以前
Flutter SDK
下一个
Python SDK
最近更新 3yr ago