Имеется файл server.py, в котором есть класс Server, который создаёт и запускает простейший вебсокет сервер:
import asyncio
import websockets
import json
class Server:
def __init__(self):
self.loop = asyncio.get_event_loop()
async def send_data(self, websocket, path):
try:
async for message in websocket:
data = json.loads(message)
if data['type'] == 'get' and data['action'] == 'OK':
message = json.dumps({'status': 'OK'})
await websocket.send(message)
elif data['type'] == 'get' and data['action'] == 'CANCEL':
message = json.dumps({'status': 'CANCEL'})
await websocket.send(message)
elif data['type'] == 'post':
message = json.dumps({'status': 'success'})
await websocket.send(message)
except Exception as msg:
logging.debug(msg)
def run_server(self):
start_server = websockets.serve(self.send_data, 'localhost', 8080)
self.loop.run_until_complete(start_server)
self.loop.run_forever()
Также есть main.py, где сервер запускается:
from server import Server
if __name__ == '__main__':
server = Server()
server.run_server()
Проблема в том, что никак не получается остановить работу сервера и завершить все потоки из кода (только через диспетчер задач). Также из-за того что нормально все закрыть не получается, постоянно при перезапуске сервера возникает ошибка, что порт занят: [Errno 10048] error while attempting to bind on address ('::1', 8080, 0, 0)
Каким образом я могу осуществить полную остановку сервера? В консоли хотя бы по сочетанию клавиш ctrl+C, например. В будущем будет GUI, в котором мне нужно будет делать это по нажатию кнопки.