socket 上传 -- 异常处理--UDP协议 --自定义socket #29

1.异常处理

''''''
"""
异常处理
"""
"""
1.什么是异常?
    程序在运行过程中出现了不可预知的错误,并且该错误没有对应的处理机制,就会以异常的形式表现出来
    造成的影响就是整个程序无法再正常运行
"""
"""
2.异常的结构:类型+信息+位置
    1.异常的类型:NAMEERROR
    2.异常的信息:name 'fdsdfsdf' is not defined
    3.异常的位置:Traceback (most recent call last):
              File "D:/python脱产10期视频/day29/01 异常处理.py", line 1, in <module>
                fdsdfsdf
"""
"""
3.异常的种类
    1.分类
        1.语法错误
            是你程序立刻就能解决的,这种错误是不能被容忍的
                语法上的错误 发现之后应该立刻解决
        2.逻辑错误
            这种错是可以被容忍的 因为一眼看不出来
                针对逻辑上的错误  可以采用异常处理机制进行捕获
    
    2.常见的错误类型 
        NAMERROR     名字错误
        SyntaxError  语法错误
        KeyError     键不存在
        ValueError   值错误
        IndexError   索引错误
        
"""
"""
4.如何避免?
    1.异常处理:
        在你认为可能出现bug的代码上方try 一下:注try内部的代码越少越好
    
    2.语法一:
        try:
            可能出错的代码
        except 出错的类型 as e:# 将报错信息赋值给变量e
            出错以后的处理机制
        except... # :ps:except可叠加
    3.语法二:主动报错
    a = 2
    b = 3
    if a > b:
        print(a+b)
    else:
        raise TypeError(a<b)
        
        
"""
# a = 2
# b = 3
# if a > b:
#     print(a+b)
# else:
#     raise TypeError(a<b)
"""
Traceback (most recent call last):
  File "E:/Python课堂内容整理/知识点框架/函数--装饰器--迭代器--生成器--常用模块--ATM/day29异常处理,,上传视频/1.异常处理/1.异常处理.py", line 57, in <module>
    raise TypeError(a<b)
TypeError: True
"""
"""
5.万能异常:finally(最终)
"""
a = 2
b = 3
try:
    if a > b:
        print(a+b)
except Exception:  # 万能异常 所有的异常类型都被捕获
    print(a<b)
else:
    print('无异常')
    print('被检测的代码没有任何的异常发生 才会走else')
finally:
    print(123)
    print('无论被检测的代码有没有异常发生 都会在代码运行完毕之后执行我')
"""
无异常
被检测的代码没有任何的异常发生 才会走else
123
无论被检测的代码有没有异常发生 都会在代码运行完毕之后执行我
"""

""""""
"""
自定义异常
"""
# 我的错误类型--继承自基类错误类型
class MyError(BaseException):
    def __init__(self,msg):
        super().__init__()
        self.msg = msg
    # 自定义打印类型
    def __str__(self):
        return "<fsghggdf%sdfgdffgfdgdfgfggd>"%self.msg
raise MyError('我自定义的异常')
# 主动抛出异常其实就是将异常类的对象打印出来,会走__str__方法
'''
'''
"""
Traceback (most recent call last):
  File "E:/Python课堂内容整理/知识点框架/函数--装饰器--迭代器--生成器--常用模块--ATM/day29异常处理,,上传视频/1.异常处理/2.自定义异常.py", line 14, in <module>
    raise MyError('我自定义的异常')
__main__.MyError: <fsghggdf我自定义的异常dfgdffgfdgdfgfggd>
"""

2.上传

import socket
import os
import json
import struct
client = socket.socket()
client.connect(('127.0.0.1',9177))
while True:
    BAST_PATH = os.path.dirname(os.path.dirname(__file__))
    DB_PATH = os.path.join(BAST_PATH,'movie')
    # 打印电影列表目录
    movie_list = os.listdir(DB_PATH)
    for movie in enumerate(movie_list,start=1):
        print(movie)
    # 选择下载目录
    choose = input('choose>>>:').strip()
    if choose.isdigit():
        choose = int(choose)
        if choose in range(1,len(movie_list)+1):

            file_name = movie_list[choose-1]
            file_path = os.path.join(DB_PATH,file_name)
            file_size = os.path.getsize(file_path)
            user_dic = {
                'file_name':file_name,
                'file_size':file_size,
                'file_path':file_path,
                'music':'后嘿嘿'
            }
            json_d = json.dumps(user_dic)
            header = struct.pack('i',len(json_d))
            client.send(header)
            client.send(json_d.encode('utf-8'))
            with open(file_path,'rb')as f:
                for line in f:
                    client.send(line)
        else:
            print('choose必须在范围内')
    else:
        print('choose必须为数字')

import socket
import struct
import json
server = socket.socket()
server.bind(('127.0.0.1',9177))
server.listen(5)
while True:
    conn,addr = server.accept()
    while True:
        try:
            header_dict = conn.recv(4)
            dict_size = struct.unpack('i',header_dict)[0]
            dict_bytes = conn.recv(dict_size)
            dict_json = json.loads(dict_bytes.decode('utf-8'))
            print(dict_json,'上传视频大小')
            recv_size = 0
            file_name = dict_json.get('file_name')
            file_size = dict_json.get('file_size')
            with open(file_name,'wb')as f:
                while recv_size < file_size:
                    date = conn.recv(1024)
                    f.write(date)
                    recv_size += len(date)
                print(recv_size,'接收文件大小')
                print(f'{recv_size}文件上传成功')

        except ConnectionResetError:
            break
    conn.close()

3.下载
client.py
server.py
4.UDP协议

import socket
# 1.不需要建立连接 直接进入通信循环
client = socket.socket(type=socket.SOCK_DGRAM)
# 1.不需要建立连接 直接进入通信循环
server_addr = ('127.0.0.1',9177)
while True:
        client.sendto(b'hello',server_addr)
        date,addr = client.recvfrom(1024)
        print(date.decode('utf-8'),'数据')
        print(addr,'地址')

import socket
# 1.UDP协议
server = socket.socket(type=socket.SOCK_DGRAM)
# 2.插卡
server.bind(('127.0.0.1',9177))
# ps:
# 1.UDP 协议不需要办连接池 ,它也没有半连接词这个概念
# 2.因为没有双向通道,不需要accpet,直接就是循环通信
while True:

    conn,addr = server.recvfrom(1024)
    # 1.客户端发来消息
    print(conn.decode('utf-8'),'数据')
    # 2.客户端的地址
    print(addr,'地址')
    server.sendto(conn.upper(),addr)

5.UDP案例qq

import socket
client = socket.socket(type=socket.SOCK_DGRAM)
server_addr = ('127.0.0.1',9744)
while True:
    msg = input('msg>>>:').strip()
    msgs = '来自客户端1的消息:%s'%msg
    client.sendto(msg.encode('utf-8'),server_addr)
    date,addr = client.recvfrom(1024)
    print(date.decode('utf-8'))

''''''
"""
qq
"""
import socket
server = socket.socket(type=socket.SOCK_DGRAM)
server.bind(('127.0.0.1',9744))
while True:
    conn,addr = server.recvfrom(1024)
    print(conn.decode('utf-8'))
    msg = input('msg>>>:').encode('utf-8')
    server.sendto(msg,addr)

6.TCP协议与UDP协议的区别

6.TCP与UDP的区别:
    1.UDP协议客户端允许发空
    2.UDP协议不会粘包(自带报头)
    3.UDP协议服务端不存在的情况下,照样不会报错(UDP只管发,不管收)

ps:UDP通信
    1.数据报协议(自带报头)

    2.没有双向通道 通信类似于发短信

7.socketserver模块

import socket
import time
client = socket.socket()
client.connect(('127.0.0.1',8999))
while True:
    client.send(b'hello')
    date = client.recv(1024)
    print(date.decode('utf-8'))
    time.sleep(1)

''''''
"""
自定义TCP协议
"""
import socketserver

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

8..socketserver模块-UDP

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

''''''
"""
自定义UDP协议
"""
import socketserver

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

readme

复习
socket套接字
TCP协议
1.最简易版本的客户端与服务端通信
2.通信循环
recv()  阻塞
3.连接循环
accept()  阻塞
4.TCP粘包问题
struct模块 对数据进行打包处理
pack  unpack

服务端:
    1.生成一个字典
    2.制定该字典的报头
    json序列化
    编码统计长度
    3.发送字典的报头
    4.发送字典
    5.最后发真实数据
客户端:
    1.现接受固定长度的4个字节字典报头
    2.解析获取字典数据的长度
    unpack(...)[0]
    3.接受字典数据
    解码,反序列化
    4.接受真实数据

ps:为什么要多加一个字典?
    1.打包的数据大小有限
    2.可以携带更多的信息

并发:看起来像同时运行的
并行:真正意义上的同时运行