Вопросы с меткой [rabbitmq]

RabbitMQ — платформа, реализующая систему обмена сообщениями между компонентами программной системы (Message Oriented Middleware) на основе протокола AMQP (Advanced Message Queuing Protocol).

Фильтрация
Сортировка
Метки
1 голос
0 ответов
30 показов

Golang: архитектура системы обработки задач по интервалам

У нас есть большой список сайтов и команд, которые нужно выполнить на этом сайте через заданный интервал в нашей базе данных. Таблица: ID, САЙТ, КОМАНДЫ (json: имя_команды => интервал минут) 1, ...
vostok.player's user avatar
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(...
Alex Black's user avatar
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 ...
Vladislav's user avatar
0 голосов
0 ответов
40 показов

Через некоторое время перестают доставляться сообщения через RabbitMQ подписчику

У нас есть очерез сообщений RabbitMQ, в которой создаются очереди для подписчиков, к которым они подписываются и обмениваются сообщениями. После создания канала сообщения доставляются как нужно, но ...
Daniel Protopopov's user avatar
0 голосов
1 ответ
31 показ

Php rabbitmq listener отправить echo в браузер

public function actionCallback(): void { $this->setHeaders(); self::listener(); } private function setHeaders(): void { set_time_limit(0); header('...
des1roer's user avatar
  • 2,676
0 голосов
0 ответов
46 показов

Запуск бота одновременно с rabbitMQ

Есть парсер, который мониторит скидки, и, если скидка появляется, отправляет сообщение через rabbit в скрипт бота. Пытаюсь сделать так, что бы запускалось только 2 скрипта - бот и парсер. При запуске ...
AlexandrOparinskiy's user avatar
0 голосов
0 ответов
50 показов

Как описать конфиг RabbitMQ с НЕСКОЛЬКИМИ очередями?

Только начал изучать RabbitMQ и не могу понять, как взаимодействовать сразу с НЕСКОЛЬКИМИ очередями. Пока я сделал только ОДНУ очередь. И через эту очередь проходят сообщения о регистрации ...
TupoScrip's user avatar
0 голосов
0 ответов
28 показов

Как подключиться к очереди брокера сообщений?

долго ломаю голову, прошу помогите. У меня есть адрес, логин(guest), пароль(guest) и название очереди, к которой мне нужно подключиться удаленно (мне прислали и нужно подключиться). Язык разработки - ...
Александр Вольф's user avatar
0 голосов
0 ответов
68 показов

Слабая документация драйвера RabbitMQ для Laravel

Всем привет. Учу очереди на ларке, использую https://github.com/vyuldashev/laravel-queue-rabbitmq драйвер, но документация в репозитории почти пустая. Подскажите плиз, где-то можно найти нормальную ...
Стас Бровин's user avatar
0 голосов
0 ответов
48 показов

Почему не работает RabbitMQ webinterface?

Установил через choco RabbitMQ, создал правила для UDP и TCP в брандмауэре Windows и в Kaspersky Total Security для порта 15672, на котором должен работать webinterface сервера RabbitMQ. Но адрес ...
Abejon's user avatar
  • 35
0 голосов
0 ответов
32 показа

Request запросы python

Могу ли я сохранить get, post запросы в какой либо вид со всеми заголовками и параметрами? Например строка. Чтобы он не выполнялся, а передать его в другой сервис, где он уже будет выполнен. Пытаюсь ...
LaiTkiLLa's user avatar
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",[[...
Vadim Bagriy's user avatar
0 голосов
0 ответов
107 показов

Не запускается rabbitmq-server

Starting broker... BOOT FAILED =========== Error during startup: {error, {rabbitmq_management_agent, {{shutdown, {...
Евгений's user avatar
-2 голоса
1 ответ
156 показов

Использование ClickHouse, Redis, RabbitMQ [закрыт]

Я новичок в некоторых вопросах. Какие есть примеры использования, указанных в заголовке вопроса технологий (ClickHouse, Redis, RabbitMQ)? Возможно ли их использование при создании сайтов? Приведите ...
wfamilyweb's user avatar
0 голосов
0 ответов
64 показа

Оптимизация приложения php

Имеется собственная разработка СРМ-системы для компании. И дело в том, что в приложении имеется база работников. Каждый из них делает расход и приход средств. И в самом приложении нужно считать эти ...
Павел Топский's user avatar
1 голос
1 ответ
79 показов

Считать заголовок сообщения RabbitMQ (C#)

Пишу обработчик сообщений на C#. В мою очередь RabbitMQ приходят сообщения с определенными заголовками. Мне необходимо считать один из них (X-App-Uid, выделен на рисунке). Каким способом это можно ...
witchgen's user avatar
0 голосов
1 ответ
73 показа

Spring Boot + RabbitMQ (JMS): Не работает ExceptionListener

У меня возникла проблема с тем, что не работает ExceptionListener при ошибке Rabbit JMS. Имеется вот такая настройка: ... private DefaultJmsListenerContainerFactory initContainerFactory(...
ulxanxv's user avatar
  • 937
0 голосов
0 ответов
50 показов

C#, RabbitMQ как обработанное сообщение отправить назад

Вот мой producer public class RabbitMQProducerService: IMessageSender { public void SendMessage<T>(T message) { var factory = new ConnectionFactory { HostName = &...
Vardan_Karapetian's user avatar
0 голосов
1 ответ
244 показа

Spring Boot + RabbitMQ: how to convert received object using convertSendAndReceive() method?

Как мне распарсить сообщение, используя convertSendAndReceive() метод? Вываливается NullPointerException из-за невозможности найти нужный для дессериализации класс в другом пакете. Пакеты сверху в ...
Митяй's user avatar
0 голосов
0 ответов
107 показов

RabbitMq как ограничить количество обработки очереди в день?

Только начал изучать RabbitMq, и мне нужно, ограничить количество выполнений в день до 200 как это можно сделать? У меня есть определённое событие, которые вызывается при обработке очереди, мне нужно ...
Fall Dimka's user avatar
0 голосов
1 ответ
25 показов

Can't execute method rabbitMq

У меня есть BackgroundService который слушает Queue. и отправляю в Queue сообшение : { "Name": "ASD" } но когда я запускаю приложение вызывается метод StartAsync , но StartAsync ...
Saba Koghuashvili's user avatar
-2 голоса
1 ответ
30 показов

Построить микросервисную архитектуру с обработкой промежуточных результатов [закрыт]

Задача звучит так: Есть три сервиса: интернет-магазин, склад интернет магазина и АПИ банка Покупатель делает заказ и получает счет для оплаты в банке Во время ожидания ответа от банка об успешной ...
евгений кунцевич's user avatar
0 голосов
1 ответ
378 показов

Yii2, Queue, RabbitMQ (amqp_interop). Не исполняются задания

Совсем не гуру в настройке очередей и не только их. Вообще с *nix системами сталкиваюсь к своему стыду крайне редко. Диагностика проблем вызывает много затруднений. Настраиваю очереди в проекте на ...
Vitaliy O's user avatar
0 голосов
1 ответ
99 показов

Возникает ошибка при повторном оправлении запроса. Без rabbitmq всё работает

Учусь программированию на nodejs, сейчас работаю над одним заданием, но возникает ошибка. Работаю над заданием не один, поэтому сам себе в очередь "Response" отправляю ответ. Суть приложения ...
bleedcloud's user avatar
1 голос
0 ответов
105 показов

Как получить результат работы потребителя при работе с очередями (через RabbitMQ)

Не совсем понимаю как получить результат работы потребителя при работе с очередями. Сразу начну с примера. Допустим у нас клиента сайта, использует сервис 1. Этот сервис 1 для своей работы должен ...
MyLoveIsSharks's user avatar
3 голоса
0 ответов
393 показа

Создание мультиплеерной игры c сервером на Asp.Net Core + SignalR

Разрабатываю онлайн игру в которой 8 игроков объединяются в отдельные комнаты. Идея в том, что игроку дается определенное время на совершенние каких-либо действий, доступных ему в определенной фазе ...
temiklis's user avatar
1 голос
1 ответ
115 показов

Что за странные очереди автоматически создаются в RabbitMQ?

Есть экосистема микросервисов, представляющих из себя ASP.NET апликейшены, работающие под IIS и общающиеся друг с другом по RabbitMQ с помощью библиотеки MassTransit. Недавно мы обнаружили, что при ...
Геннадий Круглов's user avatar
0 голосов
1 ответ
30 показов

Требует ли celery предварительного создания очередей

Требует ли celery обязательного предварительного создания очередей? Или можно запускать её и без них (для теста запуска сервиса).
vanorro228's user avatar
-1 голос
1 ответ
37 показов

Create internal exchange

Использую Nuget-пакет RabbitMQ.Client версии 6.2.2 Мне требуется подключится к amq.rabbitmq.event, созданному Event Exchange Plugin. Не смог найти программного функционала для подключения с параметром ...
Dejsving's user avatar
  • 1,282
0 голосов
1 ответ
173 показа

Очередь запросов (todo list) в Symfony через RabbitMQ

Linux. Хотел увидеть, статус моих сообщений, дошли ли они или не дошли. Для этого нужно открыть страницу RabbitMQ. Пишу в своей консоли symfony open:local:rabbitmq Но ответ таков: RabbitMQ ...
D-SK Ch's user avatar
  • 13
0 голосов
0 ответов
173 показа

Автоматически создавать очереди rabbitmq

Возьмем строчку из документации к Laravel: ProcessPodcast::dispatch($podcast)->onQueue('processing'); Тут создается задача ProcessPodcast, и помещается в очередь processing. Теперь представим, что ...
Total Pusher's user avatar
  • 6,212
1 голос
1 ответ
121 показ

Как изменить Content-Type в RabbitMQ (Spring JMS)

Всем привет! Проблема в следующем: У меня есть приложение, которое слушает определенную очередь в RabbitMQ. Когда в эту очередь поступает сообщение, то оно определенным образом обрабатывается. ...
ulxanxv's user avatar
  • 937
0 голосов
1 ответ
294 показа

Можно ли использовать классы из другого модуля?

У меня есть java проект, где есть несколько модулей(A и B) для передачи информации между ними я использую брокер сообщений RabbitMQ, так получается, что в модуле B мне нужен класс который находится в ...
Sergey's user avatar
  • 39
2 голоса
1 ответ
152 показа

Кто-нибудь может помочь разобраться с асинхронным взаимодействием между микросервисами (masstransit)?

Приведу сферический пример из головы, чтобы было нагляднее: Допустим у нас есть два микросервиса со своими базами данных. Первый служит для заполнения данных, второй для формирования из этих данных ...
Геннадий Круглов's user avatar
0 голосов
0 ответов
105 показов

Выбор MQ очереди

Необходимо выбрать MQ очередь или что-то, что можно использовать таким образом, в рамках следующих условий. Продюсеров и потребителей может быть десятки тысяч, при этом каждый из них свободно ...
Pavel's user avatar
  • 5,247
0 голосов
1 ответ
88 показов

RabbitMQ pika. Как побороть StreamLostError?

Использую библиотеку pika для взаимодействия с RabbitMQ очередями Для создания соединения использую: def get_connection(): credential = pika.PlainCredentials(LOGIN, PASS) parameters = pika....
Zimovik007's user avatar
0 голосов
1 ответ
472 показа

Как в rabbitmq накопить определённое кол-во строк и запустить эту пачку в callback?

На данный момент работает так - идёт запрос с множеством данных на сервис А, с него данные посылаются в очередь в rabbitmq, откуда читаются по одному сообщению сервисом В и пишутся в CLickHouse. Нужно ...
Alexey_Danilov's user avatar
0 голосов
1 ответ
142 показа

Rabbitmq. Можно ли создать очередь, которая подвязана к Direct Exchange, но при этом в нее будут попадать все сообщения независимо от routing key?

Суть проблемы, существует сервис на спринге, который закидывает сообщения в Direct exchnage без указания routing key. Есть очередь которая подвязана к этому обменнику и у нее тоже отсутвcует routing ...
SorryForAsking's user avatar
0 голосов
0 ответов
181 показ

Обязательно ли в rabbitmq нужно закрывать соединение?

Только начал знакомиться с rabbitmq, посмотрел примеры с офф сайта Наконец, закрываем соединение и выходим setTimeout(function() { connection.close(); process.exit(0) }, 500); мой пример ...
Smoke's user avatar
  • 78
2 голоса
1 ответ
67 показов

Тестирование микросервиса, работающего с бинарными данными

Необходимо написать интеграционные и модульные тесты для микросервиса на NodeJS. Сервис слушает очередь rabbitmq, получает ссылку на видео файл в удаленной файловой системе, перекодирует его в ...
lizaburther's user avatar
2 голоса
1 ответ
40 показов

C# RabbitMQ. Событие успешного авто восстановления коннекта

Использую RabbitMQ.Client, и тестирую функцию AutomaticRecoveryEnabled. Все хорошо работает при проблемах с Tcp коннектом или при перезапуске RabbitMQ. Хорошо бы иметь событие на отключение от ...
Aldmi's user avatar
  • 1,925
2 голоса
0 ответов
103 показа

C# EasyNetQ. Восстановление работы после рестарта Docker с RabbitMq

начал разбираться с библиотекой для работы с очередью сообщений RabbitMq, которая называется EasyNetQ. Особенность EasyNetQ в том, что очередь создается Подписчиком при активации подписки. Если ...
Aldmi's user avatar
  • 1,925
1 голос
1 ответ
875 показов

RabbitMQ прослушивание одной очереди с разных консюмеров

Есть продюсер: @Configuration public class ToDoConfig { @Bean public SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory(ConnectionFactory connectionFactory) { ...
Alex Mur's user avatar
  • 187
1 голос
0 ответов
166 показов

Как проверить работоспособность брокера RabbitMQ?

Установил RabbitMQ. Как проверить его работоспособность? Использовал в купе с celery. Но сейчас отказывается работать. Пишет, что удаленный сервер отклонил ответ. Сначала все было почти нормально, ...
Михаил Болеев's user avatar
0 голосов
0 ответов
86 показов

Нет соединения с сервером. consumer: Cannot connect to amqp://guest:**@127.0.0.1:5672//: [WinError 10061]

Следовал инструкции по подключению celery здесь. Сначала все работало, задачи попадали в очередь, но не выполнялись. Переустановил celery (более современную версию) - все перестало работать. Пробовал ...
Михаил Болеев's user avatar
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"...
Максим's user avatar
0 голосов
0 ответов
68 показов

RabbitMQ записать данные в БД

_consumers.SubscribeAsync(Do); это строка вызывает же function Do ? и передат аргумент Account да? или я ошибаюсь? в function Do я вызываю method который должен зарисать эти данные в базу но не пишет. ...
Teona Nadiradze's user avatar
1 голос
0 ответов
650 показов

Подтверждение обработки сообщения из очереди RabbitMQ

Организую для взаимосвязи приложений очередь. Использую библиотеку aio-pika для того, чтобы получать сообщения. Проблема: Сообщения успешно получаю и обрабатываю их, НО по средствам мониторинга вижу, ...
AlTheOne's user avatar
  • 2,042
0 голосов
1 ответ
299 показов

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

Имеется puppeteer сервер который выполняет авторизацию на сервере, он служит в качестве удобной авторизации над сервисом, предлагая возможность в качестве мультиаккаунтности. Проще говоря, свой сервис,...
MoloF's user avatar
  • 4,415
0 голосов
1 ответ
351 показ

Как отправить сообщение всем слушателям RabbitMQ, Spring boot

Отправка: @Service public class ProducerImp implements Producer { @Autowired private AmqpTemplate amqpTemplate; @Value("${jsa.rabbitmq.exchange}") private String exchange; ...
SerikStartAndroid's user avatar