2019.10.22

client

import socket

client = socket.socket()
client.connect(
    ('127.0.0.1',8888)
)


while 1:
    msg = input('input>>>')
    if  msg == 'q':
        break
    client.send(msg.encode('utf-8'))
    data = client.recv(1024).decode('utf-8')
    print(data)

client.close()

server

import socket
from  multiprocessing  import Process,Queue
import threading
import socketserver

# q = Queue(4)

server = socket.socket()
server.bind(
    ('127.0.0.1', 8888)
)
server.listen(3)

def se():


    while 1:
        conn,addr = server.accept()
        print(addr)

        while 1:
            try:
                data = conn.recv(1024).decode('utf-8')
                print(data)
                conn.send(data.encode('utf-8'))

            except Exception as e:
                print(e)
                break

        conn.close()



if __name__ == '__main__':

    p1 = threading.Thread(target=se)
    p2 = threading.Thread(target=se)
    p3 = threading.Thread(target=se)
    p1.start()
    p2.start()
    p3.start()