python3基于TCP实现CS架构文件传输

本文实例为大家分享了python3实现CS架构文件传输的具体代码，供大家参考，具体内容如下

1、目标：

基于tcp实现CS架构的文件传输

指令列表：（1）get：从服务器端下载文件

                    （2）put：向服务器端上传文件

                    （3）list：获得服务器端的目录

2、socket模块函数：

（1）send和sendall：send的作用是发送TCP数据，返回发送的数据大小。send函数不保证将所有数据全部发送，因此可能需要重复多次才能完成所有数据的发送。sendall的作用是发送完整的TCP数据，成功时返回None，失败时抛出异常

（2）bind：在服务器端使用，用于将socket绑定在一个特定的ip地址和端口上。在《UNIX网络编程》一书中提到，如果调用connect或者listen之前没有bind一个特定的端口，内核会为相应的套接字分配一个随机的端口。因此，在客户端调用connect函数之前不需要bind

（3）listen：通过参数设定服务器端最多可以接受几个客户端的连接，但是只有在完成与第一个客户端的传送后才会进行与第二个客户端的传送

3、代码：

（1）服务器端：

import socket import os import sys import time  Host = '127.0.0.1' Port = 12000 Addr = (Host, Port)  sockListener = socket.socket(socket.AF_INET, socket.SOCK_STREAM) sockListener.bind(Addr) sockListener.listen(5)  def recvfile(cliSocket):   print('start reveiving file...')   msg = 'no problem'   msg_utf8 = msg.encode(encoding="utf-8")   cliSocket.send(msg_utf8)   filename_utf8 = clientSocket.recv(4096)   filename = filename_utf8.decode()   f = open(filename, 'wb')   while True:     data_utf8 = cliSocket.recv(4096)     data = data_utf8.decode()     if data=='EOF':       print('received file successfully')       break     f.write(data_utf8)   f.close()  def sendfile(cliSocket):   print('start sending file...')   msg = 'no problem'   msg_utf8 = msg.encode(encoding="utf-8")   cliSocket.send(msg_utf8)   filename_utf8 = cliSocket.recv(4096)   filename = filename_utf8.decode()   f = open(filename, 'rb')   while True:     data = f.read(4096)     if not data:       break     cliSocket.sendall(data)   f.close()   time.sleep(1)   msg = 'EOF'   msg_utf8 = msg.encode(encoding="utf-8")   cliSocket.sendall(msg_utf8)   print('sent file successfully')  def getList(cliSocket):   path = sys.path[0]   every_file = os.listdir(path)   for filename in every_file:     pathmsg = filename + '/n'     pathmsg_utf8 = pathmsg.encode(encoding="utf-8")     cliSocket.sendall(pathmsg_utf8)   time.sleep(1)   msg = 'EOF'   msg_utf8 = msg.encode(encoding="utf-8")   cliSocket.sendall(msg_utf8)   print('all filenames have been send')  while True:   print('waiting for connection...')   clientSocket, addr = sockListener.accept()   print('... connection from:', addr)    while True:     msg_utf8 = clientSocket.recv(4096)     msg = msg_utf8.decode()     if msg=='exit':       print(addr, 'close the connection')       break     elif msg=='get':       sendfile(clientSocket)     elif msg=='put':       recvfile(clientSocket)     elif msg=='list':       getList(clientSocket)     else:       print('client error!')       break