Golang如何通过TCP连接远程服务器并传递XML创建服务

Golang如何通过TCP连接远程服务器并传递XML创建服务 我需要构建一个连接器来监听传入消息，并将构建的XML通过TCP服务端口发送。同时需要监听响应以判断操作成功或失败。

1 回复

更多关于Golang如何通过TCP连接远程服务器并传递XML创建服务的实战系列教程也可以访问 https://www.itying.com/category-94-b0.html


在Go语言中，通过TCP连接远程服务器并传递XML数据，同时监听响应，可以使用标准库的net包实现。以下是一个完整的示例，包括建立TCP连接、发送XML消息和异步监听响应。

示例代码

package main

import (
    "encoding/xml"
    "fmt"
    "io"
    "log"
    "net"
    "time"
)

// 定义XML结构体示例
type Message struct {
    XMLName xml.Name `xml:"message"`
    ID      string   `xml:"id,attr"`
    Content string   `xml:"content"`
}

func main() {
    // 远程服务器地址和端口
    serverAddr := "example.com:8080"
    
    // 建立TCP连接
    conn, err := net.Dial("tcp", serverAddr)
    if err != nil {
        log.Fatalf("连接服务器失败: %v", err)
    }
    defer conn.Close()
    
    fmt.Println("已连接到服务器:", serverAddr)
    
    // 创建XML消息
    msg := Message{
        ID:      "001",
        Content: "Hello, Server!",
    }
    
    // 将结构体编码为XML
    xmlData, err := xml.Marshal(msg)
    if err != nil {
        log.Fatalf("XML编码失败: %v", err)
    }
    
    // 发送XML数据到服务器
    _, err = conn.Write(xmlData)
    if err != nil {
        log.Fatalf("发送数据失败: %v", err)
    }
    
    fmt.Printf("已发送XML: %s\n", string(xmlData))
    
    // 启动goroutine监听响应
    go listenForResponse(conn)
    
    // 保持主程序运行，可根据需要调整
    time.Sleep(30 * time.Second)
}

// 监听服务器响应
func listenForResponse(conn net.Conn) {
    buffer := make([]byte, 1024)
    
    for {
        n, err := conn.Read(buffer)
        if err != nil {
            if err == io.EOF {
                fmt.Println("服务器关闭连接")
                return
            }
            log.Printf("读取响应错误: %v", err)
            return
        }
        
        response := string(buffer[:n])
        fmt.Printf("收到服务器响应: %s\n", response)
        
        // 根据响应内容判断操作结果
        if isSuccess(response) {
            fmt.Println("操作成功")
        } else {
            fmt.Println("操作失败")
        }
    }
}

// 根据业务逻辑判断响应是否成功
func isSuccess(response string) bool {
    // 这里根据实际业务逻辑实现判断
    // 示例：假设响应包含"success"表示成功
    return len(response) > 0 && response != "error"
}

关键点说明

  1. TCP连接建立：使用net.Dial("tcp", serverAddr)建立与远程服务器的连接。

  2. XML编码：通过encoding/xml包将结构体编码为XML格式数据。

  3. 数据发送：使用conn.Write()方法发送XML数据。

  4. 响应监听：

    • 使用conn.Read()在独立goroutine中持续监听响应
    • 通过io.EOF检测连接关闭
    • 实现isSuccess()函数根据业务逻辑判断操作结果

  5. 连接管理：使用defer conn.Close()确保连接正确关闭。

扩展功能

如需处理更复杂的XML结构，可以定义对应的结构体：

type ComplexMessage struct {
    XMLName  xml.Name `xml:"request"`
    Version  string   `xml:"version,attr"`
    Header   Header   `xml:"header"`
    Body     Body     `xml:"body"`
}

type Header struct {
    MessageID string `xml:"messageId"`
    Timestamp string `xml:"timestamp"`
}

type Body struct {
    Action string `xml:"action"`
    Data   string `xml:"data"`
}

此实现提供了基本的TCP通信框架，可根据具体协议和业务需求进行调整。

回到顶部