理解 RUM 采样：机制、规则与最佳实践

val rumConfig = RumConfiguration.Builder(applicationId)
    .setSessionSampleRate(20f)            // 拿到控制台配置前使用的值
    .setRemoteConfigurationEnabled(true)
    .setBeforeSampling { context ->
        val custom = context.custom
        val user = currentUser
        when {
            custom?.get("incidentMode") == true -> 100f            // 排查模式：全量采集
            user.isInternal || user.isVip -> 100f                  // 重点用户：必采
            (custom?.get("debugUsers") as? List<*>)?.contains(user.id) == true -> 100f // 排查名单：必采
            // 底座：按用户 ID 确定性哈希分桶，桶的大小跟随控制台的会话采样率
            else -> if (hash(user.id + (custom?.get("salt") ?: "")) % 100 < context.sessionSampleRate) 100f else 0f
        }
    }
    .build()
Rum.enable(rumConfig)

let rumConfig = RUM.Configuration(
    applicationID: "<RUM_APPLICATION_ID>",
    sessionSampleRate: 20,                // 拿到控制台配置前使用的值
    remoteConfigurationEnabled: true,
    beforeSampling: { context in
        let custom = context.custom
        let user = currentUser
        if custom?["incidentMode"] as? Bool == true { return 100 }   // 排查模式：全量采集
        if user.isInternal || user.isVip { return 100 }              // 重点用户：必采
        if (custom?["debugUsers"] as? [String])?.contains(user.id) == true { return 100 } // 排查名单：必采

        // 底座：按用户 ID 确定性哈希分桶，桶的大小跟随控制台的会话采样率
        let salt = custom?["salt"] as? String ?? ""
        return Float(hash(user.id + salt) % 100) < context.sessionSampleRate ? 100 : 0
    }
)
RUM.enable(with: rumConfig)

// 保留完整数据的用户占比
const DETAIL_SAMPLE_RATE = 20;
// 细节用户中再录制多少比例的回放
const REPLAY_SAMPLE_RATE = 10;

// 把分桶 key 稳定映射到 0-99，同一个 key 的所有事件落在同一个桶
function bucketOf(key) {
  let hash = 0;
  for (let i = 0; i < key.length; i++) {
    hash = (hash * 31 + key.charCodeAt(i)) | 0;
  }
  return Math.abs(hash) % 100;
}

// 业务自行实现：登录用户 ID 优先，否则用自维护的匿名 ID（生成后存入 localStorage）
const bucketKey = getCurrentUserId() || getOrCreateAnonId();
const inDetailBucket = bucketOf(bucketKey) < DETAIL_SAMPLE_RATE;

flashcatRum.init({
  applicationId: "<APPLICATION_ID>",
  clientToken: "<CLIENT_TOKEN>",
  sessionSampleRate: 100, // 会话全量采集，保证错误一条不漏
  // 重放对齐：细节用户内再抽 REPLAY_SAMPLE_RATE，其余用户永不录制（不接重放可省略本行）
  sessionReplaySampleRate: inDetailBucket ? REPLAY_SAMPLE_RATE : 0,
  trackResources: true,
  trackUserInteractions: true,
  trackLongTasks: true,
  beforeSend: (event) => {
    // 与 init() 前完全相同的判定，保证两处一致
    const isDetail = bucketOf(getCurrentUserId() || getOrCreateAnonId()) < DETAIL_SAMPLE_RATE;

    // 给每条留下来的事件盖章，标明这条会话是完整现场还是仅错误摘要
    event.context = {
      ...event.context,
      rum_sampling: isDetail ? "full" : "errors_only",
    };

    // 视图事件无法丢弃，显式放行以免触发 SDK 告警
    if (event.type === "view") return true;

    // 错误事件永远保留
    if (event.type === "error") return true;

    // 失败的请求永远保留
    if (event.type === "resource") {
      const statusCode = event.resource.status_code;
      if (statusCode === 0 || statusCode >= 400) return true;
    }

    // 其余数据只保留中签用户的
    return isDetail;
  },
});