位置: IT常识 - 正文

gin框架中如何实现流式下载(gin框架使用案例)

编辑:rootadmin
作者:张富春(ahfuzhang),转载时请注明作者和引用链接,谢谢! cnblogs博客 zhihu Github 公众号:一本正经的瞎扯 团队中之前的文件下载做得比较复杂,因为担心量太大,是后台做异步的下载,最终生成文件,传送文件到CDN服务器,最后再告诉用户下载链接。 其实在查询接口中就可以实 ...

推荐整理分享gin框架中如何实现流式下载(gin框架使用案例),希望有所帮助,仅作参考,欢迎阅读内容。

文章相关热门搜索词:gin框架原理详解,gin框架原理详解,gin框架教程,gin框架context,gin框架中文文档,gin框架原理详解,gin框架中文文档,gin框架原理详解,内容如对您有帮助,希望把文章链接给更多的朋友!

作者:张富春(ahfuzhang),转载时请注明作者和引用链接,谢谢!

cnblogs博客zhihuGithub公众号:一本正经的瞎扯

团队中之前的文件下载做得比较复杂,因为担心量太大,是后台做异步的下载,最终生成文件,传送文件到CDN服务器,最后再告诉用户下载链接。其实在查询接口中就可以实现流式下载,这样查询接口和下载接口可以合二为一,更加简单。

gin框架中如何实现流式下载(gin框架使用案例)

下面是我的demo:

1.建立一个download_file的文件夹作为项目文件夹go mod init download_file2.生成go.mod文件,并准备对应的包:go get github.com/gin-gonic/gin@latestgo get github.com/gin-contrib/gzip

go.mod文件内容如下:

module download_filego 1.17require github.com/gin-gonic/gin v1.8.1require (github.com/gin-contrib/gzip v0.0.6 // indirectgithub.com/gin-contrib/sse v0.1.0 // indirectgithub.com/go-playground/locales v0.14.0 // indirectgithub.com/go-playground/universal-translator v0.18.0 // indirectgithub.com/go-playground/validator/v10 v10.10.0 // indirectgithub.com/goccy/go-json v0.9.7 // indirectgithub.com/json-iterator/go v1.1.12 // indirectgithub.com/leodido/go-urn v1.2.1 // indirectgithub.com/mattn/go-isatty v0.0.14 // indirectgithub.com/modern-go/concurrent v0.0.0-20180228061459-e0a39a4cb421 // indirectgithub.com/modern-go/reflect2 v1.0.2 // indirectgithub.com/pelletier/go-toml/v2 v2.0.1 // indirectgithub.com/ugorji/go/codec v1.2.7 // indirectgolang.org/x/crypto v0.0.0-20210711020723-a769d52b0f97 // indirectgolang.org/x/net v0.0.0-20210226172049-e18ecbb05110 // indirectgolang.org/x/sys v0.0.0-20210806184541-e5e7981a1069 // indirectgolang.org/x/text v0.3.6 // indirectgoogle.golang.org/protobuf v1.28.0 // indirectgopkg.in/yaml.v2 v2.4.0 // indirect)3.main.go文件:3.1 初始化gin框架func main() {log.SetFlags(log.LstdFlags | log.Lshortfile)engine := gin.New()// engine.Use(gzip.Gzip(gzip.DefaultCompression)) //如果需要开启gzip压缩,取消这一行的注释engine.Handle("POST", "/query", downloadFile) // 假定查询和下载接口都是这条接口实现engine.Handle("GET", "/", homepage)engine.Run(":8080")}3.2 下载链接页,模拟post到新窗口的场景func homepage(ctx *gin.Context) {ctx.Header("Content-Type", "text/html")ctx.Writer.WriteString(`<html><body>open window and to download:<a href="javascript:download()">download</a><script>function download(){ var handle = window.open("about:blank", "my_download_window");document.forms[0].target = "my_download_window";document.forms[0].json.value="ahfu test";document.forms[0].submit();}</script><form action="/query" method="POST" enctype="multipart/form-data"><input type="hidden" name="json" value=""/></form></body></html>`)}

点击链接后,弹出新窗口,在新窗口中POST json数据

3.3 流式下载功能func downloadFile(ctx *gin.Context) {reqData, has := ctx.GetPostForm("json")if !has {ctx.Data(400, "text/plain","not found json form data")return} // 此处省略查询的业务逻辑 // todo: // 下面开始下载的准备ctx.Writer.WriteHeader(200)ctx.Header("Content-Type", "text/plain; charset=utf-8")ctx.Header("Transfer-Encoding", "chunked") // 告诉浏览器,分段的流式的输出数据// ctx.Header("Content-Encoding", "gzip") // 输出不是gzip内容,又加上这个头,浏览器会拒收。这里是个实验,不要加这行代码now := time.Now()fileName := now.Format("20060102_150405.csv")ctx.Header("Content-Disposition", fmt.Sprintf("attachment; filename=\"%s\"", fileName)) // 设置下载的文件名ctx.Writer.WriteHeaderNow()// 下面模拟一个周期非常长的数据处理和下载过程for i := 0; i < 100; i++ {ctx.Writer.WriteString("\"")ctx.Writer.WriteString(str)ctx.Writer.WriteString("\"\t")ctx.Writer.WriteString("\"")ctx.Writer.WriteString(time.Now().Format("2006-01-02 15:04:05"))ctx.Writer.WriteString("\"\n")ctx.Writer.Flush() // 产生一定的数据后, flush到浏览器端time.Sleep(time.Duration(500) * time.Millisecond)}}

打开浏览器,输入:http://127.0.0.1:8080然后点击链接,过一会儿后会出现文件下载框。点击保存后,可以看见陆续下载文件的过程。注意:为什么过了一会儿才出现文件下载框?这是由于浏览器的缓冲机制导致的。如果一开始下载的字节数很多,就会很快出现下载框

3.4 启用gzip压缩

大流量的文本下载,可能很占带宽,我们可以开启GZIP压缩:

func main() {log.SetFlags(log.LstdFlags | log.Lshortfile)engine := gin.New()engine.Use(gzip.Gzip(gzip.DefaultCompression)) //如果需要开启gzip压缩,取消这一行的注释engine.Handle("POST", "/query", downloadFile) // 假定查询和下载接口都是这条接口实现engine.Handle("GET", "/", homepage)engine.Run(":8080")}

gin框架中已经提供gzip压缩的能力。

3.5 完整代码:// main.gopackage mainimport ("fmt""log""time""github.com/gin-contrib/gzip""github.com/gin-gonic/gin")func useGzip(engine *gin.Engine) {engine.Use(gzip.Gzip(gzip.DefaultCompression))}func main() {log.SetFlags(log.LstdFlags | log.Lshortfile)engine := gin.New()// engine.Use(gzip.Gzip(gzip.DefaultCompression)) //如果需要开启gzip压缩,取消这一行的注释engine.Handle("POST", "/query", downloadFile)engine.Handle("GET", "/", homepage)engine.Run(":8080")}func downloadFile(ctx *gin.Context) {reqData, has := ctx.GetPostForm("json")if !has {ctx.Data(400, "text/plain","not found json form data")return} // 此处省略查询的业务逻辑 // todo: // 下面开始下载的准备ctx.Writer.WriteHeader(200)ctx.Header("Content-Type", "text/plain; charset=utf-8")ctx.Header("Transfer-Encoding", "chunked") // 告诉浏览器,分段的流式的输出数据// ctx.Header("Content-Encoding", "gzip") // 输出不是gzip内容,又加上这个头,浏览器会拒收。这里是个实验,不要加这行代码now := time.Now()fileName := now.Format("20060102_150405.csv")ctx.Header("Content-Disposition", fmt.Sprintf("attachment; filename=\"%s\"", fileName)) // 设置下载的文件名ctx.Writer.WriteHeaderNow()// 下面模拟一个周期非常长的数据处理和下载过程for i := 0; i < 100; i++ {ctx.Writer.WriteString("\"")ctx.Writer.WriteString(str)ctx.Writer.WriteString("\"\t")ctx.Writer.WriteString("\"")ctx.Writer.WriteString(time.Now().Format("2006-01-02 15:04:05"))ctx.Writer.WriteString("\"\n")ctx.Writer.Flush() // 产生一定的数据后, flush到浏览器端time.Sleep(time.Duration(500) * time.Millisecond)}}func homepage(ctx *gin.Context) {ctx.Header("Content-Type", "text/html")ctx.Writer.WriteString(`<html><body>open window and to download:<a href="javascript:download()">download</a><script>function download(){ var handle = window.open("about:blank", "my_download_window");document.forms[0].target = "my_download_window";document.forms[0].json.value="ahfu test";document.forms[0].submit();}</script><form action="/query" method="POST" enctype="multipart/form-data"><input type="hidden" name="json" value=""/></form></body></html>`)}

have fun. ?

本文链接地址:https://www.jiuchutong.com/zhishi/313079.html 转载请保留说明!

上一篇:Nginx 防盗链(nginx防盗链的作用)

下一篇:python多线程和多进程之间的联系(python多线程多核)

  • 预缴增值税计算公式方法
  • 盘盈的固定资产怎么做账务处理
  • 个人收到利息要交增值税吗为什么
  • 土地使用权分割转让依据
  • 小企业应收票据有哪些
  • 取得成本发票
  • 支付的管理费用可以抵税吗
  • 应交税金明细账余额怎么算
  • 物业费纳税
  • 未达起征点企业怎么处理
  • 居间费税收是多少
  • 小微企业增值税收优惠政策
  • 个人承担的社保费用算在员工工资里吗?
  • 收到外单位奖励怎么回复
  • 利润表中财务费用可以为负数吗
  • 房子报废
  • 免税进口种子要符合哪些条件?
  • 单位外汇账户可分为
  • 企业利息收入如何做分录
  • 个人从价计征房产税
  • 穿越火线封号查询官网
  • 存货跌价准备是备抵科目吗
  • 退款给客户怎么写分录
  • 报销冲销借款
  • 受托方代收代缴的消费税计入成本吗
  • php字符串变量
  • 客户预付的购货款是收入吗
  • PHP:Memcached::replaceByKey()的用法_Memcached类
  • 前端打包发布
  • vue数据实时更新
  • 工程完工后有质量问题能解除合同吗
  • 戈佐西餐厅
  • PHP:mcrypt_ofb()的用法_Mcrypt函数
  • TypeError: Cannot read properties of null (reading ‘insertBefore‘) vue项目报错
  • php基于SQLite实现的分页功能示例
  • php 断点续传
  • 为什么那么多人考公务员
  • yolov3实现
  • 学会这两种方式英语
  • php图片添加水印的方法
  • 坏账准备的账务处理例题
  • 天猫的费用
  • sqlserver编程
  • SQL Server 2008 R2 超详细安装图文教程
  • MySQL默认字符集修改
  • sqlserver、mysql获取连接字符串步骤
  • 加强mysql安全
  • 残疾人就业保障金
  • 银行汇票与商业汇票的本质不同
  • 生产企业购进的生产原材料用来装修公司会计处理
  • 合伙企业分红怎么做账
  • 人民币支付结算系统CIPS
  • 包装物属于周转材料还是低值易耗品
  • 小规模纳税人季报网上申报流程
  • mysql could not be resolved: Name or service not known
  • windows vista升级
  • centos 7 安装vnc
  • ubuntu20.04快捷键
  • 如何隐藏与显示元素
  • Win8系统网络SSID怎么设置?Win8设置网络SSID的方法
  • number mac
  • 微软禁用windows
  • win7重新安装windows
  • win8文件夹打不开
  • 网站出现问题怎么办
  • 在dos中文件是以什么目录结构
  • cocos2d开发app
  • c#中抽象类的定义
  • javascript运行在什么的脚本语言
  • 谈一谈你对人与自然关系的认识
  • jquery和angularjs的区别
  • beautiful python
  • jquery封装的函数
  • python设计gui
  • 基于jQuery Ajax实现上传文件
  • python爬虫抓取数据的步骤
  • 国家税务局网站发票验真伪
  • 环保税要求标注什么
  • 普通发票冲红怎么报税
  • 集美区区委书记什么级别
  • 免责声明:网站部分图片文字素材来源于网络,如有侵权,请及时告知,我们会第一时间删除,谢谢! 邮箱:opceo@qq.com

    鄂ICP备2023003026号

    网站地图: 企业信息 工商信息 财税知识 网络常识 编程技术

    友情链接: 武汉网站建设