5.网络编程-socker(golang版)

目录

一、什么是socket?

二、Golang中使用TCP

TCP服务端

TCP客户端​​​​​​​

三、TCP黏包,拆包

1.什么是粘包,拆包?

2.为什么UDP没有粘包,拆包?

3.粘包拆包发生场景

4.TCP黏包

黏包服务端

黏包客户端

为什么会出现粘包

解决方案

自定义协议

服务端

客户端

5.TCP拆包

为什么会出现TCP拆包

常见方案

四、Golang中使用UDP

UDP服务端

UDP客户端


一、什么是socket?

Socket是BSD UNIX的进程通信机制,通常也称作”套接字”,用于描述IP地址和端口,是一个通信链的句柄。Socket可以理解为TCP/IP网络的API,它定义了许多函数或例程,程序员可以用它们来开发TCP/IP网络上的应用程序。电脑上运行的应用程序通常通过”套接字”向网络发出请求或者应答网络请求。

Socket是应用层与TCP/IP协议族通信的中间软件抽象层。在设计模式中,Socket其实就是一个门面模式,它把复杂的TCP/IP协议族隐藏在Socket后面,对用户来说只需要调用Socket规定的相关函数,让Socket去组织符合指定的协议数据然后进行通信。

网络编程即socket编程

二、Golang中使用TCP

在Go语言中使用Socket编程,通常指的是使用标准库net包中的net.TCPConnnet.UDPConn接口来实现TCP或UDP网络通信。以下分别给出一个简单的TCP服务器和客户端示例:

TCP服务端

package mainimport ("bufio""fmt""log""net"
)func handleConnection(conn net.Conn) {defer conn.Close() // 关闭连接for {reader := bufio.NewReader(conn)var buf [128]byten, err := reader.Read(buf[:]) // 读取数据if err != nil {fmt.Println("read from client failed, err:", err)break}recvStr := string(buf[:n])fmt.Println("收到client端发来的数据:", recvStr)conn.Write([]byte(recvStr)) // 发送数据}
}func main() {listener, err := net.Listen("tcp", ":8080")if err != nil {log.Fatal(err)}defer listener.Close()log.Println("Listening for connections on :8080...")for {conn, err := listener.Accept()if err != nil {log.Println("Error accepting connection:", err)continue}go handleConnection(conn) // 在新的goroutine中处理每个连接}
}

TCP客户端

package mainimport ("bufio""fmt""log""net""os""strings"
)func main() {conn, err := net.Dial("tcp", "localhost:8080")if err != nil {log.Fatal(err)}defer conn.Close()log.Println("Connected to localhost:8080")inputReader := bufio.NewReader(os.Stdin)for {input, _ := inputReader.ReadString('\n') // 读取用户输入inputInfo := strings.Trim(input, "\r\n")if strings.ToUpper(inputInfo) == "Q" { // 如果输入q就退出return}_, err = conn.Write([]byte(inputInfo)) // 发送数据if err != nil {return}buf := [512]byte{}n, err := conn.Read(buf[:])if err != nil {fmt.Println("recv failed, err:", err)return}fmt.Printf("recv server msg: %s", buf[:n])}
}

以上示例展示了如何使用Go语言创建一个简单的TCP服务器和客户端。服务器监听8080端口,接受客户端连接并转发数据。客户端连接到本地的8080端口,发送一个消息并接收服务器的响应。

对于UDP编程,可以使用net.ListenUDP创建UDP监听器,net.DialUDP创建UDP连接,以及net.UDPConn接口进行数据收发。具体的代码实现与上述TCP示例类似,但需要注意UDP是无连接的、不可靠的传输协议,相应的编程模型和错误处理会有所不同。

三、TCP黏包,拆包

1.什么是粘包,拆包?

  • TCP的粘包和拆包问题往往出现在基于TCP协议的通讯中,比如RPC框架。
  • 在使用TCP进行数据传输时,由于TCP是基于字节流的协议,而不是基于消息的协议,可能会出现粘包(多个消息粘在一起)和拆包(一个消息被拆分成多个部分)的问题。这些问题可能会导致数据解析错误或数据不完整。

2.为什么UDP没有粘包,拆包?

UDP(User Datagram Protocol)没有粘包和拆包现象,这是由其设计特性和工作方式所决定的。以下是详细解释:

  1. 面向数据报的传输方式

    • UDP是一种面向数据报的协议,每个数据报(datagram)都是一个独立、完整的信息单元,具有明确的边界。每个数据报包含源端口、目的端口、长度、校验和等信息,以及用户数据。发送端将数据封装成一个个数据报发送,接收端则按数据报的完整单位接收,不存在数据报之间的合并或拆分。
  2. 无连接状态

    • UDP是无连接的协议,发送数据前无需建立连接,发送后也不维持连接状态。每个数据报的发送与接收都是独立的事件,没有前后关联。因此,不存在因连接状态导致的数据包合并(即“粘包”)。
  3. 无顺序保证、重传机制

    • UDP不保证数据报的顺序传递,也不进行数据重传。每个数据报在网络中独立传输,可能因为网络条件等因素导致乱序、丢失或重复,但这些都由应用层自行处理。由于每个数据报都是单独处理的,不会因为等待其他数据报而被“粘”在一起,也不会因为重传而“拆包”。
  4. 固定报头长度

    • UDP数据报的报头长度是固定的(8字节),没有可变长度的选项字段,这使得接收端可以很容易地定位到用户数据的起始位置,无需担心因为解析报头时遇到“粘包”问题。
  5. 无流控和拥塞控制

    • TCP具有滑动窗口、流量控制和拥塞控制机制,这些机制可能导致发送端积攒多个小数据包合并成一个大的TCP段发送,或者在接收端因窗口大小限制而暂时缓存数据,从而形成“粘包”。而UDP没有这些复杂的控制机制,数据报一旦发送出去,就不受发送端或接收端的流量控制和拥塞控制影响,不会发生“粘包”或“拆包”。

综上所述,由于UDP的面向数据报、无连接状态、无顺序保证、无重传、固定报头长度以及无流控和拥塞控制等特性,每个UDP数据报在发送和接收时都是独立处理的,具有明确的边界,不会与其他数据报合并(“粘包”)或需要拆分(“拆包”)。应用程序使用UDP时,需要自行处理数据完整性、顺序和重传等问题。

3.粘包拆包发生场景

因为TCP是面向流,没有边界,而操作系统在发送TCP数据时,会通过缓冲区来进行优化,例如缓冲区为1024个字节大小。

  • 如果一次请求发送的数据量比较小,没达到缓冲区大小,TCP则会将多个请求合并为同一个请求进行发送,这就形成了粘包问题。
  • 如果一次请求发送的数据量比较大,超过了缓冲区大小,TCP就会将其拆分为多次发送,这就是拆包。

关于粘包和拆包可以参考下图的几种情况:

  • 理想状况:两个数据包逐一分开发送。
  • 粘包:两个包一同发送。
  • 拆包:Server接收到不完整的或多出一部分的数据包。

4.TCP黏包

黏包服务端

package mainimport ("bufio""fmt""io""net"
)// socket_stick/server/main.gofunc process(conn net.Conn) {defer conn.Close()reader := bufio.NewReader(conn)var buf [1024]bytefor {n, err := reader.Read(buf[:])if err == io.EOF {break}if err != nil {fmt.Println("read from client failed, err:", err)break}recvStr := string(buf[:n])fmt.Println("收到client发来的数据:", recvStr)}
}func main() {listen, err := net.Listen("tcp", "127.0.0.1:8080")if err != nil {fmt.Println("listen failed, err:", err)return}defer listen.Close()for {conn, err := listen.Accept()if err != nil {fmt.Println("accept failed, err:", err)continue}go process(conn)}
}

黏包客户端

package mainimport ("fmt""net"
)// socket_stick/client/main.gofunc main() {conn, err := net.Dial("tcp", "127.0.0.1:8080")if err != nil {fmt.Println("dial failed, err", err)return}defer conn.Close()for i := 0; i < 10; i++ {msg := `你好,吃了吗?`conn.Write([]byte(msg))}
}

客户端分10次发送的数据,在服务端并没有成功的输出10次,而是多条数据“粘”到了一起。 

为什么会出现粘包

主要原因就是tcp数据传递模式是流模式,在保持长连接的时候可以进行多次的收和发。

“粘包"可发生在发送端也可发生在接收端:

  1. 由Nagle算法造成的发送端的粘包:Nagle算法是一种改善网络传输效率的算法。简单来说就是当我们提交一段数据给TCP发送时,TCP并不立刻发送此段数据,而是等待一小段时间看看在等待期间是否还有要发送的数据,若有则会一次把这两段数据发送出去。
  2. 接收端接收不及时造成的接收端粘包:TCP会把接收到的数据存在自己的缓冲区中,然后通知应用层取数据。当应用层由于某些原因不能及时的把TCP的数据取出来,就会造成TCP缓冲区中存放了几段数据。

出现"粘包"的关键在于接收方不确定将要传输的数据包的大小,因此我们可以对数据包进行封包和拆包的操作。

封包:封包就是给一段数据加上包头,这样一来数据包就分为包头和包体两部分内容了(过滤非法包时封包会加入"包尾"内容)。包头部分的长度是固定的,并且它存储了包体的长度,根据包头长度固定以及包头中含有包体长度的变量就能正确的拆分出一个完整的数据包。

我们可以自己定义一个协议,比如数据包的前4个字节为包头,里面存储的是发送的数据的长度。

解决方案

自定义协议
package protoimport ("bufio""bytes""encoding/binary"
)// Encode 将消息编码
func Encode(message string) ([]byte, error) {// 读取消息的长度,转换成int32类型(占4个字节)var length = int32(len(message))var pkg = new(bytes.Buffer)// 写入消息头err := binary.Write(pkg, binary.LittleEndian, length)if err != nil {return nil, err}// 写入消息实体err = binary.Write(pkg, binary.LittleEndian, []byte(message))if err != nil {return nil, err}return pkg.Bytes(), nil
}// Decode 解码消息
func Decode(reader *bufio.Reader) (string, error) {// 读取消息的长度lengthByte, _ := reader.Peek(4) // 读取前4个字节的数据lengthBuff := bytes.NewBuffer(lengthByte)var length int32err := binary.Read(lengthBuff, binary.LittleEndian, &length)if err != nil {return "", err}// Buffered返回缓冲中现有的可读取的字节数。if int32(reader.Buffered()) < length+4 {return "", err}// 读取真正的消息数据pack := make([]byte, int(4+length))_, err = reader.Read(pack)if err != nil {return "", err}return string(pack[4:]), nil
}
服务端
package mainimport ("bufio""csdn/proto""fmt""io""net"
)func process(conn net.Conn) {defer conn.Close()reader := bufio.NewReader(conn)for {msg, err := proto.Decode(reader)if err == io.EOF {return}if err != nil {fmt.Println("decode msg failed, err:", err)return}fmt.Println("收到client发来的数据:", msg)}
}func main() {listen, err := net.Listen("tcp", "127.0.0.1:8080")if err != nil {fmt.Println("listen failed, err:", err)return}defer listen.Close()for {conn, err := listen.Accept()if err != nil {fmt.Println("accept failed, err:", err)continue}go process(conn)}
}
客户端
package mainimport ("csdn/proto""fmt""net"
)func main() {conn, err := net.Dial("tcp", "127.0.0.1:8080")if err != nil {fmt.Println("dial failed, err", err)return}defer conn.Close()for i := 0; i < 10; i++ {msg := `你好,吃了吗?`data, err := proto.Encode(msg)if err != nil {fmt.Println("encode msg failed, err:", err)return}conn.Write(data)}
}

5.TCP拆包

为什么会出现TCP拆包

TCP拆包现象主要由以下几个原因导致:

  1. 网络传输限制 - 最大传输单元(MTU):TCP协议允许发送端将数据划分为多个数据段(segments)进行发送。这些数据段在传输过程中可能会遇到网络路径中不同设备的最大传输单元(MTU)限制。MTU是指网络层(如IP层)能够承载的最大数据包尺寸,通常以字节为单位。如果一个TCP数据段的大小超过了路径中某个设备的MTU,该设备会将数据包进行分片(fragmentation),将其分割成多个较小的数据包以便通过网络。这些分片数据包可能独立地经过网络传输,并在接收端以不同的顺序到达。尽管TCP协议会确保这些分片数据包在接收端按正确的顺序重组,但应用层接收到的数据可能不再是发送端最初连续发送的形式,从而表现为拆包。

  2. 接收端缓冲区满:接收端的TCP连接有一个缓冲区用于暂存接收到的数据。当接收端处理数据的速度赶不上数据到达的速度,或者由于其他原因导致缓冲区空间不足时,新的数据段可能会被推迟接收。这种情况下,即使原本连续的数据段在传输过程中没有被网络设备分片,也可能因为接收端暂时无法接纳而被迫分开接收,从而在应用层看起来像是发生了拆包。

  3. 网络拥塞:在网络拥塞时,数据包可能会在网络中经历更长的延迟,甚至被路由器暂时存储(队列化)。这可能导致原本连续发送的数据段到达接收端的顺序被打乱,或者由于接收端TCP窗口大小限制,只能接收部分数据,从而出现拆包现象。

综上所述,TCP拆包主要源于网络传输中的MTU限制导致的数据分片、接收端缓冲区处理能力的限制,以及网络拥塞等因素。为应对拆包问题,通常需要在应用层设计合适的协议或策略,如消息定界、使用更高层协议、合理设置接收缓冲区大小、实现应用层重传机制等。

常见方案

  1. 固定长度:发送端将每个消息固定为相同的长度,接收端按照固定长度进行拆包。这样可以确保每个消息的长度是一致的,但是对于不同长度的消息可能会浪费一些空间。
  2. 分隔符:发送端在每个消息的末尾添加一个特殊的分隔符(比如换行符或特殊字符),接收端根据分隔符进行拆包。这种方法适用于消息中不会出现分隔符的情况。
  3. 消息长度前缀:发送端在每个消息前面添加一个固定长度的消息长度字段,接收端先读取消息长度字段,然后根据长度读取相应长度的数据。这种方法可以准确地拆分消息,但需要保证消息长度字段的一致性。

四、Golang中使用UDP

在Go语言中使用UDP(User Datagram Protocol)进行网络通信,您可以使用标准库net包提供的net.UDPConn接口。以下是一个简单的UDP服务器和客户端示例:

UDP服务端

package mainimport ("fmt""net"
)func main() {// 监听指定的UDP端口serverAddr, err := net.ResolveUDPAddr("udp", ":8080")if err != nil {fmt.Println("Error resolving address:", err)return}listener, err := net.ListenUDP("udp", serverAddr)if err != nil {fmt.Println("Error listening:", err)return}defer listener.Close()fmt.Println("UDP server listening on :8080")buf := make([]byte, 1024)for {n, remoteAddr, err := listener.ReadFromUDP(buf)if err != nil {fmt.Println("Error reading:", err)continue}message := buf[:n]fmt.Printf("Received message from %v: %s\n", remoteAddr, message)// 处理消息并回复(可选)response := "Hello, UDP client!"_, err = listener.WriteToUDP([]byte(response), remoteAddr)if err != nil {fmt.Println("Error writing:", err)}}
}

UDP客户端

package mainimport ("fmt""net"
)func main() {serverAddr, err := net.ResolveUDPAddr("udp", "localhost:8080")if err != nil {fmt.Println("Error resolving address:", err)return}conn, err := net.DialUDP("udp", nil, serverAddr)if err != nil {fmt.Println("Error connecting:", err)return}defer conn.Close()message := "Hello, UDP server!"_, err = conn.Write([]byte(message))if err != nil {fmt.Println("Error sending:", err)return}fmt.Println("Sent message:", message)buf := make([]byte, 1024)n, _, err := conn.ReadFromUDP(buf)if err != nil {fmt.Println("Error reading:", err)return}response := buf[:n]fmt.Printf("Received response: %s\n", response)
}

在这个示例中,服务器监听8080端口,接收客户端发送的消息并打印出来,然后向客户端发送一条回复消息。客户端连接到服务器,发送一条消息并接收服务器的响应。注意,UDP是无连接的、不可靠的协议,不保证消息的顺序、可靠传输或重传,适用于对实时性要求较高但能容忍一定程度数据丢失的应用场景。在实际使用时,可能需要根据应用需求添加适当的错误处理、重传机制和数据校验等逻辑。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/801661.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

解决 IDEA每次打开新的项目都要重新设置maven问题

目录 一、当前项目设置maven 如下图&#xff1a; 二、设置打开的新项目的maven 如下图&#xff1a;​ 一、当前项目设置maven 对于当前项目我们都知道设置maven的配置要在 File -- Settings -- Build -- Maven 中设置 如下图&#xff1a; 二、设置打开的新项目的maven F…

整理的微信小程序日历(单选/多选/筛选)

一、日历横向多选&#xff0c;支持单日、双日、三日、工作日等选择 效果图 wxml文件 <view class"calendar"><view class"section"><view class"title flex-box"><button bindtap"past">上一页</button&…

stm32与esp8266WIFI模块

硬件介绍 WIFI模块ESP-01S 使用AT指令控制1-ESP8266-AT指令初试化及部分基础知识_ch_pd-CSDN博客 项目需求 通过ESP-01SWIFI模块控制LED状态模拟插座 串口1用于与ESP8266通讯&#xff0c;串口2连接PC&#xff0c;用于打印log&#xff0c;查看系统状态 项目接线 将WIFI模块的…

智慧农场物联网系统:重塑农业的未来

随着科技的进步&#xff0c;物联网技术正在逐渐改变我们的生活。在农业领域&#xff0c;物联网系统也正在发挥着越来越重要的作用&#xff0c;为智慧农场的发展提供了新的可能。本文将深入探讨智慧农场物联网系统的优势、应用场景、技术实现以及未来发展趋势。 一、智慧农场物…

ATAM方法架构评估实践

用ATAM方法评估软件体系结构&#xff0c;其工作分为4个基本阶段&#xff0c;即演示、调查和分析、测试和报告ATAM&#xff08;如图1所示&#xff09;。接下来分别就每个阶段的实践进行详细介绍。 图1 ATAM方法的评估实践阶段划分 1.阶段1——演示&#xff08;Presentation&…

转化延迟预估

转化数据延迟久&#xff0c;但实时反馈至关重要涉及到模型预估准度&#xff0c;进而影响客户成本。 现状&#xff1a;超过12h的转化被视为负例&#xff0c;12h以内的为正例&#xff0c;这样会导致模型低估。公示如下&#xff1a; P ( 转化 ∣ 点击 ) 延迟 ≤ 12 h 的转化 未转…

什么是人工智能?人工智能、机器学习、深度学习三者之间有什么关系吗?

深度学习是机器学习的一个分支。深度学习是机器学习的一部分&#xff0c;与机器学习的其他分支学科&#xff0c;以及统计学、人工智能等学科都有着紧密的联系。深度学习、机器学习、人工智能、统计学之间的关系如图1-4所示。 图1-4 深度学习、机器学习、人工智能、统计学之间的…

【C语言】指针篇(指针数组,数组指针,函数指针,一级、二级指针)

文章目录 一、指针基础1.什么是指针2.指针的定义和初始化3.指针的解引用4.野指针和空指针5.指针的类型6.指针的大小7.指针的运算8.指针和数组9.指针和字符串10.二级指针 二、指针数组和数组指针1.指针数组2.数组指针3.练习 三、数组传参和指针传参1.一维数组传参2.二维数组传参…

Maven POM元素解析

这是对Maven中使用的Maven项目描述符的引用。 <project xmlns"http://maven.apache.org/POM/4.0.0" xmlns:xsi"http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation"http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/…

GEE:基于CHIRPS数据集的累积降水量影像下载

作者:CSDN @ _养乐多_ 本文将介绍在 Google Earth Engine(GEE)平台上使用“UCSB-CHG/CHIRPS/DAILY”数据集计算某一段时期(某年/某个季节/某月)的累积降雨量图像,并下载。 结果如下图所示, 文章目录 一、核心函数二、代码链接三、完整代码一、核心函数 .sum() // 对影…

02 Php学习:变量

Php 变量声明 Php 变量赋值 在PHP中&#xff0c;变量赋值是指将一个值赋给一个变量。变量赋值是 PHP 中最基本和常见的操作之一&#xff0c;以下是关于变量赋值的详细说明和示例&#xff1a; 变量赋值语法&#xff1a; $variable value;$variable&#xff1a;要赋值的变量名…

【MATLAB源码-第38期】基于OFDM的块状导频和梳状导频误码率性能对比,以及LS/LMMSE两种信道估计方法以及不同调制方式对比。

操作环境&#xff1a; MATLAB 2022a 1、算法描述 块状导频和梳状导频都是用于无线通信系统中信道估计的方法。 块状导频&#xff1a; 定义&#xff1a; 在频域上&#xff0c;块状导频是连续放置的一组导频符号。这意味着所有的导频符号都集中在一个短的时间段内发送。 优点…

php站长在线工具箱源码优化版

环境要求 PHP > 7.4MySQL > 5.6fileinfo扩展使用Redis缓存需安装Redis扩展 源码下载地址&#xff1a;php站长在线工具箱源码优化版.zip

RISC-V特权架构 - 模式切换与委托

RISC-V特权架构 - 模式切换与委托 1 导致模式切换的常见动作2 异常处理规则3 异常处理时模式切换3.1 在U模式下&#xff0c;发生异常3.2 在S模式下&#xff0c;发生异常3.3 在M模式下&#xff0c;发生异常 4 系统调用时模式切换5 中断处理时模式切换 本文属于《 RISC-V指令集基…

PaddleVideo:onnx模型导出

本文节介绍 PP-TSM 模型如何转化为 ONNX 模型&#xff0c;并基于 ONNX 引擎预测。 1&#xff1a;环境准备 安装 Paddle2ONNX python -m pip install paddle2onnx 安装 ONNXRuntime # 建议安装 1.9.0 版本&#xff0c;可根据环境更换版本号 python -m pip install onnxrunti…

GEE:样本点的样式设置

作者:CSDN @ _养乐多_ 本文将介绍在Google Earth Engine (GEE)平台上为样本点设置样式的方法和代码,样本点可以设置成任何颜色,以及7种形状,以便更直观了解数据的分布和特征。 文章目录 一、统一设置样式1.1 示例代码1.2 示例代码链接二、每一类一个样式2.1 示例代码2.2…

7款公司电脑监控软件

7款公司电脑监控软件 研究证明&#xff0c;人们在家办公的效率比在办公室办公的效率低一半&#xff0c;其中原因是缺少监督&#xff0c;即便在公司办公&#xff0c;还存在员工偷闲的时刻&#xff0c;比如聊天、浏览无关网站、看剧、炒股等&#xff0c;企业想提高员工的工作效率…

【Java】maven传递依赖冲突解决

传递依赖的概念&#xff1a; 传递依赖:&#xff1a; A.jar 依赖 B.jar, B.jar 依赖 C.jar, 这个时候我们就说B是A的直接依赖, C是A传递依赖; 传递依赖可能会产生冲突: 联系着上面, 新导入一个jar包D.jar, D依赖C.jar, 但是B依赖的1.1版本, 而D依赖的是1.2版本, 这时候C这个j…

绝地求生:齐贺PUBG七周年!分享你的游玩感受及反馈赢惊喜道具

PUBG七周年庆典火热进行中&#xff0c;特殊道具、周年主题艾伦格上线&#xff01;七周年期间游玩PUBG&#xff0c;在评论区分享你的游玩感受及反馈&#xff0c;即可参与活动赢取夏日浪潮宝箱奖励。 参与方式 齐贺PUBG七周年&#xff01;在评论区分享分享你的七周年游玩感受及反…

鸿蒙OS实战开发:【多设备自适应服务卡片】

介绍 服务卡片的布局和使用&#xff0c;其中卡片内容显示使用了一次开发&#xff0c;多端部署的能力实现多设备自适应。 用到了卡片扩展模块接口&#xff0c;[ohos.app.form.FormExtensionAbility] 。 卡片信息和状态等相关类型和枚举接口&#xff0c;[ohos.app.form.formInf…