NetMq. Windows10 Ситуация следующая. Есть PUB сокет с такими опциями: rcv.Options.SendHighWatermark

Question

NetMq. Windows10 Ситуация следующая. Есть PUB сокет с такими опциями: rcv.Options.SendHighWatermark

= 5;
rcv.Options.SendBuffer = 10; // тут и 0 пробовал и точно считать в 1 сообщение - ноль эффекта
Есть SUB сокет с опциями:
sender.Options.ReceiveHighWatermark = 5;
sender.Options.ReceiveBuffer = 10; // тут и 0 пробовал и точно считать в 1 сообщение - ноль эффекта

Запускаю я всю это добро и делаю следующие
1. Запускаю PUB сокет отдельным приложением
2. Запускаю SUB сокет и прибинжеваюсь к PUB сокету
3. В PUB сокетом пишу 40 сообщений
4. Жду... (минуту например)
5. Начинаю читать SUB сокетом и оно мне читает все 40 сообщений.

Вопрос - почему? Почему у меня в очередь в PUB залезло все 40 сообщений и почему в очередь на чтение все 40 сообщений прилетели?

#backend #dot #programming #russian

0

05.10.2023

7 ответов

20 просмотров

Anton 『被遗忘的社会』 Автор вопроса

Makima
а как иначе должно было быть?

Т.к. у меня HighWatermark = 5 в PUB, то все сообщения, которые попали в очередь после 5 сообщения должны быть дропнуты (это поведение описано в zeromq) А вот на счёт того, что должно происходить на SUB я вообще не уверен, т.к. даже если я тушу сервер, то при условии, что он прочитал хоть одно сообщение даже при потушенном PUB сокете мне их достаёт из воздуха

0

05.10.2023

Makima

Anton 『被遗忘的社会』
Т.к. у меня HighWatermark = 5 в PUB, то все сообще...

ок тебе на саб все 40 долетают и саб их обрабатывает?

0

05.10.2023

Anton 『被遗忘的社会』 Автор вопроса

Makima
ок тебе на саб все 40 долетают и саб их обрабатыва...

Да

0

05.10.2023