多进程实现Socket聊天

• server端：

import multiprocessing
import socket

class Myprocess(multiprocessing.Process):

def __init__(self, connt, addr):
    super().__init__()
    self.connt = connt
    self.addr = addr

def run(self):
    self.connt.send("你好".encode("UTF-8"))
    while True:
        # mes = input("server>>>>") # 自进程不能使用input（）
        # print(1)
        # self.connt.send(mes.encode("UTF-8"))
        ret = self.connt.recv(1024).decode()
        print(ret)


if __name__ == '__main__':

so = socket.socket()
so.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
so.bind(("127.0.0.1", 9999))
so.listen(5)
while True:
    connt, addr = so.accept()
    print(addr)
    p = Myprocess(connt, addr)
    p.start()

• client端：

import socket
so = socket.socket()
so.connect(("127.0.0.1", 9999))

# so.send(b"hello")
while True:
    res = so.recv(1204).decode("utf-8")
    print(res)
    mes = input("client>>>>")
    so.send(mes.encode())