Go语言中SOAP/WSDL支持的实践与xmlutil库应用指南

type MethodCall struct {
    One XSI
    Two XSI
}

type XSI struct {
    Type string `xml:"xsi:type,attr"` // 定义xsi:type属性
    Value string `xml:",chardata"`     // 标签的字符数据
}

call := MethodCall{
    One: XSI{Type: "xsd:string", Value: "One"},
    Two: XSI{Type: "xsd:string", Value: "Two"},
}
// 编码后输出：
// <MethodCall>
//     <One xsi:type="xsd:string">One</One>
//     <Two xsi:type="xsd:string">Two</Two>
// </MethodCall>

type MethodCall struct {
    One string
    Two string
}

package main

import (
    "bytes"
    "encoding/xml"
    "fmt"
    "log"

    "github.com/webconnex/xmlutil" // 引入xmlutil库
)

// 定义SOAP Envelope和Body结构
type Envelope struct {
    XMLName xml.Name `xml:"soap:Envelope"` // 指定根元素和命名空间前缀
    Body    Body     `xml:"soap:Body"`
}

type Body struct {
    Msg interface{} `xml:",innerxml"` // 使用innerxml来包含实际消息体
}

// 定义请求消息体
type MethodCall struct {
    One string `xml:"One"`
    Two string `xml:"Two"`
}

// 定义响应消息体
type MethodCallResponse struct {
    Three string `xml:"Three"`
}

func main() {
    // 1. 初始化xmlutil实例
    x := xmlutil.NewXmlUtil()

    // 2. 注册命名空间
    // 这些命名空间将在XML文档中被引用
    x.RegisterNamespace("http://www.w3.org/2001/XMLSchema-instance", "xsi")
    x.RegisterNamespace("http://www.w3.org/2001/XMLSchema", "xsd")
    x.RegisterNamespace("http://www.w3.org/2003/05/soap-envelope", "soap")

    // 3. 注册Envelope类型及其命名空间属性
    // 这里为Envelope根元素添加xmlns属性，指定SOAP、xsi、xsd命名空间
    x.RegisterTypeMore(Envelope{}, xml.Name{"http://www.w3.org/2003/05/soap-envelope", "Envelope"}, // 指定Envelope的完整XML名称
        []xml.Attr{
            {xml.Name{"xmlns", "xsi"}, "http://www.w3.org/2001/XMLSchema-instance"},
            {xml.Name{"xmlns", "xsd"}, "http://www.w3.org/2001/XMLSchema"},
            {xml.Name{"xmlns", "soap"}, "http://www.w3.org/2003/05/soap-envelope"},
        })

    // 4. 注册所有字符串类型，为其添加xsi:type="xsd:string"属性
    // 通过注册空字符串""，表示对所有string类型应用此规则
    x.RegisterTypeMore("", xml.Name{}, []xml.Attr{
        {xml.Name{"http://www.w3.org/2001/XMLSchema-instance", "type"}, "xsd:string"},
    })

    // 5. 编码SOAP请求
    buf := new(bytes.Buffer)
    buf.WriteString(`<?xml version="1.0" encoding="utf-8"?>`)
    buf.WriteByte('\n')
    enc := x.NewEncoder(buf)

    // 创建请求消息体实例
    env := &Envelope{Body: Body{Msg: MethodCall{
        One: "one",
        Two: "two",
    }}}

    if err := enc.Encode(env); err != nil {
        log.Fatalf("编码请求失败: %v", err)
    }

    // 打印生成的SOAP请求XML
    bs := buf.Bytes()
    // 为了美观，添加换行符
    bs = bytes.ReplaceAll(bs, []byte{'>', '<'}, []byte{'>', '\n', '<'})
    fmt.Printf("生成的SOAP请求:\n%s\n\n", bs)

    /*
        // 实际应用中，您会在这里发送HTTP请求
        // var r *http.Response
        // if r, err = http.Post(url, "application/soap+xml; charset=utf-8; action="+namespace+"/"+action, buf); err != nil {
        //     return
        // }
        // dec := x.NewDecoder(r.Body)
    */

    // 6. 解码SOAP响应
    // 模拟一个SOAP响应
    responseXML := `<?xml version="1.0" encoding="utf-8"?>
    <soap:Envelope xmlns:soap="http://www.w3.org/2003/05/soap-envelope">
        <soap:Body>
            <MethodCallResponse>
                <Three>three</Three>
            </MethodCallResponse>
        </soap:Body>
    </soap:Envelope>`
    dec := x.NewDecoder(bytes.NewBufferString(responseXML))

    // 使用Find方法查找响应元素或SOAP Fault
    findTargets := []xml.Name{
        {"", "MethodCallResponse"}, // 查找本地名为"MethodCallResponse"的元素
        {"http://www.w3.org/2003/05/soap-envelope", "Fault"}, // 查找SOAP Fault元素
    }

    start, err := dec.Find(findTargets)
    if err != nil {
        log.Fatalf("查找响应元素失败: %v", err)
    }

    if start.Name.Local == "Fault" {
        // 这里可以进一步解码SOAP Fault信息
        log.Fatalf("收到SOAP Fault!")
    }

    var resp MethodCallResponse
    if err := dec.DecodeElement(&resp, start); err != nil {
        log.Fatalf("解码响应元素失败: %v", err)
    }
    fmt.Printf("解码后的SOAP响应数据: %#v\n\n", resp)

    // 7. 另一种简单的解码方式（如果知道响应结构且不需Find）
    // 如果响应结构简单，可以直接解码到Envelope结构体
    // x.RegisterType(MethodCallResponse{}) // 需要注册响应类型
    // dec2 := x.NewDecoder(bytes.NewBufferString(responseXML))
    // var envelopeResp Envelope
    // if err := dec2.Decode(&envelopeResp); err != nil {
    //  log.Fatalf("直接解码响应失败: %v", err)
    // }
    // fmt.Printf("直接解码后的Envelope: %#v\n", envelopeResp)
    // 注意：此处需要根据实际响应的XML结构调整Envelope和Body的xml标签，
    // 并且Msg字段可能需要更具体的类型而非interface{}以直接解码。
}

<soap:Envelope>
  <soap:Body>
    <MethodResponse>
      <MethodResult>
        <diffgr:diffgram>
          <NewDataSet>
            <Table1 diffgr:id="Table1" msdata:rowOrder="0" diffgr:hasChanges="inserted">
              <Three>three</Three>
            </Table1>
          </NewDataSet>
        </diffgr:diffgram>
      </MethodResult>
    </MethodResponse>
  </soap:Body>
</soap:Envelope>