Вопросы с меткой [rabbitmq]
RabbitMQ — платформа, реализующая систему обмена сообщениями между компонентами программной системы (Message Oriented Middleware) на основе протокола AMQP (Advanced Message Queuing Protocol).
144
вопроса
1
голос
0
ответов
30
показов
Golang: архитектура системы обработки задач по интервалам
У нас есть большой список сайтов и команд, которые нужно выполнить на этом сайте через заданный интервал в нашей базе данных.
Таблица: ID, САЙТ, КОМАНДЫ (json: имя_команды => интервал минут)
1, ...
1
голос
1
ответ
27
показов
Symfony 6.2 php-amqplib/rabbitmq-bundle Producer Cannot autowire service
Есть проект на symfony v6.2 с установленным пакетом php-amqplib/rabbitmq-bundle. В нём настроен один Producer (PushToQueue) и один Consumer (Send). Когда я пытаюсь добавить ещё одну пару Producer(...
0
голосов
0
ответов
20
показов
Не могу создать пользователя в rabbitmq
Вот команда:
D:\rabbit\rabbitmq_server-3.11.13\sbin>rabbitmqctl add_user test test
Stack trace:
(ArgumentError) argument error
(stdlib 4.3) io_lib.erl:187: :io_lib.format(' * effective user\'s ...
0
голосов
0
ответов
40
показов
Через некоторое время перестают доставляться сообщения через RabbitMQ подписчику
У нас есть очерез сообщений RabbitMQ, в которой создаются очереди для подписчиков, к которым они подписываются и обмениваются сообщениями.
После создания канала сообщения доставляются как нужно, но ...
0
голосов
1
ответ
31
показ
Php rabbitmq listener отправить echo в браузер
public function actionCallback(): void
{
$this->setHeaders();
self::listener();
}
private function setHeaders(): void
{
set_time_limit(0);
header('...
0
голосов
0
ответов
46
показов
Запуск бота одновременно с rabbitMQ
Есть парсер, который мониторит скидки, и, если скидка появляется, отправляет сообщение через rabbit в скрипт бота.
Пытаюсь сделать так, что бы запускалось только 2 скрипта - бот и парсер.
При запуске ...
0
голосов
0
ответов
50
показов
Как описать конфиг RabbitMQ с НЕСКОЛЬКИМИ очередями?
Только начал изучать RabbitMQ и не могу понять, как взаимодействовать сразу с НЕСКОЛЬКИМИ очередями.
Пока я сделал только ОДНУ очередь. И через эту очередь проходят сообщения о регистрации ...
0
голосов
0
ответов
28
показов
Как подключиться к очереди брокера сообщений?
долго ломаю голову, прошу помогите.
У меня есть адрес, логин(guest), пароль(guest) и название очереди, к которой мне нужно подключиться удаленно (мне прислали и нужно подключиться). Язык разработки - ...
0
голосов
0
ответов
68
показов
Слабая документация драйвера RabbitMQ для Laravel
Всем привет. Учу очереди на ларке, использую https://github.com/vyuldashev/laravel-queue-rabbitmq драйвер, но документация в репозитории почти пустая. Подскажите плиз, где-то можно найти нормальную ...
0
голосов
0
ответов
48
показов
Почему не работает RabbitMQ webinterface?
Установил через choco RabbitMQ, создал правила для UDP и TCP в брандмауэре Windows и в Kaspersky Total Security для порта 15672, на котором должен работать webinterface сервера RabbitMQ.
Но адрес ...
0
голосов
0
ответов
32
показа
Request запросы python
Могу ли я сохранить get, post запросы в какой либо вид со всеми заголовками и параметрами? Например строка.
Чтобы он не выполнялся, а передать его в другой сервис, где он уже будет выполнен.
Пытаюсь ...
0
голосов
0
ответов
52
показа
ERROR: node with name "rabbit" is already running on host "DESKTOP-AL5T0M3"
Я пытаюсь запустить запустить команду
rabbitmq-server
и он мне выдает такую ошибку:
2022-10-02T17:48:19.962000+03:00 warning: FORMATTER CRASH: {"Using
RABBITMQ_ADVANCED_CONFIG_FILE: ~s",[[...
0
голосов
0
ответов
107
показов
Не запускается rabbitmq-server
Starting broker...
BOOT FAILED
===========
Error during startup: {error,
{rabbitmq_management_agent,
{{shutdown,
{...
-2
голоса
1
ответ
156
показов
Использование ClickHouse, Redis, RabbitMQ [закрыт]
Я новичок в некоторых вопросах. Какие есть примеры использования, указанных в заголовке вопроса технологий (ClickHouse, Redis, RabbitMQ)? Возможно ли их использование при создании сайтов? Приведите ...
0
голосов
0
ответов
64
показа
Оптимизация приложения php
Имеется собственная разработка СРМ-системы для компании. И дело в том, что в приложении имеется база работников. Каждый из них делает расход и приход средств.
И в самом приложении нужно считать эти ...
1
голос
1
ответ
79
показов
Считать заголовок сообщения RabbitMQ (C#)
Пишу обработчик сообщений на C#. В мою очередь RabbitMQ приходят сообщения с определенными заголовками. Мне необходимо считать один из них (X-App-Uid, выделен на рисунке). Каким способом это можно ...
0
голосов
1
ответ
73
показа
Spring Boot + RabbitMQ (JMS): Не работает ExceptionListener
У меня возникла проблема с тем, что не работает ExceptionListener при ошибке Rabbit JMS.
Имеется вот такая настройка:
...
private DefaultJmsListenerContainerFactory initContainerFactory(...
0
голосов
0
ответов
50
показов
C#, RabbitMQ как обработанное сообщение отправить назад
Вот мой producer
public class RabbitMQProducerService: IMessageSender
{
public void SendMessage<T>(T message)
{
var factory = new ConnectionFactory { HostName = &...
0
голосов
1
ответ
244
показа
Spring Boot + RabbitMQ: how to convert received object using convertSendAndReceive() method?
Как мне распарсить сообщение, используя convertSendAndReceive() метод? Вываливается NullPointerException из-за невозможности найти нужный для дессериализации класс в другом пакете. Пакеты сверху в ...
0
голосов
0
ответов
107
показов
RabbitMq как ограничить количество обработки очереди в день?
Только начал изучать RabbitMq, и мне нужно, ограничить количество выполнений в день до 200 как это можно сделать?
У меня есть определённое событие, которые вызывается при обработке очереди, мне нужно ...
0
голосов
1
ответ
25
показов
Can't execute method rabbitMq
У меня есть BackgroundService который слушает Queue.
и отправляю в Queue сообшение :
{
"Name": "ASD"
}
но когда я запускаю приложение вызывается метод StartAsync , но StartAsync ...
-2
голоса
1
ответ
30
показов
Построить микросервисную архитектуру с обработкой промежуточных результатов [закрыт]
Задача звучит так:
Есть три сервиса: интернет-магазин, склад интернет магазина и АПИ банка
Покупатель делает заказ и получает счет для оплаты в банке
Во время ожидания ответа от банка об успешной ...
0
голосов
1
ответ
378
показов
Yii2, Queue, RabbitMQ (amqp_interop). Не исполняются задания
Совсем не гуру в настройке очередей и не только их. Вообще с *nix системами сталкиваюсь к своему стыду крайне редко. Диагностика проблем вызывает много затруднений.
Настраиваю очереди в проекте на ...
0
голосов
1
ответ
99
показов
Возникает ошибка при повторном оправлении запроса. Без rabbitmq всё работает
Учусь программированию на nodejs, сейчас работаю над одним заданием, но возникает ошибка.
Работаю над заданием не один, поэтому сам себе в очередь "Response" отправляю ответ.
Суть приложения ...
1
голос
0
ответов
105
показов
Как получить результат работы потребителя при работе с очередями (через RabbitMQ)
Не совсем понимаю как получить результат работы потребителя при работе с очередями.
Сразу начну с примера. Допустим у нас клиента сайта, использует сервис 1. Этот сервис 1 для своей работы должен ...
3
голоса
0
ответов
393
показа
Создание мультиплеерной игры c сервером на Asp.Net Core + SignalR
Разрабатываю онлайн игру в которой 8 игроков объединяются в отдельные комнаты.
Идея в том, что игроку дается определенное время на совершенние каких-либо действий, доступных ему в определенной фазе ...
1
голос
1
ответ
115
показов
Что за странные очереди автоматически создаются в RabbitMQ?
Есть экосистема микросервисов, представляющих из себя ASP.NET апликейшены, работающие под IIS и общающиеся друг с другом по RabbitMQ с помощью библиотеки MassTransit. Недавно мы обнаружили, что при ...
0
голосов
1
ответ
30
показов
Требует ли celery предварительного создания очередей
Требует ли celery обязательного предварительного создания очередей?
Или можно запускать её и без них (для теста запуска сервиса).
-1
голос
1
ответ
37
показов
Create internal exchange
Использую Nuget-пакет RabbitMQ.Client версии 6.2.2
Мне требуется подключится к amq.rabbitmq.event, созданному Event Exchange Plugin.
Не смог найти программного функционала для подключения с параметром ...
0
голосов
1
ответ
173
показа
Очередь запросов (todo list) в Symfony через RabbitMQ
Linux. Хотел увидеть, статус моих сообщений, дошли ли они или не дошли. Для этого нужно открыть страницу RabbitMQ. Пишу в своей консоли
symfony open:local:rabbitmq
Но ответ таков: RabbitMQ ...
0
голосов
0
ответов
173
показа
Автоматически создавать очереди rabbitmq
Возьмем строчку из документации к Laravel:
ProcessPodcast::dispatch($podcast)->onQueue('processing');
Тут создается задача ProcessPodcast, и помещается в очередь processing. Теперь представим, что ...
1
голос
1
ответ
121
показ
Как изменить Content-Type в RabbitMQ (Spring JMS)
Всем привет! Проблема в следующем:
У меня есть приложение, которое слушает определенную очередь в RabbitMQ. Когда в эту очередь поступает сообщение, то оно определенным образом обрабатывается. ...
0
голосов
1
ответ
294
показа
Можно ли использовать классы из другого модуля?
У меня есть java проект, где есть несколько модулей(A и B) для передачи информации между ними я использую брокер сообщений RabbitMQ, так получается, что в модуле B мне нужен класс который находится в ...
2
голоса
1
ответ
152
показа
Кто-нибудь может помочь разобраться с асинхронным взаимодействием между микросервисами (masstransit)?
Приведу сферический пример из головы, чтобы было нагляднее:
Допустим у нас есть два микросервиса со своими базами данных. Первый служит для заполнения данных, второй для формирования из этих данных ...
0
голосов
0
ответов
105
показов
Выбор MQ очереди
Необходимо выбрать MQ очередь или что-то, что можно использовать таким образом, в рамках следующих условий.
Продюсеров и потребителей может быть десятки тысяч, при этом каждый из них свободно ...
0
голосов
1
ответ
88
показов
RabbitMQ pika. Как побороть StreamLostError?
Использую библиотеку pika для взаимодействия с RabbitMQ очередями
Для создания соединения использую:
def get_connection():
credential = pika.PlainCredentials(LOGIN, PASS)
parameters = pika....
0
голосов
1
ответ
472
показа
Как в rabbitmq накопить определённое кол-во строк и запустить эту пачку в callback?
На данный момент работает так - идёт запрос с множеством данных на сервис А, с него данные посылаются в очередь в rabbitmq, откуда читаются по одному сообщению сервисом В и пишутся в CLickHouse. Нужно ...
0
голосов
1
ответ
142
показа
Rabbitmq. Можно ли создать очередь, которая подвязана к Direct Exchange, но при этом в нее будут попадать все сообщения независимо от routing key?
Суть проблемы, существует сервис на спринге, который закидывает сообщения в Direct exchnage без указания routing key. Есть очередь которая подвязана к этому обменнику и у нее тоже отсутвcует routing ...
0
голосов
0
ответов
181
показ
Обязательно ли в rabbitmq нужно закрывать соединение?
Только начал знакомиться с rabbitmq, посмотрел примеры с офф сайта
Наконец, закрываем соединение и выходим
setTimeout(function() {
connection.close();
process.exit(0)
}, 500);
мой пример ...
2
голоса
1
ответ
67
показов
Тестирование микросервиса, работающего с бинарными данными
Необходимо написать интеграционные и модульные тесты для микросервиса на NodeJS.
Сервис слушает очередь rabbitmq, получает ссылку на видео файл в удаленной файловой системе, перекодирует его в ...
2
голоса
1
ответ
40
показов
C# RabbitMQ. Событие успешного авто восстановления коннекта
Использую RabbitMQ.Client, и тестирую функцию AutomaticRecoveryEnabled.
Все хорошо работает при проблемах с Tcp коннектом или при перезапуске RabbitMQ.
Хорошо бы иметь событие на отключение от ...
2
голоса
0
ответов
103
показа
C# EasyNetQ. Восстановление работы после рестарта Docker с RabbitMq
начал разбираться с библиотекой для работы с очередью сообщений RabbitMq, которая называется EasyNetQ.
Особенность EasyNetQ в том, что очередь создается Подписчиком при активации подписки.
Если ...
1
голос
1
ответ
875
показов
RabbitMQ прослушивание одной очереди с разных консюмеров
Есть продюсер:
@Configuration
public class ToDoConfig {
@Bean
public SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory(ConnectionFactory connectionFactory) {
...
1
голос
0
ответов
166
показов
Как проверить работоспособность брокера RabbitMQ?
Установил RabbitMQ. Как проверить его работоспособность? Использовал в купе с celery. Но сейчас отказывается работать. Пишет, что удаленный сервер отклонил ответ. Сначала все было почти нормально, ...
0
голосов
0
ответов
86
показов
Нет соединения с сервером. consumer: Cannot connect to amqp://guest:**@127.0.0.1:5672//: [WinError 10061]
Следовал инструкции по подключению celery здесь. Сначала все работало, задачи попадали в очередь, но не выполнялись. Переустановил celery (более современную версию) - все перестало работать. Пробовал ...
1
голос
0
ответов
103
показа
Запуск фоновых задач через dramatiq
@dramatiq.actor(store_results=True)
def count_words(url):
try:
response = requests.get(url)
count = len(response.text.split(" "))
print(f"...
0
голосов
0
ответов
68
показов
RabbitMQ записать данные в БД
_consumers.SubscribeAsync(Do); это строка вызывает же function Do ? и передат аргумент Account да? или я ошибаюсь?
в function Do я вызываю method который должен зарисать эти данные в базу но не пишет.
...
1
голос
0
ответов
650
показов
Подтверждение обработки сообщения из очереди RabbitMQ
Организую для взаимосвязи приложений очередь.
Использую библиотеку aio-pika для того, чтобы получать сообщения.
Проблема:
Сообщения успешно получаю и обрабатываю их, НО по средствам мониторинга вижу, ...
0
голосов
1
ответ
299
показов
Как правильно реализовать систему очередей для асинхронного подтверждения авторизации, путем ожидания кода
Имеется puppeteer сервер который выполняет авторизацию на сервере, он служит в качестве удобной авторизации над сервисом, предлагая возможность в качестве мультиаккаунтности. Проще говоря, свой сервис,...
0
голосов
1
ответ
351
показ
Как отправить сообщение всем слушателям RabbitMQ, Spring boot
Отправка:
@Service
public class ProducerImp implements Producer {
@Autowired
private AmqpTemplate amqpTemplate;
@Value("${jsa.rabbitmq.exchange}")
private String exchange;
...