Golang中multipart/related请求边界设置问题求助

问题背景 #

在Golang中构建包含JSON和二进制数据的multipart/related格式HTTP请求时，服务器返回Failed to parse boundary. missing/invalide boundary错误，无法正确解析请求边界。

错误原因分析 #

1. 手动设置的边界不符合MIME规范：手动指定的----n1n2msg边界可能不符合RFC 2046对multipart边界的字符、长度要求，且易出现Content-Type声明与实际请求体中边界不匹配的问题。
2. 缺少multipart/related必填参数：multipart/related格式必须指定type参数标识根部分的媒体类型（如application/json），多数服务器会严格校验该参数。
3. 边界值同步问题：手动设置边界后，若Content-Type中的值与writer实际生成的边界不一致，会导致服务器解析失败。

修复步骤 #

1. 使用自动生成的规范边界：依赖multipart.Writer自动生成符合RFC标准的边界，避免手动设置带来的格式问题。
2. 补充multipart/related的type参数：在Content-Type头中明确指定根部分的媒体类型，符合RFC 2387规范。
3. 确保边界值完全同步：通过writer.Boundary()获取writer实际使用的边界值，用于构造Content-Type头。

修改后的完整代码 #

func CreateMultipartRelatedN1N2MessageTransferRequest(inputData models.InputData) (*models.N1N2MessageTransferRequest, string, error) {
    var buf bytes.Buffer

    // 创建multipart writer，使用自动生成的规范边界，不再手动设置
    writer := multipart.NewWriter(&buf)

    n1n2Request := models.N1N2MessageTransferRequest{}

    _, _, nfId, _, _ := config.Cfg.GetServerInfo()

    n1n2Request.JsonData = &models.N1N2MessageTransferReqData{
        N1MessageContainer: &models.N1MessageContainer{
            N1MessageClass: models.N1MessageClass_LPP,
            N1MessageContent: &models.RefToBinaryData{
                ContentId: "n1msg",
            },
            NfId: nfId,
        },
        LcsCorrelationId:       inputData.CorrelationID,
        N1n2FailureTxfNotifURI: "",
    }

    // 添加JSON根部分
    jsonPartHeader := textproto.MIMEHeader{}
    jsonPartHeader.Set("Content-Type", "application/json; charset=UTF-8")
    jsonPart, err := writer.CreatePart(jsonPartHeader)
    if err != nil {
        return nil, "", fmt.Errorf("创建JSON部分失败: %v", err)
    }

    jsonBytes, err := json.Marshal(n1n2Request.JsonData)
    if err != nil {
        return nil, "", fmt.Errorf("序列化JSON数据失败: %v", err)
    }
    _, err = jsonPart.Write(jsonBytes)
    if err != nil {
        return nil, "", fmt.Errorf("写入JSON数据失败: %v", err)
    }

    // 构建LPP消息并编码为二进制
    lppMessage := models.LPPMessage{
        TransactionID: &models.LPPTransactionID{
            TransactionNumber: common.GenerateNumber(),
            Initiator:         int(models.LocationServer),
        },
        SequenceNumber: common.GenerateNumber(),
        LPPMessageBody: &models.LPPMessageBody{
            C1: &models.C1{
                RequestLocationInformation: &models.RequestLocationInformation{
                    CriticalExtensions: &models.CriticalExtensions{
                        C1: &models.CriticalExtensionsC1{
                            RequestLocationInformationR9: &models.RequestLocationInformationR9IEs{
                                CommonIEsRequestLocationInformation: &models.CommonIEsRequestLocationInformation{
                                    LocationInformationType: int(models.LocationEstimateRequired),
                                    PeriodicalReporting: &models.PeriodicalReportingCriteria{
                                        ReportingAmount:   int(models.RA1),
                                        ReportingInterval: int(models.RI32),
                                    },
                                    LocationCoordinateTypes: &models.LocationCoordinateTypes{
                                        EllipsoidPoint: true,
                                    },
                                    VelocityTypes: &models.VelocityTypes{
                                        HorizontalVelocity: true,
                                    },
                                },
                            },
                        },
                    },
                },
            },
        },
        EndTransaction: true,
    }

    binaryData, err := aper.Marshal(lppMessage)
    if err != nil {
        logger.Log.Error().Msgf("ASN.1 PER编码失败: %v", err)
        return nil, "", err
    }

    // 添加二进制部分
    binaryPartHeader := textproto.MIMEHeader{}
    binaryPartHeader.Set("Content-ID", "<n1msg>")
    binaryPartHeader.Set("Content-Type", "application/vnd.3gpp.5gnas")
    binaryPart, err := writer.CreatePart(binaryPartHeader)
    if err != nil {
        return nil, "", fmt.Errorf("创建二进制部分失败: %v", err)
    }

    _, err = binaryPart.Write(binaryData)
    if err != nil {
        return nil, "", fmt.Errorf("写入二进制数据失败: %v", err)
    }

    err = writer.Close()
    if err != nil {
        return nil, "", fmt.Errorf("关闭multipart writer失败: %v", err)
    }

    n1n2Request.BinaryDataN1Message = buf.Bytes()

    // 构造符合规范的Content-Type，包含type参数和自动生成的边界
    contentType := fmt.Sprintf("multipart/related; type=\"application/json\"; boundary=%s", writer.Boundary())

    return &n1n2Request, contentType, nil
}

额外检查点 #

• 确认API客户端的prepareRequest方法不会对BinaryDataN1Message做额外的multipart包装，确保原始multipart数据直接作为请求体发送。
• 验证二进制部分的Content-ID值与JSON中引用的ContentId一致（JSON中为n1msg，Content-ID头中为<n1msg>，符合MIME引用规范）。

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