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

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

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

Как правильно поставить задачу в очередь и по завершению уведомить пользователя?

Есть непонимание как поставить задачу на исполнение в очередь и потом уведомить конкретного пользователя о завершении. Может быть дело в приницпе в непонимании работы очередей. Например задача: ...
4 голоса
0 ответов
80 показов
+50

MassTransit + RabbitMQ как настроить обменники?

Пытаюсь публиковать все сообщения в один обменник, которые будут раскидываться дальше в очереди по routing key, но почему-то создаются обменник с названием очереди. Пытаюсь сделать как-то так: cfg....
0 голосов
0 ответов
16 показов

Как в консольном asp.net core 6 приложении получить из DI нужную зависимость и выполнить с ней код?

Есть внешняя шина (RabbitMQ) в которую некий внешний сервис паблишит команды. У меня есть консольное asp.net core 6 приложение (в дальнейшем будет завернуто в докер), в котором через внедрение ...
0 голосов
0 ответов
22 показа

Postgres не успевает записывать данные из RabbitMQ

Есть очередь в rabbit, которую слушает consumer, написанный на python: def generate_callback(table_name, count_columns): def callback(ch, method, properties, body): body_json = json.loads(...
1 голос
0 ответов
84 показа

Вопрос по построению архитектуры с 4 сервисами и rabbitmq

Стоит задача мне как backend-разработчику по работе улучшить архитектуру работы 4 сервисов, добавить своего рода отказоустойчивость и сохранение результатов при сбое приложений с восстановлением ранее ...
0 голосов
0 ответов
47 показов

Проблема TLS1.2 подключения RabbitMQ

Ошибка c TLS 1.2: trace-log: 2024-01-29 00:00:21,152 [53] INFO - Error creating read connection, EndPoint: amqp://rabbit-t4.isb:5671, SSL enabled: True, SSL Version: Tls12, Reason: None of the ...
1 голос
1 ответ
188 показов

Повторная обработка сообщений в RabbitMQ, Golang

Смотрю пример работы с rabbitMQ на Go. Код из примера На основе этого примера написал свой код. Я беру сообщения из очереди и отправляю их на сторонний сервис для обработки. Если не произошло ошибок, ...
0 голосов
0 ответов
47 показов

Настроить Dead Letter Queue в Rabbit MQ

есть два микросервиса МС1 и МС2, которые общаются через Rabbit MQ. В МС2 в application.properties добавил настройки: spring.cloud.function.definition=messageConsumer;messageProduce spring.cloud.stream....
0 голосов
1 ответ
34 показа

Способы отслеживания недоступности микросервисов

есть несколько микросервисов, которые написаны на Spring Boot, а для общения используется Rabbit MQ. Общаются они через поставщика и потребителя (функциональные интерфейсы Supplier, Consumer). ...
0 голосов
0 ответов
26 показов

Типы передаваемых сообщений в микросервисах

В реальных приложениях десятки и сотни микросервисов, которые передают друг другу сообщения разных форматов (текст, число, какие-то объекты, файлы и т.д.).. Причем один микросервис например может ...
0 голосов
1 ответ
218 показов

Как интегрировать RabbitMQ с Wordpress? (php-amqplib)

На сайте нужно реализовать к примеру какие-то real-time odds, с удаленного сервера будут приходить данные, которые мне нужно отобразить на вп-сайте. На сервисе это реализовано на RabbitMQ, читал доки ...
1 голос
0 ответов
54 показа

Почему Celery регистрирует задачи, но не выполняет их?

Код предельно простой: tasks.py: from celery import Celery, shared_task app=Celery('tasks', broker='amqp://user:[email protected]:5672/vhost', backend='redis://localhost:6379/0') @shared_task def add(...
0 голосов
0 ответов
45 показов

Чат Бот Битрикс 24 - RabbitMQ - Телеграм бот

В общем, бьюсь уже над задачей не 1 неделю. Что имеем Телеграмм бот на Питоне Реббит Чат бота битрикса (чистый php) Вопрос в следующем, имеется ли возможность чтобы данный бот (В Битриксе) передавал ...
0 голосов
1 ответ
90 показов

Как в symfony transport динамически создавать очереди?

Как сделать так чтобы каждый запрос создавал отдельную очередь? Сейчас у меня очередь прописана напрямую вот так: MESSENGER_TRANSPORT_DSN=amqp://guest:guest@rabbitmq:5672/%2f/meta Мне нужно чтобы ...
2 голоса
1 ответ
261 показ

RabbitMQ, как построить систему?

Сейчас есть монолит, в котором в Quartz.NET крутятся задачи, которые хотелось бы вынести в отдельные микросервисы. Например возьмем сущность MeteringDevice (какой-то прибор измерения). Для него в ...
1 голос
0 ответов
82 показа

Celery не находит модели при выполнении задачи

Пишу Api для телефонной рассылки, мой код принимает заявки на рассылку и когда настает время начала рассылки он отправляет запрос на внешнюю Api, которая в свою очередь отправляет сами сообщения. Если ...
0 голосов
0 ответов
55 показов

ResultMissing при выполнении задачи Dramatiq

Для своего проекта (бэкенд интернет-магазина на Django) я реализовал имитацию оплаты заказа. Для практики решил использовать Dramatiq, чтобы потренироваться с асинхронным выполнением задач. Вот мой ...
1 голос
0 ответов
78 показов

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

У нас есть большой список сайтов и команд, которые нужно выполнить на этом сайте через заданный интервал в нашей базе данных. Таблица: ID, САЙТ, КОМАНДЫ (json: имя_команды => интервал минут) 1, ...
1 голос
1 ответ
213 показов

Symfony 6.2 php-amqplib/rabbitmq-bundle Producer Cannot autowire service

Есть проект на symfony v6.2 с установленным пакетом php-amqplib/rabbitmq-bundle. В нём настроен один Producer (PushToQueue) и один Consumer (Send). Когда я пытаюсь добавить ещё одну пару Producer(...
6 голосов
3 ответа
8k показов

Как зайти на страницу RabbitMQ?

Установил RabbitMQ. Проверил - все работает. Сообщения отправляются и принимаются. Но вот не могу зайти на страницу сервера RabbitMQ. Ввожу в браузер http://0.0.0.0:15672/ и ничего. Браузер говорит, ...
0 голосов
0 ответов
145 показов

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

У нас есть очерез сообщений RabbitMQ, в которой создаются очереди для подписчиков, к которым они подписываются и обмениваются сообщениями. После создания канала сообщения доставляются как нужно, но ...
5 голосов
0 ответов
245 показов

Как гарантировать очередность обработки сообщений из rabbitmq

Есть сервис A, который при изменении сущностей отправляет их через RabbitMQ в сервис B. Сервис B развернут на 4х нодах. Задача - гарантированно обрабатывать очередность изменений сущности с одинаковым ...
0 голосов
1 ответ
46 показов

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

public function actionCallback(): void { $this->setHeaders(); self::listener(); } private function setHeaders(): void { set_time_limit(0); header('...
0 голосов
0 ответов
52 показа

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

долго ломаю голову, прошу помогите. У меня есть адрес, логин(guest), пароль(guest) и название очереди, к которой мне нужно подключиться удаленно (мне прислали и нужно подключиться). Язык разработки - ...
0 голосов
0 ответов
36 показов

Request запросы python

Могу ли я сохранить get, post запросы в какой либо вид со всеми заголовками и параметрами? Например строка. Чтобы он не выполнялся, а передать его в другой сервис, где он уже будет выполнен. Пытаюсь ...
0 голосов
0 ответов
172 показа

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

Starting broker... BOOT FAILED =========== Error during startup: {error, {rabbitmq_management_agent, {{shutdown, {...
-2 голоса
1 ответ
343 показа

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

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

Я не понимаю как настроить celery и rabbitmq на Windows

Сейчас покажу код, делаю на ubuntu все то же самое, что и на Windows Windows код не исполняет, не отправляет email, с ubuntu этот же проект работает прекрасно.Как заставить работать celery на windows? ...
2 голоса
1 ответ
100 показов

SignalR клиент не получает сообщения через MassTransit

У меня есть проблема с отправкой сообщений клиентам SignalR через MassTransit. Всё сделано согласно документации. Есть Сервис А, который генерирует событие. Данное событие через MassTransit ловит ...
0 голосов
0 ответов
76 показов

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

Имеется собственная разработка СРМ-системы для компании. И дело в том, что в приложении имеется база работников. Каждый из них делает расход и приход средств. И в самом приложении нужно считать эти ...
2 голоса
1 ответ
190 показов

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

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

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

У меня возникла проблема с тем, что не работает ExceptionListener при ошибке Rabbit JMS. Имеется вот такая настройка: ... private DefaultJmsListenerContainerFactory initContainerFactory(...
0 голосов
0 ответов
92 показа

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

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

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

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

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

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

Дублирование сообщений при падении RabbitMQ или воркера

Имеется схема RPC в которой приложение на Java (будем называть его TaskManager'ом) отправляет задания в очередь RabbitMQ (очередь A) к приложениям на PHP (назовем их Worker'ами). После выполнения ...
0 голосов
1 ответ
644 показа

Неверно задано имя папки. Синтаксическая ошибка в имени файла, имени папки или метке тома. Ошибка при запуске RabbitMQ

Попытался настроить RabbitMQ пару дней назад. Следовал инструкциям с сайта: https://thewebland.net/development/devops/ustanovka-rabbitmq-na-windows/. Вроде как всё работало и я сделал всё как хотел. ...
0 голосов
1 ответ
33 показа

Can't execute method rabbitMq

У меня есть BackgroundService который слушает Queue. и отправляю в Queue сообшение : { "Name": "ASD" } но когда я запускаю приложение вызывается метод StartAsync , но StartAsync ...
0 голосов
1 ответ
123 показа

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

Учусь программированию на nodejs, сейчас работаю над одним заданием, но возникает ошибка. Работаю над заданием не один, поэтому сам себе в очередь "Response" отправляю ответ. Суть приложения ...
-2 голоса
1 ответ
35 показов

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

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

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

Совсем не гуру в настройке очередей и не только их. Вообще с *nix системами сталкиваюсь к своему стыду крайне редко. Диагностика проблем вызывает много затруднений. Настраиваю очереди в проекте на ...
3 голоса
0 ответов
531 показ

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

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

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

Не совсем понимаю как получить результат работы потребителя при работе с очередями. Сразу начну с примера. Допустим у нас клиента сайта, использует сервис 1. Этот сервис 1 для своей работы должен ...
1 голос
1 ответ
173 показа

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

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

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

Linux. Хотел увидеть, статус моих сообщений, дошли ли они или не дошли. Для этого нужно открыть страницу RabbitMQ. Пишу в своей консоли symfony open:local:rabbitmq Но ответ таков: RabbitMQ ...
0 голосов
1 ответ
44 показа

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

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

Create internal exchange

Использую Nuget-пакет RabbitMQ.Client версии 6.2.2 Мне требуется подключится к amq.rabbitmq.event, созданному Event Exchange Plugin. Не смог найти программного функционала для подключения с параметром ...
0 голосов
3 ответа
196 показов

Универсальный JMS клиент

Я пишу приложение spring-boot, которое должно получать и отправлять JMS-сообщения. Адрес, порт, логин и пароль для подключения к брокеру читаются из конфигов. Изначально я не знаю, с каким типом ...
0 голосов
0 ответов
271 показ

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

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

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

Всем привет! Проблема в следующем: У меня есть приложение, которое слушает определенную очередь в RabbitMQ. Когда в эту очередь поступает сообщение, то оно определенным образом обрабатывается. ...