go iris 如何用 pipe 文件 - 知否问答 - 万象云+社区

func pipeImage(ctx iris.Context) { filePath := ctx.FormValue("url") r, w := io.Pipe() go func() { defer func() { fmt.Println("w.close") w.Close() }() client := &http.Client{} resp, err := client.Get(url) if err != nil { fmt.Println(err) panic(err) } defer resp.Body.Close() fmt.Println("io.Copy") // 运行到 copy 就返回了,会继续运行下面的 r.Read(data), 没有打印出下面的 io.Copy end, 请问这是为什么？ io.Copy(w, resp.Body) fmt.Println("io.Copy end") } // 这里又申明了一个 byte,很无奈,不知道有什么方法可以方便的将 pipe 中 Reader 的数据发下去 var data []byte fmt.Println("r.read") // 运行到这里进入上面 go 的进程 r.Read(data) // 这边看了一下打印出来的值， length 是0，没有写入成功还是写入成异步了，开始写就直接读了？ // 这边我感觉有点问题，如果不设置缓存的话，是否大文件的转发会分成很多批次写入读取，但是这边只能读取一次，不知道有什么方法可以监控进度状态 fmt.Println("r.read end", len(data)) // 输出0字节 ctx.Binary(data) }

// 创建一个文件描述符 f, err := os.Create("iris.txt") if err != nil { fmt.Println(err) return } defer f.Close() // 创建一个读取器 // 使用管道读取数据 go func() { // 使用管道读取数据 fmt.Print("Enter a number: ") num, err := strconv.Atoi(strings.TrimSpace(string(p1))) if err != nil { fmt.Println(err) return } // 在数据中添加输入数字 fmt.Print("Enter another number: ") num2, err := strconv.Atoi(strings.TrimSpace(string(p2))) if err != nil { fmt.Println(err) return } // 将读取器的数据写入文件 fmt.Print("Enter a number to remove: ") n, err := strconv.Atoi(strings.TrimSpace(string(p1))) if err != nil { fmt.Println(err) return } n-- _, err = f.WriteString(strconv.Itoa(n)) if err != nil { fmt.Println(err) return } fmt.Println("Numbers removed:", n) }() // 关闭管道 p1.Close() p2.Close()

回答动态