微服务间文件传输报错：Service-1传文件至Service-2提示文件不存在

你的问题出在对文件上传和服务间文件传递的概念理解有误，导致Service2试图打开一个根本不存在的本地文件路径。我们一步步拆解问题，再给出正确的实现方式：

核心错误点 #

• 表单类型错误：你的HTML表单没有指定enctype="multipart/form-data"，这是上传文件必须的编码类型，默认的application/x-www-form-urlencoded无法正确传输文件内容。
• Service1获取文件的方式错误：你用req.FormValue("user_managers")拿到的不是文件的路径，而是文件的内容（如果是multipart表单）或者仅仅是客户端的文件名（如果是普通表单），把这个值传给Service2后，Service2用os.Open(file)去打开，自然会提示"No such file or directory"——因为这个字符串根本不是Service2服务器本地的文件路径。
• Service2处理逻辑错误：你试图从请求中拿到一个字符串当作本地文件路径打开，但实际上你需要的是直接从请求体中读取上传的文件内容，而不是去访问本地文件系统。

正确实现步骤 #

1. 修正HTML表单 #

首先给表单加上enctype="multipart/form-data"，确保能正确传输文件：

<form class="formContainer" id="my_form" action="http://usagemeter:7171/addmanagerstouser" method="POST" enctype="multipart/form-data">
  <input type="file" name="user_managers" required />
  <button type="submit">提交</button>
</form>

2. 修正Service1的文件传递逻辑 #

Service1需要正确读取客户端上传的文件，然后通过multipart请求把文件内容转发给Service2，而不是传递字符串：

// Service1的控制器代码
func yourService1Handler(w http.ResponseWriter, req *http.Request) {
    // 从客户端请求中获取上传的文件
    file, fileHeader, err := req.FormFile("user_managers")
    if err != nil {
        log.Printf("Failed to get uploaded file: %v", err)
        http.Error(w, "Failed to receive file", http.StatusBadRequest)
        return
    }
    defer file.Close()

    // 构造传给Service2的multipart请求体
    bodyBuffer := &bytes.Buffer{}
    multipartWriter := multipart.NewWriter(bodyBuffer)
    
    // 创建表单字段，写入文件内容
    filePart, err := multipartWriter.CreateFormFile("usermanagers", fileHeader.Filename)
    if err != nil {
        log.Printf("Failed to create form file: %v", err)
        http.Error(w, "Internal server error", http.StatusInternalServerError)
        return
    }
    // 复制文件内容到请求体
    _, err = io.Copy(filePart, file)
    if err != nil {
        log.Printf("Failed to copy file content: %v", err)
        http.Error(w, "Internal server error", http.StatusInternalServerError)
        return
    }
    // 关闭writer，完成请求体构造
    multipartWriter.Close()

    // 发起POST请求到Service2
    adduserManagersReq := adminservice + "/addmanagerstouser"
    resp, err := http.Post(adduserManagersReq, multipartWriter.FormDataContentType(), bodyBuffer)
    if err != nil {
        log.Printf("Failed to send request to Service2: %v", err)
        http.Error(w, "Failed to connect to Service2", http.StatusInternalServerError)
        return
    }
    defer resp.Body.Close()

    // 处理Service2的响应（根据需求添加逻辑）
    w.WriteHeader(resp.StatusCode)
    _, _ = io.Copy(w, resp.Body)
}

3. 修正Service2的文件处理逻辑 #

Service2需要从请求中读取文件内容，而不是去打开本地文件：

func addManagersToUsers(res http.ResponseWriter, req *http.Request) {
    // 解析multipart表单，设置内存限制（这里是10MB）
    err := req.ParseMultipartForm(10 << 20)
    if err != nil {
        log.Printf("Failed to parse multipart form: %v", err)
        fmt.Fprintf(res, "false")
        return
    }

    // 从请求中获取上传的文件
    file, _, err := req.FormFile("usermanagers")
    if err != nil {
        log.Println("Error retrieving file from request")
        fmt.Fprintf(res, "false")
        return
    }
    defer file.Close()

    // 这里可以直接处理文件内容，比如解析CSV
    csvReader := csv.NewReader(file)
    records, err := csvReader.ReadAll()
    if err != nil {
        log.Printf("Error parsing CSV content: %v", err)
        fmt.Fprintf(res, "false")
        return
    }

    // 处理CSV记录的业务逻辑（根据你的需求添加）
    log.Printf("Successfully read %d CSV records", len(records))
    fmt.Fprintf(res, "true")
}

总结 #

你原来的实现方式完全不可行，因为混淆了客户端上传文件和服务器本地文件的概念。正确的做法是：

• 用multipart/form-data编码传输文件
• 服务间传递文件时，通过multipart请求转发文件内容
• 接收方直接从请求体中读取文件内容，而非试图访问本地文件系统

内容的提问来源于stack exchange，提问作者Sachith Muhandiram