import socketsk = socket.socket()sk.bind((‘127.0.0.1‘, 8001))sk.listen(5)connect, address = sk.accept()while True:    receive_data = connect.recv(1024)    if not receive_data:        break    connect.sendall(receive_data.upper())connect.close()

import socketsk = socket.socket()sk.connect((‘127.0.0.1‘, 8001))while True:    msg = input(">>>").strip()    if not msg:        continue    sk.sendall(bytes(msg, encoding=‘utf8‘))    receive_data = sk.recv(1024)    print(receive_data.decode())sk.close()

import socketimport subprocesss = socket.socket()s.bind(("127.0.0.1",9999))s.listen(5)while True:    print("Wating New Connection ... ")    conn, addr = s.accept()    print("\tWating IP: {0[0]} Port: {0[1]}".format(addr))    while True:        # 捕获客户端发送过来的数据，最大接收 1024 字节        recv_data = http://www.mamicode.com/conn.recv(1024)        # 如果接收到的自己为空，则跳出循环        if not recv_data:break        # 捕获苦短发送的命令        cmd = str(recv_data, encoding=‘utf8‘)        res = subprocess.Popen(cmd, shell=True, stdout=subprocess.PIPE, stderr=subprocess.PIPE)        output = str(res.stdout.read(), encoding=‘utf8‘)        error = str(res.stderr.read(), encoding=‘utf8‘)        if error:            if output:                send_data = "%s\n%s" % (output, error)            else:                send_data = error        else:            send_data = output        print(len(send_data))        # 如果需要发送的字节大约 1024,则先发送一个 Ready|{字节大小},作为标记,然后再紧接着发送数据        if len(send_data) > 1024:            ready_tag = "Ready|%s" % len(send_data)            conn.send(bytes(ready_tag, encoding=‘utf8‘))            start_tag = conn.recv(1024)            if start_tag.deconde() == ‘Start‘:                conn.send(bytes(send_data, encoding=‘utf8‘))        else:            conn.send(bytes(send_data, encoding=‘utf8‘))    conn.close()    print("\tIP:{0[0]} Port:{0[1]} Close Connection".format(addr))

import reimport sockets = socket.socket()s.connect((‘127.0.0.1‘, 9999))while True:    try:        # 捕获输入        send_data = http://www.mamicode.com/input(">> ").strip()        # 如果捕获数据为空，则继续提示输入        if not send_data:continue        # 如果输入的数据为 exit，则跳出循环        if send_data =http://www.mamicode.com/= ‘exit‘:break        # 发送捕获到的数据，python 3.5 之后发送的数据必须为 bytes 类型        s.send(bytes(send_data, encoding=‘utf8‘))        # 接收最大 1024 字节的数据        recv_data = http://www.mamicode.com/s.recv(1024)        # 将数据转换为 str        recv_data = http://www.mamicode.com/str(recv_data, encoding=‘utf-8‘)        # 如果接收到的数据为匹配正则: Ready\|\d+$, 说明后面会有一个大约 1024的数据进行发送        # 获取到需要接收的字节大小，然后进行多次接收，并进行组合，然后再输出        if re.match(‘Ready\|\d+$‘, recv_data):            # 获取数据的字节大小            msg_size = recv_data.split("|")[-1]            msg_size = int(msg_size)            recv_data = b""     # 接受的数据            recv_size = 0       # 已接收数据大小            s.send(bytes("Start", encoding=‘utf-8‘))            while recv_size < msg_size:                recv_msg = s.recv(1024)     # 多次接收                recv_data += recv_msg       # 组合数据                recv_size += len(recv_msg)  # 修改已接收数据大小            recv_data = str(recv_data, encoding=‘utf-8‘)        # 打印数据        print(recv_data)    except KeyboardInterrupt:        breaks.close()

import socketserverclass Server(socketserver.BaseRequestHandler):    # 这里的方法必须是 handle    def handle(self):        # 定义与客户端的所有交互内容        while True:            receive_data = self.request.recv(1024)            if not receive_data:                break            send_data = receive_data.upper()            self.request.send(send_data)if __name__ == ‘__main__‘:    # 创建 TreadingTCPServer 对象，并执行 serve_forever 方法    server = socketserver.ThreadingTCPServer((‘127.0.0.1‘,9998), Server)    server.serve_forever()

import sockets = socket.socket()s.connect((‘127.0.0.1‘,9998))while True:    inp = input(">>>")    if not inp:        continue    if inp == ‘quit‘:        break    s.send(bytes(inp, encoding=‘utf-8‘))    receive_data = s.recv(1024)    print(receive_data.decode())s.close()

import socketimport selectimport threadingdef process(request, client_ip):    print("HOST[{0[0]}] Port[{0[1]}] Connect".format(client_ip))    request.sendall(bytes(‘欢迎连接到服务器。。。‘, encoding=‘utf-8‘))    while True:        receive_data = request.recv(1024)        if not receive_data:            break        request.sendall(receive_data.upper())sk = socket.socket()sk.bind((‘127.0.0.1‘,8001))sk.listen(5)while True:    # 监听 socket 是否有 IO 变化    r, w, e = select.select([sk], [], [], 1)    if sk in r:        request, client_ip = sk.accept()        # 为 socket 创建多线程        t = threading.Thread(target=process, args=(request, client_ip))        t.start()sk.close()