proxy.ModifyResponse = func(response *http.Response) error {
    go func() {
        buf := make([]byte, 4096) // 定義一個(gè)足夠大的緩沖區(qū)
        for {
            n, err := response.Body.Read(buf)
            if n > 0 {
                buffer.Write(buf[:n])
                if _, writeErr := writer.Write(buf[:n]); writeErr != nil {
                    log.Println("Error writing to pipe:", writeErr)
                    return
                }
            }
            if err != nil {
                if err != io.EOF {
                    log.Println("Error reading from response body:", err)
                }
                break
            }
        }
    }()
    return nil
}

// 創(chuàng)建一個(gè)io.Pipe用于攔截和轉(zhuǎn)發(fā)數(shù)據(jù)
reader, writer := io.Pipe()
var buffer bytes.Buffer
var mu sync.Mutex
var wg sync.WaitGroup

proxy.ModifyResponse = func(response *http.Response) error {
    log.Println("ModifyResponse started")
    wg.Add(1)
    go func() {
        defer wg.Done()
        defer func(writer *io.PipeWriter) {
            err := writer.Close()
            if err != nil {
                log.Println("Error closing pipe writer:", err)
            }
        }(writer)

        buf := make([]byte, 4096) // 定義一個(gè)足夠大的緩沖區(qū)
        for {
            n, err := response.Body.Read(buf)
            if n > 0 {
                mu.Lock()
                buffer.Write(buf[:n])
                if _, writeErr := writer.Write(buf[:n]); writeErr != nil {
                    log.Println("Error writing to pipe:", writeErr)
                    mu.Unlock()
                    return
                }
                mu.Unlock()
            }
            if err != nil {
                if err != io.EOF {
                    log.Println("Error reading from response body:", err)
                }
                break
            }
        }
    }()
    return nil
}

// 使用Goroutine將代理服務(wù)器的數(shù)據(jù)流轉(zhuǎn)發(fā)給客戶端
wg.Add(1)
go func() {
    defer wg.Done()
    log.Println("Copying to client started")
    if _, err := io.Copy(c.Writer, reader); err != nil {
        log.Println("Error copying to client:", err)
        return
    }
}()

// 實(shí)際發(fā)送請(qǐng)求到目標(biāo)服務(wù)器
proxy.ServeHTTP(c.Writer, c.Request)

// 等待所有的Goroutine完成
wg.Wait()
log.Println("All Goroutines finished")

// 在這里將完整的數(shù)據(jù)保存到數(shù)據(jù)庫(kù)
completeData := buffer.String()
log.Println("Complete data:", completeData)