如何使用Golang读取Socket数据

在Golang的网络编程场景中，通过net包操作Socket实现数据传输是非常常见的需求，读取Socket数据是完成数据交互的基础环节，需要结合连接特性和数据格式选择合适的读取方式。

Golang Socket读取的基础原理

Golang的net包提供了统一的网络操作接口，无论是TCP还是Unix域Socket，都可以通过net.Conn接口的Read方法读取数据。该方法会从连接中读取数据到传入的字节切片中，返回读取的字节数和可能的错误。需要注意的是，Read方法不一定会填满整个字节切片，它会读取当前连接中可用的数据，或者直到遇到错误或连接关闭。

基础TCP Socket读取示例

下面先实现一个简单的TCP服务端，接收客户端连接后读取客户端发送的数据并回显，再实现对应的客户端发送数据。

TCP服务端实现

服务端需要先监听指定端口，接受客户端连接，然后循环读取连接中的数据：

package main

import (
	"fmt"
	"net"
	"os"
)

func main() {
	// 监听本地8080端口
	listener, err := net.Listen("tcp", "127.0.0.1:8080")
	if err != nil {
		fmt.Println("监听端口失败:", err)
		os.Exit(1)
	}
	defer listener.Close()
	fmt.Println("服务端已启动，监听端口8080")

	for {
		// 接受客户端连接
		conn, err := listener.Accept()
		if err != nil {
			fmt.Println("接受连接失败:", err)
			continue
		}
		// 开启协程处理连接
		go handleConn(conn)
	}
}

// 处理单个客户端连接
func handleConn(conn net.Conn) {
	defer conn.Close()
	// 定义读取缓冲区，大小为1024字节
	buf := make([]byte, 1024)
	for {
		// 读取数据
		n, err := conn.Read(buf)
		if err != nil {
			fmt.Println("读取数据失败:", err)
			return
		}
		// 打印读取到的内容
		fmt.Printf("接收到数据: %sn", string(buf[:n]))
		// 回显数据给客户端
		_, err = conn.Write(buf[:n])
		if err != nil {
			fmt.Println("回显数据失败:", err)
			return
		}
	}
}

TCP客户端实现

客户端需要主动连接服务端，然后发送数据并读取服务端的回显：

package main

import (
	"fmt"
	"net"
	"os"
)

func main() {
	// 连接服务端
	conn, err := net.Dial("tcp", "127.0.0.1:8080")
	if err != nil {
		fmt.Println("连接服务端失败:", err)
		os.Exit(1)
	}
	defer conn.Close()

	// 发送数据
	sendData := []byte("Hello Golang Socket")
	_, err = conn.Write(sendData)
	if err != nil {
		fmt.Println("发送数据失败:", err)
		return
	}
	fmt.Println("已发送数据:", string(sendData))

	// 读取服务端回显
	buf := make([]byte, 1024)
	n, err := conn.Read(buf)
	if err != nil {
		fmt.Println("读取回显失败:", err)
		return
	}
	fmt.Printf("接收到回显: %sn", string(buf[:n]))
}

按指定长度读取Socket数据

如果通信双方约定了数据格式，比如前4个字节表示后续数据的长度，那么可以按照长度读取完整数据，避免读取不完整的问题：

package main

import (
	"encoding/binary"
	"fmt"
	"io"
	"net"
	"os"
)

func main() {
	listener, err := net.Listen("tcp", "127.0.0.1:8081")
	if err != nil {
		fmt.Println("监听失败:", err)
		os.Exit(1)
	}
	defer listener.Close()

	conn, err := listener.Accept()
	if err != nil {
		fmt.Println("接受连接失败:", err)
		return
	}
	defer conn.Close()

	// 先读取4字节的长度头，使用大端序
	var dataLen uint32
	err = binary.Read(conn, binary.BigEndian, &dataLen)
	if err != nil {
		fmt.Println("读取长度失败:", err)
		return
	}

	// 按照长度读取后续数据
	data := make([]byte, dataLen)
	_, err = io.ReadFull(conn, data)
	if err != nil {
		fmt.Println("读取数据失败:", err)
		return
	}
	fmt.Printf("读取到完整数据: %sn", string(data))
}

读取Socket数据的注意事项

• 读取操作默认是阻塞的，如果连接没有数据可读，会一直阻塞直到有数据或者连接关闭，需要结合超时设置使用。
• 当连接被对端关闭时，Read方法会返回io.EOF错误，需要在代码中处理这个错误场景。
• 如果传输的数据量较大，单次读取可能无法获取完整数据，需要循环读取直到获取全部内容。
• 多协程操作同一个Socket连接时，需要注意并发安全，避免同时读写导致数据混乱。

常见问题解答

读取数据时一直阻塞怎么办

可以通过SetReadDeadline方法设置读取超时时间，超过指定时间没有数据可读会返回超时错误，避免永久阻塞：

// 设置读取超时时间为5秒
conn.SetReadDeadline(time.Now().Add(5 * time.Second))
n, err := conn.Read(buf)
if err != nil {
	// 判断是否为超时错误
	if netErr, ok := err.(net.Error); ok && netErr.Timeout() {
		fmt.Println("读取超时")
	}
}

如何读取不定长的Socket数据

如果没有约定数据长度格式，可以通过自定义分隔符来判断数据结束，比如使用换行符作为分隔符，循环读取直到遇到分隔符为止。

Golangnet_SocketSocket读取数据读取修改时间：2026-07-08 15:36:29