初学python⽹络编程socket，并实现⽂件传输【含源代码】
Socket
什么是Socket
socket⼜称“套接字”， 应⽤程序通常通过“套接字”向⽹络发出请求或者应答⽹络请求，使主机间或者⼀台计算机上的进程间可以通讯。
socket()函数
Python 中，我们⽤ socket（）函数来创建套接字，语法格式如下：
socket.socket(family,type, protocol)
参数： family: 套接字家族可以使AF_UNIX或者AF_INET
type：套接字类型可以根据是⾯向连接的还是⾮连接分为SOCK_STREAM或SOCK_DGRAM
protocol: ⼀般不填默认为0.
socket 对象内建⽅法
函数 描述
服务器端套接字:
s.bind() 绑定地址（host,port）到套接字， 在AF_INET下，以元组（host,port）的形式表⽰地址。
s.listen() 开始TCP监听。backlog指定在拒绝连接之前，操作系统可以挂起的最⼤连接数量。该值⾄少为1，⼤部分应⽤程序设为5就可以了。
s.accept() 被动接受TCP客户端连接,(阻塞式)等待连接的到来 客户端套接字
公共⽤途的套接字函数
s.send() 发送TCP数据，将string中的数据发送到连接的套接字。返回值是要发送的字节数量，该数量可能⼩于string的字节⼤⼩。
s.sendall() 完整发送TCP数据，完整发送TCP数据。将string中的数据发送到连接的套接字，但在返回之前会尝试发送所有数据。成功返回None，失败则抛出异常。
s.sendto() 发送UDP数据，将数据发送到套接字，address是形式为（ipaddr，port）的元组，指定远程地址。返回值是发送的字节数。
s.close() 关闭套接字
s.setsockopt(level,optname,value) 设置给定套接字选项的值。
s.settimeout(timeout) 设置套接字操作的超时期，timeout是⼀个浮点数，单位是秒。值为None表⽰没有超时期。⼀般，超时期应该在刚创建套接字时设置，因为它们可能⽤于连接的操作（如connect()）
s.fileno() 返回套接字的⽂件描述符。
s.setblocking(flag) 如果flag为0，则将套接字设为⾮阻塞模式，否则将套接字设为阻塞模式（默认值）。⾮阻塞模式下，如果调⽤recv()没有发现任何数据，或send()调⽤⽆法⽴即发送数据，那么将引起异常。
s.makefile() 创建⼀个与该套接字相关连的⽂件
-----**** 上述来源于⽹络 ****-----------
实例：实现⽂件传输
实例演⽰：
服务器端打开
客户端运⾏，选择⽂件上传
客户端⽂件上传完毕
服务器端收到⽂件
注：本次演⽰不是在局域⽹上，⽽是在实际上的服务器上的⽂件传输演⽰源代码：
客户端
"""
author: 全洛
"""
import socket
import easygui as eg
import json
import os
import time
'''读取配置⽂件'''
f =open('clientconf.json','r', encoding='utf-8')
date = json.load(f)
date = json.load(f)
ip = ('IP')
port = ('port')
f.close()
'''创建socket对象'''
client = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
try:
'''连接服务器，指定IP和端⼝'''
'''接收⼩于 1024 字节的数据'''
msg = v(1024)
'''输出连接成功信息'''
print(msg.decode('utf-8'))
except Exception as e:
print(f'连接服务器失败', e)
else:
'''选择发送的⽂件'''
filepath = eg.fileopenbox(title='选择⽂件')
'''获取⽂件名,⽂件⼤⼩'''
filename = filepath.split("\\")[-1]
filesize = size(filepath)
# 先将⽂件名传过去
# 编码⽂件名
client.de())
time.sleep(0.5)
# 再将将⽂件⼤⼩传过去
# 编码⽂件⼤⼩
client._bytes(filesize.bit_length(), byteorder='big'))
try:
'''传输⽂件'''
start_time = time.time()
with open(filepath,'rb')as f:
size =0
while True:
#读取⽂件数据，每次1024KB
f_data = f.read(1024)
# 数据长度不为零，传输继续
if f_data:
client.send(f_data)
size +=len(f_data)
getsavefilenameif time.time()- start_time ==0:
time.sleep(0.5)
speed =(size)/(time.time()- start_time)
print('\r'+'【上传进度】:%s%.2f%%, Speed: %.2fMB/s'%('>'*int(size *50/ filesize),float(size / filesize *100),float(speed /1024/1024)), en d=' ')
# 数据长度为零传输完成
else:
print(f'{filename},{float(filesize/1024/1024):.2f}MB, 传输完成')
break
except Exception as e:
print(f'传输异常', e)
finally:
'''关闭客户端'''
client.close()
客户端配置：
{
“IP”: “182.92.112.155”,
“port”: 3636
}
服务器端
"""
author: 全洛
"""
import socket
import os
import json
import threading
import time
'''导⼊配置⽂件'''
f =open('serverconf.json','r', encoding='utf-8')
dirsave = json.load(f).get('dirSave')
f.close()
if not ists(dirsave):# 看是否有该⽂件夹，没有则创建⽂件夹
os.mkdir(dirsave)
class server:
def__init__(self):
''''''
'''创建socket对象'''
self.server = socket.socket(socket.AF_INET, socket.SOCK_STREAM) '''获取本地'''
self.host = hostname()
'''设置端⼝'''
self.port = 3636
'''绑定地址'''
self.server.bind((self.host, self.port))
'''设置最⼤连接数，超过后排队'''
self.server.listen(12)
print('服务器已上线\n等待客户端连接...\n')
def server100(self):
while True:
'''建⽴客户端连接'''
client, addr = self.server.accept()
print(f'客户端: {str(addr)}, 连接上服务器')
msg = f'已连接到服务器{self.host}!\r\n'
client.de('utf-8'))
# 有客户端连接后，创建⼀个线程给客户端
t1 = threading.Thread(self.taskfilethread(client))
# 设置线程守护
t1.setDaemon(True)
# 启动线程
t1.start()
def taskfilethread(self, client):
'''接收⽂件名,⽂件⼤⼩'''
filename = v(1024)
# time.sleep(0.5)
filesize = v(1024)
# 解码⽂件名,⽂件⼤⼩
filename = filename.decode()
filesize = int.from_bytes(filesize, byteorder='big')
'''接收⽂件'''
try:
f =open(dirsave+"\\"+ filename,'wb')
size =0
start_time = time.time()
while True:
# 接收数据
f_data = v(1024)
版权声明：本站内容均来自互联网，仅供演示用，请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198，我们将在24小时内删除。
发表评论