websocket和udp直接通信（基于socketserver实现并发tcpudp）

websocket和udp直接通信（基于socketserver实现并发tcpudp）

1.基于socketserver实现并发-tcp

1. 
   
2. #服务端
3. import socketserver
6. class MyHandler(socketserver.BaseRequesthandler):
7. def handle(self):
9. #print(self.client_address) #客户端地址
10. #print(self.request) ##self.request=conn 套接字对象
11. while True:
12. try:
13. data = self.request.recv(1024)
14. if len(data) == 0: break
15. print()
16. self.request.send(data.upper())
18. except ConnectionResetError:
19. break
22. if __name__ == '__main__':
23. s = socketserver.ThreadingTCPServer(('127.0.0.1' 8080) MyHandler bind_and_activate=True)
24. s.serve_forever() #代表连接循环
25. #循环建立连接，每建立一个连接就会启动一个线程 调用MyHandler类产生一个对象，
26. #该对象下面的handle方法，专门与刚刚建立好的连接做通信循环

1. 
   
2. #客户端
3. import socket
5. phone=socket.socket(socket.AF_INET socket.SOCK_STREAM)
7. phone.connect(('127.0.0.1' 8080))
9. while True:
10. msg=input(">>>>>>>>>>>>>").strip()
11. if len(msg)==0:continue
12. phone.send(msg.encode('utf-8'))
13. data=phone.recv(1024)
14. print(data)
15. phone.close()

1.基于socketserver实现并发-ucp

1. 
   
2. #服务端
3. import socketserver
6. class MyHandeler(socketserver.BaseRequestHandler):
7. def handle(self):
8. data = self.request[0] #request是个元组，元组的第一个是数据，第二个是一个套接字对象
9. print('消息' data)
10. self.request[1].sendto(data.upper() self.client_address) #self.request[1] 是套接字对象
13. if __name__ == '__main__':
14. s = socketserver.ThreadingUDPServer(('127.0.0.1' 8080) MyHandeler)
15. s.serve_forever()
16. #客户端
18. import socket
19. client=socket.socket(socket.AF_INET socket.SOCK_DGRAM)
20. while True:
21. msg=input('>>>>>>>').strip()
22. #msg='111111111111'
23. client.sendto(msg.encode('utf-8') ('127.0.0.1' 8080))
24. data server_addr=client.recvfrom(1024)
25. print(data)
27. client.close()