from socketserver import BaseRequestHandler, UDPServer
|
import time
|
|
packed_count = 0
|
|
class PointCloudUDPServer(BaseRequestHandler):
|
|
def handle(self):
|
|
global packed_count
|
|
print('Got connection from {}, {}'.format(self.client_address, packed_count))
|
# Get message and client socket
|
msg, sock = self.request
|
f = open('packet{}.udp'.format(packed_count), 'wb')
|
f.write(msg)
|
f.close()
|
packed_count += 1
|
if packed_count >= 100:
|
UDPServer.server_close(server)
|
|
|
if __name__ == '__main__':
|
|
global server
|
# host = '192.168.2.65'
|
host = ''
|
port = 9911
|
server =UDPServer((host, port), PointCloudUDPServer)
|
print(time.asctime(),'Server started on port', port)
|
print('....')
|
print('ctrl-c to quit server.')
|
try:
|
server.serve_forever()
|
except KeyboardInterrupt:
|
server.server_close()
|
print(time.asctime(),"Server Stopped")
|
except:
|
server.server_close()
|
print(time.asctime(),"Server Stopped")
|
