fk0легенда (10.07.2020 19:39, просмотров: 831) ответил lloyd на Про сокеты - можно просто взять ZeroMQ, там такой сценарий есть из
коробки XPUB/XSUB. Записывать в один поток в получателе[ZX]
-
- А вот затем, что см. комментарий выше - 0MQ обеспечивает границу
сообщений на любом транспорте (межпотоковый, межпроцессный, TCP).
Там получаешь или все, или ничего (такое тоже бывает) - lloyd(10.07.2020 19:48)
- Границу сообщений можно сделать массой разных способов, 0MQ не
серебряная пуля. Если размер сообщения известен в момент отправки,
то очевидно, можно каждое сообщение предварять его длиной. - fk0(10.07.2020 19:51)
- Как будто ZMTP под капотом делает что-то другое. Вообще суть
предложения была в том, чтобы не пытаться героически превозмогать
многопоточную задачу, а перевести ее в однопоточку брокера
сообщений - lloyd(10.07.2020 19:54)
- Вызвать write() для записи в пайп -- это героическое превозмогание?
Почему бы за уши не притянуть ещё всяких брокеров, они ж такие
полезные. А потом с этом всем попытаться взлететь... - fk0(10.07.2020 19:57)
- Я так полагаю самая сложная задача - не в файл записать, а данные получить. Но пусть ТС меня поправит - lloyd(10.07.2020 20:02)
- Вызвать write() для записи в пайп -- это героическое превозмогание?
Почему бы за уши не притянуть ещё всяких брокеров, они ж такие
полезные. А потом с этом всем попытаться взлететь... - fk0(10.07.2020 19:57)
- Как будто ZMTP под капотом делает что-то другое. Вообще суть
предложения была в том, чтобы не пытаться героически превозмогать
многопоточную задачу, а перевести ее в однопоточку брокера
сообщений - lloyd(10.07.2020 19:54)
- Границу сообщений можно сделать массой разных способов, 0MQ не
серебряная пуля. Если размер сообщения известен в момент отправки,
то очевидно, можно каждое сообщение предварять его длиной. - fk0(10.07.2020 19:51)
- А вот затем, что см. комментарий выше - 0MQ обеспечивает границу
сообщений на любом транспорте (межпотоковый, межпроцессный, TCP).
Там получаешь или все, или ничего (такое тоже бывает) - lloyd(10.07.2020 19:48)