Как я могу ограничить количество входящих запросов к серверу websocket? - PullRequest
0 голосов
/ 17 декабря 2018

Я использую autobahn.asyncio.Я программно отправляю 100 000 запросов на сервер без задержки.Загрузка процессора достигает 100%, а другие запросы не выполняются.Я ничего не делаю на событие onMessage.Как ограничить количество запросов в секунду для каждого соединения?Можно ли это сделать с помощью опций?

async def onConnect(self, request):
    (validate_ok, wsguid, real_ip, conn_method, error_mess) = validate_request(self, request)

    if validate_ok:
        self._WS_MAGIC = uuid.uuid4().hex
        await wsserver.onconnection(wsguid, conn_method, self._WS_MAGIC, real_ip)
    else:
        await drop_connect_throw_exception(error_mess, wsguid, real_ip)

async def onMessage(self, payload, isBinary):
    pass

async def onOpen(self):
    await wsserver.onopen(self)
...