Описание тега message-queue
"Очередь сообщений" - это шаблон проектирования или компонент разработки программного обеспечения, который определяет дисциплину или API для связи между двумя или более взаимосвязанными процессами или системами. Очередь сообщений обеспечивает асинхронную обработку и слабую связь. В зависимости от реализации они могут также предоставлять гарантии доставки и заказа сообщений. Гарантии обработки сообщений явно исключены из конструкции.
1
ответ
Каково ожидаемое поведение, когда в долговременной очереди RabbitMQ заканчивается ОЗУ?
Мое понимание долговременных очередей RabbitMQ (т. Е. Delivery_mode = 2) состоит в том, что они работают в ОЗУ, но сообщения сбрасываются на диск, чтобы их можно было восстановить в случае перезапуска процесса или перезагрузки компьютера. Однако мне…
22 авг '12 в 00:15
2
ответа
Как настроить Websphere MQ для активации моего компонента при получении сообщений?
Как настроить Websphere MQ для активации моего компонента при получении сообщений? Я хочу избежать постоянного опроса новых входящих сообщений с помощью какой-либо службы Windows, я хочу, чтобы новые сообщения передавались мне, а не наоборот. Я рабо…
03 июн '13 в 21:43
3
ответа
Как эффективно получать данные из очереди Kestrel
По некоторым причинам мы планируем использовать очередь kestrel в нашем проекте. Мы делаем несколько демонов, основная проблема в том, как извлечь данные из очереди с низкой загрузкой процессора и эффективно. Способ, которым мы реализовали выборку, …
08 июл '11 в 07:43
3
ответа
Какое асинхронное долговременное решение для службы очередей сообщений использовать для веб-службы ASP.NET?
У меня есть веб-сервис ASP.NET, который должен публиковать запросы для асинхронной обработки другим сервисом (отдельный процесс). Таким образом, требование представляет собой длительную очередь. Сервер Windows Server работает под управлением SQL Ser…
24 ноя '15 в 13:57
2
ответа
Устранение утечки памяти в GTK+ / Очередь с окнами
Я пробовал приложение GTK в Windows и только сейчас начал изучать GTK. Версия GTK: gtk+-bundle_2.24.10-20120208_win32 Требование к применению: 1. Multi threaded 2. Queue based communication 3. GTK window to update a image data in screen with 5 secs …
08 дек '13 в 20:10
1
ответ
Как регистрировать / отслеживать выбранные сообщения WM_USER+n Windows?
Некоторые диалоги и модули данных в моем коде должны задерживать выполнение и делать это, вызывая PostMessage(). Это не распространяется на модули, т. Е. Модуль данных будет иметь обработчик для PostMessage, выпущенного там, как и диалоговое окно. С…
28 апр '15 в 09:16
1
ответ
Могу ли я создать программное обеспечение для Gearman в 2015 году?
Я ищу инструмент очереди / работы, и Gearman идеально подошел бы под мои нужды. Однако развитие кажется застопорившимся: Последний выпуск был 1,5 года назад: https://launchpad.net/gearmand/+download Последний коммит также сопровождающими: https://co…
22 июл '15 в 15:27
1
ответ
Нужно ли закрывать очередь сообщений systemv?
Я использую систему v Очередь сообщений. Очередь создается и удаляется другим процессом. Итак, в этом примере я использую уже созданную очередь сообщений: #include <sys/types.h> #include <sys/ipc.h> #include <sys/msg.h> ... key = f…
23 май '18 в 09:45
1
ответ
Блокировка очереди сообщений Мандельброта - C
У меня проблемы с использованием очередей сообщений в этой программе. Предполагается, что она запускает ряд процессов, которые передаются в аргументе программе из командной строки, но она только запускает и вычисляет баллы для одного процесса... дру…
18 май '12 в 05:03
1
ответ
MSMQ: MessageQueue.Close() создает исключение -1073741536 в.EndReceive()
Я использую MSMQ внутри службы Windows. Когда служба приостановлена, я бы хотел закрыть MSMQ и снова открыть его, когда служба возобновится. Код выглядит так: OnStart _mq.ReceiveCompleted += this.ReceiveCompletedHandler; _mq.BeginReceive(); OnPause …
22 окт '13 в 15:55
3
ответа
Рекомендовать службу очереди сообщений с открытым исходным кодом
Кто-нибудь может порекомендовать мне очередь сообщений с открытым исходным кодом? как JMS, gearmand,zeroMq,Amazon SQS. Tt лучше всего удовлетворить следующие пункты (не обязательно): распределенный и масштабируемый. поддерживается асинхронное сообще…
04 май '12 в 01:54
2
ответа
Механизм подключения / обновления базы данных для непрерывных данных
Я работаю в системе, где существует огромное (2000-5000 записей в минуту) количество входящих событий, которые должны быть записаны в базе данных (SQL Server 2000). Мы используем соединение ODBC для связи с базой данных. В настоящее время мы открыва…
17 сен '10 в 11:32
5
ответов
Как в Win32 реализовано программирование на основе событий?
В приложении Win32 C++ мы запускаем цикл обработки сообщений, который извлекает сообщения из очереди, переводит их и затем отправляет. В конце концов, каждое сообщение достигает нашего WndProc, где может быть обработано соответствующее событие. Я по…
19 апр '09 в 13:35
0
ответов
MSMQ Trigger открывает исполняемый файл в качестве фонового процесса
Я использую триггер Microsoft Message Queuing (MSMQ) для запуска автономного исполняемого файла в Windows 8.1. Exe не запускался, поэтому я попытался открыть Блокнот ( спасибо Джон). Это тоже не сработало, поэтому я запустил диспетчер задач и замети…
21 мар '14 в 00:35
1
ответ
Обойти предварительную выборку в Tibco EMS и.NET API
Все в контексте Tibco EMS 5.* и API.NET. Я должен работать по существующей модели обработки сообщений, в которой в цикле: соединение создано / открыто сессия создана / открыта получатель сообщения создан метод приема называется если сообщение!= ноль…
10 ноя '10 в 10:56
5
ответов
Проблема с балансировкой при чтении сообщений в Кафке
Я пытаюсь читать сообщения на тему Кафки, но не могу прочитать. Процесс завершается через некоторое время, без чтения каких-либо сообщений. Вот ошибка перебалансировки, которую я получаю: [2014-03-21 10:10:53,215] ERROR Error processing message, sto…
21 мар '14 в 15:50
1
ответ
Сохранить порядок доставки после запроса
Я разрабатываю приложение для обмена сообщениями с использованием Rabbit MQ. Я использую явный ACK: model.BasicConsume(queueName,false, consumer); и сделать ACK после обработки сообщения: consumer.Received += (ch, ea) => { try { var message = Enc…
15 фев '17 в 08:16
1
ответ
Как настроить Beanstalkd с PHP
Недавно я исследовал использование Beanstalkd с PHP. Я многому научился, но у меня есть несколько вопросов о настройке на сервере и т. Д. Вот как я вижу это работает: Я устанавливаю Beanstalkd и все зависимости (например, libevent) на свой сервер Ub…
11 окт '11 в 18:17
1
ответ
Интеграция с динамическими клиентами
У меня есть вопрос архитектурного дизайна. Наша компания недавно представила COTS (продукт на основе.NET) для управления делами. Этот продукт имеет сложный модуль интеграции, который выкладывает полную информацию по делу в MQ при каждом действии пол…
15 сен '17 в 18:36
1
ответ
Ищем текущий пример использования MDB сообщений из удаленной очереди в Wildfly 10
У меня есть экземпляр Wildfly 10, который определяет очередь, публикует в эту очередь, а также получает из этой очереди через MDB. Это было достигнуто. Теперь я хочу добавить второй экземпляр Wildfly 10, работающий на другом компьютере, который такж…
08 окт '17 в 14:38