当前位置：首页 > news >正文

Yakit 热加载入门学习指南

news 来源：原创 2025/6/13 10:34:00

什么是 Yakit 热加载

Yakit 热加载（HotPatch）是 yaklang 平台中一个强大的功能，允许用户在运行时动态加载和执行 Yak 脚本代码，无需重启应用程序。这个功能在 MITM（中间人攻击）代理、Web 模糊测试和安全测试场景中特别有用，能够让安全研究人员快速调试和修改测试逻辑。

热加载的核心概念是将用户编写的 Yak 代码动态编译并注入到正在运行的系统中，实现实时的功能扩展和修改。这种机制使得 Yakit 具有了极高的灵活性和可扩展性。

热加载的技术架构

核心组件

热加载功能主要由以下几个核心组件构成：

HotPatch 处理器：负责编译和执行热加载代码
MixPluginCaller：管理插件调用和生命周期
YakToCallerManager：处理 Yak 函数到调用者的映射
FuzzTag 系统：支持在模糊测试中使用热加载

热加载处理流程

热加载的核心处理逻辑在 buildHotpatchHandler 函数中实现。这个函数接收用户的 Yak 代码，创建一个新的脚本引擎来执行代码，并返回一个处理函数。

处理流程包括：

代码验证和编译
创建执行环境
函数查找和参数处理
结果返回和错误处理

MITM 中的热加载应用

加载热加载脚本

在 MITM 代理中，热加载功能通过 LoadHotPatch 方法实现：

这个方法执行以下步骤：

重置过滤器状态
移除之前的热加载脚本
添加新的热加载脚本到调用管理器
处理加载错误和反馈

MITM 热加载集成

在 MITM 服务中，热加载脚本的加载过程如下：

当检测到热加载脚本内容时，系统会：

调用 LoadHotPatch 方法加载脚本
更新当前的 Hook 状态
处理加载错误并广播错误信息
继续处理后续请求

模糊测试中的热加载

FuzzTag 热加载支持

热加载功能也集成到了模糊测试的 FuzzTag 系统中：

这里定义了两种热加载 FuzzTag：

yak：标准热加载标签
yak:dyn：动态热加载标签

热加载配置选项

系统提供了多种热加载配置选项：

Fuzz_WithHotPatch：添加标准热加载支持
Fuzz_WithDynHotPatch：添加动态热加载支持
Fuzz_WithAllHotPatch：同时添加两种热加载支持

热加载模板管理

模板存储和管理

Yakit 提供了完整的热加载模板管理系统：

模板管理功能包括：

创建和更新模板
模板查询和检索
模板删除和清理

模板操作

系统支持灵活的模板更新操作，可以单独更新模板的名称、内容或类型。

实际使用示例

基础热加载脚本

以下是一个简单的热加载脚本示例：

// 定义一个处理函数
handle = func(params) {// 解析参数if params == "" {return ["default_value"]}// 处理逻辑result = str.ToUpper(params)return [result]
}// 定义一个带回调的处理函数
handleWithCallback = func(params, yield) {values = str.Split(params, ",")for value in values {yield(str.Trim(value))}
}

MITM 热加载脚本

在 MITM 场景中的热加载脚本：

// HTTP 请求劫持
hijackHTTPRequest = func(isHttps, url, reqInstance, forward, drop) {// 修改请求头reqInstance.Header["X-Custom-Header"] = ["HotPatch-Modified"]// 记录请求信息log.info("劫持请求: %s", url)// 转发请求forward(reqInstance)
}// HTTP 响应劫持
hijackHTTPResponse = func(isHttps, url, rspInstance, forward, drop) {// 修改响应内容body = rspInstance.GetBody()if str.Contains(body, "error") {log.warn("检测到错误响应: %s", url)}// 转发响应forward(rspInstance)
}

模糊测试热加载

在模糊测试中使用热加载：

// 自定义 payload 生成器
generatePayload = func(params) {base = paramsif base == "" {base = "test"}payloads = []// 生成 SQL 注入 payloadpayloads = append(payloads, base + "' OR 1=1--")payloads = append(payloads, base + "'; DROP TABLE users;--")// 生成 XSS payloadpayloads = append(payloads, base + "<script>alert('xss')</script>")payloads = append(payloads, base + "javascript:alert('xss')")return payloads
}// 动态 payload 生成器
dynamicGenerator = func(params, yield) {for i = 0; i < 10; i++ {payload = sprintf("%s_%d", params, i)yield(payload)}
}

热加载最佳实践

1. 错误处理

在热加载脚本中，始终要包含适当的错误处理：

handle = func(params) {try {// 主要逻辑result = processData(params)return [result]} catch err {log.error("热加载脚本错误: %v", err)return [params] // 返回原始值作为后备}
}

2. 性能考虑

热加载脚本应该保持轻量级，避免耗时操作：

// 好的做法：快速处理
handle = func(params) {return [str.ToUpper(params)]
}// 避免：耗时操作
handle = func(params) {// 避免在热加载中进行网络请求或文件 I/O// time.Sleep(5 * time.Second) // 不要这样做return [params]
}

3. 状态管理

使用全局变量来维护状态：

// 全局计数器
counter = 0handle = func(params) {counter++result = sprintf("%s_%d", params, counter)return [result]
}

4. 调试技巧

使用日志来调试热加载脚本：

handle = func(params) {log.info("热加载输入: %s", params)result = processData(params)log.info("热加载输出: %s", result)return [result]
}

常见问题和解决方案

1. 函数未找到错误

问题：热加载脚本报告函数未找到

解决方案：

确保函数名称正确
检查函数参数数量
验证函数定义语法

2. 参数类型错误

问题：传递给热加载函数的参数类型不匹配

解决方案：

在函数开始处添加类型检查
使用类型转换函数
提供默认值处理

3. 性能问题

问题：热加载脚本执行缓慢

解决方案：

优化算法复杂度
避免重复计算
使用缓存机制

4. 内存泄漏

问题：长时间运行后内存使用增加

解决方案：

及时清理不需要的变量
避免创建大量对象
使用适当的数据结构

高级特性

1. 动态函数注册

热加载支持动态注册多个处理函数：

// 注册多个处理器
handlers = {"encode": func(params) {return [codec.EncodeBase64(params)]},"decode": func(params) {return [codec.DecodeBase64(params)]},"hash": func(params) {return [codec.Md5(params)]}
}// 主处理函数
handle = func(params) {parts = str.Split(params, "|")if len(parts) < 2 {return [params]}action = parts[0]data = parts[1]if handler, ok = handlers[action]; ok {return handler(data)}return [params]
}

2. 配置驱动的热加载

使用配置文件驱动热加载行为：

// 配置对象
config = {"enabled": true,"debug": false,"max_length": 1000,"allowed_patterns": ["*.php", "*.jsp"]
}handle = func(params) {if !config["enabled"] {return [params]}if config["debug"] {log.info("处理参数: %s", params)}if len(params) > config["max_length"] {return [params[:config["max_length"]]]}return [processParams(params)]
}

3. 插件化架构

实现插件化的热加载架构：

// 插件接口
plugins = []// 注册插件
registerPlugin = func(name, handler) {plugin = {"name": name,"handler": handler}plugins = append(plugins, plugin)
}// 执行所有插件
handle = func(params) {result = paramsfor plugin in plugins {result = plugin["handler"](result)[0]}return [result]
}// 注册具体插件
registerPlugin("uppercase", func(data) {return [str.ToUpper(data)]
})registerPlugin("trim", func(data) {return [str.Trim(data)]
})