// TinkerUncaughtHandler.java
public class TinkerUncaughtHandler implements Thread.UncaughtExceptionHandler {private static final String TAG = "Tinker.UncaughtHandler";private final Thread.UncaughtExceptionHandler originalHandler;public TinkerUncaughtHandler() {// 获取原始的异常处理器this.originalHandler = Thread.getDefaultUncaughtExceptionHandler();// 设置当前实例为全局异常处理器Thread.setDefaultUncaughtExceptionHandler(this);}@Overridepublic void uncaughtException(Thread t, Throwable e) {// 处理异常handleException(e);// 如果原始处理器不为空，则调用原始处理器处理异常if (originalHandler != null) {originalHandler.uncaughtException(t, e);} else {// 否则终止当前线程android.os.Process.killProcess(android.os.Process.myPid());System.exit(10);}}private void handleException(Throwable e) {// 记录异常信息TinkerLog.e(TAG, "uncaughtException: " + e.getMessage(), e);// 检查是否是Tinker相关异常if (isTinkerRelatedException(e)) {// 处理Tinker相关异常handleTinkerException(e);}// 收集错误信息collectErrorInfo(e);// 上报错误信息reportErrorInfo();}// 其他辅助方法...
}

// AnrMonitor.java
public class AnrMonitor {private static final String TAG = "Tinker.AnrMonitor";private static final long ANR_TIMEOUT = 5000; // 5秒private final Handler mainHandler = new Handler(Looper.getMainLooper());private final Object lock = new Object();private boolean monitoring = false;private long lastCheckTime = 0;public void start() {if (monitoring) {return;}monitoring = true;// 启动定时检查任务mainHandler.postDelayed(new Runnable() {@Overridepublic void run() {checkAnr();if (monitoring) {mainHandler.postDelayed(this, ANR_TIMEOUT);}}}, ANR_TIMEOUT);}public void stop() {monitoring = false;mainHandler.removeCallbacksAndMessages(null);}private void checkAnr() {synchronized (lock) {long currentTime = System.currentTimeMillis();// 如果主线程处理时间过长，认为发生了ANRif (currentTime - lastCheckTime > ANR_TIMEOUT * 2) {TinkerLog.e(TAG, "ANR detected!");// 收集ANR信息collectAnrInfo();// 上报ANR信息reportAnrInfo();}lastCheckTime = currentTime;}}// 其他辅助方法...
}

// ErrorReporter.java
public class ErrorReporter {private static final String TAG = "Tinker.ErrorReporter";public static void collectErrorInfo(Throwable throwable) {if (throwable == null) {return;}// 创建错误信息对象ErrorInfo errorInfo = new ErrorInfo();// 设置错误类型errorInfo.setErrorType(throwable.getClass().getName());// 设置错误消息errorInfo.setErrorMessage(throwable.getMessage());// 设置错误堆栈errorInfo.setStackTrace(getStackTrace(throwable));// 设置时间戳errorInfo.setTimestamp(System.currentTimeMillis());// 保存错误信息saveErrorInfo(errorInfo);}private static String getStackTrace(Throwable throwable) {StringWriter sw = new StringWriter();PrintWriter pw = new PrintWriter(sw);try {// 打印异常堆栈throwable.printStackTrace(pw);// 获取嵌套异常堆栈Throwable cause = throwable.getCause();while (cause != null) {pw.print("\nCaused by: ");cause.printStackTrace(pw);cause = cause.getCause();}return sw.toString();} finally {pw.close();}}// 其他辅助方法...
}

// EnvironmentCollector.java
public class EnvironmentCollector {private static final String TAG = "Tinker.EnvCollector";public static EnvironmentInfo collectEnvironmentInfo(Context context) {if (context == null) {return null;}EnvironmentInfo envInfo = new EnvironmentInfo();try {// 收集设备信息collectDeviceInfo(envInfo);// 收集应用信息collectAppInfo(context, envInfo);// 收集Tinker信息collectTinkerInfo(context, envInfo);// 收集内存信息collectMemoryInfo(envInfo);// 收集CPU信息collectCpuInfo(envInfo);// 收集电池信息collectBatteryInfo(context, envInfo);// 收集网络信息collectNetworkInfo(context, envInfo);} catch (Exception e) {TinkerLog.e(TAG, "collectEnvironmentInfo: Exception", e);}return envInfo;}// 其他辅助方法...
}

// TinkerInfoCollector.java
public class TinkerInfoCollector {private static final String TAG = "Tinker.InfoCollector";public static void collectTinkerInfo(Context context, EnvironmentInfo envInfo) {if (context == null || envInfo == null) {return;}try {// 获取Tinker实例Tinker tinker = Tinker.with(context);// 获取补丁信息PatchInfo patchInfo = tinker.getPatchInfo();if (patchInfo != null) {// 设置补丁版本envInfo.setPatchVersion(patchInfo.getNewVersion());// 设置补丁状态envInfo.setPatchState(patchInfo.isEnabled() ? "enabled" : "disabled");// 设置补丁路径envInfo.setPatchPath(patchInfo.getPatchPath());// 设置补丁加载时间envInfo.setPatchLoadTime(patchInfo.getLoadTime());}// 获取Tinker运行模式envInfo.setTinkerRunMode(tinker.isMainProcess() ? "main_process" : "other_process");// 获取Tinker版本envInfo.setTinkerVersion(TinkerInstaller.getTinkerVersion(context));} catch (Exception e) {TinkerLog.e(TAG, "collectTinkerInfo: Exception", e);}}
}

// ErrorInfoSerializer.java
public class ErrorInfoSerializer {private static final String TAG = "Tinker.ErrorSerializer";public static String serialize(ErrorInfo errorInfo) {if (errorInfo == null) {return null;}try {// 创建JSON对象JSONObject jsonObject = new JSONObject();// 设置基本错误信息jsonObject.put("errorType", errorInfo.getErrorType());jsonObject.put("errorMessage", errorInfo.getErrorMessage());jsonObject.put("stackTrace", errorInfo.getStackTrace());jsonObject.put("timestamp", errorInfo.getTimestamp());// 设置环境信息if (errorInfo.getEnvironmentInfo() != null) {jsonObject.put("environmentInfo", serializeEnvironmentInfo(errorInfo.getEnvironmentInfo()));}return jsonObject.toString();} catch (JSONException e) {TinkerLog.e(TAG, "serialize: JSONException", e);return null;}}private static JSONObject serializeEnvironmentInfo(EnvironmentInfo envInfo) throws JSONException {JSONObject envJson = new JSONObject();// 设置设备信息envJson.put("deviceInfo", serializeDeviceInfo(envInfo.getDeviceInfo()));// 设置应用信息envJson.put("appInfo", serializeAppInfo(envInfo.getAppInfo()));// 设置Tinker信息envJson.put("tinkerInfo", serializeTinkerInfo(envInfo.getTinkerInfo()));// 设置系统信息envJson.put("systemInfo", serializeSystemInfo(envInfo.getSystemInfo()));// 设置性能信息envJson.put("performanceInfo", serializePerformanceInfo(envInfo.getPerformanceInfo()));return envJson;}// 其他辅助方法...
}

// ErrorStorage.java
public class ErrorStorage {private static final String TAG = "Tinker.ErrorStorage";private static final String ERROR_DIR = "tinker_error";private static final String ERROR_FILE_PREFIX = "error_";private static final String ERROR_FILE_SUFFIX = ".json";private static final int MAX_ERROR_FILES = 100; // 最多保存100个错误文件private final Context context;public ErrorStorage(Context context) {this.context = context.getApplicationContext();}public void saveErrorInfo(ErrorInfo errorInfo) {if (errorInfo == null) {return;}try {// 获取错误目录File errorDir = getErrorDirectory();// 创建错误文件File errorFile = createErrorFile(errorDir);// 序列化错误信息String errorJson = ErrorInfoSerializer.serialize(errorInfo);if (errorJson != null) {// 写入文件FileOutputStream fos = new FileOutputStream(errorFile);fos.write(errorJson.getBytes());fos.close();TinkerLog.i(TAG, "Error info saved to: " + errorFile.getAbsolutePath());}// 清理旧的错误文件cleanOldErrorFiles(errorDir);} catch (Exception e) {TinkerLog.e(TAG, "saveErrorInfo: Exception", e);}}private File getErrorDirectory() {File errorDir = new File(context.getFilesDir(), ERROR_DIR);if (!errorDir.exists()) {errorDir.mkdirs();}return errorDir;}// 其他辅助方法...
}

// ErrorReportPolicy.java
public class ErrorReportPolicy {private static final String TAG = "Tinker.ReportPolicy";private static final int MAX_REPORTS_PER_DAY = 10; // 每天最多上报10次private static final int MIN_INTERVAL = 5 * 60 * 1000; // 两次上报之间的最小间隔为5分钟private final Context context;private final SharedPreferences preferences;public ErrorReportPolicy(Context context) {this.context = context.getApplicationContext();this.preferences = context.getSharedPreferences("tinker_error_policy", Context.MODE_PRIVATE);}public boolean shouldReport() {try {// 检查网络连接if (!isNetworkAvailable()) {TinkerLog.i(TAG, "Network not available, skip reporting");return false;}// 检查上报频率if (!checkReportFrequency()) {TinkerLog.i(TAG, "Report frequency exceeded, skip reporting");return false;}// 检查是否处于调试模式if (isDebugMode()) {TinkerLog.i(TAG, "App is in debug mode, skip reporting");return false;}return true;} catch (Exception e) {TinkerLog.e(TAG, "shouldReport: Exception", e);return false;}}private boolean isNetworkAvailable() {ConnectivityManager cm = (ConnectivityManager) context.getSystemService(Context.CONNECTIVITY_SERVICE);NetworkInfo networkInfo = cm.getActiveNetworkInfo();return networkInfo != null && networkInfo.isConnected();}// 其他辅助方法...
}

// ErrorReportScheduler.java
public class ErrorReportScheduler {private static final String TAG = "Tinker.ReportScheduler";private static final long INITIAL_DELAY = 10 * 1000; // 初始延迟10秒private static final long PERIOD = 30 * 60 * 1000; // 周期为30分钟private final Context context;private final ScheduledExecutorService executorService;private final ErrorReportPolicy reportPolicy;private final ErrorReporter errorReporter;public ErrorReportScheduler(Context context) {this.context = context.getApplicationContext();this.executorService = Executors.newSingleThreadScheduledExecutor();this.reportPolicy = new ErrorReportPolicy(context);this.errorReporter = new ErrorReporter(context);}public void start() {// 提交定时任务executorService.scheduleAtFixedRate(new Runnable() {@Overridepublic void run() {try {// 检查是否应该上报if (reportPolicy.shouldReport()) {// 执行上报errorReporter.reportPendingErrors();}} catch (Exception e) {TinkerLog.e(TAG, "Report task error", e);}}}, INITIAL_DELAY, PERIOD, TimeUnit.MILLISECONDS);}public void stop() {executorService.shutdownNow();}// 其他辅助方法...
}

// NetworkClient.java
public class NetworkClient {private static final String TAG = "Tinker.NetworkClient";private static final String REPORT_URL = "https://example.com/tinker/report";private final OkHttpClient client;public NetworkClient() {// 配置OkHttp客户端client = new OkHttpClient.Builder().connectTimeout(10, TimeUnit.SECONDS).readTimeout(30, TimeUnit.SECONDS).writeTimeout(30, TimeUnit.SECONDS).build();}public boolean reportError(String errorJson) {if (errorJson == null || errorJson.isEmpty()) {return false;}try {// 创建请求体RequestBody requestBody = RequestBody.create(MediaType.parse("application/json; charset=utf-8"),errorJson);// 创建请求Request request = new Request.Builder().url(REPORT_URL).post(requestBody).build();// 执行请求Response response = client.newCall(request).execute();if (response.isSuccessful()) {TinkerLog.i(TAG, "Error reported successfully");return true;} else {TinkerLog.w(TAG, "Error report failed, code: " + response.code());return false;}} catch (Exception e) {TinkerLog.e(TAG, "reportError: Exception", e);return false;}}// 其他辅助方法...
}

// ErrorReporter.java
public class ErrorReporter {private static final String TAG = "Tinker.ErrorReporter";private static final int BATCH_SIZE = 5; // 每次上报5个错误private final Context context;private final ErrorStorage errorStorage;private final NetworkClient networkClient;public ErrorReporter(Context context) {this.context = context.getApplicationContext();this.errorStorage = new ErrorStorage(context);this.networkClient = new NetworkClient();}public void reportPendingErrors() {try {// 获取待上报的错误文件List<File> errorFiles = errorStorage.getPendingErrorFiles();if (errorFiles == null || errorFiles.isEmpty()) {TinkerLog.i(TAG, "No pending errors to report");return;}// 分批上报int batchCount = (int) Math.ceil((double) errorFiles.size() / BATCH_SIZE);for (int i = 0; i < batchCount; i++) {int start = i * BATCH_SIZE;int end = Math.min(start + BATCH_SIZE, errorFiles.size());List<File> batchFiles = errorFiles.subList(start, end);// 合并错误信息String batchJson = mergeErrorFiles(batchFiles);if (batchJson != null) {// 上报boolean success = networkClient.reportError(batchJson);// 如果上报成功，删除已上报的错误文件if (success) {for (File file : batchFiles) {file.delete();}}}}} catch (Exception e) {TinkerLog.e(TAG, "reportPendingErrors: Exception", e);}}// 其他辅助方法...
}

// ErrorReporter.java
private void handleReportSuccess(List<File> reportedFiles) {if (reportedFiles == null || reportedFiles.isEmpty()) {return;}try {// 删除已上报的错误文件for (File file : reportedFiles) {if (file.exists()) {file.delete();}}// 记录上报成功信息int count = reportedFiles.size();TinkerLog.i(TAG, "Successfully reported " + count + " error(s)");// 更新上报统计信息updateReportStats(count);} catch (Exception e) {TinkerLog.e(TAG, "handleReportSuccess: Exception", e);}
}

// ErrorReporter.java
private void handleReportFailure(List<File> failedFiles) {if (failedFiles == null || failedFiles.isEmpty()) {return;}try {// 记录上报失败信息int count = failedFiles.size();TinkerLog.w(TAG, "Failed to report " + count + " error(s)");// 更新失败统计信息updateFailureStats(count);// 安排重试scheduleRetry();} catch (Exception e) {TinkerLog.e(TAG, "handleReportFailure: Exception", e);}
}

// ErrorAnalyzer.java
public class ErrorAnalyzer {private static final String TAG = "Tinker.ErrorAnalyzer";public static List<ErrorGroup> analyzeErrors(List<ErrorInfo> errorInfos) {if (errorInfos == null || errorInfos.isEmpty()) {return Collections.emptyList();}// 按错误类型分组Map<String, List<ErrorInfo>> errorGroups = new HashMap<>();for (ErrorInfo errorInfo : errorInfos) {String errorType = errorInfo.getErrorType();if (!errorGroups.containsKey(errorType)) {errorGroups.put(errorType, new ArrayList<>());}errorGroups.get(errorType).add(errorInfo);}// 转换为错误分组对象List<ErrorGroup> result = new ArrayList<>();for (Map.Entry<String, List<ErrorInfo>> entry : errorGroups.entrySet()) {ErrorGroup group = new ErrorGroup();group.setErrorType(entry.getKey());group.setErrorCount(entry.getValue().size());group.setErrorInfos(entry.getValue());// 计算最早和最晚时间long earliestTime = Long.MAX_VALUE;long latestTime = Long.MIN_VALUE;for (ErrorInfo errorInfo : entry.getValue()) {long timestamp = errorInfo.getTimestamp();earliestTime = Math.min(earliestTime, timestamp);latestTime = Math.max(latestTime, timestamp);}group.setFirstOccurrenceTime(earliestTime);group.setLastOccurrenceTime(latestTime);result.add(group);}// 按错误数量排序Collections.sort(result, (g1, g2) -> g2.getErrorCount() - g1.getErrorCount());return result;}// 其他辅助方法...
}

// CustomErrorHandler.java
public class CustomErrorHandler implements TinkerUncaughtHandler.ErrorHandler {private static final String TAG = "CustomErrorHandler";@Overridepublic void handleError(Throwable throwable) {// 记录错误信息TinkerLog.e(TAG, "Custom error handling: " + throwable.getMessage(), throwable);// 收集额外的错误信息collectAdditionalErrorInfo(throwable);// 调用默认的错误处理逻辑TinkerUncaughtHandler.getDefaultHandler().handleError(throwable);}private void collectAdditionalErrorInfo(Throwable throwable) {// 收集额外的错误信息，如用户行为、应用状态等// ...}// 其他自定义方法...
}

// MyApplication.java
public class MyApplication extends Application {@Overridepublic void onCreate() {super.onCreate();// 注册自定义错误处理器TinkerUncaughtHandler.registerErrorHandler(new CustomErrorHandler());// 初始化TinkerTinkerInstaller.install(this);}
}

// AsyncErrorReporter.java
public class AsyncErrorReporter {private static final String TAG = "Tinker.AsyncReporter";private static final int CORE_POOL_SIZE = 1;private static final int MAX_POOL_SIZE = 3;private static final long KEEP_ALIVE_TIME = 60L;private static final TimeUnit TIME_UNIT = TimeUnit.SECONDS;private final ExecutorService executorService;private final ErrorReporter errorReporter;public AsyncErrorReporter(Context context) {// 创建线程池executorService = new ThreadPoolExecutor(CORE_POOL_SIZE,MAX_POOL_SIZE,KEEP_ALIVE_TIME,TIME_UNIT,new LinkedBlockingQueue<Runnable>(),new ThreadFactory() {private final AtomicInteger threadNumber = new AtomicInteger(1);@Overridepublic Thread newThread(Runnable r) {return new Thread(r, "Tinker-Error-Reporter-" + threadNumber.getAndIncrement());}});this.errorReporter = new ErrorReporter(context);}public void reportErrorAsync(final Throwable throwable) {if (throwable == null) {return;}// 提交任务到线程池executorService.submit(new Runnable() {@Overridepublic void run() {try {// 收集错误信息ErrorInfo errorInfo = ErrorInfoCollector.collectErrorInfo(throwable);if (errorInfo != null) {// 保存错误信息errorReporter.saveErrorInfo(errorInfo);// 检查是否需要立即上报if (shouldReportImmediately(throwable)) {errorReporter.reportPendingErrors();}}} catch (Exception e) {TinkerLog.e(TAG, "reportErrorAsync: Exception", e);}}});}// 其他辅助方法...
}

// ErrorReportPolicy.java
private boolean checkReportFrequency() {long currentTime = System.currentTimeMillis();long lastReportTime = preferences.getLong("last_report_time", 0);int todayReports = preferences.getInt("today_reports", 0);// 检查是否是新的一天Calendar calendar = Calendar.getInstance();calendar.setTimeInMillis(currentTime);int currentDay = calendar.get(Calendar.DAY_OF_YEAR);calendar.setTimeInMillis(lastReportTime);int lastReportDay = calendar.get(Calendar.DAY_OF_YEAR);if (currentDay != lastReportDay) {// 新的一天，重置计数Editor editor = preferences.edit();editor.putInt("today_reports", 0);editor.apply();todayReports = 0;}// 检查上报次数是否超过限制if (todayReports >= MAX_REPORTS_PER_DAY) {return false;}// 检查上报间隔if (currentTime - lastReportTime < MIN_INTERVAL) {return false;}return true;
}