Публикации по теме 'message-queue'
Могу ли я использовать Redis в качестве очереди сообщений?
Redis — это хранилище структур данных в памяти, которое можно использовать в качестве базы данных, кэша и брокера сообщений. Одним из наиболее распространенных приложений Redis является очередь сообщений. В этом посте мы рассмотрим, что такое очередь сообщений и как Redis можно использовать в качестве очереди сообщений.
Вопросы по теме 'message-queue'
Барьер идемпотентности для обмена сообщениями
Недавняя презентация , посвященная RabbitMQ упомянул об использовании так называемого "барьера идемпотентности" для дедупликации сообщений. Это просто причудливое название для конфлятора сообщений или что-то более конкретное. Если да, то что...
1098 просмотров
schedule
03.09.2022
Очередь сообщений msgsnd текстовое поле
При использовании msgsnd структура, упомянутая на странице руководства,
struct mymsg {
long mtype; /* message type */
char mtext[1]; /* body of message */
};
Но если вы используете его как
func(char *array, int...
887 просмотров
schedule
24.10.2023
Вызов finish() после запуска нового действия
Первое действие, которое загружается в моем приложении, — это действие инициализации, и после его завершения загружается новое действие. Я хочу убедиться, что если пользователь нажмет «Назад», он перейдет прямо к панели запуска, а не к экрану...
19298 просмотров
schedule
13.10.2023
Выбор очереди сообщений?
Мы используем SysV Message Queue для нашей распределенной системы обработки данных уже более 15 лет. По какой-то причине мы хотим заменить его более новым механизмом очереди сообщений. Есть предложения?
Требования:
Быстрый отклик, сводящий к...
871 просмотров
schedule
25.08.2022
Как лучше отправлять обновления данных клиентам в .net?
Когда пользователь обновляет некоторые данные в нашем приложении .net, наш сервер отправляет обновления заинтересованным клиентам, сообщая им, что эти данные обновлены. В настоящее время каждый клиент также является сервером (т.е. они прослушивают...
104 просмотров
schedule
14.05.2024
Какой тип диаграммы UML мне нужно использовать в таком случае?
Просто для моей личной вики я хочу нарисовать диаграмму, показывающую, как сообщение обрабатывается через пару очередей сообщений.
(Например, xml-сообщение поступает из source1 в Queue1, затем передается в систему, где сообщение преобразуется в...
1163 просмотров
schedule
07.08.2022
Как происходит асинхронная обработка запросов с помощью rails, redis и node.js?
Для веб-разработки я хотел бы смешать rails и node.js, так как я хочу получить лучшее из обоих миров (rails для быстрой веб-разработки и node для параллелизма). Я знаю, что некоторые люди предпочитают просто использовать полный стек ruby с...
937 просмотров
schedule
22.02.2024
Распределите рабочую нагрузку с помощью очереди заданий
У меня есть приложение, которое создает ряд заданий, и я хочу иметь возможность обрабатывать эти задания на нескольких серверах для распределения нагрузки.
Каждое задание имеет категорию, и все задания в категории располагаются в особом порядке,...
519 просмотров
schedule
25.07.2022
Рекомендации для удаленных очередей сообщений C/C++
Я работаю над проектом, который включает несколько программ на C++, каждая из которых принимает входные данные и генерирует выходные данные. Данные (от десятков до сотен байтов, вероятно, в формате JSON) по существу передаются (асинхронно) в одном...
16395 просмотров
schedule
10.08.2022
Как использовать модуль Tibco JMS, определенный в weblogic, и отправлять ему сообщения с помощью Spring
Я новичок в spring... У меня есть изменение, в соответствии с которым нам нужно добавить сообщение в очередь Tibco. Очередь определяется в веб-логике в разделе «Модули JMS» как внешний сервер (настройка с фабрикой соединений и местом назначения)....
3179 просмотров
schedule
21.11.2023
Уникальные идентификаторы заданий в очереди сообщений?
У меня есть приложение, которое я пишу, которое должно выполнять длительные вычисления в фоновом режиме, поэтому у меня есть следующий рабочий процесс:
Клиент отправляет задание на пограничный «диспетчерский» сервер.
Диспетчерский сервер...
7159 просмотров
schedule
06.04.2024
Задачи Celery с невыбираемыми аргументами
Я пытаюсь внедрить систему очередей сообщений для отправки операций в API AdWords.
class Call(object):
@celery.task(filter=task_method)
def MUTATE(self, operations):
assert hasattr(self, '__throwaway_service')
with...
1216 просмотров
schedule
20.04.2024
Как я могу использовать RabbitMQ между двумя приложениями, пока я не могу изменить одно из них?
У меня есть существующая система, состоящая из двух узлов, модель клиент/сервер. Я хочу обмениваться сообщениями между ними с помощью RabbitMQ. т.е. Клиент будет отправлять все свои запросы в RabbitMQ, а сервер будет бесконечно прослушивать...
797 просмотров
schedule
23.02.2024
Очередь сообщений - несколько процессов отправляют cmd в msgqueue
У меня есть сценарий, в котором несколько процессов (p1, p2 и т.д.) одновременно отправляют команду (сообщение) в очередь сообщений (cmd_msg_q).
И есть один процесс-получатель (R1), который извлекает сообщение из очереди и отправляет...
3469 просмотров
schedule
12.08.2022
JMS/Active MQ — брокер против повторной доставки потребителю
Насколько я понимаю ( http://activemq.apache.org/message-redelivery-and-dlq-handling.html ) повторная доставка может быть выполнена либо потребителем, либо брокером. У меня есть несколько вопросов:
Как работает повторная доставка потребителем?...
2462 просмотров
schedule
17.11.2022
Почему для errno установлено значение 22: mq_open() POSIX
Я получаю errno 22 при попытке создать message_queue в POSIX с помощью C. Насколько я могу судить, по сравнению с примером кода, доступным в Интернете, я правильно установил параметры.
Вот фрагмент:
int open_flags;
mqd_t mqfd;...
7201 просмотров
schedule
25.09.2022
Eventbus по сравнению с шиной событий MessageQueue, который лучше передает рыночные данные в сценарии алгоритмической торговли?
Я пытаюсь решить, какую технологию использовать для передачи моих рыночных данных в реальном времени в мои торговые стратегии. Сценарий следующий,
У меня есть несколько торговых стратегий, подписанных на разные тикеры, по мере получения рыночных...
564 просмотров
schedule
11.03.2024
RabbitMQ: как отправить обмен недоставленными письмами из клиента Erlang
Я хочу отправить Dead Letter Exchange из клиента Erlang, но пробовал несколько дней, но не смог понять, как я могу легко отправить его через клиент Ruby.
amqp_channel:call(Channel, #'queue.declare'{
queue = QueueName,
arguments =...
267 просмотров
schedule
12.01.2024
Время вызова WindowProc
Я новичок в сообщениях win32. Я хотел бы знать, что когда WindowProc находится в середине обработки сообщения, возможно ли, чтобы он был прерван для обработки другого сообщения? Возьмем пример ниже, если выполняются и [A] и [B], возможно ли...
128 просмотров
schedule
16.12.2023
Публикация нескольких сообщений в RabbitMQ из файла
Публикацию отдельных сообщений в очереди RabbitMQ можно легко выполнить с помощью пользовательского интерфейса, просто поместив сообщение в пользовательский интерфейс и нажав кнопку «Опубликовать сообщение».
Как опубликовать пакет сообщений?
У...
25125 просмотров
schedule
07.04.2024
