Как поставить в очередь GET запросы в API?

Question

[Toshi Young]

Есть сервис со звонками на PHP.
PHP приложение передает на сервер с Asterisk GET запрос с номером телефона.
На сервере Asterisk есть обработчик, который принимает GET запросы с номером телефона, после запроса передает данные в Asteriks идет звонок на данный номер.
У нас есть ограничение, не более 10 одновременных звонков.

Как можно ограничить кол-во одновременных запросов до 10, а остальных поставить в очередь?

Думаю в сторону Beanstalkd. PHP приложение отправляет запрос с данными на сервер Beanstalkd, далее Worker получая задачу делает запрос к Asterisk.
Правильно ли я мыслю? Если да, то как можно ограничить в Beanstalkd кол-во этих соединений до 10 одновременных или они просто последовательно обрабатываются?
Ни разу не сталкивался с очередями, так что сильное не пинайте.

Comments

[Сергей Соколов]

это для телефоного спама?

[Toshi Young]

Сергей Соколов, Нет. Подтверждения аккаунта, решили через звонки данный сервис сделать, вместо отправки СМС.

[Сергей Соколов]

Не совсем понятны моменты:

1. По окончании звонка Asterisk как-то информирует PHP о результате?
   
2. Что делает PHP-процесс во время звонка: ждёт ответа или отправил GET-запрос и можно отключаться?
   
3. Время каждого звонка примерно одинаково?
   
4. Одним процессом PHP выполняется одновременно один GET-запрос, или можно несколько (Curl-multi).
   
   

[Toshi Young]

Сергей Соколов,
1. По окончанию не информирует, просто передает в Asterisk и отключается. Если запрос прошел, то дозвон должен совершиться.
2. Да, отправил и отключился.
3. С Asterisk идет дозвон в течении 2-3 секунд и звонок скидывается.
4. Сейчас просто один GET запрос, но можно поменять и до Мульти Курла.

[Сергей Соколов]

Toshi Young, т.е. PHP действует вслепую? Можно просто брать из БД "не более 10" задач и отправлять их одной пачкой curl-multi. А затем держать паузу в 4 секунды, чтобы наверняка?

[Сергей Соколов]

Asterisk как-то иначе реагирует, если у него все 10 «слотов» уже заняты и поступает 11-й GET-запрос?

[Toshi Young]

Хм, то же вариант. А Воркер в данном случае получится ежесекундный CRON с выгребанием из базы этих задач. Спасибо.

[Toshi Young]

Сергей Соколов, "Asterisk как-то иначе реагирует, если у него все 10 «слотов» уже заняты и поступает 11-й GET-запрос?" — Нет, он просто не сработает и ничего об этом не скажет.

[Евгений Антипов]

Нет, он просто не сработает и ничего об этом не скажет.

Быть такого не может. Сомневаюсь, что ребята из диджиума оказались глупее юзеров их софта) Всегда все запросы как минимум логируются, следовательно их можно также мониторить и использовать для записи в бд например.

[Toshi Young]

Дмитрий Петров, Возможно. Я не настраивал и не работал с сервером Asterisk там админ колдует, я лишь PHP приложение пишу, и мне дали задачу: Запросов можно обработать только 10, а остальных в очередь. Вот и не рассматриваю возможности самого Asteriskа

[Евгений Антипов]

Toshi Young, Ну вы сами смотрите конечно, но я бы пошел в первую очередь пинать админа и ломать голову ему. А затем бы уже в случае чего принялся за поломку своей.
Да и вообще... https://wiki.asterisk.org/wiki/pages/viewpage.acti...
Собсно... asterisk.ru/knowledgebase/Asterisk+Manager+API+Act...

Answer 1

[Anton fon Faust]

Элементарная очередь, которая легко делается связкой php(или любой другой яп)+mysql (или любое другое хранилище).
С сайта - пишете в таблицу нужные данные: номер телефона, звонок выполнен или нет, метка обработчика, id (с автоинкрементом).
В фоне запускаете нужное количество обработчиков (хоть сто), каждый обработчик раз в сколько-то секунд работает по такому принципу: update queue set worker_id = $id_of_worker where worker_id = null order by id limit 1, а дальше select * from queue where worker_id = $id_of_worker.
После того, как получили и отзвонились, записываем все в лог и делаем delete from queue where worker_id = $id_of_worker.

Делается за пол часа, очередь из миллионов запросов разбирается за считанные минуты.

Answer 2

[Дмитрий Шицков]

Предлагаю такой алгоритм.
Считаете количество активных вызовов в Астериск (легко делается, пример найти не сложно гуглом).
В очередь прилетает, предположим, 15 вызовов. Ваш воркер начинает хватать вызовы из очереди и скармливать астериску, пока не получит от него в ответ: "хватит, уже 10 активных вызовов идет". Воркер пытается подпихивать вызовы с некоторой периодичностью, пока астериск не сможет их принять