zoukankan html css js c++ java

Python 异常及处理文件上传事例 UDP socketserver模块

一异常及异常处理

1.什么是异常：程序在运行的过程中出现了不可预知的错误，如果没有对应的处理机制和处理不当的话，会造成程序无法正常运行下去。

2.异常的结构：

#1.异常类型：NameError

#2异常信息： name 'name' is not defined

#3异常位置： File "E:/python10期/day29 基于tcp文件上传 udp scketserver/代码/发送大文件/test.py", line 1, in <module>

3.异常分类：

#1.语法错误：运行代码前都会先检测代码，期间发生的异常就是语法异常。作为一名合格的程序员不应该出现语法错误，出现问题后立即解决。

#2.逻辑错误：主要是因为逻辑不正确没有得到程序正确的执行结果，需要理清代码逻辑更改。

常见的错误类型
            NAMERROR     名字错误
            SyntaxError  语法错误
            KeyError     键不存在
            ValueError   值错误
            IndexError   索引错误

View Code

4.异常处理：

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

View Code

# 拓展

try:
    # 代码块
  
except Exception:  # 万能异常  所有的异常类型都被捕获（代码块报错时执行）
#     print('老子天下无敌')
else: # 代码块没有错误时执行
#     print('被检测的代码没有任何的异常发生 才会走else')
finally: # （最后一定执行）
#     print('无论被检测的代码有没有异常发生 都会在代码运行完毕之后执行我')

View Code

# 抛出异常和断言

当我们的程序在执行过程中由于接收到的参数不正确或者其他情况导致,后续代码无法执行时,可以主动抛出异常

使用raise关键字,后面跟任意Exception的子类或子类实例

# 直接抛出异常 
raise TypeError
# 直接抛出异常 并附加错误信息
raise TypeError("类型错误")


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

View Code

断言是就是断定的意思,当一些代码的执行必须满足某个条件时,就需要先断定条件在继续执行,当然你可以使用`if`判断来处理
# l = [1,2,3]
# assert len(l) < 0  # 断言  预言
# 猜某个数据的状态 猜对了 不影响代码执行 正常走

View Code

# 自定义异常
# 自定义异常
class MyError(BaseException):
     def __init__(self,msg):
         super().__init__()
         self.msg=msg
     def __str__(self):
         return '<dfsdf%ssdfsdaf>' %self.msg

raise MyError('我自己定义的异常')  # 主动抛出异常其实就是将异常类的对象打印出来,会走__str__方法

View Code

二 UDP通信

1.什么是udp协议：中文名是用户数据报协议，提供简单不可靠信息传送服务。

2.udp特点：

1.udp协议客户端允许发空
2.udp协议不会粘包（自带报头，每一次发送都是一个单独的数据报，所以不会产生粘包问题）
3.udp协议服务端不存在的情况下，客户端照样不会报错？
4.udp协议支持并发

3.语法：

客户端
import socket


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)
    print('服务端的地址',addr)

服务端
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)

# 注意：发送和接收时的地址和端口一定是对方的

View Code

4.UDP实现简单版QQ功能

#客服端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'))

View Code

#客服端2

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'))

View Code

#服务端

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)

View Code

5.UDP和TCP区别

1.没有连接  

2.不会粘包     每次发送都是一个独立的数据包    



TCP 对数据完整性要求较高 : 在线支付  ,文字信息 

 UDP: 对数据不要求完整性 但是要快 :  视频 语音 游戏

View Code

三 socketserver模块

# 基于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'))

服务端
import socketserver


class MyServer(socketserver.BaseRequestHandler):
    def handle(self):
        # print('来啦 老弟')
        while True:
            data = self.request.recv(1024)
            print(self.client_address)  # 客户端地址
            print(data.decode('utf-8'))
            self.request.send(data.upper())


if __name__ == '__main__':
    """只要有客户端连接  会自动交给自定义类中的handle方法去处理"""
    server = socketserver.ThreadingTCPServer(('127.0.0.1',8080),MyServer)  # 创建一个基于TCP的对象
    server.serve_forever()  # 启动该服务对象

基于tcp socketserver

# 基于UDP

#1.客户端
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速度太快多个客户端没办法同时连接服务器

#2.服务端
import socketserver

class MyServer(socketserver.BaseRequestHandler):
    def handle(self):
        # print('来啦 老弟')
        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__':
    """只要有客户端连接  会自动交给自定义类中的handle方法去处理"""
    server = socketserver.ThreadingUDPServer(('127.0.0.1',8080),MyServer)  # 创建一个基于TCP的对象
    server.serve_forever()  # 启动该服务对象

基于udpsocketserver

四基于TCP实现文件上传

#客户端
import socket
import json
import os
import struct

client = socket.socket()
try:
    client.connect(('127.0.0.1',8080))
    while True:
        BASE_PATH = r'E:python10期day29 基于tcp文件上传 udp scketserver视频'
        # 展示电影
        movie_list = os.listdir(BASE_PATH)
        for k,v in enumerate(movie_list,start=1):
            print(k,v)
        # 选择电影
        choice = input('请选择电影编号：').strip()
        if choice.isdigit():
            choice  = int(choice)-1
            if choice in range(0,len(movie_list)):
                # 电影名
                movie_name = movie_list[choice]
                # 电影路径 大小
                movie_path = os.path.join(BASE_PATH,movie_name)
                movie_size = os.path.getsize(movie_path)
                # 封装报头
                header_dic = {'name':movie_name,'size':movie_size}
                # 报头转换字符串
                json_byte = json.dumps(header_dic).encode('utf-8')
                # json_byte = json_str.encode('utf-8')
                # 打包 发包 发送字节字典
                len_pack = struct.pack('i',len(json_byte))
                client.send(len_pack)
                client.send(json_byte)

                # 发送电影
                with open(movie_path,'rb') as f:
                    for line in f:
                        client.send(line)
                print('上传成功')

            else:
                print('请选择正确的范围编号')
        else:
            print('请选择数字')
except ConnectionRefusedError :
    print('连接服务端失败')
except ConnectionResetError:
    print('服务端断开了')
# 服务端
import socket
import json
import struct

server = socket.socket()
server.bind(('127.0.0.1',8080))
server.listen()
while True:
    conn,addr = server.accept()
    while True:
        try:
            len_pack = conn.recv(4)
            if not len_pack:break
            json_byte_len = struct.unpack('i',len_pack)[0]
            # 接收报头字符串
            json_str = conn.recv(json_byte_len).decode('utf-8')
            # json_str = json_byte.decode('utf-8')
            # 转为报头字典
            header_dic = json.loads(json_str)
            # 获取影片大小 和名字
            movie_size = header_dic.get('size')
            movie_name = header_dic.get('name')
            # 接收影片
            recv_size = 0
            with open(movie_name,'wb') as f:
                while recv_size < movie_size:
                    date = conn.recv(1024)
                    f.write(date)
                    recv_size += len(date)
            print('接收完毕')
        except ConnectionRefusedError as e:
            print('服务端异常断开')
    conn.close()

View Code

客户端
client = socket.socket()
client.connect(('127.0.0.1',8080))

while True:
    # 获取电影列表 循环展示
    MOVIE_DIR = r'D:python脱产10期视频day25视频'
    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')

服务端
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_len = conn.recv(4)
            # 解析字典报头
            header_len = struct.unpack('i',header_len)[0]
            # 再接收字典数据
            header_dic = conn.recv(header_len)
            real_dic = json.loads(header_dic.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()

View Code

查看全文

相关阅读:
自定义返回模型
 【读书笔记】C#高级编程第二十五章事务处理
 【读书笔记】C#高级编程第二十四章文件和注册表操作
 【读书笔记】C#高级编程第二十二章安全性
 【读书笔记】C#高级编程第二十一章任务、线程和同步
 【读书笔记】C#高级编程第二十章诊断
 【读书笔记】C#高级编程第十九章程序集
 【读书笔记】C#高级编程第十六章错误和异常
 【读书笔记】C#高级编程第十五章反射
 【读书笔记】C#高级编程第十四章内存管理和指针

原文地址：https://www.cnblogs.com/tfzz/p/11322482.html

Python 异常及处理 文件上传事例 UDP socketserver模块

一 异常及异常处理

二 UDP通信

三 socketserver模块

四 基于TCP实现文件上传

Python 异常及处理文件上传事例 UDP socketserver模块

一异常及异常处理

四基于TCP实现文件上传