首页 > 其他分享 >【Socket】解决TCP粘包问题

【Socket】解决TCP粘包问题

时间：2024-06-04 13:01:32浏览次数：16  
标签：index socket buffer sock TCP 粘包 message server Socket

一、介绍

TCP一种面向连接的、可靠的、基于字节流的传输层协议。

三次握手：

  1. 客户端发送服务端连接请求，等待服务端的回复。
  2. 服务端收到请求，服务端回复客户端，可以建立连接，并等待。
  3. 客户端收到回复并发送，确认连接。服务端收到回复。连接成功。
    image.png
    四次挥手：

与三次握手不同，客户端和服务端都可以主动断开连接。

  1. 服务A向服务B发送FIN报文段，表示没有数据要传输
  2. 服务B收到报文段，回复一个ACK报文段，表示也没有数据需要传输了。
  3. 服务B发送FIN报文段，请求关闭连接。
  4. 服务A收到报文段，服务B发送ACK报文段，服务B收到报文段后直接关闭连接，服务A没有收到回复，也开始断开连接。
    image.png

因为复杂的三次握手和四次挥手，保证了数据的可靠性和安全性。因此也造成了更大的开销。

二、产生的问题

由于TCP的可靠性传输，可以理解为客户端和服务端之间建立了一个传输管道，可以互相不断的传输数据。但是可能由于数据的传输与接收之间存在差异。使用在服务端和客户端之间，存在一个缓冲区，用于数据的缓冲。数据传输之前会先到缓冲区。

例如服务端A和客户端B。A不断向服务端传输数据，B不断处理服务A传输的数据。服务A发送数据到缓冲区，服务B从缓冲区获取数据来处理。由于服务B处理的速度比较慢，就会导致缓冲区堆积多个数据包。当服务B处理完再取时，取出的可能是多个数据包粘在一起的数据包，这时候处理就会出现问题。
image.png

三、解决方案

设置包长、包头包尾、消息分隔符解决粘包和拆包问题。这些方法通过明确消息边界，确保接收端能够准确地解析每个完整的消息。这里举例数据包分隔符。

1、设置包头包尾

现在我们模拟粘包情况，也就是客户端数据堆积。

Server

import socket
import time

def receive_message(sock):
    buffer = b""
    while True:
        packet = sock.recv(1024)
        if not packet:
            break
        buffer += packet
        print("缓冲区数据 : "+ str(buffer))
        time.sleep(5)
        while True:
            start_index = buffer.find(b"StartPackage")
            end_index = buffer.find(b"EndPackage")
            if start_index != -1 and end_index != -1 and start_index < end_index:
                start_index += len(b"StartPackage")
                message = buffer[start_index:end_index]
                buffer = buffer[end_index + len(b"EndPackage"):]  
                print("收到客户端消息: "+message.decode())
            else:
                break 

server_sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server_sock.bind(('localhost', 8888))
server_sock.listen(1)

client_sock, _ = server_sock.accept()

receive_message(client_sock)
client_sock.close()
server_sock.close()

Client

import socket
import time

def send_message(sock, message):
    packet = b"StartPackage" + message.encode() + b"EndPackage"  
    sock.sendall(packet)

sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
sock.connect(('localhost', 8888))

for i in range(1,11,1):
    message = "Hello, world!--"+str(i)
    send_message(sock, message)
    print("发送消息 "+message)
    time.sleep(1)
sock.close()

根据服务端输出可以看到，缓冲区已经出现粘包，多个数据包堆积到一起，这里利用包头包尾进行拆包，确保数据的完整性。

2、设置包长

Server

import socket
import struct
import time

def receive_message(sock):
    buffer = b""
    while True:
        packet = sock.recv(1024)
        if not packet:
            break
        buffer += packet
        print(f"缓冲区数据 : {buffer}")
        
        while len(buffer) >= 4:  
            header = buffer[:4]
            message_length = struct.unpack('>I', header)[0]
            print(f"包长为: {message_length}")

            if len(buffer) < 4 + message_length:
                break

            start_index = 4
            end_index = 4 + message_length
            message = buffer[start_index:end_index]
            buffer = buffer[end_index:] 
            print(f"收到客户端消息: {message.decode()} ")
        time.sleep(5)  

server_sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server_sock.bind(('localhost', 8888))
server_sock.listen(1)
client_sock, _ = server_sock.accept()
receive_message(client_sock)
client_sock.close()
server_sock.close()

Client

import socket
import struct
import time

def send_message(sock, message):
    message_bytes = message.encode()
    message_length = len(message_bytes)
    header = struct.pack('>I', message_length)
    packet = header + message_bytes
    sock.sendall(packet)

sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
sock.connect(('localhost', 8888))

for i in range(1, 11):
    message = "Hello, world!--" + str(i)
    send_message(sock, message)
    print(f"发送消息:{message}" )
    time.sleep(1)

sock.close()

可以看到由于处理的时间过长，导致数据堆积在缓冲区形成粘包。通过在消息头部设置包长，确定数据包的完整性。通过包长将粘包进行拆包。

3、设置包分隔符

Server

import socket
import time

def receive_message(sock):
    buffer = b""
    delimiter = b"<END>"
    while True:
        packet = sock.recv(1024)
        if not packet:
            break
        buffer += packet
        print("f缓冲区数据: {buffer} ")
        
        while True:
            end_index = buffer.find(delimiter)
            if end_index != -1:  
                message = buffer[:end_index]  
                buffer = buffer[(end_index + len(delimiter)):]  
                print(f"收到客户端消息: { message.decode()} ")
            else:
                break
        time.sleep(5)              

server_sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
server_sock.bind(('localhost', 8888))
server_sock.listen(1)
client_sock, _ = server_sock.accept()
receive_message(client_sock)
client_sock.close()
server_sock.close()

Client

import socket
import time

def send_message(sock, message):
    delimiter = b"<END>"
    packet = message.encode() + delimiter 
    sock.sendall(packet)

sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
sock.connect(('localhost', 8888))

for i in range(10):
    message = "Hello, world!--" + str(i)
    send_message(sock, message)
    print(f"发送消息: {message}")
    time.sleep(1)
sock.close()

可以看到也是出现了数据堆积，粘包，但是最后打印的结果是正确的。通过使用数据包分隔符，保证数据的完整性。

四、总结

TCP粘包问题是由于TCP的流式传输特点导致的，在传输过程中多个数据包可能会粘在一起。粘包问题会导致接收端无法正确解析数据包，因为接收端无法区分哪些字节属于哪个数据包，可能会出现数据包内容混乱或不完整的情况。为了解决这个问题，可以使用固定长度消息、消息分隔符、消息头加消息体、应用层协议等方法。具体选择哪种方法需要根据应用场景和需求来确定。

标签：index,socket,buffer,sock,TCP,粘包,message,server,Socket
From： https://www.cnblogs.com/changwan/p/18230554

相关文章

  • 《计算机网络微课堂》实验24 TCP的运输连接管理
    下面我们来进行一个仿真实验，本仿真实验的目的在于验证TCP使用三报文握手来建立连接，使用四报文挥手来释放连接。我们首先来构建一个非常简单的网络拓扑，只需要一台普通的主机和一台普通的服务器，然后将它们直连即可，选择这里的终端设备，然后拖动一台普通的主机到逻辑工作空间，再拖动......
  • TCP协议的核心机制
    TCP协议的核心机制一:确认应答机制1.2:超时重传接收缓冲区超时重传时间重置连接一:确认应答机制对于TCP协议来说,要解决的一个很重要的问题,就是可靠传输可靠传输,不是指发送方能够100%的把数据发送给接收方,而是尽可能.尤其是让发送方知道,接收方是否收到.举个......
  • 郑州大学计算机网络实验04 TCP协议探索和连接管理分析
    实验四：TCP协议探索和连接管理分析【实验目的】1、掌握TCP协议数据格式；2、掌握TCP首部各字段含义；3、掌握TCP建立连接和释放连接的过程；4、熟悉Linux下truncate命令的使用方法；5、了解Linux中利用nc命令开启远程shell的方法。【实验步骤与结果记录】要求：根据实验指导书中的......
  • socket网络编程——套接字地址结构
    一、通用socket地址结构  socket网络编程接口中表示socket地址的是结构体sockaddr，其定义如下：1.#include<bits/socket.h>2.3.structsockaddr4.{5.sa_family_tsa_family;6.charsa_data[14];7.}; sa_family成员是地址族类型（sa_family_t）的变量。......
  • ruoyi若依整合websocket
    原文链接：https://blog.csdn.net/qq_33342112/article/details/132096930注：本文档中的ruoyi框架为前后不分离版本，nginx配置与前后分离版有所不同。一、导pom，版本需与springboot版本一致<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot......
  • DDOS之TCP连接耗尽攻击与防御
    攻击原理connectionflood攻击是非常有效的利用小流量冲击大带宽的攻击手段，这种攻击方式曾经风靡一时。攻击的原理是利用真实IP向服务器发起大量的连接，并且建立连接之后很长时间不释放，占用服务器的资源，造成服务器服务器上WAIT连接状态过多，效率降低，消耗对方网络资源甚至耗尽，无......
  • 拼多多面试：Netty如何解决粘包问题？
    粘包和拆包问题也叫做粘包和半包问题，它是指在数据传输时，接收方未能正常读取到一条完整数据的情况（只读取了部分数据，或多读取到了另一条数据的情况）就叫做粘包或拆包问题。从严格意义上来说，粘包问题和拆包问题属于两个不同的问题，接下来我们分别来看。1.粘包问题粘包问题是指在网络......
  • Socket编程模型
    Socket，套接字就是两台主机之间逻辑连接的端点，其属于TCP/IP协议中的传输层协议，主要解决数据如何在网络中传输。而HTTP是应用层协议，主要解决如何包装数据(数据的格式化)。Socket是通信的基石，是支持TCP/IP协议的网络通信的基本操作单元。它是网络通信过程中端点的抽象表示，包......
  • iPhone网络抓包教程：运行tcpdump并在Wireshark进行网络抓包
    热烈欢迎，请直接点击！！！进入博主AppStore主页，下载使用各个作品！！！注：博主将坚持每月上线一个新app！！ 1、安装Xcode，创建项目并连接至iPhone。2、iPhone连接至iMac，通过访达，获取iPhone的UDID。3、检查是否已安装rvictl。通常其随Xcode一起安装的：$whichrvictl/Library/Apple/usr/......
  • RTCP报文解析
     RTCP包的头部结构体定义structRTCP_Header{unsignedshortrc:5;unsignedshortpadding:1;unsignedshortversion:2;//1charunsignedshortpayloadtype:8;//2charunsignedshortlength;//3,4charunsignedintssrc;//5,6,7,8char......

赞助商

阅读排行

网站主页关于我们联系我们网站地图

本网站内容转载自其他媒体，侵权联系[admin##ips99.com]。

Copyright © 2020-2023 IPS99 版权所有 IPS99