码迷,mamicode.com
首页 > 其他好文 > 详细

网络编程之UDP

时间:2019-08-09 01:45:48      阅读:89      评论:0      收藏:0      [点我收藏+]

标签:def   模块   路径问题   基本语法   %s   pre   range   index   返回   

大文件上传

服务端
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()
客户端
import socket
import json
import os
import struct

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

while True:
    MOVIE_DIR = r‘E:\视频‘
    movie_list = os.listdir(MOVIE_DIR)
    for i,movie in enumerate(movie_list,1):
         print(i,movie)

    choice = input(‘please choice movie to upload>>>:‘)
    if choice.isdigit():
        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‘)

            header = struct.pack(‘i‘,len(json_bytes))
            client.send(header)
            client.send(json_bytes)
            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‘)

 异常处理

异常处理分成两种:

一种是语法错误,这种错误没办法过python解释器的语法检测,必须在发生之后就改正 

#语法错误示范一
if
#语法错误示范二
def test:
    pass
#语法错误示范三
class Foo
    pass
#语法错误示范四
print(haha

  

还有一种是逻辑错误,这种错误看不出来,可以采用异常处理机制进行捕获

#TypeError:int类型不可迭代
for i in 3:
    pass
#ValueError
num=input(">>: ") #输入hello
int(num)

#NameError
aaa

#IndexError
l=[‘egon‘,‘aa‘]
l[3]

#KeyError
dic={‘name‘:‘egon‘}
dic[‘age‘]

#AttributeError
class Foo:pass
Foo.x

#ZeroDivisionError:无法完成计算
res1=1/0
res2=1+‘str‘

 

异常种类

AttributeError 试图访问一个对象没有的树形,比如foo.x,但是foo没有属性x
IOError 输入/输出异常;基本上是无法打开文件
ImportError 无法引入模块或包;基本上是路径问题或名称错误
IndentationError 语法错误(的子类) ;代码没有正确对齐
IndexError 下标索引超出序列边界,比如当x只有三个元素,却试图访问x[5]
KeyError 试图访问字典里不存在的键
KeyboardInterrupt Ctrl+C被按下
NameError 使用一个还未被赋予对象的变量
SyntaxError Python代码非法,代码不能编译(个人认为这是语法错误,写错了)
TypeError 传入对象类型与要求的不符合
UnboundLocalError 试图访问一个还未被设置的局部变量,基本上是由于另有一个同名的全局变量,
导致你以为正在访问它
ValueError 传入一个调用者不期望的值,即使值的类型是正确的

避免发生错误,需要用到try...except:在错误发生之后进行处理

#基本语法为
try:
    被检测的代码块
except 异常类型:
    try中一旦检测到异常,就执行这个位置的逻辑
#举例
try:
    f=open(‘a.txt‘)
    g=(line.strip() for line in f)
    print(next(g))
    print(next(g))
    print(next(g))
    print(next(g))
    print(next(g))
except StopIteration:
    f.close()

 

#1 异常类只能用来处理指定的异常情况,如果非指定异常则无法处理。
s1 = hello
try:
    int(s1)
except IndexError as e: # 未捕获到异常,程序直接报错
    print e

#2 多分支
s1 = hello
try:
    int(s1)
except IndexError as e:
    print(e)
except KeyError as e:
    print(e)
except ValueError as e:
    print(e)

#3 万能异常Exception
s1 = hello
try:
    int(s1)
except Exception as e:
    print(e)

#4 多分支异常与万能异常
#4.1 如果你想要的效果是,无论出现什么异常,我们统一丢弃,或者使用同一段代码逻辑去处理他们,那么骚年,大胆的去做吧,只有一个Exception就足够了。
#4.2 如果你想要的效果是,对于不同的异常我们需要定制不同的处理逻辑,那就需要用到多分支了。

#5 也可以在多分支后来一个Exception
s1 = hello
try:
    int(s1)
except IndexError as e:
    print(e)
except KeyError as e:
    print(e)
except ValueError as e:
    print(e)
except Exception as e:
    print(e)

#6 异常的其他机构
s1 = hello
try:
    int(s1)
except IndexError as e:
    print(e)
except KeyError as e:
    print(e)
except ValueError as e:
    print(e)
#except Exception as e:
#    print(e)
else:
    print(try内代码块没有异常则执行我)
finally:
    print(无论异常与否,都会执行该模块,通常是进行清理工作)

#7 主动触发异常
try:
    raise TypeError(类型错误)
except Exception as e:
    print(e)

#8 自定义异常
class EgonException(BaseException):
    def __init__(self,msg):
        self.msg=msg
    def __str__(self):
        return self.msg

try:
    raise EgonException(类型错误)
except EgonException as e:
    print(e)

#9 断言:assert 条件
assert 1 == 1  
assert 1 == 2

#10 总结try..except

1:把错误处理和真正的工作分开来
2:代码更易组织,更清晰,复杂的工作任务更容易实现;
3:毫无疑问,更安全了,不至于由于一些小的疏忽而使程序意外崩溃了;

 

UDP

UDP则是面向无连接的协议。

数据包就是这种形式。比如:短信。只要数据发送出去。无需去管对方是否接收到。

使用UDP协议时,不需要建立连接,只需要知道对方的IP地址和端口号,就可以直接发数据包。但是,能不能到达就不知道了。

虽然用UDP传输数据不可靠,但它的优点是和TCP比,速度快,对于不要求可靠到达的数据,就可以使用UDP协议。

我们来看看如何通过UDP协议传输数据。和TCP类似,使用UDP的通信双方也分为客户端和服务器。服务器首先需要绑定端口:

服务器:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
# -*- coding: utf-8 -*-
import socket
 
‘‘‘
使用UDP协议时,不需要建立连接,只需要知道对方的IP地址和端口号,就可以直接发数据包。但是,能不能到达就不知道了。
 
虽然用UDP传输数据不可靠,但它的优点是和TCP比,速度快,对于不要求可靠到达的数据,就可以使用UDP协议。
 
我们来看看如何通过UDP协议传输数据。和TCP类似,使用UDP的通信双方也分为客户端和服务器。服务器首先需要绑定端口
绑定端口和TCP一样,但是不需要调用listen()方法,而是直接接收来自任何客户端的数据
‘‘‘
# ipv4        SOCK_DGRAM指定了这个Socket的类型是UDP
s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
# 绑定 客户端口和地址:
s.bind((127.0.0.1, 9999))
print Bind UDP on 9999...
while True:
    # 接收数据 自动阻塞 等待客户端请求:
    data, addr = s.recvfrom(1024)
    print Received from %s:%s. % addr
    s.sendto(Hello, %s! % data, addr)
#recvfrom()方法返回数据和客户端的地址与端口,这样,服务器收到数据后,直接调用sendto()就可以把数据用UDP发给客户端。
  客户端:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
# -*- coding: utf-8 -*-
 
import socket
 
‘‘‘
客户端使用UDP时,首先仍然创建基于UDP的Socket,然后,不需要调用connect(),直接通过sendto()给服务器发数据:
‘‘‘
s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
 
for data in [a, b, c]:
    # 发送数据:
    s.sendto(data, (127.0.0.1, 9999))
    # 接收数据:
    print s.recv(1024)
s.close()

 

网络编程之UDP

标签:def   模块   路径问题   基本语法   %s   pre   range   index   返回   

原文地址:https://www.cnblogs.com/pangqian/p/11324535.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!