AMQP / RabbitMQ
Restorm реалізує AMQP 0-9-1 — протокол RabbitMQ.
Клацніть правою кнопкою в дереві ▸ Додати ▸ Запит AMQP.
Спільна конфігурація
Section titled “Спільна конфігурація”| Поле | Роль |
|---|---|
| URL | amqp:// або amqps:// |
| Vhost | Віртуальний хост; типово / |
| Користувач / Пароль | Пароль приймає значення типу «Секрет» |
| Режим | publish, subscribe або browse |
Режим publish
Section titled “Режим publish”| Поле | Роль |
|---|---|
| Обмін | Назва обміну; порожній рядок позначає типовий обмін |
| Ключ маршрутизації | Ключ маршрутизації, який приймає {{variables}} |
| Вміст | Тіло повідомлення |
Режим subscribe
Section titled “Режим subscribe”| Поле | Роль |
|---|---|
| Черга | Черга, яку споживають |
| Автоматичне підтвердження | Типово увімкнено; вимкніть, щоб спостерігати поведінку повторної доставки |
| Prefetch | Максимальна кількість непідтверджених повідомлень у польоті |
Режим browse
Section titled “Режим browse”Переглядає вміст черги, не споживаючи його: Restorm бере обмежену кількість повідомлень (типово 50) і повертає їх на місце.
Це саме той режим, що потрібен для відповіді на питання «що зараз у цій черзі?», не порушуючи роботу системи. Він доступний у вкладці запиту; на відміну від двох інших режимів, окремої дії сценарію в нього немає.
У сценарії
Section titled “У сценарії”З’єднання AMQP (споживає чергу в режимі subscribe й генерує подію на
кожне повідомлення), Публікація AMQP (публікує на обмін і ключ
маршрутизації із запиту) та Закриття з’єднання AMQP. Див.
З’єднання та потоки.
Фрагменти коду
Section titled “Фрагменти коду”Вісім цілей: JavaScript (amqplib — для публікації, споживання та огляду),
Python (pika), amqp-publish і amqp-consume (amqp-tools), rabbitmqadmin.