异常处理/UDP通信/socketserver模块应用/上传大型文件

异常处理

什么是异常?

程序在运行过程中出现了不可预知的错误
并且该错误没有对应的处理机制,那么就会以异常的形式表现出来
造成的影响就是整个程序无法再正常运行

异常的结构

1.异常的类型:NAMEERROR
2.异常的信息:name 'fasdsadsa' is not defined
3.异常的位置:

# 异常的位置信息与路径
Traceback (most recent call last): File ".../.../... 异常处理.py", line1, in<module> fasdsadsa

异常的种类

分为两大类

1.语法错误
- 是你程序立刻就能解决的,这种错误是不能被容忍的
- 语法上的错误,发现之后应该立刻解决
2.逻辑错误
- 这种错是可以被容忍的,因为一眼看不出来
- 针对逻辑上的错误,可以采用异常处理机制进行捕获

常见的错误类型

NAMERROR 名字错误
SyntaxError 语法错误
KeyError 键不存在
ValueError 值错误
IndexError 索引错误

错误类型案例:

try:
    name
    l = [1,2,3]
    l[111]
    d = {'name':'jason'}
    d['password']
except NameError:
    print('NameError')
except IndexError:
    print('indexerror')
except KeyError:
    print('keyerror')
# 以上错误依次对应

注意:

错误发生之后,会立刻停止代码的运行
执行except语句,比对错误类型

万能异常BaseException

try:
    name
    l = [1,2,3]
    l[111]
    d = {'name':'jason'}
    d['password']
    Exception
except BaseException:  # 万能异常  所有的异常类型都被捕获
    print('老子天下无敌')

try>>>else>>>finally

try:
    name
    l = [1,2,3]
    l[111]
    d = {'name':'jason'}
    d['password']# except Exception:  # 万能异常  所有的异常类型都被捕获
    print('老子天下无敌')
else:
    print('被检测的代码没有任何的异常发生 才会走else')
finally:
    print('无论被检测的代码有没有异常发生 都会在代码运行完毕之后执行我')

主动抛异常以及assert的应用

if 'egon' == 'DSB':
     pass
else:
     raise TypeError('尽说大实话')
# 关键字raise就是主动抛出异常

l = [1,2,3]
assert len(l) < 0  # 断言  预言
# 猜某个数据的状态 猜对了 不影响代码执行 正常走
# 猜错了  直接报错

如何避免

异常处理
- 再你认为可能会出现bug的代码块上方try一下:注意try内部的代码块越少越好
语法如下:

try:
    可能出错的代码
except 出错的类型 as e:  # 将报错信息赋值给变量e
    出错之后的处理机制

自定义异常

class MyError(BaseException):
     def __init__(self,msg):
         super().__init__()
         self.msg=msg
     def __str__(self):
         return '<dfsdf%ssdfsdaf>' %self.msg
raise MyError('我自己定义的异常')  # 主动抛出异常其实就是将异常类的对象打印出来,会走__str__方法

UDP通信

定义:数据报协议(自带报头)

总结:

1.udp协议客户端允许发空
2.udp协议不会粘包
3.udp协议服务端不存在的情况下,客户端照样不会报错
4.udp协议支持并发

并发:看起来像同时运行的

并行:真正意义上的同时运行

服务端

import socket

server = socket.socket(type=socket.SOCK_DGRAM)  # UDP协议
server.bind(('127.0.0.1',8080))
# UDP不需要设置半连接池,它也没有半连接池的概念

# 因为没有双向通道,不需要accept,直接就是通信循环
while True:
    data, addr = server.recvfrom(1024)
    print('数据:',data)  # 客户端发来的消息
    print('地址',addr)  # 客户端发来的地址
    server.sendto(data.upper(),addr)

客户端

import socket

client = socket.socket(type=socket.SOCK_DGRAM)
# 不需要建立连接,直接进入通信循环
server_address = ('1227.0.0.1',8080)
while True:
    client.sendto(b'hello',server_address)
    data, addr = client.recvfrom(1024)
    print('服务端发来的数据:',data)
    print('服务端发来的地址:',addr)

关于socketserver模块的应用

PS:可以让TCP协议也支持并发

TCP协议服务端

import socketserver

class MyServer(socketserver.BaseRequestHandler):
    def handle(self):
        while True:
            data = self.request.recv(1024)
            print(self.client_address)  # 客户端地址
            print(data.dncode('utf-8'))
            self.request.send(data.upper())
        
if __name__ == '__main__':
    # 创建一个基于TCP的对象,只要有客户端连接,会自动交给自定义类中的handle方法去处理
    socketserver.ThreadingTCPServer(('127.0.0.1',8080),MyServer)  # 创建一个基于TCP的对象
    # 启动该服务对象
    server.serve_forever()

TCP协议客户端

import socket

client = socket.socket()
client.connect(('127.0.0.1'),8080)

while True:
    client.send(b'hello')
    data = client.recv(1024)
    print(data.decode('utf-8'))

UDP协议服务端

import socketserver

class MyServer(socketserver.BaseRequestHandler):
    def handle(self):
        while True:
            data,sock = self.request
            print(self.client_address)  # 客户端地址
            print(data.decode('utf-8'))
            sock.sendto(data.upper(),self.client_address)
        
if __name__ == '__main__':
    # 创建一个基于TCP的对象,只要有客户端连接,会自动交给自定义类中的handle方法去处理
    sever = socketserver.ThreadingUDPServer(('127.0.0.1',8080),MyServer)  # 创建一个基于UDP的对象
    # 启动该服务对象
    server.serve_forever()

UDP协议客户端

import socket
import time

client = socket.socket(type=socket.SOCK_DGRAM)
server_address(('127.0.0.1'),8080)

while True:
    client.sendto(b'hello',server_address)
    data,addr = client.recvfrom(1024)
    print(data.decode('utf-8'),addr)
    time.sleep(1)

用UDP实现简易版本的QQ

服务端

import socket

server = socket.socket(type=socket.SOCK_DGRAM)
server.bind(('127.0.0.1',8080))

while True:
    data, addr = server.recvfrom(1024)
    print(data.decode('utf-8'))
    msg = input('>>>:')
    server.sendto(msg.encode('utf-8'),addr)

客户端1

import socket

client = socket.socket(type=socket.SOCK_DGRAM)
server_address = ('127.0.0.1',8080)

while True:
    msg = input('>>>:')
    msg = '来自客户端1的消息:%s'%msg
    client.sendto(msg.encode('utf-8'),server_address)
    data, server_addr = client.recvfrom(1024)
    print(data.decode('utf-8'))

客户端2

import socket

client = socket.socket(type=socket.SOCK_DGRAM)
server_address = ('127.0.0.1',8080)

while True:
    msg = input('>>>:')
    msg = '来自客户端2的消息:%s'%msg
    client.sendto(msg.encode('utf-8'),server_address)
    data, server_addr = client.recvfrom(1024)
    print(data.decode('utf-8'))

客户端3

import socket

client = socket.socket(type=socket.SOCK_DGRAM)
server_address = ('127.0.0.1',8080)

while True:
    msg = input('>>>:')
    msg = '来自客户端3的消息:%s'%msg
    client.sendto(msg.encode('utf-8'),server_address)
    data, server_addr = client.recvfrom(1024)
    print(data.decode('utf-8'))

上传大型资源类文件

服务端

1.socket创建TCP服务
2.连接循环
3.通信循环
- 接收固定长度的字典的报头
- 解析获取字典数据的真实长度
- 接收字典数据,解码,反序列化成字典
- 从字典中获取文件大小,以及文件名等其他信息
4.循环接受文件数据
- 文件操作,接收一行就往文件中写入一行

客户端

1.socket客户端代码
2.利用os.listdir获取文件夹中的所有文件名
3.循环打印,供用户选择想要上传的文件,以及用户选择是否符合要求
4.根据用户选择以及os.path.join方法拼接用户想要上传的文件绝对路径
5.根据文件路径获取文件大小os.path.getsize()
6.定义一个发送给服务端的字典

{
"file_name":用户选择的文件名,
"file_size":文件大小
　　...额外的键值信息
}

7.制作字典的报头(序列化,编码)
8.发送字典的报头
9.发送字典的数据
10.发文件(文件操作,一行行读取并发送,因为TCP协议是流式协议)

服务端

import socket
import os
import json
import struct

server = socket.socket()
server.bind(('127.0.0.1',8080))
server.listen(5)

while True:
    conn,addr = server.accept()
    while True:
        try:
            header_dic = conn.recv(4)
            # 解析字典报头
            header_len = struct.unpack('i',header_dic)[0]
            # 再接收字典数据
            header_bytes = conn.recv(header_len)
            real_dic = json.loads(header_bytes.decode('utf-8'))
            # 获取数据长度
            total_size = real_dic.get('file_size')
            # 循环接收并写入文件
            recv_size = 0
            with open(real_dic.get('file_name'),'wb') as f:
                while recv_size < total_size:
                    data = conn.recv(1024)
                    f.write(data)
                    recv_size += len(data)
                print('上传成功')
        except ConnectionResetError as e:
            print(e)
            break
    conn.close()

客户端

import socket
import json
import os
import struct

client = socket.socket()
client.connect(('127.0.0.1',8080))

while True:
    # 获取电影列表 循环展示
    MOVIE_DIR = r'绝对路径'
    movie_list = os.listdir(MOVIE_DIR)
    # print(movie_list)
    for i,movie in enumerate(movie_list,1):
        print(i,movie)
    # 用户选择
    choice = input('please choice movie to upload>>>:')
    # 判断是否是数字
    if choice.isdigit():
        # 将字符串数字转为int
        choice = int(choice) - 1
        # 判断用户选择在不在列表范围内
        if choice in range(0,len(movie_list)):
            # 获取到用户想上传的文件路径
            path = movie_list[choice]
            # 拼接文件的绝对路径
            file_path = os.path.join(MOVIE_DIR,path)
            # 获取文件大小
            file_size = os.path.getsize(file_path)
            # 定义一个字典
            res_d = {
                'file_name':'性感荷官在线发牌.mp4',
                'file_size':file_size,
                'msg':'注意身体,多喝营养快线'
            }
            # 序列化字典
            json_d = json.dumps(res_d)
            json_bytes = json_d.encode('utf-8')

            # 1.先制作字典格式的报头
            header = struct.pack('i',len(json_bytes))
            # 2.发送字典的报头
            client.send(header)
            # 3.再发字典
            client.send(json_bytes)
            # 4.再发文件数据(打开文件循环发送)
            with open(file_path,'rb') as f:
                for line in f:
                    client.send(line)
        else:
            print('not in range')
    else:
        print('must be a number')

异常处理/UDP通信/socketserver模块应用/上传大型文件

异常处理

什么是异常?

异常的结构

异常的种类

常见的错误类型

错误类型案例:

注意:

万能异常BaseException

try>>>else>>>finally

主动抛异常以及assert的应用

如何避免

语法如下:

自定义异常

UDP通信

服务端

客户端

关于socketserver模块的应用

TCP协议服务端

TCP协议客户端

UDP协议服务端

UDP协议客户端

用UDP实现简易版本的QQ

服务端

上传大型资源类文件

服务端

客户端

服务端

客户端