线程实现socket_server

# Time   : 2018/12/16 21:49

import socket
from threading import Thread


def (conn, addr):
	print('addr:', addr)
	while True:
		msg = input('>>>').encode('utf-8')
		conn.send(msg)
		rev = conn.recv(1024).decode('utf-8')
		print('%s发来消息：%s'%(addr, rev))
	conn.close()


if __name__ == '__main__':
	sk = socket.socket()
	sk.bind(('127.0.0.1', 4567))
	sk.listen()
	while True:
		conn, addr = sk.accept()

		Thread(target=chat, args=(conn, addr)).start()
	sk.close()

# Time   : 2018/12/16 21:49

import socket

sk = socket.socket()

sk.connect(('127.0.0.1', 4567))

while True:
	rev = sk.recv(1024).decode('utf-8')
	print(rev)
	msg = input('>>>').encode('utf-8')
	sk.send(msg)
sk.close()