本地分流 Java SDK 集成（A/B Testing）

普通Java项目初始化SDK

        // 初始化神策分析 SDK
        final ISensorsAnalytics sa = new SensorsAnalytics(new ConcurrentLoggingConsumer("file.log"));
        // 构建配置 A/B Testing 试验全局参数
        ABGlobalConfig abGlobalConfig = ABGlobalConfig.builder()
                                            .setApiUrl("分流试验请求地址")    
                                            .setSensorsAnalytics(sa)    // 神策分析埋点 SDK 实例
                                            .build();
        // 初始化 A/B Testing SDK
        final ISensorsABTestLocal abTest = new SensorsABTestLocal(abGlobalConfig);

静态工厂

public class ABTestInstanceFactory {

  public static ISensorsABTestLocal getABTestConfigInstance(String url, ISensorsAnalytics sa)
      throws InvalidArgumentException {
    ABGlobalConfig config = ABGlobalConfig.builder().setApiUrl(url).setSensorsAnalytics(sa).build();
    return new SensorsABTestLocal(config);
  }

}

xml创建bean对象

使用注解创建Bean对象

@Configuration
public class SensorsConfig {

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

  @Bean
  public ISensorsABTestLocal initSensorsABTest(ISensorsAnalytics sa) throws InvalidArgumentException {
    String url = "分流试验地址";
    ABGlobalConfig config = ABGlobalConfig.builder().setApiUrl(url).setSensorsAnalytics(sa).build();
    return new SensorsABTestLocal(config);
  }

}

在业务代码中调用Bean对象

@Service
public class TestServiceImpl implements ITestService {

  //注入神策实例化对象
  @Autowired
  ISensorsAnalytics sa;
  
  //注入 A/B Testing 实例化对象
  @Autowired
  ISensorsABTestLocal abTest;
  
  public String abTest(String userId) throws InvalidArgumentException, IOException {
    Experiment experiment = abTest.fastFetchABTest(userId, true, "color", "grey");
    String result = experiment.getResult();
    switch (result) {
      case "试验值一":
        //命中试验一 do something
        break;
      case "试验值二":
        //命中试验二 do something
        break;
      case "grey":
        //没有命中任何试验，返回设置默认值
        break;
    }
    return "success";
  }
}

获取分流试验变量信息

String distinctId = "fz123456"; // 具体的用户 ID 标识
boolean isLoginId = true; // 当前用户是否是登录 ID
  
// Integer 类型试验（第四个参数 0，表示未命中试验时，会返回此默认值，请根据业务需要更改此处的值）
Experiment experiment = abTest.fastFetchABTest(distinctId, isLoginId, "具体的试验参数", 0);
int result = experiment.getResult();                 
// TODO 根据 result 处理相应逻辑
        switch (result) {
            case 0:
                break;
            case 1:
                // 试验组 1 的处理逻辑
                break;
            case 2:
                // 试验组 2 的处理逻辑
                break;
            // ……
            // ……
            default:
                // 其他情况的处理逻辑
                break;
        }

携带自定义属性获取试验变量

// 当前为 Integer 类型试验（第二个参数 0，表示未命中试验时，会返回此默认值，请根据业务需要更改此处的值）
String distinctId = "fz123456"; // 具体的用户 ID 标识
boolean isLoginId = true; // 当前用户是否是登录 ID
Map properties = Maps.newHashMap();
properties.put("自定义属性对应英文名", "自定义属性对应 value"); // 自定义属性

// 当前为 Integer 类型试验（第四个参数 0，表示未命中试验时，会返回此默认值，请根据业务需要更改此处的值）
Experiment experiment = abTest.fastFetchABTest(distinctId, isLoginId, "具体的试验参数", 0, properties);
// TODO 请根据 experiment.getResult() 进行自己的试验
switch (result) {
    case 0:
        break;
    case 1:
        // 试验组 1 的处理逻辑
        break;
    case 2:
        // 试验组 2 的处理逻辑
        break;
    // ……
    // ……
    default:
        // 其他情况的处理逻辑
        break;
}

自定义主体分流

String distinctId = "fz123456"; // 具体的用户 ID 标识
boolean isLoginId = true; // 当前用户是否是登录 ID
  
// Integer 类型试验（第四个参数 0，表示未命中试验时，会返回此默认值，请根据业务需要更改此处的值）
Experiment experiment = abTest.fastFetchABTest(
              SensorsABParams.starter(distinctId, isLoginId, "具体的试验参数", 0).addCustomId("自定义主体参数名", "自定义主体参数值").build());
int result = experiment.getResult();                 
// TODO 根据 result 处理相应逻辑
        switch (result) {
            case 0:
                break;
            case 1:
                // 试验组 1 的处理逻辑
                break;
            case 2:
                // 试验组 2 的处理逻辑
                break;
            // ……
            // ……
            default:
                // 其他情况的处理逻辑
                break;
        }

//如果需要上报事件参与AB试验指标计算，需要将该自定义主体作为事件属性
      sa.track(EventRecord.builder().setDistinctId(distinctId).isLoginId(isLoginId)
          .setEventName("buy")
          .addProperty("自定义主体参数名", "自定义主体参数值")
          .addProperty("price", 100)
          .build());

获取设备主体试验变量

String distinctId = "anonymous_id"; // 匿名ID
boolean isLoginId = false; // 当前distinctId不是登录ID
   
// Integer 类型试验（第四个参数 0，表示未命中试验时，会返回此默认值，请根据业务需要更改此处的值）
Experiment experiment = abTest.fastFetchABTest(distinctId, isLoginId, "具体的试验参数", 0);
int result = experiment.getResult();                
// TODO 根据 result 处理相应逻辑
        switch (result) {
            case 0:
                break;
            case 1:
                // 试验组 1 的处理逻辑
                break;
            case 2:
                // 试验组 2 的处理逻辑
                break;
            // ……
            // ……
            default:
                // 其他情况的处理逻辑
                break;
        }
 
//如果需要上报事件参与AB设备主体试验指标计算，需要在每条埋点事件中将anonymous_id作为事件属性上报，如下所示
sa.track(EventRecord.builder().setDistinctId(distinctId).isLoginId(isLoginId)
  .setEventName("buy")
  .addProperty("anonymous_id", distinctId)    //将anonymous_id作为事件属性上报
  .addProperty("price", 100)
  .build());

手动触发AB事件

// 手动触发 A/B 测试（$ABTestTrigger）事件
abTest.trackABTestTrigger(experiment)