自学教程：python实现TCP文件接收发送

# 由客户端向服务器传数据，文件import socketimport tqdmimport osdef send(filename):    # 传输数据间隔符    SEPARATOR = '<SEPARATOR>'    # 服务器信息    host = '127.0.0.1'    port =1234    # 文件缓冲区    Buffersize = 4096*10    # 传输文件名字    filename = filename    # 文件大小    file_size  = os.path.getsize(filename)    # 创建socket链接    s = socket.socket()    print(f'服务器连接中{host}:{port}')    s.connect((host, port))    print('与服务器连接成功')    # 发送文件名字和文件大小，必须进行编码处理    s.send(f'{filename}{SEPARATOR}{file_size}'.encode())    # 文件传输    progress = tqdm.tqdm(range(file_size), f'发送{filename}', unit='B', unit_divisor=1024)    with open(filename,'rb') as f :        # 读取文件        for _ in progress:            bytes_read = f.read(Buffersize)            if not bytes_read:                break            # sendall 确保网络忙碌的时候，数据仍然可以传输            s.sendall(bytes_read)            progress.update(len(bytes_read))    # 关闭资源    s.close()if __name__ == '__main__':    filename = input('请输入文件名：')    send(filename)

import socketimport tqdmimport osimport threadingdef received():    # 设置服务器的ip和 port    # 服务器信息    sever_host = '127.0.0.1'    sever_port =1234    # 传输数据间隔符    SEPARATOR = '<SEPARATOR>'    # 文件缓冲区    Buffersize = 4096*10    s = socket.socket()    s.bind((sever_host, sever_port))    # 设置监听数    s.listen(128)    print(f'服务器监听{sever_host}:{sever_port}')    # 接收客户端连接    client_socket, address = s.accept()    # 打印客户端ip    print(f'客户端{address}连接')    # 接收客户端信息    received = client_socket.recv(Buffersize).decode()    filename ,file_size = received.split(SEPARATOR)    # 获取文件的名字,大小    filename = os.path.basename(filename)    file_size = int(file_size)    # 文件接收处理    progress = tqdm.tqdm(range(file_size), f'接收{filename}', unit='B', unit_divisor=1024, unit_scale=True)    with open('8_18_'+filename,'wb') as f:        for _ in progress:            # 从客户端读取数据            bytes_read = client_socket.recv(Buffersize)            # 如果没有数据传输内容            if not bytes_read:                break            # 读取写入            f.write(bytes_read)            # 更新进度条            progress.update(len(bytes_read))    # 关闭资源    client_socket.close()    s.close()if __name__ == '__main__':    received()