Форум программистов, компьютерный форум, киберфорум
Наши страницы
PHP
Войти
Регистрация
Восстановить пароль
 
CyanoFresh
0 / 0 / 0
Регистрация: 09.01.2016
Сообщений: 7
1

Message queue с минимальной задержкой

27.10.2017, 14:50. Просмотров 440. Ответов 6
Метки нет (Все метки)

Здравствуйте. Есть weboscket демон(сервер) на php. При получении сообщения от клиента добавляет его в очередь https://github.com/yiisoft/yii2-queue на redis. Все ок, но проходит больше 600мс, перед тем, как воркер получит сообщение и начнет работу. Это достаточно много. Как уменьшить задержку? Поможет ли переход на beanstalkd, gearman?
0
QA
Эксперт
41792 / 34177 / 6122
Регистрация: 12.04.2006
Сообщений: 57,940
27.10.2017, 14:50
Ответы с готовыми решениями:

Message queue
Добрый день. Есть проблема с использованием очереди сообщений. Для начала поясню суть задачи....

Программа для изменения голоса в реальном времени с минимальной задержкой или без нее
Здравствуйте. Недавно купил себе микрофон, но он немного искажает мой голос, хотелось бы довести...

Разница между queue.synchronized и concurrent queue
По сути 2 коллекции потокобезопасные, что лучше использовать? Queue que =...

Переполнение Queue, методы оптимизации Queue
Доброго времени суток. Я тут планирую пенгатон взять под контроль.:- StreamReader...

Queue vs Queue.Synchronized vs ConcurrentQueue
Ситуация такова, что один поток постоянно толкает в очередь объекты (Enqueue), а второй забирает...

6
ytf
237 / 257 / 184
Регистрация: 15.08.2017
Сообщений: 1,483
29.10.2017, 15:23 2
Один mysql запрос выполняется 1 секунду, а тут в 2 раза меньше.
0
CyanoFresh
0 / 0 / 0
Регистрация: 09.01.2016
Сообщений: 7
29.10.2017, 15:25  [ТС] 3
где же такие запросы интересные у вас?
0
santaatnas
0 / 6 / 0
Регистрация: 10.04.2016
Сообщений: 66
30.10.2017, 21:47 4
CyanoFresh, Смотрите как настроены воркеры. Yii::$app->queue->delay(5 * 60) вот так выставляется задержка. У вас какая стоит?
0
CyanoFresh
0 / 0 / 0
Регистрация: 09.01.2016
Сообщений: 7
30.10.2017, 21:52  [ТС] 5
Цитата Сообщение от santaatnas Посмотреть сообщение
CyanoFresh, Смотрите как настроены воркеры. Yii::$app->queue->delay(5 * 60) вот так выставляется задержка. У вас какая стоит?
задержку нигде не указывал. Да и получиться ли сделать тем методом рандомную задержку ~500мс (+-100мс)?
0
santaatnas
0 / 6 / 0
Регистрация: 10.04.2016
Сообщений: 66
31.10.2017, 22:16 6
CyanoFresh, Вы хоть пример кода скиньте что-ли. Так гадать сложно. На чем очереди сделаны?. Redis? Rabit или бд??? Все занимает время, как минимум на создание когда, произведение всех инициализаций и создание экземпляров классов + как минимум 1 запись и чтение из хранилища. Если очень важна скорость реакции - слушайте сокет и делайте на лету. Но такой подход может не подойти, может у вас воркер вообще на другом сервере работает.
0
CyanoFresh
0 / 0 / 0
Регистрация: 09.01.2016
Сообщений: 7
31.10.2017, 23:28  [ТС] 7
Цитата Сообщение от santaatnas Посмотреть сообщение
CyanoFresh, Вы хоть пример кода скиньте что-ли. Так гадать сложно. На чем очереди сделаны?. Redis? Rabit или бд??? Все занимает время, как минимум на создание когда, произведение всех инициализаций и создание экземпляров классов + как минимум 1 запись и чтение из хранилища. Если очень важна скорость реакции - слушайте сокет и делайте на лету. Но такой подход может не подойти, может у вас воркер вообще на другом сервере работает.
https://github.com/yiisoft/yii2-queue/issues/160 создал issue. Проблема явно где то в yii2-queue, примеры из php rabbitmq работают мгновенно
0
31.10.2017, 23:28
Answers
Эксперт
37091 / 29110 / 5898
Регистрация: 17.06.2006
Сообщений: 43,301
31.10.2017, 23:28

И снова проблема со Struts (validate): Cannot find message resources under key org.apache.struts.action.Message
Имеем imdex.jsp: <%@ page language='java' %> <%@ taglib uri='/WEB-INF/struts-html.tld'...

Ошибка в xml-файле: cannot load response message. Invalid SOAP message. Only one top level element is allowed in an XML document.
Всем добрый день. Хочу попросить помощи по следующей проблеме: Хочу сделать SOAP-запрос Set...

Error C2664: Client::First: невозможно преобразовать параметр 1 из "std::queue<_Ty>" в "std::queue<_Ty> &"
barbershop.h: #ifndef __BARBERSHOP_H__ #define __BARBERSHOP_H__ #include &lt;vector&gt; #include...


Искать еще темы с ответами

Или воспользуйтесь поиском по форуму:
7
Ответ Создать тему
Опции темы

КиберФорум - форум программистов, компьютерный форум, программирование
Powered by vBulletin® Version 3.8.9
Copyright ©2000 - 2019, vBulletin Solutions, Inc.