zoukankan      html  css  js  c++  java
  • Go语言模拟文件断点续传以及多协程读取写入文件操作

    今天整理了一个Go语言多协程拷贝文件的案例,之前用Java写过,这次用Go语言来写一下,代码不难,也很简单,但是网上没有案例,整了很长时间。下面贴出来,供其他人参考学习。

    func main(){
    
    	fileName := "F:\myWorks\丽君-全家福.png"
    	desfileName := "F:\myWorks\丽君-全家福-bak.png"
    	sfile,err := os.Open(fileName)
    	if err != nil{
    		fmt.Println(nil)
    	}
    
      
    	info,_ := os.Stat(fileName)
    	size := info.Size()
    	var scount  int64 = 1
        //这里切分原意为通过协程来分段读取
    	if size % 2 == 0{
    		scount *= 2
    	}else if size % 3 == 0 {
    		scount *= 3
    	}else{
    		scount *= 1
    	}
    	si := size / scount
    	fmt.Printf("文件总大小:%v, 分片数:%v,每个分片大小:%v",size,scount,si)
    
    	desF,err := os.OpenFile(desfileName,os.O_CREATE|os.O_RDONLY|os.O_APPEND,0755)
    	if err != nil{
    		fmt.Println(err)
    	}
    
    	for i:=0;i<=int(scount);i++{
    			//申明一个byte
    			b := make([]byte,si)
    			//从哪个位置开始读
    			sfile.Seek(int64(i)*si,0)
    			//读到byte数组里边
    			sfile.Read(b)
    			//从哪个位置开始写
    			desF.Seek(int64(i)*si,0)
    			//写入
    			desF.Write(b)
    	}
    
    	defer desF.Close()
    	defer sfile.Close()
    }

    上面的版本是一个按顺序写入的,虽然说是分片了但还是单协程,接下来改造一个多协程版本的。

    func main(){
    
    	fileName := "F:\myWorks\首页_1.png"
    	desfileName := "F:\myWorks\首页_1-bak.png"
    	sfile,err := os.Open(fileName)
    	if err != nil{
    		fmt.Println(nil)
    	}
    
    	info,_ := os.Stat(fileName)
    	size := info.Size()
    	var scount  int64 = 1
    	if size % 2 == 0{
    		scount *= 2
    	}else if size % 3 == 0 {
    		scount *= 3
    	}else{
    		scount *= 1
    	}
    
    	si := size / scount
    	fmt.Printf("文件总大小:%v, 分片数:%v,每个分片大小:%v
    ",size,scount,si)
    
    	desF,err := os.OpenFile(desfileName,os.O_CREATE|os.O_RDWR,0755)
    	if err != nil{
    		fmt.Println(err)
    	}
    
    	for i:=0;i<int(si);i++{
    		go func(vs int){
    			//申明一个byte
    			b := make([]byte,si)
    			//从指定位置开始读
    			sfile.ReadAt(b,int64(vs)*si)
    			//从指定位置开始写
    			desF.WriteAt(b,int64(vs)*si)
    
    		}(i)
    	}
    	time.Sleep(time.Second*5)
    	defer desF.Close()
    	defer sfile.Close()
    }

    有问题可以在下方评论,技术问题可以私聊我。

  • 相关阅读:
    抽象类中可以存在的成员
    读暗时间后感
    使用正则表达式限制QLineEdit不能输入大于某个整数
    QSharedMemory 使用
    BUUCTF-misc九连环 详解
    BUUCTF-数据包中的线索 1
    BUUCTF-Windows系统密码
    [CISCN2019 华北赛区 Day2 Web1]Hack World 1详解
    [ZJCTF 2019]NiZhuanSiWei 1详解
    BUUCTF [BJDCTF2020]Easy MD5 详解
  • 原文地址:https://www.cnblogs.com/c1024/p/11011991.html
Copyright © 2011-2022 走看看