달성된 효과는 아래 Gif에 표시되어 있으며 이는 파일 다운로드 및 전송을 구현하는 네트워크 통신 소켓 모듈입니다.
먼저 로컬 IP를 얻어야 합니다. 여기서 서버는 함수를 정의한 다음 스레딩을 사용하여 작업을 생성하는 멀티 스레딩 방법을 사용합니다. 클라이언트는 성공적으로 연결되고 다운로드된 파일명인 클라이언트의 요청 정보를 받습니다. 따라서 출력 파일에 바이트 수가 있는지 판단해야 합니다. 그런 다음 사용자에게 다운로드할 것인지 묻고 while True:를 사용하여 정보를 얻은 후 파일의 내용을 읽은 다음 보냅니다. 코드를 보고 무슨 일이 일어나고 있는지 확인하세요.
import socketimport osimport threading# 获取本机ipdef get_host_ip(): try: s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) s.connect(('8.8.8.8', 80)) ip = s.getsockname()[0]
finally: s.close() return ip# 处理客户端请求下载文件的操作（从主线程提出来的代码）def deal_client_request(ip_port, service_client_socket):
# 连接成功后，输出“客户端连接成功”和客户端的ip和端口 print("客户端连接成功", ip_port)
# 接收客户端的请求信息【recv】 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)
#发送和打印文件信息【send】 service_client_socket.send(senddata.encode("utf-8")) print("请求文件名：%s 文件大小：%.2f MB"%(file_name_data,fmb))
#接受客户是否需要下载【recv】 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 #progress = cnum/nums*100 #print("当前已下载：%.2f%%"%progress,end = "\r") if file_data:
# 只要读取到数据，就向客户端进行发送【send】 service_client_socket.send(file_data)
# 数据读完，退出循环 else: print("请求的文件数据发送完成") break
else: print("下载取消！") else: print("下载的文件不存在！")
# 关闭服务当前客户端的套接字【close】 service_client_socket.close()if __name__ == '__main__':
# 获取本机ip
print("TCP文件传输服务器，本机IP:" + get_host_ip())
# 把工作目录切换到data目录下 os.chdir("./data")
# 创建套接字【socket】 tcp_server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
# 绑定端口号【bind】 tcp_server_socket.bind(("", 3356))
# 设置监听，将主动套接字变为被动套接字【listen】 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()复制代码
클라이언트는 서버에 연결하고 파일 다운로드 요청을 보내고 작성할 폴더를 정의하는 것이 더 간단합니다. 더 이상 글을 쓰지 말고 코드만 보세요.
# -*- coding:utf-8 -*-# 多任务文件下载器客户端import socketimport osif __name__ == '__main__':
# 创建套接字【socket】 tcp_client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
# 和服务端连接【connect】 server_ip = input("输入服务器IP：") tcp_client_socket.connect((server_ip, 3356))
# 发送下载文件的请求 file_name = input("请输入要下载的文件名：")
# 编码 file_name_data = file_name.encode("utf-8")
# 发送文件下载请求数据【send】 tcp_client_socket.send(file_name_data)
# 接收要下载的文件信息【recv】 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
# 是否下载？输入ｙ 确认 输入ｑ 取消 opts = input("是否下载？(y 确认 q 取消)") if opts == 'q': print("下载取消！程序退出") else: print("正在下载 >>>>>>")
#向服务器确认正在下载【send】 tcp_client_socket.send(b'y') recvpath = "./receive/" if not os.path.exists(recvpath): os.mkdir(recvpath)
# 把数据写入到文件里 with open(recvpath + file_name, "wb") as file:
#目前接收到的数据包数目 cnum = 0 while True:
# 循环接收文件数据【recv】 file_data = tcp_client_socket.recv(1024)
# 接收到数据 if file_data:
# 写入数据 file.write(file_data) cnum = cnum+1 #progress =cnum/fileszie2*100 #print("当前已下载：%.2f%%"%progress,end = "\r")
# 接收完成 else: print("下载结束！") break
# 关闭套接字【close】 tcp_client_socket.close()复制代码
휴대폰이 컴퓨터(컴퓨터와 휴대폰 사이)에서 파일을 다운로드하려면 컴퓨터와 휴대폰에 연결된 네트워크가 동일한 라우터에 있는지 확인해야 합니다
를 통해 IP 보기 ipconfig
명령줄에 python -m http.server 8888를 입력하여 LAN을 구축하세요python -m http.server 8888来搭建局域网
手机访问192.168.0.101:8888
192.168.0.101:8888을 방문하여 다운로드하세요. 파일
🎜관련 무료 학습 권장사항: python 비디오 튜토리얼
위 내용은 네트워크 통신을 통한 파일 전송 구현 소켓 모듈의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!