标签：pip one 一点 ddr int none close 连续 一个
# 出现黏包的场景
# 连续send两个小数据
# 两个recv，第一个recv特别小
# 本质上：你不知道到底要接受多大的数据
# 解决
# 首先：发送一下这个数据到底有多大
# 再按照数据的长度接收数据
#这种解决方式的好处：
#确定了我到底要接收多大的数据
#在文件中配置一个配置项：就是每一次recv的大小 buffer=4096
# 当我们要发送大数据的时候，要明确的告诉接收方要发送多大的数据，以便接收方能够
# 准确的接收到所有的数据
# 多在文件的传输过程中
# 大文件的传输一定是按照字节读，每一次读固定的字节
# 服务端：一边读，一边传 ---------------------- 接收端：一边收，一边写
# send这个大文件之前，40000个字节，send(4096) 40000-4096-4096... -->0以此类推，一点点传
# recv这个大文件之前，recv 40000字节，recv(4096) 40000-4096-4096 -->0以此类推，一点点接
#但是为了不让你发送的数据大小也遇到黏包问题，在此引入struct模块
#以shell命令为例
import struct import socket sk = socket.socket() sk.bind((‘127.0.0.1‘,8080)) sk.listen(0) conn,addr = sk.accept() while True: cmd = input(‘>>>‘) if cmd == ‘q‘: conn.send(b‘q‘) break conn.send(cmd.encode(‘gbk‘)) num = conn.recv(4) num = struct.unpack(‘i‘,num)[0] res = conn.recv(int(num)).decode(‘gbk‘) print(res) conn.close() sk.close()
import socket import subprocess import struct sk = socket.socket() sk.connect((‘127.0.0.1‘,8080)) while True: cmd = sk.recv(1024).decode(‘gbk‘) if cmd == ‘q‘: break res = subprocess.Popen(cmd,shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE ) std_out = res.stdout.read() std_err = res.stderr.read() len_num = len(std_err)+len(std_out) num_by = struct.pack(‘i‘,len_num) sk.send(num_by) sk.send(std_out) sk.send(std_err) sk.close()
标签：pip one 一点 ddr int none close 连续 一个
原文地址：https://www.cnblogs.com/Mr-Feng/p/10886337.html
