zogo/fileupload

zogo/fileupload

通用大文件分片上传 Go/Gin 服务端核心（zogo 子包）。 六接口（init/chunk/merge/check/task/abort）+ 分片幂等 + 断点续传 + .part 原子改名 + 合并整文件 MD5 校验 + 秒传。 不依赖宿主的响应封装、ORM 或业务表——存储走 Repository 接口注入，业务衔接走 Options 回调。

用法

import "git.zeroonesoft.cn/golib/zogo/fileupload"

opts := fileupload.Options{
    ChunkRoot:      "./data/upload-chunks",        // 分片临时目录（建议在静态根之外）
    CloudDir:       "./data/uploads/cloud",        // 合并产物目录
    WebPathPrefix:  "cloud",                       // storagePath 的 Web 前缀（须与 CloudDir 相对静态根的子目录一致）
    URLPrefix:      "/uploads",                    // fileUrl = URLPrefix + "/" + storagePath
    MaxTotalSizeMB: 2048,                          // 0=不限
    OnMerged: func(t fileupload.TaskInfo) error {
        // 合并成功：宿主写自己的业务表（如云盘记录行）；失败则 merge 整体失败
        return nil
    },
    OnInstantHit: func(t fileupload.TaskInfo) error {
        // 秒传命中：宿主确保业务侧可见行（可空回调）
        return nil
    },
    Envelope: func(c *gin.Context, resp any, err error) {
        // 宿主自己的响应封装，如 httpx.HandleResult(c, resp, err)
    },
}
_ = fileupload.Mount(api.Group("/upload"), opts, myRepo,
    fileupload.WithIdentity(func(c *gin.Context) (string, int64) {
        return c.GetString("UserName"), c.GetInt64("TenantId")
    }))

Repository（12 个方法）由宿主按自己的表结构实现；软删/硬删自定，但删除后查询必须不可见。 鉴权由宿主路由组的 JWT 中间件统一负责，本库不感知。

版本

• v0.1.0 首版：自 FileUpload 项目 restful/upload 模块抽出