Вопросы с меткой [rabbitmq]
RabbitMQ — платформа, реализующая систему обмена сообщениями между компонентами программной системы (Message Oriented Middleware) на основе протокола AMQP (Advanced Message Queuing Protocol).
140
вопросов
0
голосов
0
ответов
19
показов
Как парсить объект тела сообщения в RabbitMQ & Spring Boot
Как обмениваться объектами в разных приложениях? При попытке распарсить объект требует указать путь до класса для дессериализации JSON. Где нужно это указать?
Лог ошибки:
2022-05-18 18:47:21.120 ERROR ...
0
голосов
0
ответов
13
показов
Как поймать ACK на aio_pika?
Хочу отследить доставку сообщения до консумера. Поменять статус задачи когда он заберет её из очереди.
0
голосов
0
ответов
23
показа
Перестали приходить сообщения в RabbitMQ
Всем привет,
У меня есть GoLang код на клиенте который шлёт в очередь сообщение для получения данных:
ch, errCreateChannel := structs.RabbitMQ.Channel()
if errCreateChannel != nil {
return symbols,...
0
голосов
0
ответов
22
показа
RabbitMq как ограничить количество обработки очереди в день?
Только начал изучать RabbitMq, и мне нужно, ограничить количество выполнений в день до 200 как это можно сделать?
У меня есть определённое событие, которые вызывается при обработке очереди, мне нужно ...
0
голосов
0
ответов
20
показов
rabbitMq добавить запись в List
есть Queue в котором нахдиться такой json
{
"created": "B8",
"approved": "12",
"fields": {
"14": "Group",
...
0
голосов
1
ответ
24
показа
Can't execute method rabbitMq
У меня есть BackgroundService который слушает Queue.
и отправляю в Queue сообшение :
{
"Name": "ASD"
}
но когда я запускаю приложение вызывается метод StartAsync , но StartAsync ...
-2
голоса
1
ответ
20
показов
Построить микросервисную архитектуру с обработкой промежуточных результатов [закрыт]
Задача звучит так:
Есть три сервиса: интернет-магазин, склад интернет магазина и АПИ банка
Покупатель делает заказ и получает счет для оплаты в банке
Во время ожидания ответа от банка об успешной ...
0
голосов
1
ответ
60
показов
Yii2, Queue, RabbitMQ (amqp_interop). Не исполняются задания
Совсем не гуру в настройке очередей и не только их. Вообще с *nix системами сталкиваюсь к своему стыду крайне редко. Диагностика проблем вызывает много затруднений.
Настраиваю очереди в проекте на ...
0
голосов
1
ответ
52
показа
Возникает ошибка при повторном оправлении запроса. Без rabbitmq всё работает
Учусь программированию на nodejs, сейчас работаю над одним заданием, но возникает ошибка.
Работаю над заданием не один, поэтому сам себе в очередь "Response" отправляю ответ.
Суть приложения ...
1
голос
0
ответов
18
показов
Как получить результат работы потребителя при работе с очередями (через RabbitMQ)
Не совсем понимаю как получить результат работы потребителя при работе с очередями.
Сразу начну с примера. Допустим у нас клиента сайта, использует сервис 1. Этот сервис 1 для своей работы должен ...
3
голоса
0
ответов
175
показов
Создание мультиплеерной игры c сервером на Asp.Net Core + SignalR
Разрабатываю онлайн игру в которой 8 игроков объединяются в отдельные комнаты.
Идея в том, что игроку дается определенное время на совершенние каких-либо действий, доступных ему в определенной фазе ...
1
голос
1
ответ
58
показов
Что за странные очереди автоматически создаются в RabbitMQ?
Есть экосистема микросервисов, представляющих из себя ASP.NET апликейшены, работающие под IIS и общающиеся друг с другом по RabbitMQ с помощью библиотеки MassTransit. Недавно мы обнаружили, что при ...
0
голосов
0
ответов
11
показов
Счётчик обработок сообщений из очереди rabbitmq
Стояла задача реализовать количество обработок сообщений из очереди. Если сообщение было обработано с ошибками n раз. То заносить это сообщение в бд и акать его в очереди. На данный момент сделал ...
0
голосов
1
ответ
11
показов
Требует ли celery предварительного создания очередей
Требует ли celery обязательного предварительного создания очередей?
Или можно запускать её и без них (для теста запуска сервиса).
-1
голос
1
ответ
22
показа
Create internal exchange
Использую Nuget-пакет RabbitMQ.Client версии 6.2.2
Мне требуется подключится к amq.rabbitmq.event, созданному Event Exchange Plugin.
Не смог найти программного функционала для подключения с параметром ...
0
голосов
1
ответ
62
показа
Очередь запросов (todo list) в Symfony через RabbitMQ
Linux. Хотел увидеть, статус моих сообщений, дошли ли они или не дошли. Для этого нужно открыть страницу RabbitMQ. Пишу в своей консоли
symfony open:local:rabbitmq
Но ответ таков: RabbitMQ ...
0
голосов
0
ответов
39
показов
Автоматически создавать очереди rabbitmq
Возьмем строчку из документации к Laravel:
ProcessPodcast::dispatch($podcast)->onQueue('processing');
Тут создается задача ProcessPodcast, и помещается в очередь processing. Теперь представим, что ...
1
голос
1
ответ
63
показа
Как изменить Content-Type в RabbitMQ (Spring JMS)
Всем привет! Проблема в следующем:
У меня есть приложение, которое слушает определенную очередь в RabbitMQ. Когда в эту очередь поступает сообщение, то оно определенным образом обрабатывается. ...
0
голосов
1
ответ
72
показа
Можно ли использовать классы из другого модуля?
У меня есть java проект, где есть несколько модулей(A и B) для передачи информации между ними я использую брокер сообщений RabbitMQ, так получается, что в модуле B мне нужен класс который находится в ...
2
голоса
1
ответ
65
показов
Кто-нибудь может помочь разобраться с асинхронным взаимодействием между микросервисами (masstransit)?
Приведу сферический пример из головы, чтобы было нагляднее:
Допустим у нас есть два микросервиса со своими базами данных. Первый служит для заполнения данных, второй для формирования из этих данных ...
0
голосов
0
ответов
11
показов
Интеграция Graylog с RabbitMQ
Всем доброго времени суток.
Стоит задача собирать логи из приложения в одном месте. Решили использовать GrayLog + RabbitMQ
Для теста развернул у себя контейнеры RabbitMQ, mongo, elasticsearch, graylog ...
0
голосов
0
ответов
44
показа
Выбор MQ очереди
Необходимо выбрать MQ очередь или что-то, что можно использовать таким образом, в рамках следующих условий.
Продюсеров и потребителей может быть десятки тысяч, при этом каждый из них свободно ...
0
голосов
0
ответов
28
показов
AsyncIO, aio_pika проблемы с блоком try-except
Делаю healthcheck ендпоинт. Нужно проверить доступность rabbitMQ.
async def rmq_connection(self, url: str):
"""
Проверяет подключение к указанному RabbitMQ.
...
0
голосов
0
ответов
20
показов
rabbitmq не могу авторизоваться
Пытаюсь авторизоваться в установленном rabbitmq, установлен локально. Версия:
{rabbit,"RabbitMQ","3.6.10"}
При попытке зайти происходит ошибка:
sudo rabbitmqctl authenticate_user ...
0
голосов
1
ответ
25
показов
RabbitMQ pika. Как побороть StreamLostError?
Использую библиотеку pika для взаимодействия с RabbitMQ очередями
Для создания соединения использую:
def get_connection():
credential = pika.PlainCredentials(LOGIN, PASS)
parameters = pika....
0
голосов
0
ответов
26
показов
Настройка Spring Cloud Rabbit
Сделал рабочую конфигурацию для реббита, суть которой перебрасывать из основной очереди в ожидающую (dead-letter) с заданным ttl и по его истечении забрасывать обратно:
@Configuration
@...
0
голосов
1
ответ
204
показа
Как в rabbitmq накопить определённое кол-во строк и запустить эту пачку в callback?
На данный момент работает так - идёт запрос с множеством данных на сервис А, с него данные посылаются в очередь в rabbitmq, откуда читаются по одному сообщению сервисом В и пишутся в CLickHouse. Нужно ...
0
голосов
0
ответов
16
показов
RabbitMq можно ли реализовать отправку пакетами транзакционно?
Я выбираю из базы postgres пакет объектов (допустим по 5 тыс) и хочу переложить все эти объекты в очередь RabbitMq (приложение на спринге). Если объект успешно попал в очередь, то я меняю статус этого ...
0
голосов
0
ответов
23
показа
Почему RabbitMq работает только в одном потоке после поднятия
Вот конфигурация кролика
@Configuration
public class RabbitConfig {
@Bean
public CachingConnectionFactory connectionFactory() {
return new CachingConnectionFactory("localhost&...
0
голосов
0
ответов
17
показов
Пытаюсь повесить слушателя очереди с андроид-приложения на ПК java приложение
Что сделано:
Написан Producer на java(располагается на ПК):
public class Sender {
public static final TestMessage testMessage = new TestMessage("HELLO FROM BSM");
public static final ...
0
голосов
0
ответов
13
показов
Как отправить письмо пользователю с очереди RabbitMQ?
Есть АПИ и СМПТ сервис, после покупки товара - пользователю должно прийти на почту письмо что он заказал.
После того как пользователь подтверждает заказ:
[HttpPost]
public async Task<...
0
голосов
0
ответов
18
показов
RabbitMQ какой тип exchange выбрать для сообщений?
Бизнес логика :
user1 создает событие (event)
user1.....userN отправляют заявку на участие в событии (не оновременно а в течении актуальности срока до начала события)
user1 получает заявку из очереди ...
0
голосов
0
ответов
19
показов
Получить сообщения с помощью JMS API из RabbitMQ [Spring]
Есть два сервера. Один отправляет сообщения с помощью Spring AMQP. Другой сервер должен принимать сообщения с использованием JMS API. Вся проблема в том, что у RMQConnectionFactory нету метода ...
0
голосов
1
ответ
32
показа
Rabbitmq. Можно ли создать очередь, которая подвязана к Direct Exchange, но при этом в нее будут попадать все сообщения независимо от routing key?
Суть проблемы, существует сервис на спринге, который закидывает сообщения в Direct exchnage без указания routing key. Есть очередь которая подвязана к этому обменнику и у нее тоже отсутвcует routing ...
0
голосов
0
ответов
103
показа
Обязательно ли в rabbitmq нужно закрывать соединение?
Только начал знакомиться с rabbitmq, посмотрел примеры с офф сайта
Наконец, закрываем соединение и выходим
setTimeout(function() {
connection.close();
process.exit(0)
}, 500);
мой пример ...
2
голоса
1
ответ
47
показов
Тестирование микросервиса, работающего с бинарными данными
Необходимо написать интеграционные и модульные тесты для микросервиса на NodeJS.
Сервис слушает очередь rabbitmq, получает ссылку на видео файл в удаленной файловой системе, перекодирует его в ...
2
голоса
1
ответ
25
показов
C# RabbitMQ. Событие успешного авто восстановления коннекта
Использую RabbitMQ.Client, и тестирую функцию AutomaticRecoveryEnabled.
Все хорошо работает при проблемах с Tcp коннектом или при перезапуске RabbitMQ.
Хорошо бы иметь событие на отключение от ...
2
голоса
0
ответов
45
показов
C# EasyNetQ. Восстановление работы после рестарта Docker с RabbitMq
начал разбираться с библиотекой для работы с очередью сообщений RabbitMq, которая называется EasyNetQ.
Особенность EasyNetQ в том, что очередь создается Подписчиком при активации подписки.
Если ...
1
голос
1
ответ
155
показов
RabbitMQ прослушивание одной очереди с разных консюмеров
Есть продюсер:
@Configuration
public class ToDoConfig {
@Bean
public SimpleRabbitListenerContainerFactory rabbitListenerContainerFactory(ConnectionFactory connectionFactory) {
...
1
голос
0
ответов
93
показа
Как проверить работоспособность брокера RabbitMQ?
Установил RabbitMQ. Как проверить его работоспособность? Использовал в купе с celery. Но сейчас отказывается работать. Пишет, что удаленный сервер отклонил ответ. Сначала все было почти нормально, ...
0
голосов
0
ответов
77
показов
Нет соединения с сервером. consumer: Cannot connect to amqp://guest:**@127.0.0.1:5672//: [WinError 10061]
Следовал инструкции по подключению celery здесь. Сначала все работало, задачи попадали в очередь, но не выполнялись. Переустановил celery (более современную версию) - все перестало работать. Пробовал ...
1
голос
0
ответов
70
показов
Запуск фоновых задач через dramatiq
@dramatiq.actor(store_results=True)
def count_words(url):
try:
response = requests.get(url)
count = len(response.text.split(" "))
print(f"...
0
голосов
0
ответов
41
показ
RabbitMQ записать данные в БД
_consumers.SubscribeAsync(Do); это строка вызывает же function Do ? и передат аргумент Account да? или я ошибаюсь?
в function Do я вызываю method который должен зарисать эти данные в базу но не пишет.
...
1
голос
0
ответов
271
показ
Подтверждение обработки сообщения из очереди RabbitMQ
Организую для взаимосвязи приложений очередь.
Использую библиотеку aio-pika для того, чтобы получать сообщения.
Проблема:
Сообщения успешно получаю и обрабатываю их, НО по средствам мониторинга вижу, ...
0
голосов
1
ответ
73
показа
Как правильно реализовать систему очередей для асинхронного подтверждения авторизации, путем ожидания кода
Имеется puppeteer сервер который выполняет авторизацию на сервере, он служит в качестве удобной авторизации над сервисом, предлагая возможность в качестве мультиаккаунтности. Проще говоря, свой сервис,...
0
голосов
1
ответ
168
показов
Как отправить сообщение всем слушателям RabbitMQ, Spring boot
Отправка:
@Service
public class ProducerImp implements Producer {
@Autowired
private AmqpTemplate amqpTemplate;
@Value("${jsa.rabbitmq.exchange}")
private String exchange;
...
0
голосов
0
ответов
97
показов
Я не понимаю как настроить celery и rabbitmq на Windows
Сейчас покажу код, делаю на ubuntu все то же самое, что и на Windows
Windows код не исполняет, не отправляет email, с ubuntu этот же проект работает прекрасно.Как заставить работать celery на windows?
...
1
голос
2
ответа
58
показов
Как асинхронно вызвать синхронный метод?
Насколько я понимаю в текущей реализации библиотеки RabbitMQ.Client (https://www.nuget.org/packages/RabbitMQ.Client/) для c# нет асинхронного варианта для метода BasicPublish.
Я хотел бы что бы вызов ...
0
голосов
1
ответ
117
показов
Установить RabbitMQ для Laravel 5.8. Ошибка composer - Your requirements could not be resolved to an installable set of packages
Всем заглянувшим, доброго времени суток!
Сам сервер запускается и работает нормально(Docker).
Но при добавлении данной либы через composer composer require vladimir-yuldashev/laravel-queue-rabbitmq ...
0
голосов
0
ответов
75
показов
Вернуть ответ клиенту из после RabbitMQ
Есть сервер, который принимает запрос от клиента и отправляет в RabbitMQ, есть слушатель, который получает сообщения из очереди, обрабатывает его и должен обратно вернуть клиенту.Вопрос в том, как ...