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()
    }

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

  • 相关阅读:
    Objective C中提供了线程同步和异常处理
    iOS singleton单例模式的实现
    转:IOS UITableView中行的操作
    Javascript 函数
    ios category类别的使用
    vmware Ubuntu非法关机后启动不起来
    C++ Socket编程步骤
    C/C++ 笔试、面试题目大汇总(转)
    Linux下基于C/C++的Socket编程基础
    C++经典面试题
  • 原文地址:https://www.cnblogs.com/c1024/p/11011991.html
Copyright © 2011-2022 走看看