# -*- coding: utf-8 -*-
# @Time : 2019/11/28 15:40
# @Author : John
# @Email : 2398344557@qq.com
# @File : udp.py
# @Software: PyCharm
UDP（user datagram protocol）：用户数据报协议（位于传输层中）
UDP是面向非连接的协议，不与对方建立链接，而是直接把我要发的数据报发给对方
因此，UDP适合一次传输数据量很少、对可靠性要求不高的、对实时性要求高的应用场景
UDP通信模型，类似于我们生活中的写信（只需将信件投入信息，而不能确认收信人最终是否收到），
即不需要建立相关的链接，只需要发送数据即可。
【例】（简单文本传输）将客户端发给服务器的信息，回应回去（可以一次发送多条信息）
两方互发信息（多发多收）：udp-receive.py 和 udp-send.py 或 （文本）udp-server.py 和 （文本）udp-client.py
- udp-receive.py
import socket
import threading
s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
s.bind(('127.0.0.1', 8000))
def receive():
while True:
global addr
receive_data, addr = s.recvfrom(1024)
print(receive_data.decode())
def sent():
while True:
sent_data = input()
s.sendto(sent_data.encode(), addr)
t1 = threading.Thread(target=receive)
t2 = threading.Thread(target=sent)
t1.start()
t2.start()
- udp-send.py
import socket
import threading
s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
def sent():
while True:
sent_data = input()
s.sendto(sent_data.encode(), ('127.0.0.1', 8000))
def receive():
while True:
s.connect(('127.0.0.1', 8000))
receive_data, addr = s.recvfrom(1024)
print(receive_data.decode())
t1 = threading.Thread(target=sent)
t2 = threading.Thread(target=receive)
t1.start()
t2.start()
先执行udp-receive.py文件，再执行udp-send.py文件：
udp-receive.py.png
udp-send.py.png
可以在任意文件对应终端框中输入信息：
（绿色字体为自己发的信息，白色字体为对方发的信息）
udp-send.py的终端.png
udp-receive.py的终端.png
-------------------------------------------------------------------------------------------
- （文本）udp-server.py
from socket import *
from time import ctime
HOST = ''
PORT = 8888
BUFSIZ = 1024
ADDR = (HOST, PORT)
udpSerSock = socket(AF_INET, SOCK_DGRAM)
udpSerSock.bind(ADDR)
while True:
print('waiting for message...')
data, addr = udpSerSock.recvfrom(BUFSIZ)
content = '[%s] %s' % (bytes(ctime(), "utf-8"), data)
udpSerSock.sendto(content.encode("utf-8"), addr)
print('...received from and returned to:', addr, data)
print()
udpSerSock.close()
- （文本）udp-client.py
from socket import *
HOST = 'localhost'
PORT = 8888
BUFSIZ = 1024
ADDR = (HOST, PORT)
udpCliSock = socket(AF_INET, SOCK_DGRAM)
while True:
data = input('> ')
if not data:
break
udpCliSock.sendto(data.encode("utf-8"), ADDR)
data, ADDR = udpCliSock.recvfrom(BUFSIZ)
if not data:
break
print(data)
udpCliSock.close()
同上，先执行（文本）udp-server.py文件，再执行（文本）udp-client.py文件
可以在任意文件对应终端框中输入信息：
（绿色字体为自己发的信息，白色字体为对方发的信息）
（文本）udp-client.py的终端.png
（文本）udp-server.py的终端.png
====================================================
【例】（文件传输）将客户端发给服务器的信息，回应回去
（文件）udp-server.py 和（文件）udp-client.py
- （文件）udp-server.py
'''
规定:
服务器接受客户端请求,得知要发送文件了(实际就得知该发送哪个)
向其发送文件,然后不停的发送(大文件分段发送),此处我还要接受客户端的接受成功消息
'''
import socket
BUF_SIZE = 1024
server_addr = ('127.0.0.1',8888)
#socket的类型是socket.SOCK_DGRAM(udp使用的)
server = socket.socket(socket.AF_INET,socket.SOCK_DGRAM)
#服务端照例绑定地址
server.bind(server_addr)
#循环接受客户端发送数据,并将数据发回
count = 0
flag = 1
f = open('1.mp4', 'rb')
while True:
if count == 0:
print("Are You Ready?")
data, client_addr = server.recvfrom(BUF_SIZE)
print('来自', client_addr, ' 的数据是: ', data.decode('utf-8'))
data = f.read(BUF_SIZE)
if str(data) != "b''":
server.sendto(data, client_addr)
print(data)#此处打印注意被刷屏,仅测试用
else:
server.sendto('end'.encode('utf-8'), client_addr)#此处为文件结束,发送结束通知给客户端
break
data, client_addr = server.recvfrom(BUF_SIZE)
print('接受自 ',client_addr, ' 收到数据为 : ', data.decode('utf-8'))
count += 1
print('循环了'+str(count))
server.close()
（文件）udp-client.py
'''
规定:
客户端向服务端请求文件(音频或者视屏等完整性要求不高的)
先打个招呼,要文件了(实际可以为要哪个文件)
然后开始接受文件,不停的接受即可(这里我每接受一次就回复一句ok))
'''
import socket
import struct
BUF_SIZE = 1024
server_addr = ('127.0.0.1', 8888)
client = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
count = 0
#不停的发送数据 ,没发一次尝试接受一次数据并打印
f = open('b.mp4', 'wb')
while True:
if count == 0:
data ='Yes,I\'m Ready'
client.sendto(data.encode('utf-8'),server_addr)
data, addr = client.recvfrom(BUF_SIZE)
if str(data) != "b'end'":
f.write(data)
# print(data)#此处打印注意被刷屏,仅测试用
else:
break;#接受到结束通知,结束循环,打印循环次数,然后去指定路径查找file_copy.jar尝试运行
client.sendto('ok'.encode('utf-8'),addr)#向服务端发送成功通知
count+=1
print('循环了'+str(count))
f.close()
client.close()
同上，先执行（文件）udp-server.py文件，再执行（文件）udp-client.py文件
（文件）udp-server.py的终端.png
（文件）udp-client.py的终端.png
把1.mp4复制，生成新文件b.mp4：
udp文件夹.png
