Go并发图片缩放压缩需用image库处理图像、sync.WaitGroup协调、Worker Pool控并发数(如6个worker),避免内存爆炸;processImage函数负责解码、Lanczos缩放、按扩展名选择编码器并控制JPEG质量。
用 Go 实现并发图片缩放与压缩,核心是结合 image 标准库处理图像 + sync.WaitGroup 控制并发 + goroutine 并行执行。关键不是“开很多 goroutine”,而是合理控制并发数、避免内存爆炸、统一错误处理。
Go 自带 image/* 包(如 image/jpeg, image/png),无需第三方库即可完成基础缩放和压缩。若需更高性能或支持 WebP/HEIC,可选 disintegration/imaging(轻量、API 简洁)或 h2non/bimg(基于 libvips,内存友好)。
推荐起步用 imaging:
go get -u github.com/disintegration/imaging
定义任务结构体,方便传参:
type ImageTask struct {
SrcPath string
DstPath string
Width int
Height int
Quality int // JPEG 质量 1-100
}
直接为每个文件启一个 goroutine 容易在处理上百张图时打爆内存或触发系统 open files 限制。应使用固定数量的 worker 处理任务队列。
ImageTask 发送到 channel示例启动逻辑:
tasks := make(chan ImageTask, 1000) var wg sync.WaitGroup// 启动 6 个 worker for i := 0; i < 6; i++ { wg.Add(1) go func() { defer wg.Done() for task := range tasks { if err := processImage(task); err != nil { log.Printf("fail on %s: %v", task.SrcPath, err) } } }() }
// 发送所有任务 for _, t := range allTasks { tasks <- t } close(tasks) wg.Wait() // 等所有 worker 完成
processImage 函数负责读取、缩放、编码、写入。注意三点:内存释放、格式推断、质量控制。
os.Open 读源文件,处理完立即 Close()
image.Decode 自动识别格式(支持 JPEG/PNG/GIF)imaging.Resize 缩放(支持 Linear/Bicubic/CatmullRom 等滤镜).jpg/.jpeg → jpeg.Encode,.png → png.Encode
jpeg.Options{Quality: task.Quality} 控制;PNG 无质量参数,但可用 png.Encoder{CompressionLevel: ...}
简化版处理函数:
func processImage(task ImageTask) error {
srcFile, err := os.Open(task.SrcPath)
if err != nil {
return err
}
defer srcFile.Close()
img, format, err := image.Decode(srcFile)
if err != nil {
return fmt.Errorf("de
code %s: %w", task.SrcPath, err)
}
// 缩放(等比缩放示例:保持宽高比,限制最大边长)
resized := imaging.Resize(img, task.Width, task.Height, imaging.Lanczos)
dstFile, err := os.Create(task.DstPath)
if err != nil {
return err
}
defer dstFile.Close()
switch strings.ToLower(filepath.Ext(task.DstPath)) {
case ".jpg", ".jpeg":
opts := jpeg.Options{Quality: task.Quality}
return jpeg.Encode(dstFile, resized, &opts)
case ".png":
return png.Encode(dstFile, resized)
default:
return fmt.Errorf("unsupported output format: %s", filepath.Ext(task.DstPath))
}}
增强实用性:进度反馈与错误聚合
真实场景需要知道“处理了 73/200 张”。可在 worker 中发送完成信号到计数 channel:
done := make(chan struct{}, len(allTasks))
go func() {
for range done {
processed++
fmt.Printf("\rProcessed: %d/%d", processed, len(allTasks))
}
}()
// 在 worker 内部处理完一张后:
done <- struct{}{}
错误建议收集到 slice(加锁)或发到 error channel,最后统一打印,避免日志刷屏。
# git
# go
# github
# golang
# 编码
# ai
# switch
# 标准库
# Error
# 结构体
# 并发
# channel
# 滤镜
# 自动识别
# 可在
# 更高
# 扩展名
# 可选
# 三点
# 发送到
# 自带
# 第三方
相关文章:
小说建站VPS选用指南:性能对比、配置优化与建站方案解析
制作ppt免费网站有哪些,有哪些比较好的ppt模板下载网站?
香港服务器网站推广:SEO优化与外贸独立站搭建策略
如何快速搭建高效WAP手机网站?
天河区网站制作公司,广州天河区如何办理身份证?需要什么资料有预约的网站吗?
TestNG的testng.xml配置文件怎么写
如何续费美橙建站之星域名及服务?
如何配置IIS站点权限与局域网访问?
如何用狗爹虚拟主机快速搭建网站?
如何在阿里云ECS服务器部署织梦CMS网站?
网站专业制作公司有哪些,做一个公司网站要多少钱?
如何在西部数码注册域名并快速搭建网站?
如何撰写建站申请书?关键要点有哪些?
专业公司网站制作公司,用什么语言做企业网站比较好?
建站之星2.7模板快速切换与批量管理功能操作指南
如何通过老薛主机一键快速建站?
韩国网站服务器搭建指南:VPS选购、域名解析与DNS配置推荐
制作网页的网站有哪些,电脑上怎么做网页?
深圳防火门网站制作公司,深圳中天明防火门怎么编码?
济南网站建设制作公司,室内设计网站一般都有哪些功能?
,怎么用自己头像做动态表情包?
交易网站制作流程,我想开通一个网站,注册一个交易网址,需要那些手续?
如何在Golang中实现微服务服务拆分_Golang微服务拆分与接口管理方法
制作网站的软件下载免费,今日头条开宝箱老是需要下载怎么回事?
网站微信制作软件,如何制作微信链接?
建站之星代理如何获取技术支持?
建站主机类型有哪些?如何正确选型
浅析上传头像示例及其注意事项
建站之星与建站宝盒如何选择最佳方案?
整人网站在线制作软件,整蛊网站退不出去必须要打我是白痴才能出去?
如何在阿里云虚拟主机上快速搭建个人网站?
如何通过万网虚拟主机快速搭建网站?
建站主机无法访问?如何排查域名与服务器问题
上海网站制作网站建设公司,建筑电工证网上查询系统入口?
商务网站制作工程师,从哪几个方面把握电子商务网站主页和页面的特色设计?
如何确认建站备案号应放置的具体位置?
公司网站建设制作费用,想建设一个属于自己的企业网站,该如何去做?
如何通过FTP空间快速搭建安全高效网站?
小建面朝正北,A点实际方位是否存在偏差?
定制建站如何定义?其核心优势是什么?
建站之星安装路径如何正确选择及配置?
常州自助建站工具推荐:低成本搭建与模板选择技巧
建站之星如何一键生成手机站?
寿县云建站:智能SEO优化与多行业模板快速上线指南
如何在IIS中新建站点并配置端口与IP地址?
陕西网站制作公司有哪些,陕西凌云电器有限公司官网?
如何彻底卸载建站之星软件?
如何快速选择适合个人网站的云服务器配置?
专业的网站制作设计是什么,如何制作一个企业网站,建设网站的基本步骤有哪些?
如何规划企业建站流程的关键步骤?
*请认真填写需求信息,我们会在24小时内与您取得联系。