#服务器端
import socket
import threading
import time
s = socket.socket()
s.bind(("127.0.0.1", 9999))
s.listen(5)
print("waiting for connection")
def tcplink(sock, addr):
print('Accept new connection from %s:%s...' %addr)
sock.send(b'welcome')
while True:
data = sock.recv(1024)
if data.decode('utf-8') == 'exit':
break;
sock.send(('hello, %s' % data.decode('utf-8')).encode('utf-8'))
sock.close()
print('connection is over from %s:%s' % addr)
while True:
sock, addr = s.accept()
t = threading.Thread(target=tcplink, args=(sock, addr))
t.start()
蓝萨节
#客户端 import socket import time s = socket.socket() s.connect(('127.0.0.1', 9999))
for i in ['nico', 'emma', 'julita', 'jj']: s.send(i.encode('utf-8')) time.sleep(1) msg = s.recv(1024).decode('utf-8') print(msg)
s.send('exit'.encode('utf-8')) time.sleep(1) s.close()
#服务器端 import socket import threading import time s = socket.socket() s.bind(("127.0.0.1", 9999)) s.listen(5) print("waiting for connection")
def tcplink(sock, addr): print('Accept new connection from %s:%s...' %addr) sock.send(b'welcome') while True: data = sock.recv(1024) if data.decode('utf-8') == 'exit': break; sock.send(('hello, %s' % data.decode('utf-8')).encode('utf-8')) sock.close() print('connection is over from %s:%s' % addr)
while True: sock, addr = s.accept() t = threading.Thread(target=tcplink, args=(sock, addr)) t.start()