首页 > 其他分享 >tcp协议通信的粘包问题

tcp协议通信的粘包问题

时间:2022-12-13 15:45:03浏览次数:32  
标签:res 通信 tcp 粘包 total recv server conn size

粘包问题出现的原因

  1. tcp协议是流式协议,数据和水流一样粘在一起,没有任何界限区分

  2. 客户端收数据的时候没有收干净,这就会使得和下次结果混合在一起

解决粘包问题的思路

  1. 拿到数据的总大小total_size
  2. recv_size=0,循环接收,每接收一次recv_size+=接收的长度
  3. 直到recv_size=total_size,结束循环

自定义协议解决粘包问题!!

服务端,自定义头部大小

# 服务端应该满足两个特点:
# 1、一直对外提供服务
# 2、并发地服务多个客户端
import subprocess # 这个包是用来将对应命令结果返回的
import struct # 这个包是将数据转换成固定字节的包
from socket import *

server=socket(AF_INET,SOCK_STREAM)
server.setsockopt(SOL_SOCKET,SO_REUSEADDR,1) #就是它,在bind前加
server.bind(('127.0.0.1',8083))
server.listen(5)

#  服务端应该做两件事
# 第一件事:循环地从板连接池中取出链接请求与其建立双向链接,拿到链接对象
while True:
    conn,client_addr=server.accept()

    # 第二件事:拿到链接对象,与其进行通信循环
    while True:
        try:
            cmd=conn.recv(1024)
            if len(cmd) == 0:break
            obj=subprocess.Popen(cmd.decode('utf-8'),
                             shell=True,
                             stdout=subprocess.PIPE,
                             stderr=subprocess.PIPE
                             )

            stdout_res=obj.stdout.read() # 得到正确的结果
            stderr_res=obj.stderr.read() # 得到错误的结果
            total_size=len(stdout_res)+len(stderr_res) # 得到要发送给客户端的具体大小

            # 1、先发头信息(固定长度的bytes):对数据描述信息
            # int->固定长度的bytes
            header=struct.pack('i',total_size)
            conn.send(header)

            # 2、再发真实的数据
            conn.send(stdout_res)
            conn.send(stderr_res)

        except Exception:
            break
    conn.close()

客户端接收头部和具体数据大小

import struct
from socket import *

client=socket(AF_INET,SOCK_STREAM)
client.connect(('127.0.0.1',8083))

while True:
    cmd=input('请输入命令>>:').strip()
    if len(cmd) == 0:continue
    client.send(cmd.encode('utf-8'))

    # 解决粘包问题思路:
    # 一、先收固定长度的头:解析出数据的描述信息,包括数据的总大小total_size
    header=client.recv(4) # 这个4是头部定义好的固定大小
    total_size=struct.unpack('i',header)[0] # 这里是解包,得到真正数据的大小

    # 二、根据解析出的描述信息,接收真实的数据
    # 2、recv_size=0,循环接收,每接收一次,recv_size+=接收的长度
    # 3、直到recv_size=total_size,结束循环
    recv_size = 0
    while recv_size < total_size:
        recv_data=client.recv(1024)
        recv_size+=len(recv_data)
        print(recv_data.decode('utf-8'),end='')
    else:
        print()


# 粘包问题出现的原因
# 1、tcp是流式协议,数据像水流一样粘在一起,没有任何边界区分
# 2、收数据没收干净,有残留,就会下一次结果混淆在一起
# 解决的核心法门就是:每次都收干净,不要任何残留

当头部需要包含的数据比较多时,可以把头制成一个字典传输到客户端

import subprocess
import struct
import json
from socket import *

server=socket(AF_INET,SOCK_STREAM)
server.setsockopt(SOL_SOCKET,SO_REUSEADDR,1) #就是它,在bind前加
server.bind(('127.0.0.1',8083))
server.listen(5)

#  服务端应该做两件事
# 第一件事:循环地从板连接池中取出链接请求与其建立双向链接,拿到链接对象
while True:
    conn,client_addr=server.accept()

    # 第二件事:拿到链接对象,与其进行通信循环
    while True:
        try:
            cmd=conn.recv(1024)
            if len(cmd) == 0:break
            obj=subprocess.Popen(cmd.decode('utf-8'),
                             shell=True,
                             stdout=subprocess.PIPE,
                             stderr=subprocess.PIPE
                             )

            stdout_res=obj.stdout.read()
            stderr_res=obj.stderr.read()
            total_size=len(stdout_res)+len(stderr_res)

            # 1、制作头
            header_dic={
                "filename":"a.txt",
                "total_size":total_size,
                "md5":"123123xi12ix12"
            }

            json_str = json.dumps(header_dic)
            json_str_bytes = json_str.encode('utf-8')


            # 2、先把头的长度发过去
            x=struct.pack('i',len(json_str_bytes))
            conn.send(x)

            # 3、发头信息
            conn.send(json_str_bytes)
            # 4、再发真实的数据
            conn.send(stdout_res)
            conn.send(stderr_res)

        except Exception:
            break
    conn.close()

标签:res,通信,tcp,粘包,total,recv,server,conn,size
From: https://www.cnblogs.com/suncolor/p/16978988.html

相关文章

  • 基于tcp协议的套接字通信
    1、套接字socket简介Socket是应用层与TCP/UDP协议通信的中间软件抽象层,它充当一种接口的角色!封装了传输层以下的东西。1.1基于tcp的socket通信流程图2.tcp服务端搭建......
  • Vue笔记 - Vue组件间通信方法合集
    Vue组件间通讯方法总结目录Vue组件间通讯方法总结1.props2.$emit和$on3.$refs4.$attrs和$listeners5.provide和inject6.Vuex7.eventBus8.$parent,$children,$ro......
  • 面向连接的运输:TCP
    面向连接的运输:TCPTCP依赖于可靠数据传输,其中包括差错检测、重传、累积确认、定时器以及用于序号和确认号的首部子弹。TCP连接TCP被称为是面向连接的,这是因为在一个应用进程......
  • Tcp实现对象传输
    服务器处理用户连接线程类:publicclassServerThreadextendsThread{privateSocketsocket=null;publicServerThread(Socketsocket){this.socket=sock......
  • 进程通信之管道
    写在前面今天主要的任务就是知道什么是进程通信?进程通信是如何实现的?前面我们学习了基础IO,再往前看又学习进程的相关的概念,那么今天我们通过进程的通信来把他们用起来.......
  • 前端开发系列052-基础篇之数据流和组件通信(Vue)
    title:前端开发系列052-基础篇之数据流和组件通信(Vue)tags:categories:[]date:2017-12-2100:00:00本文是早期学习Vue整理的一些阶段性总结,内容主要关于Vue框架......
  • React组件之间的通信方式总结(下)
    一、写一个时钟用react写一个每秒都可以更新一次的时钟importReactfrom'react'importReactDOMfrom'react-dom'functiontick(){letele=<h1>{ne......
  • React组件之间的通信方式总结(上)
    先来几个术语:官方我的说法对应代码ReactelementReact元素letelement=<span>A爆了</span>Component组件classAppextendsReact.Component{}无Ap......
  • python服务端与android客户端基于TCP协议的简单通信
    点击连接服务器后接收传来的数据,改变Textview的文字内容在服务器端建立一个py文件server.pyimportsockethost='10.0.1.15''''上边这里填服务器的内网地址我也不知......
  • Qt开发:Windows 下进程间通信的可行桥梁:窗体消息SendMessage
    Qt开发:Windows下进程间通信的可行桥梁:窗体消息注:窗体消息仅适用于有窗口的进程,如果没有窗口是无法收到窗体消息的(哪怕是隐形的都可以),比如Qt中如果需要使用WindowsMessage......