2019-04-10-day029-粘包处理
时间:2019-04-15
本文章向大家介绍2019-04-10-day029-粘包处理,主要包括2019-04-10-day029-粘包处理使用实例、应用技巧、基本知识点总结和需要注意事项,具有一定的参考价值,需要的朋友可以参考一下。
内容回顾
osi五层协议
- 不是真实存在的,只是抽象出来的模型
- 应用层
- 传输层 TCP/UDP
- TCP :全双工,可靠的,面向连接的,速度慢,对数据大小没有限制
- 建立连接 :三次握手 SYN ACK
- 断开连接 :四次挥手 FIN ACK
- UDP :不可靠,无连接的,速度快,对数据大小有限制
- TCP :全双工,可靠的,面向连接的,速度慢,对数据大小没有限制
- 网络层 arp(ip-->mac) rarp(mac-->ip)
- 数据链路层 arp(ip-->mac) rarp(mac-->ip)
- 物理层 网线
TCP/IP 也是抽象出来的模型
struct 模块
import struct
ret = struct.pack('i',112849)
print(ret)
ret2 = struct.unpack('i',ret)
print(ret2)
总结
- 黏包现象 发送的两条数据粘在一起了
- 成因 :
- 发送端粘 : 合包机制
- 接收端粘 : 接收不及时
- 数据与数据之间是无边界的流式传输
- 解决黏包现象
- 自定义协议
- struct模块
- 把任意长度的数字变成固定的4个字节
- 低级
- 先发送数据的长度
- 再发送数据
- 高级
- 先把所有想发送的数据信息放在字典里
- 发送字典的长度
- 发送字典
- 发送涉及的数据
##作业:
- struct模块
- 自定义协议
- 默写 黏包协议
- 上传大文件(文件\视频\图片)
- 和你的同桌调通 从你的计算机上传一个视频到你同桌的电脑上
- 进阶 : 带上登录
课上代码
登陆一
server:
import sys
import json
import socket
import hashlib
def get_md5(username,password):
md5 = hashlib.md5(username.encode('utf-8'))
md5.update(password.encode('utf-8'))
return md5.hexdigest()
def login(dic_msg):
print(dic_msg['user'], dic_msg['pwd'])
with open('userinfo', encoding='utf-8') as f:
for line in f:
user, pwd = line.strip().split('|')
if user == dic_msg['user'] and pwd == get_md5(dic_msg['user'], dic_msg['pwd']):
return {'opt':'login','result':True}
else:return {'opt':'login','result':False}
sk= socket.socket()
sk.bind(('127.0.0.1',9001))
sk.listen()
while True:
conn,addr = sk.accept()
msg = conn.recv(1024).decode('utf-8')
dic_msg = json.loads(msg)
if hasattr(sys.modules[__name__],dic_msg['operate']):
ret = getattr(sys.modules[__name__],dic_msg['operate'])(dic_msg)
content = json.dumps(ret).encode('utf-8')
conn.send(content)
conn.close()
sk.close()
Client
import json
import socket
username = input('用户名 :')
password = input('密 码 :')
sk = socket.socket()
sk.connect(('127.0.0.1',9001))
msg = {'operate':'login',
'user':username,
'pwd':password}
str_msg = json.dumps(msg)
sk.send(str_msg.encode('utf-8'))
content = sk.recv(1024)
str_content = content.decode('utf-8')
dic_content = json.loads(str_content)
if dic_content['result']:
print('登录成功')
else:
print('登录失败')
sk.close()
登陆二
Server
import sys
import json
import socket
import hashlib
def get_md5(username,password):
md5 = hashlib.md5(username.encode('utf-8'))
md5.update(password.encode('utf-8'))
return md5.hexdigest()
def login(dic_msg):
print(dic_msg['user'], dic_msg['pwd'])
with open('userinfo', encoding='utf-8') as f:
for line in f:
user, pwd = line.strip().split('|')
print(pwd,get_md5(dic_msg['user'], dic_msg['pwd']))
if user == dic_msg['user'] and pwd == get_md5(dic_msg['user'], dic_msg['pwd']):
return {'opt':'login','result':True}
else:return {'opt':'login','result':False}
sk= socket.socket()
sk.bind(('127.0.0.1',9001))
sk.listen()
while True:
conn,addr = sk.accept()
msg = conn.recv(1024).decode('utf-8')
dic_msg = json.loads(msg)
if hasattr(sys.modules[__name__],dic_msg['operate']):
ret = getattr(sys.modules[__name__],dic_msg['operate'])(dic_msg)
content = json.dumps(ret).encode('utf-8')
conn.send(content)
conn.close()
sk.close()
Client
import json
import socket
import hashlib
def get_md5(username,password):
md5 = hashlib.md5(username[::2].encode('utf-8'))
md5.update(password.encode('utf-8'))
return md5.hexdigest()
username = input('用户名 :')
password = input('密 码 :')
sk = socket.socket()
sk.connect(('127.0.0.1',9001))
msg = {'operate':'login',
'user':username,
'pwd':get_md5(username,password)}
str_msg = json.dumps(msg)
sk.send(str_msg.encode('utf-8'))
content = sk.recv(1024)
str_content = content.decode('utf-8')
dic_content = json.loads(str_content)
if dic_content['result']:
print('登录成功')
else:
print('登录失败')
sk.close()
黏包练习
Server
import struct
import socket
sk = socket.socket()
sk.bind(('127.0.0.1',9001))
sk.listen()
conn,addr = sk.accept()
num = conn.recv(4)
num = struct.unpack('i',num)[0]
file_name = conn.recv(num).decode('utf-8')
filesize = conn.recv(4)
filesize = struct.unpack('i',filesize)[0]
with open(file_name,'wb') as f:
content = conn.recv(filesize)
f.write(content)
conn.close()
sk.close()
Client
import os
import struct
import socket
sk = socket.socket()
sk.connect(('127.0.0.1',9001))
filepath = input('请输入文件路径 :')
filename = os.path.basename(filepath).encode('utf-8')
name_len = struct.pack('i',len(filename))
sk.send(name_len)
sk.send(filename)
filesize = os.path.getsize(filepath)
file_len = struct.pack('i',filesize)
sk.send(file_len)
with open(filepath,'rb') as f:
content = f.read()
sk.send(content)
sk.close()
# 先发送字典的长度
# 再发字典 {'filename':xxxx,'filesize':xxxxx}
# 再发文件内容
黏包现象
Server
import socket
sk = socket.socket()
sk.bind(('127.0.0.1',9001))
sk.listen()
conn,addr = sk.accept()
conn.send(b'0015hello,你好么')
conn.send(b'5world')
conn.close()
sk.close()
Client
import time
import socket
sk = socket.socket()
sk.connect(('127.0.0.1',9001))
time.sleep(0.1)
num= sk.recv(2).decode('utf-8')
num = int(num)
msg1 = sk.recv(num)
num= sk.recv(1).decode('utf-8')
num = int(num)
msg2 = sk.recv(num)
print(msg1,msg2)
sk.close()
黏包现象2
Server
import struct
import socket
sk = socket.socket()
sk.bind(('127.0.0.1',9001))
sk.listen()
conn,addr = sk.accept()
str_msg = 'hello,你好么'
byets_msg = str_msg.encode('utf-8')
num = len(byets_msg)
len_bytes = struct.pack('i',num)
conn.send(len_bytes)
conn.send(byets_msg)
conn.send(b'world')
conn.close()
sk.close()
Client
import time
import struct
import socket
sk = socket.socket()
sk.connect(('127.0.0.1',9001))
time.sleep(0.1)
num= sk.recv(4)
num = struct.unpack('i',num)[0]
msg2 = sk.recv(num)
print(msg2.decode('utf-8'))
print(sk.recv(1024))
sk.close()
黏包协议
Server
import json
import struct
import socket
sk = socket.socket()
sk.bind(('127.0.0.1',9001))
sk.listen()
conn,addr = sk.accept()
num = conn.recv(4)
num = struct.unpack('i',num)[0]
str_dic = conn.recv(num).decode('utf-8')
dic = json.loads(str_dic)
with open(dic['filename'],'wb') as f:
content = conn.recv(dic['filesize'])
f.write(content)
conn.close()
sk.close()
Client
import os
import json
import struct
import socket
sk = socket.socket()
sk.connect(('127.0.0.1',9001))
filepath = input('请输入文件路径 :')
filename = os.path.basename(filepath)
filesize = os.path.getsize(filepath)
dic = {'filename':filename,'filesize':filesize}
str_dic = json.dumps(dic)
bytes_dic = str_dic.encode('utf-8')
len_dic = len(bytes_dic)
bytes_len = struct.pack('i',len_dic)
sk.send(bytes_len)
sk.send(bytes_dic)
with open(filepath,'rb') as f:
content = f.read()
sk.send(content)
sk.close()
# 先发送字典的长度
# 再发字典 {'filename':xxxx,'filesize':xxxxx}
# 再发文件内容
一对多人聊天
Server
import json
import socket
sk = socket.socket(type=socket.SOCK_DGRAM)
sk.bind(('127.0.0.1',9001))
user_info = {
1234:('alex','\033[1;32m'),
5678:('宝元','\033[1;31m'),
}
while True:
msg,addr = sk.recvfrom(1024)
str_msg = msg.decode('utf-8')
dic_msg = json.loads(str_msg)
code = dic_msg['code']
content = dic_msg['msg']
print('%s%s : %s\033[0m'%(user_info[code][1],user_info[code][0],content))
ret = input('>>>').encode('utf-8')
sk.sendto(ret,addr)
sk.close()
ClientI
import json
import socket
sk = socket.socket(type=socket.SOCK_DGRAM)
addr = ('127.0.0.1',9001)
code = 5678
while True:
msg = input('>>>')
if msg.upper() == 'Q': break
send_msg = {'code':code,'msg':msg}
str_msg = json.dumps(send_msg)
sk.sendto(str_msg.encode('utf-8'),addr)
ret = sk.recv(1024).decode('utf-8')
if ret.upper() == 'Q': break
print(ret)
sk.close()
ClientII
import json
import socket
sk = socket.socket(type=socket.SOCK_DGRAM)
addr = ('127.0.0.1',9001)
code = 1234
while True:
msg = input('>>>')
if msg.upper() == 'Q':break
send_msg = {'code':code,'msg':msg}
str_msg = json.dumps(send_msg)
sk.sendto(str_msg.encode('utf-8'),addr)
ret = sk.recv(1024).decode('utf-8')
if ret.upper() == 'Q':break
print(ret)
sk.close()
- 动态规划之01背包详解【解题报告】
- hihoCoder #1078 : 线段树的区间修改(线段树区间更新板子题)
- HDU 2546 饭卡(01背包裸题)
- 漫谈文件系统
- AI知识搜索利器:基于ElasticSearch构建专知实时高性能搜索系统
- 【深度干货】专知主题链路知识推荐#5-机器学习中似懂非懂的马尔科夫链蒙特卡洛采样(MCMC)入门教程01
- hihoCoder #1043 : 完全背包(板子题)
- 【深度干货】专知主题链路知识推荐#7-机器学习中似懂非懂的马尔科夫链蒙特卡洛采样(MCMC)入门教程02
- hihoCoder #1038 : 01背包(板子题)
- 最小二乘法多项式曲线拟合原理与实现
- HDU 1166 敌兵布阵(线段树单点更新,板子题)
- 一文看懂ovirt的supervdsmd服务
- openstack如何扩展API之二:扩展原有核心API
- selenium+python自动化77-autoit文件上传
- JavaScript 教程
- JavaScript 编辑工具
- JavaScript 与HTML
- JavaScript 与Java
- JavaScript 数据结构
- JavaScript 基本数据类型
- JavaScript 特殊数据类型
- JavaScript 运算符
- JavaScript typeof 运算符
- JavaScript 表达式
- JavaScript 类型转换
- JavaScript 基本语法
- JavaScript 注释
- Javascript 基本处理流程
- Javascript 选择结构
- Javascript if 语句
- Javascript if 语句的嵌套
- Javascript switch 语句
- Javascript 循环结构
- Javascript 循环结构实例
- Javascript 跳转语句
- Javascript 控制语句总结
- Javascript 函数介绍
- Javascript 函数的定义
- Javascript 函数调用
- Javascript 几种特殊的函数
- JavaScript 内置函数简介
- Javascript eval() 函数
- Javascript isFinite() 函数
- Javascript isNaN() 函数
- parseInt() 与 parseFloat()
- escape() 与 unescape()
- Javascript 字符串介绍
- Javascript length属性
- javascript 字符串函数
- Javascript 日期对象简介
- Javascript 日期对象用途
- Date 对象属性和方法
- Javascript 数组是什么
- Javascript 创建数组
- Javascript 数组赋值与取值
- Javascript 数组属性和方法
- 智能合约编程语言-solidity快速入门(上)
- Redis系列:项目中哪些常用的命令
- Chrome 插件编写-用几行js代码实现写入剪贴板功能
- Python 技术篇-socket套接字实现服务器客户端消息传递,UDP实现
- Python 技巧篇-如何避免python报错导致强制关闭窗口
- UML急速入门
- Python 技术篇-socket套接字实现两个窗口间消息传递,TCP实现
- 解决HttpServletRequest的输入流只能读取一次的问题
- 使用RSA算法对接口参数签名及验签
- 最基础的动态数据结构:链表
- Python 微信机器人-如何查看别人撤回的消息,实战演示!
- Python 技术篇-全局变量引用,local variable referenced before assignment.解决办法
- 线性结构之栈和队列
- pyHook 转码问题-MouseSwitch() missing 8 required positional arguments...,原因及解决办法
- 将Java中的数组进行二次封装成属于我们自己的数组