利用Python3来实现TCP协议,和UDP类似。UDP应用于及时通信,而TCP协议用来传送文件、命令等操作,因为这些数据不允许丢失,否则会造成文件错误或命令混乱。下面代码就是模拟客户端通过命令行操作服务器。客户端输入命令,服务器执行并且返回结果。
TCP(Transmission Control Protocol 传输控制协议):是一种面向连接的、可靠的、基于字节流的传输层通信协议,由IETF的RFC 793定义。
使用TCP编写一个简易的文件下载器要求:需编写文件下载器服务端和文件下载器客户端
服务器端代码:
import socket import os import threading # 处理客户端请求下载文件的操作(从主线程提出来的代码) def deal_client_request(ip_port, service_client_socket): # 连接成功后,输出“客户端连接成功”和客户端的ip和端口 print("客户端连接成功", ip_port) # 接收客户端的请求信息 file_name = service_client_socket.recv(1024) # 解码 file_name_data = file_name.decode("utf-8") # 判断文件是否存在 if os.path.exists(file_name_data): #输出文件字节数 fsize = os.path.getsize(file_name_data) #转化为兆单位 fmb = fsize/float(1024*1024) #要传输的文件信息 senddata = "文件名:%s 文件大小:%.2fMB"%(file_name_data,fmb) #发送和打印文件信息 service_client_socket.send(senddata.encode("utf-8")) print("请求文件名:%s 文件大小:%.2f MB"%(file_name_data,fmb)) #接受客户是否需要下载 options = service_client_socket.recv(1024) if options.decode("utf-8") == "y": # 打开文件 with open(file_name_data, "rb") as f: # 计算总数据包数目 nums = fsize/1024 # 当前传输的数据包数目 cnum = 0 while True: file_data = f.read(1024) cnum = cnum + 1 jindu = cnum/nums*100 print("当前已下载:%.2f%%"%jindu,end = "\r") if file_data: # 只要读取到数据,就向客户端进行发送 service_client_socket.send(file_data) # 数据读完,退出循环 else: print("请求的文件数据发送完成") break else: print("下载取消!") else: print("下载的文件不存在!") # 关闭服务当前客户端的套接字 service_client_socket.close() if __name__ == '__main__': # 把工作目录切换到data目录下 os.chdir("./data") # 创建套接字 tcp_server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM) # 绑定端口号 tcp_server_socket.bind(("", 3356)) # 设置监听,将主动套接字变为被动套接字 tcp_server_socket.listen(128) # 循环调用accept,可以支持多个客户端同时连接,和多个客户端同时下载文件 while True: service_client_socket, ip_port = tcp_server_socket.accept() # 连接成功后打印套接字号 #print(id(service_client_socket)) # 创建子线程 sub_thread = threading.Thread(target=deal_client_request, args=(ip_port, service_client_socket)) # 启动子线程 sub_thread.start()
客户端代码:
# 多任务文件下载器客户端 import socket if __name__ == '__main__': # 创建套接字 tcp_client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM) # 和服务端连接 server_ip = input("输入服务器IP:") tcp_client_socket.connect((server_ip, 3356)) # 发送下载文件的请求 file_name = input("请输入要下载的文件名:") # 编码 file_name_data = file_name.encode("utf-8") # 发送文件下载请求数据 tcp_client_socket.send(file_name_data) # 接收要下载的文件信息 file_info = tcp_client_socket.recv(1024) # 文件信息解码 info_decode = file_info.decode("utf-8") print(info_decode) #获取文件大小 fileszie = float(info_decode.split(':')[2].split('MB')[0]) fileszie2 = fileszie*1024 # 是否下载?输入y 确认 输入q 取消 opts = input("是否下载?(y 确认 q 取消)") if opts == 'q': print("下载取消!程序退出") else: print("正在下载 》》》") #向服务器确认正在下载 tcp_client_socket.send(b'y') # 把数据写入到文件里 with open("./" + file_name, "wb") as file: #目前接收到的数据包数目 cnum = 0 while True: # 循环接收文件数据 file_data = tcp_client_socket.recv(1024) # 接收到数据 if file_data: # 写入数据 file.write(file_data) cnum = cnum+1 jindu =cnum/fileszie2*100 print("当前已下载:%.2f%%"%jindu,end = "\r") # 接收完成 else: print("下载结束!") break # 关闭套接字 tcp_client_socket.close()
运行窗口如下:
1)服务器端
2)客户端
注意:客户端和服务器端不要运行在IDLE中,直接使用终端运行。
总结
以上所述是小编给大家介绍的Python3使用TCP编写一个简易的文件下载器功能,希望对大家有所帮助,如果大家有任何疑问请给我留言,小编会及时回复大家的。在此也非常感谢大家对网站的支持!
如果你觉得本文对你有帮助,欢迎转载,烦请注明出处,谢谢!
华山资源网 Design By www.eoogi.com
广告合作:本站广告合作请联系QQ:858582 申请时备注:广告合作(否则不回)
免责声明:本站资源来自互联网收集,仅供用于学习和交流,请遵循相关法律法规,本站一切资源不代表本站立场,如有侵权、后门、不妥请联系本站删除!
免责声明:本站资源来自互联网收集,仅供用于学习和交流,请遵循相关法律法规,本站一切资源不代表本站立场,如有侵权、后门、不妥请联系本站删除!
华山资源网 Design By www.eoogi.com
暂无评论...
更新日志
2024年09月20日
2024年09月20日
- 战锤40K星际战士2狙击职业介绍|狙击职业技能效果一览
- RobertSaxtonTheResurrectionoftheSoldiers(2024)[24Bit-192kHz]FLAC
- 唐成杨东哥弹唱《情若真HQ》头版限量编号[WAV+CUE]
- 柏菲·HIFI风情1《一杯香茶》限量开盘母带ORMCD[WAV+CUE]
- 发糖了!《黑神话》动画导演绘制八戒紫蛛儿中秋贺图
- “时光系列”新作《时光3:永耀之境》首曝:画风更真实的恋爱模拟RPG
- 《战地》游戏主管:始终认为《战地》未来销量能超越《使命召唤》
- 《伤感民谣 值得收藏的音乐极品 2CD》[WAV/分轨][1.2GB]
- 《邓紫棋 巨肺唱将小天后有心人 2CD》[WAV/分轨][1.2GB]
- 《迪克牛仔 坛奇精选 2CD台首版》 [WAV+CUE][600MB]
- 陈明.1998-为了爱影视歌曲+新歌【中唱】【WAV+CUE】
- 黄小琥.2009-简单/不简单【华纳】【WAV+CUE】
- 洪卓立.2010-TASTE.OF.LOVE新曲+精丫英皇娱乐】【WAV+CUE】
- 战锤40K星际战士2职业强度排行
- 交错战线PVE国家队成员以及常用角色推荐