Вопросы по теме 'producer'
Издатель и подписчик ActiveMQ на нескольких языках (C ++ Java)
Я хочу использовать ActiveMQ в качестве брокера сообщений, обменивающегося данными между компонентом C ++ и компонентом Java в двух процессах. Например. Компонент C ++ является издателем, а компонент Java - подписчиком (может быть несколько...
2358 просмотров
schedule
25.03.2024
Система производителя/потребителя, использующая базу данных (MySql), возможно ли это?
Мне нужно использовать что-то для координации моей системы с несколькими потребителями/производителями, каждый из которых работает на разных машинах с разными операционными системами. Я исследовал использование MySql для этого, но это кажется...
3246 просмотров
schedule
15.06.2023
Методика быстрой и лучшей очереди производителя / потребителя BlockingCollection против параллельной очереди
Я использую Generic.Queue в C # 3.0 и Monitor.Enter, wait, exit for wait перед использованием очереди (подождите, пока элемент будет поставлен в очередь). Теперь я перехожу на C # 4.
Может ли кто-нибудь подсказать мне, какой из них быстрый и...
60647 просмотров
schedule
28.05.2024
Шаблон производитель/потребитель в Java
Я думаю, как реализовать паттерн производитель/потребитель в Java.
Предположим, что у меня есть 3 потока и список, содержащий задачи (скажем, около 5 задач). Каждый поток берет задачу из списка и выполняет ее одновременно. Мой текущий подход...
864 просмотров
schedule
27.05.2022
.NET Consumer/Producer (очередь)
Я новичок в .NET/Threads и хотел бы знать, может ли кто-нибудь помочь мне в этом упражнении. Мне нужно заменить комментарии, чтобы заставить его работать без блокировки потоков:
private Queue<int> queue;
public void ConsumeFunc(){...
516 просмотров
schedule
24.07.2023
многопоточный потребитель, код производителя C, не работает?
Я пытаюсь создать простой многопоточный потребитель/производитель, в котором несколько потоков чтения и записи читают из файла в буфер, а затем из буфера обратно в файл. Он должен быть потокобезопасным. однако он работает не так, как я ожидал. Он...
3143 просмотров
schedule
24.09.2022
Потоки производителя HornetQ застряли в состоянии WAITING
Мы используем HornetQ 2.2.5, и наша проблема заключается в том, что на стороне клиента (который отправляет сообщения в Q) все потоки-производители застряли в состоянии WAITING.
обратите внимание, что производитель находится на одной машине, а...
3233 просмотров
schedule
29.10.2022
Насколько размер сообщения влияет на отправку RabbitMQ Producer в Queue?
Итак, я учился, работая с RabbitMQ, и у меня настроены серверы и производитель; не заботясь о потребителе, пока я не исправлю это. Итак, я собираю свои строковые данные за 30 секунд, объединяю их и отправляю в виде 1 большой строки; средний размер...
911 просмотров
schedule
07.10.2022
Ошибка сегментации в многопоточной программе C-потребитель-производитель
В настоящее время я знакомлюсь с концепцией многопоточных программ и получил задание смоделировать фондовый рынок с использованием потоков и семафоров. Вот код:
#include <stdlib.h>
#include <stdio.h>
#include <unistd.h>
#include...
899 просмотров
schedule
05.01.2024
Переключатели флажков iAd Producer?
Я новичок в iAd Producer — мне действительно нужна замена Dashcode, поскольку Apple, похоже, отказалась от него. Но хотя кажется, что iAd Producer МОЖЕТ создавать виджеты iBooks Author, похоже, что ему не хватает нескольких основных объектов, а...
111 просмотров
schedule
10.05.2024
Взаимодействие с контейнером докеров kafka извне хоста докеров
Я создал контейнер докеров kafka и оркестровал его с помощью docker-compose.
Позвонив docker ps , я получаю следующий ввод:
CONTAINER ID IMAGE COMMAND CREATED STATUS PORTS...
19498 просмотров
schedule
02.07.2022
Лидер недоступен Kafka в Console Producer
Я пытаюсь использовать Kafka. Все настройки выполнены правильно, но когда я пытаюсь создать сообщение с консоли, я продолжаю получать следующую ошибку
WARN Error while fetching metadata with correlation id 39 :...
211129 просмотров
schedule
22.02.2022
Соединение Flume отказало брокеру Kafka
Я пытаюсь отправить сообщения из Apache Flume в мой экземпляр Apache Kafka. Когда я делаю все это локально через localhost, у меня нет проблем. Когда я пробую это с разных виртуальных машин на моей машине, я получаю сообщение об отказе в подключении...
853 просмотров
schedule
03.11.2022
WSO2 esb в качестве производителя jms с тайм-аутом передачи при сбое
Используя wso2 esb 4.9.0, я хотел бы, чтобы API-интерфейс HTTP отправлял сообщения в очередь JMS (activemq). Отправка jms должна использовать аварийное переключение, но если ни один из брокеров activemq недоступен, он должен выполнить...
271 просмотров
schedule
28.06.2023
Ошибка сегментации (дамп ядра) у производителя и потребителя с использованием семафора
Я изучаю системное программирование Linux, поэтому я просто попытался написать очень распространенную программу, которая является производителем и потребителем. Я использовал механизм семафора для реализации своего кода. К сожалению, у меня возникла...
532 просмотров
schedule
02.02.2024
Как обычно работают производители и потребители при отправке видеофайла?
Насколько я понимаю, когда я хочу отправить фильм (4 ГБ) брокеру Kafka, один продюсер отправит этот 4 ГБ байт видеофайла (сериализовал его) и отправит его брокеру Kafka и многим потребителям, которые хотят посмотреть этот фильм. будет использовать...
441 просмотров
schedule
04.04.2023
Как узнать, когда остановить параллельный foreach, когда потребитель также является производителем в С#
Я пытаюсь обработать некоторые элементы в BlockingCollection параллельно, используя Parallel.ForEach(). При обработке элемента он может сгенерировать еще 0-2 элемента для обработки. Количество элементов для обработки всегда в конечном итоге...
233 просмотров
schedule
03.09.2022
Конфигурация Kafka HTTP Topic Producer acks = all
Как установить acks = all для темы HTTP KAFKA? Я попытался отправить приведенный ниже JSON как acks: all Но он выдает с нераспознанным свойством. В шапке тоже пробовал ставить. Но в заголовке, когда я устанавливаю любое значение, например 0,1, all...
38 просмотров
schedule
03.12.2023
