diff --git a/.obsidian/plugins/home-tab/data.json b/.obsidian/plugins/home-tab/data.json index 9669f58d..af3ad49b 100644 --- a/.obsidian/plugins/home-tab/data.json +++ b/.obsidian/plugins/home-tab/data.json @@ -24,12 +24,16 @@ "unresolvedLinks": false, "recentFilesStore": [ { - "filepath": "_inbox/2024-08-19 1724063500.md", - "timestamp": 1724063500085 + "filepath": "_inbox/Варианты взаимодействия.md", + "timestamp": 1724063587127 + }, + { + "filepath": "_inbox/Queue.md", + "timestamp": 1724063584717 }, { "filepath": "Обработка сообщений в RabbitMQ.md", - "timestamp": 1724063480400 + "timestamp": 1724063522856 }, { "filepath": "_inbox/00 RabbitMQ.md", @@ -38,10 +42,6 @@ { "filepath": "_inbox/Exchange Topics.md", "timestamp": 1724063454382 - }, - { - "filepath": "_inbox/Exchange.md", - "timestamp": 1724063448750 } ], "bookmarkedFileStore": [], diff --git a/.obsidian/plugins/recent-files-obsidian/data.json b/.obsidian/plugins/recent-files-obsidian/data.json index c7dfd132..c202ec25 100644 --- a/.obsidian/plugins/recent-files-obsidian/data.json +++ b/.obsidian/plugins/recent-files-obsidian/data.json @@ -1,8 +1,12 @@ { "recentFiles": [ { - "basename": "2024-08-19 1724063500", - "path": "_inbox/2024-08-19 1724063500.md" + "basename": "Варианты взаимодействия", + "path": "_inbox/Варианты взаимодействия.md" + }, + { + "basename": "Queue", + "path": "_inbox/Queue.md" }, { "basename": "Обработка сообщений в RabbitMQ", @@ -32,10 +36,6 @@ "basename": "Exchange Fanout", "path": "_inbox/Exchange Fanout.md" }, - { - "basename": "Queue", - "path": "_inbox/Queue.md" - }, { "basename": "Событийно-ориентированное программирование", "path": "_inbox/Событийно-ориентированное программирование.md" diff --git a/_inbox/2024-08-19 1724063500.md b/_inbox/2024-08-19 1724063500.md deleted file mode 100644 index 57204984..00000000 --- a/_inbox/2024-08-19 1724063500.md +++ /dev/null @@ -1,9 +0,0 @@ ---- -aliases: -tags: - - зрелость/🌱 -date: [[2024-08-19]] -zero-link: -parents: -linked: ---- diff --git a/_inbox/Варианты взаимодействия.md b/_inbox/Варианты взаимодействия.md new file mode 100644 index 00000000..c3582e94 --- /dev/null +++ b/_inbox/Варианты взаимодействия.md @@ -0,0 +1,21 @@ +--- +aliases: +tags: + - зрелость/🌱 +date: + - - 2024-08-19 +zero-link: + - "[[00 RabbitMQ]]" +parents: + - "[[Обработка сообщений в RabbitMQ]]" +linked: +--- +## Consume +![](Pasted%20image%2020240819133226.png) +В таком режиме каждый consumer получает свою порцию сообщений из [Queue](Queue.md). То есть нагрузка распределяется по consumer-ам. + +Параметр prefetch позволяет указать сколько сообщений одновременно будет забирать consumer, если значение будет слишком большое, а потом сообщений не большой, то нагрузка будет распределяться не равномерно. По умолчанию это значение равно 100. + +## Sub/Pub +![](Pasted%20image%2020240819133554.png) +В таком режиме создаются уникальные [Queue](Queue.md) для каждого Consumer. Сообщения в эти очереди отправляются одинковые. Т \ No newline at end of file diff --git a/meta/files/Pasted image 20240819133226.png b/meta/files/Pasted image 20240819133226.png new file mode 100644 index 00000000..d8531904 Binary files /dev/null and b/meta/files/Pasted image 20240819133226.png differ diff --git a/meta/files/Pasted image 20240819133554.png b/meta/files/Pasted image 20240819133554.png new file mode 100644 index 00000000..51054b25 Binary files /dev/null and b/meta/files/Pasted image 20240819133554.png differ diff --git a/Обработка сообщений в RabbitMQ.md b/Обработка сообщений в RabbitMQ.md index 60fb0389..54d11798 100644 --- a/Обработка сообщений в RabbitMQ.md +++ b/Обработка сообщений в RabbitMQ.md @@ -16,4 +16,6 @@ linked: - [Exchange](Exchange.md) получает Message и отвечает за его перенаправление. Он берет различные атрибуты, такие как Routing Key, зависимость на тип обмена и другие. - Создается Binding между [Queue](Queue.md) и [Exchange](Exchange.md) - Сообщение остается в [Queue](Queue.md) до тех пор, пока не будет обработано Consumer -- Consumer обрабатывает сообщение \ No newline at end of file +- Consumer обрабатывает сообщение + +- [Варианты взаимодействия](Варианты%20взаимодействия.md) \ No newline at end of file