#!/usr/bin/env python
#coding=utf-8import time
import socket
import threadinglocal_addr = ('127.0.0.1',8888)
buff_len = 1024def conn_proc(sock, addr):print('accept new connection from %s:%s...' % addr)# 发送数据给客户端sock.send('welcome'.encode('utf-8'))while True:print('wating for message...')# 阻塞接收客户端数据date = sock.recv(buff_len)if not date or date.decode('utf-8')=='exit':break print(date.decode('utf-8')) time.sleep(1.5)sock.send(('server '+str(time.time())).encode('utf-8'))sock.close()print('close connection %s:%s' % addr)if __name__ == '__main__':# 创建一个sockettcp = socket.socket(socket.AF_INET, socket.SOCK_STREAM)# 绑定监听的地址和端口
    tcp.bind(local_addr)# 开始监听端口，等待连接的最大数量为10tcp.listen(10)while True:# 阻塞等待客户端过来的tcp连接sock,addr = tcp.accept()# 创建一个新线程来处理TCP连接threading.Thread(target=conn_proc,args=(sock,addr)).start()# 关闭socket   tcp.close()

#!/usr/bin/env python
#coding=utf-8import time
import socketserver_addr = ('127.0.0.1',8888)
buff_len = 1024if __name__ == '__main__':# 创建一个sockettcp = socket.socket(socket.AF_INET,socket.SOCK_STREAM)# 建立连接
    tcp.connect(server_addr)# 发送数据给服务器tcp.send('hello server.'.encode('utf-8'))# 阻塞接收服务器数据print(tcp.recv(buff_len).decode('utf-8'))while True:tcp.send(str(time.time()).encode('utf-8'))date = tcp.recv(buff_len)if not date or date.decode('utf-8')=='exit':break print(date.decode('utf-8'))# 关闭sockettcp.close()

#!/usr/bin/env python
#coding=utf-8import time
import socketlocal_addr = ('127.0.0.1',8888)
buff_len = 1024if __name__ == '__main__':# 创建一个socketudp = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)# 绑定监听的地址和端口
    udp.bind(local_addr)while True:print('wating for message...')# 阻塞接收客户端数据data, addr = udp.recvfrom(buff_len)print('received from %s data:%s' % (addr, data.decode('utf-8')))time.sleep(1.5)# 发送数据给客户端udp.sendto(('server '+str(time.time())).encode('utf-8'), addr)# 关闭socket  udp.close()

#!/usr/bin/env python
#coding=utf-8import time
import socketserver_addr = ('127.0.0.1',8888)
buff_len = 1024if __name__ == '__main__':# 创建一个socketudp = socket.socket(socket.AF_INET,socket.SOCK_DGRAM)# 发送数据给服务器udp.sendto('hello server.', server_addr)# 阻塞接收服务器数据print(udp.recv(buff_len).decode('utf-8'))while True:udp.sendto(str(time.time()).encode('utf-8'),server_addr)print(udp.recv(buff_len).decode('utf-8'))# 关闭socketudp.close()

import ctypesmain_wnd = ctypes.windll.kernel32.GetConsoleWindow()
if main_wnd != 0:    ctypes.windll.user32.ShowWindow(main_wnd, 0)    ctypes.windll.kernel32.CloseHandle(main_wnd)