import socket
import threading
people_name = ''
people_send = ''
#101.34.212.195
def client_send(sock):
    global people_name
    global people_send
    while True:
        people_send = input() #接收输入
        people_send = people_name + ':' + people_send
        sock.send(people_send.encode('utf-8'))
        if 'exit' in people_send:
            sock.shutdown(2)
            sock.close()
            break

def client_accept(sock):
    global people_send
    while True:
        try:
            accept = sock.recv(1024).decode('utf-8') #一次接收数据1024
            #print(type(accept))
            if not accept:
                break
            if accept != people_send:
                print(accept)
        except:
            print("error")
            break
people_name = input('输入你的名字:')
service_ip = '101.34.212.195'
service_port = 10011
sock = socket.socket() #创建socket对象
sock.connect((service_ip, service_port))    #address的格式为元组（hostname,port）
sock.send(people_name.encode('utf-8'))
th_send = threading.Thread(target=client_send, args=[(sock)]) #发送消息线程
th_send.start() #启动线程
th_accept = threading.Thread(target=client_accept, args=[(sock)]) #发送消息线程
th_accept.start() #启动线程