vault backup: 2024-08-19 13:36:42

This commit is contained in:
Struchkov Mark 2024-08-19 13:36:42 +03:00
parent 2e663b0ce5
commit 9b63530136
No known key found for this signature in database
GPG Key ID: A3F0AC3F0FA52F3C
7 changed files with 37 additions and 23 deletions

View File

@ -24,12 +24,16 @@
"unresolvedLinks": false, "unresolvedLinks": false,
"recentFilesStore": [ "recentFilesStore": [
{ {
"filepath": "_inbox/2024-08-19 1724063500.md", "filepath": "_inbox/Варианты взаимодействия.md",
"timestamp": 1724063500085 "timestamp": 1724063587127
},
{
"filepath": "_inbox/Queue.md",
"timestamp": 1724063584717
}, },
{ {
"filepath": "Обработка сообщений в RabbitMQ.md", "filepath": "Обработка сообщений в RabbitMQ.md",
"timestamp": 1724063480400 "timestamp": 1724063522856
}, },
{ {
"filepath": "_inbox/00 RabbitMQ.md", "filepath": "_inbox/00 RabbitMQ.md",
@ -38,10 +42,6 @@
{ {
"filepath": "_inbox/Exchange Topics.md", "filepath": "_inbox/Exchange Topics.md",
"timestamp": 1724063454382 "timestamp": 1724063454382
},
{
"filepath": "_inbox/Exchange.md",
"timestamp": 1724063448750
} }
], ],
"bookmarkedFileStore": [], "bookmarkedFileStore": [],

View File

@ -1,8 +1,12 @@
{ {
"recentFiles": [ "recentFiles": [
{ {
"basename": "2024-08-19 1724063500", "basename": "Варианты взаимодействия",
"path": "_inbox/2024-08-19 1724063500.md" "path": "_inbox/Варианты взаимодействия.md"
},
{
"basename": "Queue",
"path": "_inbox/Queue.md"
}, },
{ {
"basename": "Обработка сообщений в RabbitMQ", "basename": "Обработка сообщений в RabbitMQ",
@ -32,10 +36,6 @@
"basename": "Exchange Fanout", "basename": "Exchange Fanout",
"path": "_inbox/Exchange Fanout.md" "path": "_inbox/Exchange Fanout.md"
}, },
{
"basename": "Queue",
"path": "_inbox/Queue.md"
},
{ {
"basename": "Событийно-ориентированное программирование", "basename": "Событийно-ориентированное программирование",
"path": "_inbox/Событийно-ориентированное программирование.md" "path": "_inbox/Событийно-ориентированное программирование.md"

View File

@ -1,9 +0,0 @@
---
aliases:
tags:
- зрелость/🌱
date: [[2024-08-19]]
zero-link:
parents:
linked:
---

View File

@ -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. Сообщения в эти очереди отправляются одинковые. Т

Binary file not shown.

After

Width:  |  Height:  |  Size: 890 KiB

Binary file not shown.

After

Width:  |  Height:  |  Size: 881 KiB

View File

@ -16,4 +16,6 @@ linked:
- [Exchange](Exchange.md) получает Message и отвечает за его перенаправление. Он берет различные атрибуты, такие как Routing Key, зависимость на тип обмена и другие. - [Exchange](Exchange.md) получает Message и отвечает за его перенаправление. Он берет различные атрибуты, такие как Routing Key, зависимость на тип обмена и другие.
- Создается Binding между [Queue](Queue.md) и [Exchange](Exchange.md) - Создается Binding между [Queue](Queue.md) и [Exchange](Exchange.md)
- Сообщение остается в [Queue](Queue.md) до тех пор, пока не будет обработано Consumer - Сообщение остается в [Queue](Queue.md) до тех пор, пока не будет обработано Consumer
- Consumer обрабатывает сообщение - Consumer обрабатывает сообщение
- [Варианты взаимодействия](Варианты%20взаимодействия.md)