Python XMLRPC с параллельными запросами

Question

Я ищу способ предотвратить запуск несколькими одновременными командами для прослушивателя XMLRPC на Python. Слушатель отвечает за запуск сценариев для выполнения задач в этой системе, которые потерпят неудачу, если несколько пользователей попытаются выпустить эти команды одновременно. Есть ли способ заблокировать все входящие запросы, пока один экземпляр не завершит?

Answer 1

Я думаю, что модуль SimpleXMLRPCServer python - это то, что вы хотите. Я считаю, что поведение по умолчанию этой модели блокирует новые запросы при обработке текущего запроса. Поведение по умолчанию дало мне массу проблем, и я изменил это поведение путем смешивания в классе ThreadingMixIn, чтобы сервер xmlrcc мог отвечать на несколько запросов одновременно.

class RPCThreading(SocketServer.ThreadingMixIn, SimpleXMLRPCServer.SimpleXMLRPCServer): 
    pass 

Если я правильно понял ваш вопрос, SimpleXMLRPCServer - это решение. Просто используйте его напрямую.

Answer 2

У вас есть другой канал связи? Если «да», то между сервером и клиентами будет выполняться протокол «перезвони мне, когда моя очередь».

Другими словами, каждый клиент зарегистрирует свое намерение выдавать запросы серверу, и указанный сервер «обратится» к следующему клиенту, когда он будет готов.

Answer 3

Есть несколько вариантов: сервер

1. Использование однопроцессный-один поток, как SimpleXMLRPCServer для обработки запросов в дальнейшем.
2. Используйте threading.Lock() в потоковом сервере.
3. Вы используете внешний механизм блокировки (например, модуль lockfile или GET_LOCK() в mysql) на многопроцессорном сервере.