Публикации по теме 'rabbitmq'
Событийно-ориентированная ⚙️ Архитектура и сообщение 📱 Очереди 👨👩👧👦
Событийно-ориентированная ⚙️ Архитектура и сообщение 📱 Очереди 👨👩👧👦
Понимание архитектур, управляемых событиями, и очередей сообщений — это навык, который вам нужен как серверный разработчик.
Введение
Представьте себе оживленную платформу электронной коммерции во время быстрой распродажи, где тысячи покупателей одновременно размещают заказы, обновляют свои корзины и оформляют покупки. В этом хаотическом безумии цифровых покупок важность бесперебойной связи в режиме реального..
Инструменты для архитектуры, управляемой событиями: интеграция Jenkins и RabbitMQ
Привет! Надеюсь, вам понравился этот пост. На этот раз я объясню, как использовать Jenkins и RabbitMQ в архитектуре, управляемой событиями.
Преимущества:
– Выполнять асинхронные задания jenkins от производителя. – Запускать развертывания в разных средах. – Отвечать от Jenkins потребителю, чтобы уведомить о выполнении задач.
Откройте веб-приложение Jenkins и нажмите Новый элемент .
Разрешающий штекер
Откройте веб-приложение Jenkins и нажмите Управление Jenkins .
Затем..
Путь к созданию полноценного микросервисного приложения. Контейнер RabbitMQ и подключение.
Привет, ребята, сегодня я публикую 14-ю статью этого трека. Я надеюсь, что это путешествие побудит вас узнать больше о микросервисах и нескольких технологиях, которые нам нужно изучить, чтобы создать настоящее микросервисное приложение. Сегодня мы добавим новый сервис Docker Compose, RabbitMQ , и создадим связь между микросервисом и RabbitMQ. Предположим, вы не знаете, что такое RabbitMQ и почему мы должны его использовать, прочитайте вводную тему ниже. Давайте начнем.
Прежде..
Как реализовать простую очередь сообщений в Node.js
Очередь сообщений обеспечивает асинхронную связь, когда приложение помещает сообщение в очередь сообщений и не требует немедленного ответа на продолжение обработки.
Производитель и потребитель не взаимодействуют напрямую друг с другом, но они взаимодействуют с очередью сообщений. Этот способ обработки сообщений отделяет производителя от потребителя, поэтому им не нужно одновременно взаимодействовать с очередью сообщений.
В этой статье мы рассмотрим, как создать простую очередь..
Реализовать шину событий с помощью Akka
Вы, наверное, много раз читали такие сообщения и хотите знать, что еще я могу рассказать вам по этой теме. Может быть, немного, но моя идея для этого поста была вдохновлена реальным сценарием, который я реализовал в своем проекте. Я начну с событий, входящих / исходящих с помощью веб-сокетов, которые затем распространяются на актеров Akka. В следующем посте я добавлю RabbitMQ для поддержки нескольких модулей / экземпляров приложения.
Задний план
В проекте, над которым я..
Ошибки при повторной доставке RabbitMQ
В этом посте я собираюсь описать некоторые особенности брокера RabbitMQ о том, как он работает с неработающими сообщениями, и расскажу о некоторых решениях.
Все примеры основаны на библиотеке Enqueue PHP Messaging .
По умолчанию сервер RabbitMQ не ждет подтверждения от потребителя. Сообщение удаляется из очереди, как только оно доставляется потребителю. Следовательно, сообщение может быть потеряно, если потребитель умирает во время обработки сообщения. В некоторых случаях это может..
Вопросы по теме 'rabbitmq'
Барьер идемпотентности для обмена сообщениями
Недавняя презентация , посвященная RabbitMQ упомянул об использовании так называемого "барьера идемпотентности" для дедупликации сообщений. Это просто причудливое название для конфлятора сообщений или что-то более конкретное. Если да, то что...
1098 просмотров
schedule
03.09.2022
Задача Celery, которая общается с Twitter
Каков правильный подход при написании задач сельдерея, которые взаимодействуют со службой, которая имеет ограничения по скорости и иногда отсутствует (не отвечает) в течение длительного периода времени?
Должен ли я использовать повтор задачи? Что...
296 просмотров
schedule
29.10.2022
Зависимость работы в RabbitMQ
Я пытаюсь выяснить, как лучше всего настроить следующий сценарий:
Несколько заданий типа A добавляются в очередь
После завершения всех заданий типа A потребуется задание типа B или C (по одному на задание типа A).
Когда все задания типов A, B...
2224 просмотров
schedule
02.05.2024
Десериализация Byte[] в кодировке UTF8 в javascript в браузере или в приложении node.js?
У меня есть класс событий в С#:
public class AreaInterventoCreata{
//public properties
}
var message= new AreaInterventoCreata();
Я создаю экземпляр этого класса на стороне сервера. Моя цель состоит в том, чтобы сообщить об этом творении...
1071 просмотров
schedule
01.04.2024
Как обеспечить порядок приема сообщений в MassTransit
У меня есть сага с 3 состояниями; Исходный, Получающие ряды, Завершенный -
public static State Initial { get; set; }
public static State ReceivingRows { get; set; }
public static State Completed { get; set; }
Он переходит от...
2282 просмотров
schedule
17.12.2023
Конкурирующие потребители из приложения балансировки нагрузки в MassTransit / RabbitMQ
Я только что закончил создание API, в котором запросы от API перенаправляются в серверную службу через MassTransit / RabbitMQ с использованием шаблона запроса / ответа. Сейчас мы планируем внедрить это в производство и хотим, чтобы несколько...
2142 просмотров
schedule
09.07.2022
Celerybeat не работает должным образом
Я создаю какой-то проект с бутылкой, и мне нужно, чтобы он периодически запускал определенные запланированные действия.
Я решил использовать rabbitmq + celery, так как это казалось наиболее надежным и полным решением для программного управления...
2992 просмотров
schedule
22.04.2024
Уникальные идентификаторы заданий в очереди сообщений?
У меня есть приложение, которое я пишу, которое должно выполнять длительные вычисления в фоновом режиме, поэтому у меня есть следующий рабочий процесс:
Клиент отправляет задание на пограничный «диспетчерский» сервер.
Диспетчерский сервер...
7159 просмотров
schedule
06.04.2024
RabbitMQ: попробуйте отправить сообщение еще раз
У меня есть сервер , который отправляет сообщение в MQ. Сообщение удаляется из очереди при ответе worker :
channel.basic_ack(delivery_tag=method_frame.delivery_tag)
но когда рабочий генерирует ошибку, он не отвечает о доставке товара....
417 просмотров
schedule
30.01.2024
Celerybeat иногда пропускает задачи
У нас есть установка Celery (+Celerybeat) с серверной частью RabbitMQ, выполняющей запланированные и незапланированные задачи. Я заметил, что иногда пропускаю/отбрасываю выполнение запланированной задачи. Все продолжает работать правильно, и задача...
803 просмотров
schedule
04.09.2022
Получить длину очереди с помощью Celery (RabbitMQ, Django)
Я использую Celery в проекте django, мой брокер RabbitMQ, и я хочу получить длину очередей. Я просмотрел код Celery, но не нашел инструмента для этого. Я обнаружил эту проблему в stackoverflow ( Проверить размер очереди RabbitMQ от клиента ), но Я...
6354 просмотров
schedule
09.09.2022
RabbitMq: установка флага AMQP_AUTODELETE на Exchange с помощью PHP AMQP
Я пытаюсь установить флаг AMQP_AUTODELETE на своем обменнике, используя AMQPExchange::setFlags ( int $flags )
http://php.net/manual/en/amqp.constants.php http://www.php.net/manual/en/amqpexchange.setflags.php
не работает... :(
$exchange...
777 просмотров
schedule
25.10.2023
Измерение времени выполнения задачи Celery
Я преобразовал автономное пакетное задание, чтобы использовать сельдерей для отправки работы, которую необходимо выполнить. Я использую RabbitMQ. Все выполняется на одной машине, и никакие другие процессы не используют экземпляр RabbitMQ. Мой...
8476 просмотров
schedule
29.06.2022
Не удалось подключиться к Rabbitmq с помощью Spring 4.0 webstock stomp api
Я попытался подключить STOMP к RabbitMQ, используя класс Spring 4.0 WebSocketMessageBrokerConfigurer, но не удалось?
Снап кода здесь.
@Configuration
@EnableWebSocketMessageBroker
public class WebSocketConfig implements...
1317 просмотров
schedule
08.09.2022
Как я могу использовать RabbitMQ между двумя приложениями, пока я не могу изменить одно из них?
У меня есть существующая система, состоящая из двух узлов, модель клиент/сервер. Я хочу обмениваться сообщениями между ними с помощью RabbitMQ. т.е. Клиент будет отправлять все свои запросы в RabbitMQ, а сервер будет бесконечно прослушивать...
797 просмотров
schedule
23.02.2024
Отправка бинарного файла через RabbitMQ
Прямо сейчас я разрабатываю дизайн, в котором RabbitMQ используется в качестве очереди сообщений. Сообщение будет иметь тело JSON, и для одного сообщения, в частности, я хотел бы добавить небольшой двоичный файл.
Я хотел бы знать, должны ли данные...
33692 просмотров
schedule
07.12.2023
Android не получает сообщения от сервера rabbitmq с сообщениями, отправленными из ruby-amqp
Я использую рельсы с драгоценным камнем ruby-amqp. он отлично работает с самим приложением rails, но клиент Android java не может получать сообщения.
клиент Android основан на этом...
672 просмотров
schedule
04.05.2024
Получить имя очереди RabbitMQ, из которой было получено сообщение
Использование SimpleMessageListenerContainer , подключенного к нескольким очередям и настроенного с помощью ChannelAwareMessageListener . Можно ли определить, из какой очереди было получено сообщение? В частности, если сообщение было направлено в...
1458 просмотров
schedule
10.12.2023
Можно ли развернуть Consumer и Producer для rabbitmq как одно веб-приложение на tomcat?
Я использую java в качестве серверной части и хочу интегрировать rabbitmq для масштабируемости.
Моя цель здесь такова.
У меня есть (веб-приложение 1) сервер 1, который будет отправлять какое-то сообщение в rabbitmq (т.е. действовать как...
1113 просмотров
schedule
18.08.2022
Как подключиться к кластеру RabbitMQ с помощью клиента Python с помощью pika?
У меня есть клиент Python, который использует пакет Pika (0.9.13) и извлекает данные с одного узла в кластере RabbitMQ. Кластер состоит из двух узлов, размещенных на двух разных хостах (url_1 и url_2). Как я могу заставить свой клиент Python...
6328 просмотров
schedule
30.10.2023
