python socket单线程通信

import socket
server = socket.socket()
server.bind(("127.0.0.1",6969))
server.listen()

con,addr=server.accept()
while True:
    data=con.recv(1024)
    data_uper=str(data,"utf-8").upper()
    con.send(bytes(data_uper,"utf-8"))

import socket
client = socket.socket()
client.connect(('127.0.0.1',6969))
x=input(">>:")
client.send(bytes("good 你好",encoding="utf-8"))
data=client.recv(1024)
print(str(data,"utf-8"))

import socket
server = socket.socket()
server.bind(("127.0.0.1",6969))
server.listen()
while True:
    con,addr=server.accept()
    print(addr)
    while True:
        try:
            data=con.recv(1024)#在程序正常退出，也就是con的tcp连接正常中断，data直接为0执行下一步
        except Exception as e:
            break   #防止在windows下，强制关闭，con通道错误而报错，linux下不用这样
        if not data:break
        print(str(data,"utf8"))
        x=input(">：")
        con.send(bytes(x,"utf-8"))

import socket
client = socket.socket()
client.connect(('127.0.0.1',6969))
while True:
    x=input(">>:")
    if not x:continue #解决在阻塞模型下，直接回车卡住的bug
    client.send(bytes(x,encoding="utf-8"))
    data=client.recv(1024)
    print(str(data,"utf-8"))

import os
import socket
server = socket.socket()
server.bind(("127.0.0.1",6969))
server.listen()
while True:
    con,addr=server.accept()
    print(addr)
    while True:
        try:
            data=con.recv(1024)#在程序正常退出，也就是con的tcp连接正常中断，data直接为0执行下一步
        except Exception as e:
            break   #防止在windows下，强制关闭，con通道错误而报错，linux下不用这样
        if not data:break
        cmd_line=str(data,"utf-8")

        cmd_result=os.popen(cmd_line,"r").read()
        if not cmd_result: #当os.popen执行非系统命令时，返回值为空
            cmd_result = "未知命令"
        cmd_result=bytes(cmd_result,"utf-8")
        cmd_result_len=bytes(str(len(cmd_result)),"utf-8")
        #int与bytes之间不能直接转换。
        #len 在str与bytes类型之间的长度是不一致的！！！
        print("发送数据长度",str(cmd_result_len,"utf-8"))

        con.send(cmd_result_len)
        flag=con.recv(1024)  #通过一次recv来解决两个send之间粘包的问题。
        con.send(cmd_result)

import socket
client = socket.socket()
client.connect(('127.0.0.1',6969))
while True:
    x=input(">>:")
    if not x:continue
    client.send(bytes(x,encoding="utf-8"))
    recv_len=int(str(client.recv(1024),"utf-8"))
    client.send(bytes("ok","utf-8"))
    print(recv_len)
    data=bytes()
    while len(data) != recv_len:
        data += client.recv(1024)
    print(str(data,"utf-8"))

import os
import socket
server = socket.socket()
server.bind(("127.0.0.1",6969))
server.listen()

while True:
    con,addr = server.accept()
    while True:
        cmd=str(con.recv(1024),"utf-8")
        print(cmd)
        cmd = cmd.split()
        if cmd[0] == "push":
            print(cmd[0])
            f = open(cmd[1], "rb")
            file_size = os.stat(cmd[1]).st_size
            print(file_size)
            con.send(bytes(str(file_size), encoding="utf-8"))

            flag=con.recv(1024)
            # for line in f:
            #     con.send(line)
            data_size=0
            while file_size != data_size:
                data=f.read(1024)
                con.send(data)
                data_size += len(data)
            print(data_size)
            print("发送完毕")

            f.close()

import socket
import os
client = socket.socket()
client.connect(("127.0.0.1",6969))

while True:
    cmd=bytes(input("->:"),"utf8")
    client.send(cmd)

    file_size = int(str(client.recv(1024), "utf-8"))
    client.send("ok".encode("utf-8"))
    data_len = 0
    f = open("1.new.avi","wb")
    while file_size != data_len:
        data = client.recv(1024)
        data_len += len(data)
        f.write(data)
        print(data_len)
    f.close()

import socketserver

class MyTCPHandler(socketserver.BaseRequestHandler):
    """
    The request handler class for our server.

    It is instantiated once per connection to the server, and must
    override the handle() method to implement communication to the
    client.
    """

    def handle(self):
        # self.request is the TCP socket connected to the client
        self.data = self.request.recv(1024).strip()
        print("{} wrote:".format(self.client_address[0]))
        print(self.data)
        # just send back the same data, but upper-cased
        self.request.sendall(self.data.upper())

if __name__ == "__main__":
    HOST, PORT = "localhost", 9999

    # Create the server, binding to localhost on port 9999
    server = socketserver.TCPServer((HOST, PORT), MyTCPHandler)

    # Activate the server; this will keep running until you
    # interrupt the program with Ctrl-C
    server.serve_forever()