From ec095fefb9c479fa9b8f6f87458fe1636128bca0 Mon Sep 17 00:00:00 2001 From: Struchkov Mark Date: Wed, 3 Jul 2024 10:26:00 +0300 Subject: [PATCH] vault backup: 2024-07-03 10:26:00 --- .obsidian/plugins/home-tab/data.json | 16 ++++++++-------- .../plugins/recent-files-obsidian/data.json | 12 ++++++------ _inbox/00 RabbitMQ.md | 3 +-- _inbox/Exchange.md | 2 +- _inbox/Queue.md | 17 +++++++++++++++++ _inbox/Флаги очередей в RabbitMQ.md | 7 +++++-- Обработка сообщений в RabbitMQ.md | 4 ++-- 7 files changed, 40 insertions(+), 21 deletions(-) create mode 100644 _inbox/Queue.md diff --git a/.obsidian/plugins/home-tab/data.json b/.obsidian/plugins/home-tab/data.json index 045672f8..3dffc1dd 100644 --- a/.obsidian/plugins/home-tab/data.json +++ b/.obsidian/plugins/home-tab/data.json @@ -24,12 +24,16 @@ "unresolvedLinks": false, "recentFilesStore": [ { - "filepath": "_inbox/Флаги очередей в RabbitMQ.md", - "timestamp": 1719991160610 + "filepath": "_inbox/00 RabbitMQ.md", + "timestamp": 1719991553169 }, { - "filepath": "_inbox/00 RabbitMQ.md", - "timestamp": 1719991158104 + "filepath": "_inbox/Флаги очередей в RabbitMQ.md", + "timestamp": 1719991550601 + }, + { + "filepath": "_inbox/Queue.md", + "timestamp": 1719991515165 }, { "filepath": "_inbox/Exchange.md", @@ -38,10 +42,6 @@ { "filepath": "_inbox/Exchange Topics.md", "timestamp": 1719991136425 - }, - { - "filepath": "_inbox/Exchange Headers.md", - "timestamp": 1719988705226 } ], "bookmarkedFileStore": [], diff --git a/.obsidian/plugins/recent-files-obsidian/data.json b/.obsidian/plugins/recent-files-obsidian/data.json index c3de53f5..7164584b 100644 --- a/.obsidian/plugins/recent-files-obsidian/data.json +++ b/.obsidian/plugins/recent-files-obsidian/data.json @@ -1,12 +1,16 @@ { "recentFiles": [ + { + "basename": "00 RabbitMQ", + "path": "_inbox/00 RabbitMQ.md" + }, { "basename": "Флаги очередей в RabbitMQ", "path": "_inbox/Флаги очередей в RabbitMQ.md" }, { - "basename": "00 RabbitMQ", - "path": "_inbox/00 RabbitMQ.md" + "basename": "Queue", + "path": "_inbox/Queue.md" }, { "basename": "Exchange", @@ -195,10 +199,6 @@ { "basename": "Kromax20ATLANTIS-70", "path": "meta/files/Kromax20ATLANTIS-70.jpg" - }, - { - "basename": "6706110398", - "path": "meta/files/6706110398.jpg" } ], "omittedPaths": [], diff --git a/_inbox/00 RabbitMQ.md b/_inbox/00 RabbitMQ.md index 2f270d79..be14ea5c 100644 --- a/_inbox/00 RabbitMQ.md +++ b/_inbox/00 RabbitMQ.md @@ -24,8 +24,7 @@ linked: - [Репликация](_inbox/Репликация.md) Терминология: -- Queue - Буфер, который хранит messages. Никакой логики. - - [Флаги очередей в RabbitMQ](Флаги%20очередей%20в%20RabbitMQ.md) +- [Queue](Queue.md) - Буфер, который хранит messages. Никакой логики. - Connection - [TCP](TCP.md) соединение между приложениями и менеджером очередей. - Channel - Виртуальное соединение внутри Connection. Когда вы публикуете или получаете message через Queue, это все делается в Channel. По факту сессия. - [Exchange](Exchange.md) - получает messages от producer и отправляет его в Queue. Он решает в какую Queue будет помещено message. diff --git a/_inbox/Exchange.md b/_inbox/Exchange.md index 94fabbe9..1dcf72e7 100644 --- a/_inbox/Exchange.md +++ b/_inbox/Exchange.md @@ -9,7 +9,7 @@ zero-link: parents: [] linked: --- -Exchange получает messages от producer и отправляет его в Queue. Он решает в какую Queue будет помещено message. +Exchange получает messages от producer и отправляет его в [Queue](Queue.md). Он решает в какую [Queue](Queue.md) будет помещено message. Типы Exchange: - [direct](Exchange%20Direct.md) diff --git a/_inbox/Queue.md b/_inbox/Queue.md new file mode 100644 index 00000000..338d1611 --- /dev/null +++ b/_inbox/Queue.md @@ -0,0 +1,17 @@ +--- +aliases: +tags: + - зрелость/🌱 +date: + - - 2024-07-03 +zero-link: + - "[[00 RabbitMQ]]" +parents: +linked: +--- +Буфер, который хранит messages. Никакой логики. + +Обычно очередь создается автоматически в случае отсутствия, если это не запрещено конфигурацией. + +Флаги очередей: +![Флаги очередей в RabbitMQ](Флаги%20очередей%20в%20RabbitMQ.md) \ No newline at end of file diff --git a/_inbox/Флаги очередей в RabbitMQ.md b/_inbox/Флаги очередей в RabbitMQ.md index 6315e9f7..dd571fe1 100644 --- a/_inbox/Флаги очередей в RabbitMQ.md +++ b/_inbox/Флаги очередей в RabbitMQ.md @@ -6,9 +6,12 @@ date: - - 2024-07-03 zero-link: - "[[00 RabbitMQ]]" -parents: +parents: + - "[[Queue]]" linked: --- - auto-delete - если очередь пустая и к ней нет активных Channel, очередь автоматически удаляется - durable - устойчивая очередь, сообщения не теряются при рестарте RabbitMQ, при публикации и до окончания отдачи храняться в базе данных -- exclusive - очередь предназначенная для одного \ No newline at end of file +- exclusive - очередь предназначенная для одного подключения единовременно +- passive - при объявлении очереди пассивной, при обращении клиента сервер будет считать, что очередь уже создана, то есть не будет автоматически создавать ее в случае отсутствия. Этот вариант нужен, если вы хотите обратиться к серверу не изменяя его состояние. +- internal - очередь между [Exchange](Exchange.md) \ No newline at end of file diff --git a/Обработка сообщений в RabbitMQ.md b/Обработка сообщений в RabbitMQ.md index 483898ff..60fb0389 100644 --- a/Обработка сообщений в RabbitMQ.md +++ b/Обработка сообщений в RabbitMQ.md @@ -14,6 +14,6 @@ linked: - Producer публикует Message в [Exchange](Exchange.md). - [Exchange](Exchange.md) получает Message и отвечает за его перенаправление. Он берет различные атрибуты, такие как Routing Key, зависимость на тип обмена и другие. -- Создается Binding между Queue и [Exchange](Exchange.md) -- Сообщение остается в Queue до тех пор, пока не будет обработано Consumer +- Создается Binding между [Queue](Queue.md) и [Exchange](Exchange.md) +- Сообщение остается в [Queue](Queue.md) до тех пор, пока не будет обработано Consumer - Consumer обрабатывает сообщение \ No newline at end of file