作业 4/21 下载

服务端：

from socket import *
import subprocess
import struct


phone=socket(AF_INET,SOCK_STREAM) # 流式协议=》tcp协议
phone.setsockopt(SOL_SOCKET,SO_REUSEADDR,1) #就是它，在bind前加
phone.bind(('172.17.128.175',8083)) # 0-65535, 1024以前的都被系统保留使用
phone.listen(5) # 5指的是半连接池的大小

#  服务端应该做两件事
# 第一件事：循环地从板连接池中取出链接请求与其建立双向链接，拿到链接对象
while True:
    conn,client_addr=phone.accept()
    # 第二件事：拿到链接对象，与其进行通信循环
    while True:
        try:
            data=conn.recv(1024) # 最大接收的数据量为1024Bytes，收到的是bytes类型
            if len(data) == 0:
                # 在unix系统洗，一旦data收到的是空
                # 意味着是一种异常的行为：客户度非法断开了链接
                break
            data = data.decode('utf-8')
            cmd, file = data.split(' ',1)
            if cmd == 'get':
                try:
                    with open(file,'rb') as f:
                        data = f.read()
                        print(data)
                    conn.send(struct.pack('i',len(data))+data)
                    print("客户端发来的消息：
",data.decode('utf-8'))
                except Exception:
                    conn.send('路径不存在'.encode('utf-8'))
            else:
                conn.send('命令不正确'.encode('utf-8'))
        except Exception:
            # 针对windows系统
            break

    # 6、关闭电话连接conn（必选的回收资源的操作)
    conn.close()

    # 7、关机（可选操作）     要实现不断地从半连接池中取出连接请求，服务器不能关闭
    # phone.close()

客户端：

import socket
import struct




phone=socket.socket(socket.AF_INET,socket.SOCK_STREAM) # 流式协议=》tcp协议
phone.connect(('101.200.80.78',8083))  # '101.200.80.78''127.0.0.1'
print('下载数据')
while True:
    # get 文件路径 保存文件路径
    try:
        msg=input("命令get>>>: ").strip() #msg=''
        if len(msg) == 0:continue
        msg,file = msg.rsplit(' ',1)
        print(msg,file)
        phone.send(msg.encode('utf-8'))
        top = phone.recv(4)
        top_len = struct.unpack('i',top)
        print(top_len)
        size = 0
        try:
            with open(file,'wb') as f:
                while size < top_len[0]:
                    data=phone.recv(1024)
                    f.write(data)
                    size += len(data)
        except Exception:
            print('保存路径不存在')
    except Exception:
        print('命令可能不正确')
#4、关闭连接(必选的回收资源的操作)
phone.close()