#####################################client

import socket
ip_port=("127.0.0.1",9998)

sk=socket.socket()
sk.connect(ip_port)
print("客户端启动...")

print(str(sk.recv(1024),"utf8"))

while True:
    inp=input("please input:").strip()

    sk.sendall(bytes(inp,"utf8"))
    basic_info_bytes=sk.recv(1024)
    print(str(basic_info_bytes,"utf8"))
    # sk.send(bytes('ok','utf8'))
    result_length=int(str(basic_info_bytes,"utf8").split("|")[1])

    print(result_length)
    has_received=0
    content_bytes=bytes()
    while has_received<result_length:
        fetch_bytes=sk.recv(1024)
        has_received+=len(fetch_bytes)
        content_bytes+=fetch_bytes
    cmd_result=str(content_bytes,"utf8")
    print(cmd_result)

sk.close()

实现简单FTP功能

ftp_server.py

#!/usr/bin/env python
# -*- coding:utf-8 -*-
#Author:WangHuafeng


import socketserver
import subprocess
import json

class MyServer(socketserver.BaseRequestHandler):
    def handle(self):
        self.request.sendall(bytes("欢迎使用Python Server！", encoding='utf-8'))
        while True:
            data = self.request.recv(1024)
            if len(data) == 0:break
            print('data', data)
            print("[%s] says:%s" % (self.client_address, data.decode()))
            task_data = json.loads(data.decode())
            task_action = task_data.get('action')
            if hasattr(self, 'task_%s' % task_action):
                func = getattr(self, 'task_%s' % task_action)
                func(task_data)
            else:
                print('task action is not supported', task_action)

    def task_put(self, *args, *kwargs):
        print("---put", args, kwargs)
        filesize = args[0].get('file_size')
        filename = args[0].get('filename')
        server_response = {'status':200}
        self.request.send(bytes(json.dumps(server_response), encoding='utf-8'))
        recv_size = 0
        with open(filename, 'wb') as f:
            while recv_size < filesize:
                data = self.request.recv(4096)
                f.write(data)
                recv_size += len(data)
        print("file recv sucess")

if __name__ == '__main__':
    server = socketserver.ThreadingTCPServer(('192.168.6.130', 8999), MyServer)
    server.serve_forever()

ftp_client.py