CI Release Swift Platforms SPM License
HTTPMediaCache 是一个 Swift-only 的本地 HTTP 多媒体缓存库。它通过本地代理承接播放器请求,支持普通文件与 HLS 资源的边播边缓存、Range 请求、预加载、HLS 播放列表改写、缓存查询和缓存清理。
- 本地 HTTP 代理,播放器可直接使用代理 URL 播放。
- 支持 HTTP Range 请求,按已缓存区间和远端区间组合读取。
- 支持 MP4 等文件资源的完整或指定字节数预加载。
- 支持 HLS master/media playlist 改写,segment、key、init map 可进入缓存链路。
- 支持 HLS 预加载策略:全部、segment 数、目标时长、目标字节数。
- 支持自定义缓存 identity、HLS 分资源请求头策略和 URLSession 下载指标回调。
- 支持缓存列表、缓存进度、完整文件路径、总缓存大小和删除 API。
- 支持 iOS 与 macOS,包含示例工程和 Swift Package 测试。
- iOS 15.0+
- macOS 12.0+
- Swift 5.10+
- Swift Package Manager
在 Package.swift 中添加依赖:
.package(url: "https://github.com/sunimp/HTTPMediaCache.git", from: "1.0.3")
然后将 HTTPMediaCache 添加到 target dependencies:
.target( name: "YourApp", dependencies: ["HTTPMediaCache"] )
启动本地代理,并将原始媒体 URL 转成播放器可播放的代理 URL:
import AVFoundation import HTTPMediaCache try await HTTPMediaCache.start(port: 0) let originalURL = URL(string: "https://example.com/video.mp4")! let proxyURL = try await HTTPMediaCache.proxyURL(for: originalURL) let player = AVPlayer(url: proxyURL)
需要识别或还原代理 URL 时:
if HTTPMediaCache.isProxyURL(proxyURL) { let restoredURL = HTTPMediaCache.originalURL(from: proxyURL) }
应用退出或不再需要代理时可以停止服务:
await HTTPMediaCache.stop()
完整架构图可查看 Documentation/architecture.html,维护说明可查看 Documentation/architecture.md。
flowchart LR
App[业务 App / AVPlayer] --> API[API<br/>HTTPMediaCache / CacheRequest / PreloadTask]
Example[Example<br/>iOS / macOS] --> API
Tests[Tests<br/>XCTest] --> API
API --> Runtime[Core<br/>CacheRuntime / ByteRange / ProxyURLCodec]
API --> Coordinator[PreloadCoordinator]
Coordinator --> FilePreload[Pipeline<br/>FilePreloadExecutor]
Coordinator --> HLSPreload[HLS<br/>HLSPreloadExecutor]
Runtime --> Proxy[Proxy<br/>NIOProxyServer / HTTPRequestRouter]
Proxy --> Writer[HTTPResponseWriter<br/>StreamingProxyBodyPump]
Proxy --> Pipeline[Pipeline<br/>DataReader / SourcePlanner]
Proxy --> HLS[HLS<br/>Parser / Rewriter / Selection / Policy]
FilePreload --> Pipeline
HLSPreload --> HLS
HLS --> Pipeline
Pipeline --> Storage[Storage<br/>CacheIndex / CacheUnit / FileStore]
Pipeline --> Network[Network<br/>CacheDownloading / URLSessionDownloader]
HLS --> Network
Storage --> Disk[(本地缓存文件)]
Network --> Origin[(Origin / CDN)]
HTTPMediaCache 对普通 file-based media 与 HLS 使用同一个本地代理入口,但进入代理后会按资源类型分流:
flowchart TD
A[播放器请求代理 URL] --> B[NIOProxyServer]
B --> C{是否为 ping 或无效代理 URL?}
C -- 是 --> D[返回 ping 或 404]
C -- 否 --> E[解码原始 URL<br/>透传允许的请求头并规范化 Range]
E --> F{是否为 HLS playlist?}
F -- 是 --> H1[按 HLS playlist 策略清洗请求头<br/>不使用播放器 Range]
H1 --> H2{本地是否有完整原始 playlist?}
H2 -- 是 --> H3[读取本地原始 playlist]
H2 -- 否 --> H4[回源下载原始 playlist]
H4 --> H5[缓存原始 playlist<br/>清除代理标记内容]
H3 --> H6[解析 master/media playlist]
H5 --> H6
H6 --> H7[按 variant/rendition 选择策略过滤]
H7 --> H8[改写 variant、rendition、key、init map、segment URI 为代理 URL]
H8 --> H9[返回改写后的 playlist]
H9 --> H10[播放器继续请求被改写后的子资源]
H10 --> E
F -- 否 --> G{是否为 HLS 子资源代理 URL?}
G -- 是 --> G1[按 kind 清洗请求头<br/>playlist/key/完整 segment 不带 Range<br/>init map/byte-range segment 使用 playlist Range]
G -- 否 --> G2[使用普通媒体请求策略]
G1 --> I
G2 --> I
I{是否命中完整缓存<br/>且客户端未显式请求 Range?}
I -- 是 --> J[返回 200 + 本地完整数据]
I -- 否 --> K{是否命中请求区间缓存?}
K -- 是 --> L[返回 200/206 + 本地区间数据]
K -- 否 --> M{是否为 HEAD 请求?}
M -- 是 --> N[回源获取响应头<br/>返回 200/206 head]
M -- 否 --> O{是否可流式回源?}
O -- 是,部分命中 --> P[SourcePlanner 拆分 file/network 段<br/>本地段读缓存,远端段流式下载并写缓存]
O -- 是,未命中 --> Q[流式回源响应<br/>边写播放器边写缓存]
O -- 否 --> R[SourcePlanner 拼接缓存段和回源段<br/>缺失 Range 可按配置分块下载]
P --> S[HTTPResponseWriter 返回 200/206]
Q --> S
R --> S
普通 file-based media 的核心是字节区间缓存:代理会先检查完整缓存或请求区间缓存;如果只命中部分区间,SourcePlanner 会把请求拆成 file 和 network 段,本地段直接从 FileStore 读取,缺失段回源下载并写回缓存,最后按客户端是否请求 Range 返回 200 或 206。
HLS 的核心是 playlist 改写:代理识别 .m3u 资源后,会缓存原始 playlist,并在响应播放器前把 playlist 中的 variant、rendition、segment、key、init map URI 改写成新的代理 URL。播放器随后请求这些子资源时,子资源会重新进入普通文件缓存链路;其中 playlist、key 和完整 segment 回源默认不带播放器请求头,也不会额外生成默认 Range;init map 和 byte-range segment 只使用 playlist 中声明的 BYTERANGE 生成 Range。
预加载也会按同样的边界分流:
flowchart TD
A[HTTPMediaCache.preload] --> B[注册 PreloadTask<br/>进入并发队列]
B --> C{请求 URL 是否为 HLS playlist?}
C -- 否:file-based media --> D{FileLimit}
D -- all --> E{目标 Range 是否已完整缓存?}
E -- 是 --> F[进度 1.0<br/>完成]
E -- 否 --> G{Downloader 是否支持 streaming?}
G -- 是 --> H[流式下载目标 Range<br/>边下载边写缓存并上报进度]
G -- 否 --> I[下载目标数据<br/>一次性写入缓存]
D -- byteCount --> J[探测或读取 total length]
J --> K[计算目标前缀区间]
K --> L{起点为 0 且 probe 区间未缓存?}
L -- 是 --> M[下载 probe 区间并写入缓存]
L -- 否 --> N[读取当前缓存区间]
M --> N
N --> O[按缓存区间规划缺失 Range]
O --> P[按目标长度拆分下载缺失 Range<br/>写入缓存并上报进度]
C -- 是:HLS playlist --> Q[按 HLS playlist 策略下载或读取原始 playlist]
Q --> R[解析 master/media playlist]
R --> T{选择策略是否命中 child playlist?}
T -- 是 --> U[按选中的 variant/rendition<br/>递归预加载子 playlist]
U --> R
T -- 否 --> V[按 HLSLimit 计算目标 segment 数]
V --> W[生成资源动作队列<br/>key、init map、segment]
W --> X{资源是否已完整缓存?}
X -- 是 --> Y[复用缓存并推进进度]
X -- 否 --> Z{Downloader 是否支持 streaming?}
Z -- 是 --> AA[流式下载资源<br/>边写缓存边上报 segment 进度]
Z -- 否 --> AB[通过 DataReader 下载并写缓存]
Y --> AC{是否达到 segment 数、时长或字节数限制?}
AA --> AC
AB --> AC
AC -- 否 --> X
AC -- 是 --> AD[进度 1.0<br/>完成]
H --> AD
I --> AD
P --> AD
使用统一的 CacheRequest 与 PreloadOptions 控制预加载范围:
let request = CacheRequest(url: originalURL) let task = try await HTTPMediaCache.preload( request, options: .init(hlsLimit: .duration(30), fileLimit: .byteCount(2 * 1024 * 1024)) ) for await progress in task.progress { print("preload progress:", progress) } try await task.waitForCompletion()
也可以使用便捷入口:
// 预加载完整资源 let fullTask = try await HTTPMediaCache.preload(originalURL) // 文件资源预加载指定字节数;HLS 资源按 segment 累计到指定字节数 let sizeTask = try await HTTPMediaCache.preload(originalURL, prefetchSize: 2 * 1024 * 1024) // HLS 资源预加载指定 segment 数;文件资源会预加载完整文件 let countTask = try await HTTPMediaCache.preload(originalURL, prefetchFileCount: 3) // HLS 资源按 EXTINF 累计到目标时长;segment 会完整缓存,不做时间点截断 let durationTask = try await HTTPMediaCache.preload(originalURL, preloadDuration: 30)
文件资源按字节数预加载时会先探测资源总长度,再按连续 Range 分段下载缺失的前缀区间;已有缓存区间不会重复下载。
控制预加载队列:
await HTTPMediaCache.setMaxConcurrentPreloadCount(2) let count = await HTTPMediaCache.maxConcurrentPreloadCount() await HTTPMediaCache.cancelAllPreloadTasks()
除了本地代理播放,也可以直接创建读取器或加载器,在业务层读取数据并复用同一套缓存索引:
let request = CacheRequest(url: originalURL, range: ByteRange(start: 0, end: 1023)) let reader = await HTTPMediaCache.cacheReader(with: request) let data = try await reader.read() let loader = await HTTPMediaCache.cacheLoader(with: CacheRequest(url: originalURL)) let fullData = try await loader.load() let hlsLoader = await HTTPMediaCache.cacheHLSLoader(with: CacheRequest(url: playlistURL)) let playlistData = try await hlsLoader.load()
如果 master playlist 中有多个清晰度、音轨或字幕,可以设置选择回调。未设置时会使用默认策略。
await HTTPMediaCache.setHLSVariantStreamSelectionHandler { streams, _, _ in streams.max { 0ドル.bandwidth < 1ドル.bandwidth } } await HTTPMediaCache.setHLSRenditionSelectionHandler { type, renditions, _, _ in switch type { case .audio: return renditions.first { 0ドル.isDefault } ?? renditions.first default: return renditions.first } }
也可以在 HLS 内容返回给播放器前进行最后处理:
await HTTPMediaCache.setHLSContentHandler { playlist in playlist }
如果 HLS 子资源需要独立鉴权或业务请求头,可以按资源类型提供下载请求头。Provider 返回的 Range 会被忽略,init map 和 byte-range segment 的 Range 仍由 playlist 中的 BYTERANGE 决定。
await HTTPMediaCache.setHLSDownloadHeaderProvider { context in switch context.kind { case .playlist, .variantPlaylist, .renditionPlaylist, .subtitlePlaylist, .iFramePlaylist: return ["Authorization": "Bearer playlist-token"] case .key: return ["Authorization": "Bearer key-token"] case .initialization, .segment: return ["Authorization": "Bearer media-token"] } }
let item = try await HTTPMediaCache.cacheItem(for: originalURL) let allItems = try await HTTPMediaCache.allCacheItems() let totalLength = try await HTTPMediaCache.totalCacheLength() let completeFileURL = try await HTTPMediaCache.completeFileURL(for: originalURL) try await HTTPMediaCache.deleteCache(for: originalURL) try await HTTPMediaCache.deleteAllCaches()
限制缓存空间:
await HTTPMediaCache.setMaxCacheLength(500 * 1024 * 1024) let maxLength = await HTTPMediaCache.maxCacheLength()
当写入新数据会超过最大缓存空间时,缓存索引会按最近访问时间淘汰未使用中的旧缓存,并跳过正在读取或写入的缓存单元。成功写入、读取缓存数据和获取完整缓存文件路径都会刷新缓存单元的最近访问时间;单纯查询 cacheItem 或缓存列表不会改变淘汰顺序。
默认缓存目录为系统 Caches/HTTPMediaCache。系统可按平台策略清理该目录,业务侧仍可通过 deleteCache 或 deleteAllCaches 主动清理缓存。
如果单次写入长度超过最大缓存空间,相关预加载、读取或代理链路会抛出 CacheError.insufficientCacheSpace(requiredLength:maxCacheLength:),调用方可以按需单独处理该错误。
可以配置下载超时、透传请求头、额外请求头和可接受的响应类型:
await HTTPMediaCache.setDownloadTimeoutInterval(30) await HTTPMediaCache.setDownloadWhitelistHeaderKeys(["User-Agent", "Cookie"]) await HTTPMediaCache.setDownloadAdditionalHeaders(["X-Client": "YourApp"]) await HTTPMediaCache.setDownloadAcceptableContentTypes(["video/", "audio/", "application/vnd.apple.mpegurl"])
当服务端返回业务上可忽略的非媒体内容类型时,可以通过 disposer 决定是否接受该响应:
await HTTPMediaCache.setDownloadUnacceptableContentTypeDisposer { url, contentType in contentType == "application/octet-stream" }
缺失缓存区间回源时默认会按请求区间下载;如果需要控制单次 Range 请求长度,可以配置分段策略:
await HTTPMediaCache.setDownloadRequestHeaderRangeLength { url, totalLength in min(totalLength, 2 * 1024 * 1024) }
如果业务存在 URL 鉴权、重定向或 CDN 参数转换,可以使用 URL converter 统一处理下载侧 URL:
await HTTPMediaCache.setURLConverter { url in url }
如果不同 URL 实际指向同一份缓存内容,可以自定义缓存 identity。设置后优先级高于 URL converter:
await HTTPMediaCache.setCacheIdentifierProvider { url in var components = URLComponents(url: url, resolvingAgainstBaseURL: false) components?.query = nil return components?.url?.absoluteString ?? url.absoluteString }
需要观测默认 URLSession 下载性能时,可以接收每个任务的 URLSessionTaskMetrics:
await HTTPMediaCache.setDownloadMetricsHandler { url, metrics in print("download metrics:", url, metrics) }
HTTPMediaCache 默认不输出控制台日志,也不记录日志文件。需要排查问题时可以按需开启:
await HTTPMediaCache.setConsoleLogEnable(true) await HTTPMediaCache.setRecordLogEnable(true) await HTTPMediaCache.addLog("custom business log") let logFileURL = await HTTPMediaCache.recordLogFileURL() await HTTPMediaCache.deleteRecordLogFile()
预加载或代理链路中的错误会按 URL 记录,可用于业务侧展示或诊断:
let error = await HTTPMediaCache.error(for: originalURL) let errors = await HTTPMediaCache.errors() await HTTPMediaCache.cleanError(for: originalURL) await HTTPMediaCache.cleanErrors()
仓库内提供 iOS 与 macOS 示例工程:
open Example/HTTPMediaCacheExample.xcodeproj
也可以直接运行测试:
swift test欢迎提交 issue 和 pull request。提交前请尽量保证:
- 新增或修改行为有对应测试。
- 公开 API 保持文档注释清晰。
- Swift 代码已格式化。
- README 中的示例仍然可编译。
HTTPMediaCache 的实现参考了以下开源项目的设计与经验:
HTTPMediaCache 基于 MIT 协议开源,详见 LICENSE。