day25_python

1.内容回顾

2.作业讲解

3.今日作业

4.粘包问题

5.tcp和udp

6.udp-socket

7.udp-socket 多人聊天

8.socketserver-tcp-socket并发

9.pickle模块的补充

1.内容回顾

# socket 套接字
# tcp协议三次握手和四次挥手
# 如何基于tcp协议来完成一个socket网络通信
# 聊天的小程序
# 时间同步的
# 粘包现象
# 为什么会出现粘包现象：
# 本质：接收端不知道发送端发送的数据长度是多少
# tcp协议本身的特点导致的：
# 流式传输、无边界
# 合包机制
# 缓存机制
# 拆包机制
# 如何解决这个问题的？
# 自定义协议：先发送要传递数据的字节长度，再发送数据
# 接受端先接收4个字节，然后再根据长度接受数据

2.作业讲解

3.今日作业

# 1.完成一个在网络上对文件的传输（进阶需求如果这个文件非常大 2个G）
　　# 1）完成文件的下载
　　# 2）把用户认证这个功能加上
　　　　# 必须先认证再进行上传下载
　　# 3）文件的一致性校验
# 2.练习一些udp协议的操作
# 3.使用socketserver实现一个并发的基于tcp协议的多人聊天

# 网编的大作业

4.粘包问题

# 1.两个连续的send就会发生粘包
# 2.用struct自定义协议可以解决粘包问题
# 3.什么情况下我们不需要解决粘包：文件的传输
# 4.自定义协议的进阶版本
# 先发送字符串的长度，再发送字符串
# 先发送json的长度，再发送json，json的字典中包含着下一条信息的长度，然后按照长度接受

5.tcp和udp

# tcp
# 面向连接的可靠的全双工的流式传输
# 面向连接：同一时刻只能和一个客户端通信
# 三次握手、四次挥手
# 可靠的：数据不丢失、慢
# 全双工：能够双向通信
# 流式传输：粘包无边界
# udp
# 无连接的面向数据包不可靠的快速的
# 无连接的：不需要accept/connect 也没有握手
# 面向数据包的：不会粘包
# 不可靠的：没有自动回复的机制
# 快速的：没有那些复杂的计算、保证数据传输的机制

6.udp-socket

server

import socket

sk = socket.socket(type=socket.SOCK_DGRAM)sk.bind(('127.0.0.1',9600))

msg,clt_addr = sk.recvfrom(1024)print(msg)sk.sendto(b'hi',clt_addr)

sk.close()

client

import socket

sk = socket.socket(type=socket.SOCK_DGRAM)

sk.sendto(b'hello',('127.0.0.1',9600))msg,addr = sk.recvfrom(1024)print(msg)sk.close()

7.udp-socket 多人聊天

server

import socket

sk = socket.socket(type=socket.SOCK_DGRAM)sk.bind(('127.0.0.1',9600))while True:    msg,clt_addr = sk.recvfrom(1024)    print(msg.decode())    content = input('>>>')    sk.sendto(content.encode(),clt_addr)

sk.close()

client

import socket

sk = socket.socket(type=socket.SOCK_DGRAM)

while True:    content = input('>>>')    content = '%s : %s'%('wusir',content)    sk.sendto(content.encode(),('127.0.0.1',9600))    msg,addr = sk.recvfrom(1024)    print(msg.decode())

sk.close()

8.socketserver-tcp-socket并发

server

import socketserver

class Myserver(socketserver.BaseRequestHandler):    def handle(self):        conn = self.request        while True:            conn.send(b'hello')

server = socketserver.ThreadingTCPServer(('127.0.0.1',9600),Myserver)server.serve_forever()

client #多个

import socket

sk = socket.socket()sk.connect(('127.0.0.1',9600))while True:    msg = sk.recv(1024)    print(msg)sk.close()

9.pickle模块的补充

import pickleclass Course:    def __init__(self,name,period,price,teacher):        self.name = name        self.period = period        self.price = price        self.teacher = teacher

python = Course('python','6 months',19800,'太亮')linux = Course('linux','5 months',15800,'赵班长')with open('course_info','wb') as f:    pickle.dump(python,f)    pickle.dump(linux,f)with open('course_info','rb') as f:    while True:        try:            obj = pickle.load(f)            print(obj.__dict__)        except EOFError:            break

# dumps str->bytes
# dump str->文件里的bytes
# 1.json能处理的数据类型有限，但是所有语言通用
# pickle支持python中几乎所有对象，但是只能再python语言中使用
# 2.json的dumps的结果str，pickle dumps的结果是一个bytes
# 3.json不能连续dump多个数据到文件中
# pickle可以

巴特西

day25_python_1124

最新文章

热门文章