集成文档（Java）

	
        
        
            com.sensorsdata.analytics.javasdk
            SensorsAnalyticsSDK
            3.4.3
        
	

dependencies {
    compile 'com.sensorsdata.analytics.javasdk:SensorsAnalyticsSDK:3.4.3'
}

// 使用 ConcurrentLoggingConsumer 初始化 SensorsAnalytics
final SensorsAnalytics sa = new SensorsAnalytics(new ConcurrentLoggingConsumer("您的日志文件路径"));

// 用户的 Distinct ID
String distinctId = "ABCDEF123456789";

// 记录用户登录事件
EventRecord loginRecord = EventRecord.builder().setDistinctId(distinctId).isLoginId(Boolean.TRUE)
                              .setEventName("UserLogin")
                              .build();
sa.track(loginRecord);

// 使用神策分析记录用户行为数据
// ...

@Configuration
public class SensorsConfig {

    @Bean(destroyMethod = "shutdown")
    public ISensorsAnalytics init() throws IOException {
        //本地日志模式（此模式会在指定路径生成相应的日志文件）
        return new SensorsAnalytics(new ConcurrentLoggingConsumer("您的日志文件路径"));
        //debug 模式(此模式只适用于测试集成 SDK 功能，千万不要使用到生产环境！！！)
        //return new SensorsAnalytics(new DebugConsumer("数据接收地址", true));
        //网络批量发送模式（此模式在容器关闭的时候，如果存在数据还没有发送完毕，就会丢失未发送的数据！！！）
        //return new SensorsAnalytics(new BatchConsumer("数据接收地址"));
    }

}

// 从神策服务器数据接入引导页面获取的数据接收的 URL
String serverUrl = ""; 
ISensorsAnalytics sa = new SensorsAnalytics(new DebugConsumer(serverUrl,true));

// 将数据输出到 /data/sa 下的 access.log.2017-01-11 文件中，每天一个文件；对应目录文件需要自己创建，日志文件后缀会自动生成
final SensorsAnalytics sa = new SensorsAnalytics(new ConcurrentLoggingConsumer("/data/sa/access.log"));

// !! 注意 !! 如果是在 Windows 环境下使用 ConcurrentLoggingConsumer 并使用 LogAgent 发送数据，
// 需要额外通过构造函数的第二个参数指定一个文件地址用于文件锁，例如：
// SensorsAnalytics sa = new SensorsAnalytics(new ConcurrentLoggingConsumer("D:\\data\\service", "D:\\var\\sa.lock"));
// 若该文件与数据文件同目录，配置 LogAgent 的 pattern 时请不要匹配到这个文件。

// 从神策分析获取的数据接收的 URL
final String SA_SERVER_URL = "YOUR_SERVER_URL";
// 当缓存的数据量达到50条时，批量发送数据
final int SA_BULK_SIZE = 50;
// 数据同步失败不抛出异常
final boolean THROW_EXCEPTION = false;
// 内存中数据最大缓存条数，如此值大于0，代表缓存的数据会有条数限制，最小 3000 条，最大 6000 条。否则无条数限制。
final int MAX_CACHE_SIZE = 0;
// 使用 BatchConsumer 初始化 SensorsAnalytics
// 不要在任何线上的服务中使用此 Consumer
final SensorsAnalytics sa = new SensorsAnalytics(new BatchConsumer(SA_SERVER_URL, SA_BULK_SIZE, MAX_CACHE_SIZE, THROW_EXCEPTION));

 	//发送失败的数据，收集容器。（仅测试使用，避免网络异常时，大批量数据发送失败同时保存内存中，导致 OOM ）
    final List failedDataList = new ArrayList<>();

    //参数含义：数据接收地址，是否定时上报，非定时上报阈值触发条数，内部缓存最大容量，定时刷新时间间隔，网络请求超时时间，请求失败之后异常数据回调
	//提供多重构造函数，可以根据实际去调用不同的构造函数
    final FastBatchConsumer fastBatchConsumer =
        new FastBatchConsumer("serviceUri", false, 50, 6000, 2, 3, new Callback() {
          @Override
          public void onFailed(FailedData failedData) {
            //收集发送失败的数据
            failedDataList.add(failedData);
          }
        });
    //构建 sa 实例对象
    final SensorsAnalytics sa = new SensorsAnalytics(fastBatchConsumer);

    //do something track event
    sa.track(EventRecord.builder().build());

    //异常数据的重发送设置(重发送尽量由另外一个单独的线程来处理完成，避免影响主线程处理逻辑)
    if (!failedDataList.isEmpty()) {
      for (FailedData failedData : failedDataList) {
        try {
          //返回重发送接口发送成功与否，true:发送成功；false:发送失败
          boolean b = fastBatchConsumer.resendFailedData(failedData);
        } catch (Exception e) {
          //处理重发送数据校验异常的情况
          e.printStackTrace();
        }
      }
    }

// 将数据输出到标准输出
final Writer writer = new PrintWriter(System.out);

// 使用 ConsoleConsumer 初始化 SensorsAnalytics
final SensorsAnalytics sa = new SensorsAnalytics(new ConsoleConsumer(writer));

// 使用神策分析记录用户行为数据
// ...

// Flush the writer
writer.flush();