Golang实现异步上传文件支持进度条查询的方法

2020-01-28 13:59:36王冬梅

将错误信息以channel接收,使用 package "sync" 的 sync.WaitGroup 控制异步协程。在入库的过程中,将当前的进度存入redis。

查询进度接口


func QueryImport()(){
  conn, err := connect()
  if err != nil {
    return nil, err
  }
  defer conn.Close()

  progress, _ := conn.Do("hget", key, field)
  if pro, ok := progress.([]uint8); ok {
    ba := []byte{}
    for _, b := range pro {
      ba = append(ba, byte(b))
    }
    progress,_ = strconv.Atoi(string(ba))
  }
  return progress
}

从redis中取出来的数据是[]uint8类型数据,先断言,然后转类型返回。

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持易采站长站。