tcp套接字粘包解决办法
2023-03-20 14:43:19 时间
粘包只会出现在tcp,udp传输不会产生粘包现象。解决粘包的原理就是服务器预先向客户端发送客户端即将获取文件的大小。
第一版解决方案:
服务器:
1 # Author : Kelvin 2 # Date : 2019/2/2 17:38 3 from socket import * 4 import subprocess 5 6 ip_conf = ("127.0.0.1", 8888) 7 buffer_capacity = 1024 8 tcp_server = socket(AF_INET, SOCK_STREAM) 9 tcp_server.bind(ip_conf) 10 tcp_server.listen(5) 11 while True: 12 conn, addr = tcp_server.accept() 13 while True: 14 try: 15 cmd = conn.recv(buffer_capacity) # 如果强制断开连接会触发try,try正是解决强制中断连接的问题 16 print("收到的cmd:%s" % cmd) 17 if not cmd: # 如果使用quit断开连接,服务器会死循环收到空,该判断正是解决此问题 18 break 19 res = subprocess.Popen(cmd.decode("utf8"), shell=True, stdout=subprocess.PIPE, stdin=subprocess.PIPE, 20 stderr=subprocess.PIPE) 21 err = res.stderr.read() 22 if err: 23 back_msg = err 24 else: 25 back_msg = res.stdout.read() 26 if not back_msg: 27 back_msg = "acute successful!".encode("gbk") 28 length = len(back_msg) 29 conn.send(str(length).encode("gbk")) 30 re_ready = conn.recv(buffer_capacity).decode("utf8") 31 if re_ready == "ready": 32 conn.send(back_msg) 33 except Exception as e: 34 print(e) 35 break 36 tcp_server.close()
客户端:
1 # Author : Kelvin 2 # Date : 2019/2/2 17:38 3 from socket import * 4 5 ip_conf = ("127.0.0.1", 8888) 6 buffer_capacity = 1024 7 tcp_client = socket(AF_INET, SOCK_STREAM) 8 tcp_client.connect(ip_conf) 9 while True: 10 cmd = input("Please input cmd : ") 11 if not cmd: 12 continue 13 if cmd == "quit": 14 break 15 tcp_client.send(cmd.encode("utf8")) 16 re_size = int(tcp_client.recv(buffer_capacity).decode("utf-8")) 17 print("大小:", re_size) 18 tcp_client.send("ready".encode("utf8")) 19 recved_size = 0 20 recved_data = b"" 21 while recved_size < re_size: 22 recved_data += tcp_client.recv(buffer_capacity) 23 recved_size = len(recved_data) 24 back_msg = recved_data.decode("gbk") 25 print(back_msg) 26 tcp_client.close()
升级版:
服务器:
1 # Author : Kelvin 2 # Date : 2019/2/2 17:38 3 from socket import * 4 import subprocess 5 import struct 6 7 ip_conf = ("127.0.0.1", 8888) 8 buffer_capacity = 1024 9 tcp_server = socket(AF_INET, SOCK_STREAM) 10 tcp_server.bind(ip_conf) 11 tcp_server.listen(5) 12 while True: 13 conn, addr = tcp_server.accept() 14 while True: 15 try: 16 cmd = conn.recv(buffer_capacity) # 如果强制断开连接会触发try,try正是解决强制中断连接的问题 17 print("收到的cmd:%s" % cmd) 18 if not cmd: # 如果使用quit断开连接,服务器会死循环收到空,该判断正是解决此问题 19 break 20 res = subprocess.Popen(cmd.decode("utf8"), shell=True, stdout=subprocess.PIPE, stdin=subprocess.PIPE, 21 stderr=subprocess.PIPE) 22 err = res.stderr.read() 23 if err: 24 back_msg = err 25 else: 26 back_msg = res.stdout.read() 27 if not back_msg: 28 back_msg = "acute successful!".encode("gbk") 29 length = len(back_msg) 30 re_length = struct.pack("i", length) 31 conn.send(re_length) 32 conn.send(back_msg) 33 except Exception as e: 34 print(e) 35 break 36 tcp_server.close()
客户端:
1 # Author : Kelvin 2 # Date : 2019/2/2 17:38 3 from socket import * 4 import struct 5 ip_conf = ("127.0.0.1", 8888) 6 buffer_capacity = 1024 7 tcp_client = socket(AF_INET, SOCK_STREAM) 8 tcp_client.connect(ip_conf) 9 while True: 10 cmd = input("Please input cmd : ") 11 if not cmd: 12 continue 13 if cmd == "quit": 14 break 15 tcp_client.send(cmd.encode("utf8")) 16 re_size = struct.unpack("i",tcp_client.recv(4))[0] 17 print("大小:", re_size) 18 recved_size = 0 19 recved_data = b"" 20 while recved_size < re_size: 21 recved_data += tcp_client.recv(buffer_capacity) 22 recved_size = len(recved_data) 23 back_msg = recved_data.decode("gbk") 24 print(back_msg) 25 tcp_client.close()
相关文章
- 三、shell变量子串
- 小课堂 | 根据ip获取城市名
- 衡阳之后,重估自动驾驶落地
- 四、变量的赋值方法
- 五、数组基础
- 说话夹杂English的人:我不是要装X,只是Brain功能太强
- 真的有能开光追的手游了!自带实机演示的那种,OPPO这次玩“大”了
- 清华打造足球AI:首次实现同时控制10名球员完成比赛,胜率94.4%
- 科创板首发过会,格灵深瞳“三变”交出IPO答卷
- 斩获“卡脖子”领域世界冠军!这支华科战队全网刷屏,平均年龄24岁
- 任天堂经典拳击游戏可以体感操作了,打开网页就能玩,击败泰森不是梦
- CDN内容分发网络加速效果测试(上)
- 八、条件表达式
- SpaceX再送4人上太空,马斯克保证这次飞船厕所不会漏了
- CDN内容分发网络加速效果测试(下)
- R语言ggplot2做柱形图并在指定的位置添加灰色背景
- 手把手教你为基于Netty的IM生成自签名SSL/TLS证书
- 用GAN也可以P图,效果还不输PS | 英伟达出品
- 强势登场,不可拒绝的IDEA 中的热部署神器!
- BannerStudio---第四阶段考核项目(一)