Вопросы, помеченные тегом «message-queue»

«Очередь сообщений» - это шаблон проектирования или компонент разработки программного обеспечения, который определяет дисциплину или API для связи между двумя или более взаимосвязанными процессами или системами. Очередь сообщений обеспечивает асинхронную обработку и слабую связь. В зависимости от реализации они могут также предоставлять гарантии доставки и заказа сообщений. Гарантии обработки сообщений явно исключены из конструкции.
avatar
SpongeBob
8 августа 2021 в 21:15
181
1

«Выстрелить и забыть» или «Опубликовать» Подписаться

Я знаю, что Fire And Forget — это шаблон, который позволяет добавить сообщение в очередь сообщений, не дожидаясь подтверждения. Кроме того, я знаю, что Pub/Sub — это шаблон, который публикуют издатели, а подписчики потребляют данные. В чем разница между этими двумя...
avatar
FBryant87
8 августа 2021 в 08:45
125
2

Обеспечение того, чтобы служебная шина Azure никогда не теряла ни одного сообщения

У меня есть система, в которой потеря сообщений из служебной шины Azure была бы катастрофой, то есть данные были бы потеряны навсегда без каких-либо практических средств для устранения повреждений без серьезного сбоя. Смогу ли я когда-нибудь полностью положиться на ASB...
avatar
xyf
6 августа 2021 в 01:43
153
0

mq_send и mq_receive кажутся заблокированными - кажется, что передача не происходит

Я пишу приложение производителя/потребителя, в котором один поток записывает в очередь сообщений, а другой потребляет/читает из нее, но кажется, что и mq_send(), и mq_receive() заблокированы, поэтому передача не происходит. Другими словами, я не вижу отпечатков из...
avatar
xyf
5 августа 2021 в 23:02
69
1

Плохой файловый дескриптор при записи в очередь сообщений с флагом O_WRONLY

У меня есть следующая программа, которая выдает ошибку Client unable to send message to server: Bad file descriptor, которая находится внутри функции Transmit(). Из того, что я нашел об этой ошибке, кажется, что это происходит, когда разрешения неверны, но в моем...
avatar
Shan
4 августа 2021 в 20:31
32
1

Как отправить большой файл XML нижестоящим службам

У меня есть служба, которая вызывает внешний API для получения большого XML-файла, выполняет некоторую фильтрацию этого XML-файла и отправляет новый XML-файл нескольким нижестоящим службам. Мне интересно, как этого добиться. Должен ли я разделить файл на несколько...
avatar
xyf
2 августа 2021 в 21:09
156
1

mq_receive возвращает «Сообщение слишком длинное», хотя msg_len больше, чем mq_msgsize.

Я пытаюсь понять, как работают очереди сообщений в Linux. В конце концов, я хотел бы иметь программу, в которой я мог бы отправлять и получать информацию между различными потоками/процессами, но для начала я только создаю очередь сообщений и блокирую ее на входе в...
avatar
Jonathan W.
1 августа 2021 в 17:09
313
0

связь между тире и другим потоком с использованием очереди

Я написал программу, которая периодически получает и обрабатывает географические данные. Я хотел бы изобразить пары (широта, долгота), созданные этой программой, в приложении dash, предоставляющем график plotly Scattergeo, более или менее по мере поступления...
avatar
djna
31 июля 2021 в 19:56
143
0

perl msgrcv() ошибка 22 (EINVAL) Ubuntu

У меня есть два процесса Perl, которые взаимодействуют через System V IPC message Q в Ubuntu. Приемник какое-то время успешно работает, получает сообщения в функции опроса, подобные этой sub getCompleteRecord { while( msgrcv($q, $buff, $size, $msgType,...
avatar
oubaydos
28 июля 2021 в 11:21
46
1

Учитывает ли aws sqs атрибуты сообщений/системные атрибуты, когда включена дедупликация на основе контента?

Я работаю над проектом, используя aws sqs, я хочу использовать дедупликацию на основе содержимого для очередей FIFO, но я не смог найти в документации, рассматривает ли sqs атрибуты сообщений и системные атрибуты сообщений как "Content" или №
avatar
muazfaiz
27 июля 2021 в 10:31
790
1

Обработка нескольких сообщений SQS AWS с помощью одной лямбда-функции

Я настроил очередь SQS, в которую пути S3 отправляются каждый раз при загрузке файла. Итак, у меня есть настройка, в которой я буду получать 10 небольших файлов csv, и я хочу держать их в очереди SQS и запускать лямбда-выражение только один раз, когда все файлы будут...
avatar
Jagadesh
24 июля 2021 в 08:18
69
1

Сообщение ActiveMQ потребляется из очереди, занимает больше в среде Linux

Я создаю пример решения .net core в локальном и более крупном IIS, получая сообщения в очереди в течение секунды, но я развернут на сервере Linux, поэтому для обработки сообщений в очереди может потребоваться больше времени. Я не знаю, как это решить, пожалуйста,...
avatar
Abdul Majid Zargar
20 июля 2021 в 22:07
62
1

Отправлять push-уведомления водителям такси, но с задержкой для каждого цикла - php laravel

Итак, это простой диспетчерский сервер такси, встроенный в php Laravel, который отправляет push-уведомления соответствующим онлайн-водителям такси в радиусе действия клиента, используя цикл foreach: foreach ($Providers_active as $key => $Provider) { (new...
avatar
SoCal
20 июля 2021 в 21:46
22
2

Можно ли подписаться на тему сообщения в другой теме?

У меня есть подозрение, что ответ "нет", но я хочу проверить. Я видел похожий вопрос, в ответах на который нужно было пометить сообщения для автоматической переадресации, но это не то же самое. По сути, TopicA находится на уровне предприятия, а TopicB — на каком-то...
avatar
Fabian Klose
19 июля 2021 в 07:03
60
0

RabbitMQ обрабатывает только один тип за раз

Я использую RabbitMQ с несколькими очередями. В одном из них есть сообщения, которые имеют значение типа. Есть ли способ, как я могу сказать RabbitMQ не обрабатывать значение одного и того же типа параллельно? Или есть другая система обмена сообщениями, отвечающая этим...
avatar
blue sky
16 июля 2021 в 07:24
79
1

basicNack и basicReject в RabbitMQ

1.что означает массовое сообщение в basicNack Спецификация AMQP 0-9-1 определяет метод basic.reject, который позволяет клиентам отклонять отдельные доставленные сообщения, предписывая брокеру либо отбросить их, либо повторно поставить в очередь. К сожалению,...
avatar
Tary
16 июля 2021 в 06:41
78
0

Является ли очередь на основе файлов в каталоге (папке) хорошей идеей?

Недавно я столкнулся со следующей реализацией очереди. У нас есть папка Queue. Команды "insert_command_here".txt создаются в папке другим скриптом. Скрипт Queue бесконечно просматривает папку, и если файл command.txt найден, заголовок txt передается как команда...
avatar
Chavdar Emilov
14 июля 2021 в 11:44
90
1

Тест Karate API: TestRunner.testParallel: 15 Многопоточный доступ запрошен потоком Thread [pool-1-thread-1,3], но не разрешен для языков js

Тестирование API с помощью Karate: имитации и реализация очереди: Ошибка TestRunner.testParallel:15 Многопоточный доступ запрошен потоком Thread[pool-1-thread-1,3,main], но не разрешен для язык(и) js. создается при попытке использовать очередь с несколькими...
avatar
Daniel Qiao
12 июля 2021 в 11:11
664
1

Элегантно ждать, пока задание в очереди Redis не будет выполнено, без ожидания?

Я пытаюсь реализовать очередь Redis в текущей системе. job будет отправлено другому модулю, и он должен дождаться завершения задания и вернуть результат job.result, затем двигаться дальше: with Connection(redis_connection): job = job_queue.enqueue(worker_func,...
avatar
Kris-I
9 июля 2021 в 12:54
292
2

Невозможно прочитать сообщение очереди с помощью Masstransit

У меня есть очередь с сообщениями (создана с помощью Masstransit). Я попробовал этот фрагмент кода для получения сообщений (см. ниже). Я ожидал получить сообщения в строке Console.Out, но я так и не нажал на эту строку, и сообщения все еще находятся в очереди. Я не...
avatar
Chirag Shah
8 июля 2021 в 20:45
122
0

Отличие сервера IBM MQ с клиентскими подключениями от клиента IBM MQI MQ

У нас есть требование использовать MQi Client только для подключения к удаленной очереди. У меня есть вопрос: мы уже используем сервер MQ на стороне клиента для обработки других локальных/удаленных очередей. Для этого нового требования мы также можем добавить новую...