答案:通过Go语言实现TCP通信,使用消息头携带长度信息解决粘包拆包问题,结合goroutine池和多路复用提升高并发性能,并通过心跳检测与日志记录保障连接可靠性。

Golang TCP数据包发送与接收,简单来说,就是用Go语言实现客户端和服务端通过TCP协议进行数据通信。下面给出一个基本的示例,展示如何发送和接收数据包。
// 服务端
package main
import (
"fmt"
"net"
"os"
)
const (
SERVER_HOST = "localhost"
SERVER_PORT = "9988"
SERVER_TYPE = "tcp"
)
func main() {
fmt.Println("Server Running...")
server, err := net.Listen(SERVER_TYPE, SERVER_HOST+":"+SERVER_PORT)
if err != nil {
fmt.Println("Error listening:", err.Error())
os.Exit(1)
}
defer server.Close()
fmt.Println("Listening on " + SERVER_HOST + ":" + SERVER_PORT)
fmt.Println("Waiting for client...")
for {
connection, err := server.Accept()
if err != nil {
fmt.Println("Error accept:", err.Error())
return
}
fmt.Println("Client connected")
go processClient(connection)
}
}
func processClient(connection net.Conn) {
buffer := make([]byte, 1024)
mLen, err := connection.Read(buffer)
if err != nil {
fmt.Println("Error reading:", err.Error())
return
}
fmt.Println("Received: ", string(buffer[:mLen]))
_, err = connection.Write([]byte("Message received."))
if err != nil {
fmt.Println("Error writing:", err.Error())
return
}
connection.Close()
}
// 客户端
package main
import (
"fmt"
"net"
"os"
)
const (
SERVER_HOST = "localhost"
SERVER_PORT = "9988"
SERVER_TYPE = "tcp"
)
func main() {
connection, err := net.Dial(SERVER_TYPE, SERVER_HOST+":"+SERVER_PORT)
if err != nil {
fmt.Println("Error dialing:", err.Error())
os.Exit(1)
}
defer connection.Close()
fmt.Println("Connected to server")
_, err = connection.Write([]byte("Hello Server!"))
if err != nil {
fmt.Println("Error writing:", err.Error())
os.Exit(1)
}
buffer := make([]byte, 1024)
mLen, err := connection.Read(buffer)
if err != nil {
fmt.Println("Error reading:", err.Error())
os.Exit(1)
}
fmt.Println("Received: ", string(buffer[:mLen]))
}
TCP是面向流的协议,这意味着数据在传输过程中可能会发生粘包和拆包。简单来说,粘包就是多个小数据包被合并成一个大数据包发送,而拆包就是一个大数据包被拆分成多个小数据包发送。
解决粘包和拆包的常见方法有:
固定长度消息: 每个数据包都使用固定长度,接收方按照固定长度读取数据。这实现简单,但不够灵活,浪费带宽。
立即学习“go语言免费学习笔记(深入)”;
使用分隔符: 在每个数据包的末尾添加一个特殊的分隔符,接收方通过查找分隔符来分割数据包。例如,使用换行符
\n
消息头包含长度信息: 在每个数据包的头部添加一个字段,用于表示数据包的长度。接收方首先读取头部,获取数据包长度,然后按照长度读取数据。这是最常用的方法,也比较灵活。
下面是一个使用消息头包含长度信息的示例:
// 服务端 (修改后的 processClient 函数)
func processClient(connection net.Conn) {
for {
headerBuffer := make([]byte, 4) // 假设长度信息使用 4 字节
_, err := connection.Read(headerBuffer)
if err != nil {
fmt.Println("Error reading header:", err)
return
}
messageLength := binary.BigEndian.Uint32(headerBuffer) // 将字节转换为 uint32
messageBuffer := make([]byte, messageLength)
_, err = connection.Read(messageBuffer)
if err != nil {
fmt.Println("Error reading message:", err)
return
}
fmt.Println("Received:", string(messageBuffer))
// 发送响应
response := "Message received."
responseBytes := []byte(response)
responseLength := uint32(len(responseBytes))
responseHeader := make([]byte, 4)
binary.BigEndian.PutUint32(responseHeader, responseLength)
_, err = connection.Write(responseHeader)
if err != nil {
fmt.Println("Error writing response header:", err)
return
}
_, err = connection.Write(responseBytes)
if err != nil {
fmt.Println("Error writing response:", err)
return
}
}
}
// 客户端 (修改后的 main 函数)
func main() {
connection, err := net.Dial(SERVER_TYPE, SERVER_HOST+":"+SERVER_PORT)
if err != nil {
fmt.Println("Error dialing:", err.Error())
os.Exit(1)
}
defer connection.Close()
fmt.Println("Connected to server")
message := "Hello Server! This is a longer message."
messageBytes := []byte(message)
messageLength := uint32(len(messageBytes))
header := make([]byte, 4)
binary.BigEndian.PutUint32(header, messageLength) // 将长度转换为字节
_, err = connection.Write(header)
if err != nil {
fmt.Println("Error writing header:", err)
os.Exit(1)
}
_, err = connection.Write(messageBytes)
if err != nil {
fmt.Println("Error writing message:", err)
os.Exit(1)
}
// 读取响应
headerBuffer := make([]byte, 4)
_, err = connection.Read(headerBuffer)
if err != nil {
fmt.Println("Error reading response header:", err)
os.Exit(1)
}
responseLength := binary.BigEndian.Uint32(headerBuffer)
responseBuffer := make([]byte, responseLength)
_, err = connection.Read(responseBuffer)
if err != nil {
fmt.Println("Error reading response:", err)
os.Exit(1)
}
fmt.Println("Received:", string(responseBuffer))
}这个示例中,使用了
encoding/binary
在高并发场景下,单个goroutine处理一个连接的方式效率较低。可以使用goroutine池来复用goroutine,或者使用epoll等多路复用技术来提高性能。
Goroutine 池: 预先创建一组goroutine,并将连接分配给这些goroutine处理。这样可以避免频繁创建和销毁goroutine的开销。
本文档主要讲述的是android rtsp流媒体播放介绍;实时流协议(RTSP)是应用级协议,控制实时数据的发送。RTSP提供了一个可扩展框架,使实时数据,如音频与视频,的受控、点播成为可能。数据源包括现场数据与存储在剪辑中数据。该协议目的在于控制多个数据发送连接,为选择发送通道,如UDP、组播UDP与TCP,提供途径,并为选择基于RTP上发送机制提供方法。希望本文档会给有需要的朋友带来帮助;感兴趣的朋友可以过来看看
0
多路复用 (epoll, kqueue): 使用操作系统提供的多路复用机制,可以在单个goroutine中同时监听多个socket连接。Go语言的
net
一个简单的goroutine池的实现思路:
package main
import (
"fmt"
"net"
"os"
"sync"
)
const (
SERVER_HOST = "localhost"
SERVER_PORT = "9988"
SERVER_TYPE = "tcp"
POOL_SIZE = 10 // Goroutine池大小
)
type Job struct {
Conn net.Conn
}
var jobQueue chan Job
func worker(jobQueue chan Job, wg *sync.WaitGroup) {
defer wg.Done()
for job := range jobQueue {
processConnection(job.Conn)
}
}
func processConnection(conn net.Conn) {
defer conn.Close()
buffer := make([]byte, 1024)
mLen, err := conn.Read(buffer)
if err != nil {
fmt.Println("Error reading:", err.Error())
return
}
fmt.Println("Received: ", string(buffer[:mLen]))
_, err = conn.Write([]byte("Message received."))
if err != nil {
fmt.Println("Error writing:", err.Error())
return
}
}
func main() {
fmt.Println("Server Running...")
server, err := net.Listen(SERVER_TYPE, SERVER_HOST+":"+SERVER_PORT)
if err != nil {
fmt.Println("Error listening:", err.Error())
os.Exit(1)
}
defer server.Close()
fmt.Println("Listening on " + SERVER_HOST + ":" + SERVER_PORT)
fmt.Println("Waiting for client...")
jobQueue = make(chan Job, 100) // 缓冲大小为 100
var wg sync.WaitGroup
// 启动 goroutine 池
for i := 0; i < POOL_SIZE; i++ {
wg.Add(1)
go worker(jobQueue, &wg)
}
for {
connection, err := server.Accept()
if err != nil {
fmt.Println("Error accept:", err.Error())
return
}
fmt.Println("Client connected")
jobQueue <- Job{Conn: connection} // 将连接放入 jobQueue
}
close(jobQueue) // 关闭 jobQueue
wg.Wait() // 等待所有 worker 完成
}这个例子中,创建了一个固定大小的goroutine池,每个连接都作为一个
Job
jobQueue
错误处理是TCP编程中非常重要的一部分。需要对各种可能出现的错误进行处理,例如连接错误、读取错误、写入错误等。同时,为了方便调试和排查问题,需要进行日志记录。
错误处理: 使用
if err != nil
日志记录: 使用
log
logrus
zap
package main
import (
"fmt"
"log"
"net"
"os"
"time"
)
const (
SERVER_HOST = "localhost"
SERVER_PORT = "9988"
SERVER_TYPE = "tcp"
)
func main() {
// 初始化日志
logFile, err := os.OpenFile("server.log", os.O_CREATE|os.O_WRONLY|os.O_APPEND, 0666)
if err != nil {
fmt.Println("Error opening log file:", err)
os.Exit(1)
}
defer logFile.Close()
log.SetOutput(logFile)
log.SetFlags(log.Ldate | log.Ltime | log.Lshortfile)
fmt.Println("Server Running...")
server, err := net.Listen(SERVER_TYPE, SERVER_HOST+":"+SERVER_PORT)
if err != nil {
log.Println("Error listening:", err.Error())
os.Exit(1)
}
defer server.Close()
fmt.Println("Listening on " + SERVER_HOST + ":" + SERVER_PORT)
fmt.Println("Waiting for client...")
for {
connection, err := server.Accept()
if err != nil {
log.Println("Error accept:", err.Error())
continue // 继续监听
}
fmt.Println("Client connected")
go processClient(connection)
}
}
func processClient(connection net.Conn) {
defer connection.Close()
buffer := make([]byte, 1024)
connection.SetReadDeadline(time.Now().Add(10 * time.Second)) // 设置读取超时
mLen, err := connection.Read(buffer)
if err != nil {
log.Println("Error reading:", err.Error())
return
}
log.Printf("Received: %s from %s\n", string(buffer[:mLen]), connection.RemoteAddr().String())
_, err = connection.Write([]byte("Message received."))
if err != nil {
log.Println("Error writing:", err.Error())
return
}
}这个例子中,使用了
log
SetReadDeadline
心跳检测用于检测客户端和服务端之间的连接是否仍然有效。客户端定期向服务端发送心跳包,服务端如果在一定时间内没有收到心跳包,则认为连接已断开。
// 服务端 (修改后的 processClient 函数)
func processClient(connection net.Conn) {
defer connection.Close()
for {
connection.SetReadDeadline(time.Now().Add(30 * time.Second)) // 设置读取超时为 30 秒
buffer := make([]byte, 1024)
mLen, err := connection.Read(buffer)
if err != nil {
log.Println("Error reading:", err.Error())
return // 连接超时或发生错误,退出循环
}
message := string(buffer[:mLen])
if message == "heartbeat" {
log.Println("Received heartbeat from", connection.RemoteAddr())
// 可以选择发送一个响应,表示收到心跳
_, err = connection.Write([]byte("heartbeat_ack"))
if err != nil {
log.Println("Error writing heartbeat ack:", err.Error())
return
}
} else {
log.Printf("Received: %s from %s\n", message, connection.RemoteAddr().String())
_, err = connection.Write([]byte("Message received."))
if err != nil {
log.Println("Error writing:", err.Error())
return
}
}
}
}
// 客户端 (修改后的 main 函数)
func main() {
connection, err := net.Dial(SERVER_TYPE, SERVER_HOST+":"+SERVER_PORT)
if err != nil {
fmt.Println("Error dialing:", err.Error())
os.Exit(1)
}
defer connection.Close()
fmt.Println("Connected to server")
// 定期发送心跳
ticker := time.NewTicker(10 * time.Second) // 每 10 秒发送一次心跳
defer ticker.Stop()
for range ticker.C {
_, err := connection.Write([]byte("heartbeat"))
if err != nil {
fmt.Println("Error writing heartbeat:", err.Error())
return // 连接断开,退出循环
}
fmt.Println("Sent heartbeat")
// 可以选择读取服务器的响应
buffer := make([]byte, 1024)
connection.SetReadDeadline(time.Now().Add(5 * time.Second)) // 设置读取超时
_, err = connection.Read(buffer)
if err != nil {
fmt.Println("Error reading heartbeat ack:", err.Error())
// 可以选择重试或者退出
continue
}
fmt.Println("Received heartbeat ack:", string(buffer))
}
}在这个例子中,客户端每10秒发送一次心跳包,服务端如果在30秒内没有收到心跳包,则认为连接已断开。客户端也设置了读取超时,防止一直阻塞。
这些示例代码只是最基本的实现,实际应用中还需要根据具体需求进行修改和完善。例如,可以添加更完善的错误处理、日志记录、数据校验等功能。
以上就是GolangTCP数据包发送与接收示例的详细内容,更多请关注php中文网其它相关文章!
每个人都需要一台速度更快、更稳定的 PC。随着时间的推移,垃圾文件、旧注册表数据和不必要的后台进程会占用资源并降低性能。幸运的是,许多工具可以让 Windows 保持平稳运行。
Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号