如何使用Golang创建TCP连接_Golang net Dial与Listen TCP使用方法

Go语言TCP编程核心是net.Dial(客户端连接)和net.Listen(服务端监听),配合net.Conn读写、超时控制与goroutine并发处理实现高效通信。

Go 语言通过 net 包提供了简洁、高效的 TCP 网络编程支持。核心是 net.Dial(发起连接)和 net.Listen(监听连接),两者配合即可完成客户端与服务端的通信。

使用 net.Dial 建立 TCP 客户端连接

net.Dial 是客户端主动连接远程服务器的标准方式,返回一个 net.Conn 接口,可用于读写数据。

基本用法:

conn, err := net.Dial("tcp", "127.0.0.1:8080", nil)
if err != nil {
    log.Fatal(err)
}
defer conn.Close()

// 发送数据 conn.Write([]byte("Hello Server\n"))

// 接收响应 buf := make([]byte, 1024) n, _ := conn.Read(buf) fmt.Println("收到:", string(buf[:n]))

  • 第一个参数是网络类型,TCP 固定为 "tcp"(IPv4)或 "tcp4"/"tcp6"
  • 第二个参数是地址,格式为 "host:port",如 "google.com:80""192.168.1.100:3000"
  • 第三个参数可传 *net.Dialer 自定义超时、KeepAlive、本地地址等(常用于控制连接行为)

使用 net.Listen 启动 TCP 服务端

net.Listen 在指定地址上启动监听,返回 net.Listener,之后调用 Accept() 阻塞等待新连接。

简单服务端示例:

ln, err := net.Listen("tcp", ":8080")
if err != nil {
    log.Fatal(err)
}
defer ln.Close()

fmt.Println("服务器运行在 :8080")

for { conn, err := ln.Accept() if err != nil { log.Println("接受连接失败:", err) continue }

// 每个连接开 goroutine 处理,避免阻塞后续连接
go handleConnection(conn)

}

handleConnection 示例:

func handleConnection(conn net.Conn) {
    defer conn.Close()
    buf := make([]byte, 1024)
    n, _ := conn.Read(buf)
    fmt.Printf("收到:%s", string(buf[:n]))
    conn.Write([]byte("OK\n"))
}
  • 监听地址用 ":8080" 表示监听本机所有 IPv4/IPv6 地址的 8080 端口
  • "127.0.0.1:8080" 则只监听本地回环,更安全
  • 务必用 go handleConnection(conn) 启协程处理每个连接,否则串行处理会卡死

常见实用技巧与注意事项

实际开发中,几个关键点容易忽略但影响稳定性:

  • 设置连接超时:用 &net.Dialer{Timeout: 5 * time.Second} 避免 Dial 卡死
  • 设置读写超时:调用 conn.SetReadDeadline()conn.SetWriteDeadline() 防止 I/O 挂起
  • 正确关闭连接:服务端需在处理完后 conn.Close(),客户端同理;多次关闭无害,但漏关会导致资源泄漏
  • 错误处理别忽略Read 返回 0, io.EOF 表示对端关闭,应退出循环而非报错

完整可运行的小例子(服务端 + 客户端)

把下面两段代码分别保存为 server.goclient.go,先运行服务端再运行客户端,就能看到通信效果。

服务端(server.go):

package main

import ( "fmt" "io" "log" "net" )

func main() { ln, _ := net.Listen("tcp", ":9000") defer ln.Close() fmt.Println("服务启动,监听 :9000")

for {
    conn, err := ln.Accept()
    if err != nil {
        log.Println(err)
        continue
    }
    go func(c net.Conn) {
        defer c.Close()
        io.Copy(c, c) // 回显所有收到的数据
    }(conn)
}

}

客户端(client.go):

package main

import ( "fmt" "io" "log" "net" )

func main() { conn, err := net.Dial("tcp", "127.0.0.1:9000", nil) if err != nil { log.Fatal(err) } defer conn.Close()

conn.Write([]byte("Hi there!\n"))
io.Copy(os.Stdout, conn) // 把响应输出到终端

}

注意:客户端示例中用了 os.Stdout,需补上 import "os"

基本上就这些。Golang 的 TCP 编程模型干净直接,DialListen 是入口,剩下的就是按需读写、超时控制和并发管理。不复杂但容易忽略细节,比如超时和 goroutine 泄漏,上线前务必检查。