Z
Size: a a a
2020 December 11
ВС
но там нет управления сетями, а если тесты запускаются внутри контейнера с сокетом, нужно наводить сеть между ними
FL
А есть кто nomad юзает?
DN
А есть кто nomad юзает?
Есть
FL
Есть
Могу по stateful спросить?
На примере муськи
На примере муськи
D
господа
а кто-то юзает https://github.com/gorilla/websocket ?
сколько коннектов выдерживает при активном общении клиентов между собой ?
у меня на 2к коннектах которые раз в 10 секунд шлют сообщение которое потом рестранслируется остальным проц уходит в 99% нагрузки,pprof говорит что основная нагрузка идет на syscall.Syscall
а кто-то юзает https://github.com/gorilla/websocket ?
сколько коннектов выдерживает при активном общении клиентов между собой ?
у меня на 2к коннектах которые раз в 10 секунд шлют сообщение которое потом рестранслируется остальным проц уходит в 99% нагрузки,pprof говорит что основная нагрузка идет на syscall.Syscall
П
раз в 10 секунд происходит рассылка 2k*2k(4 миллиона) сообщений
ВС
можно покрутить размер ReadBufferSize, WriteBufferSize, чтобы уменьшить число системных вызовов, но цена этому будет увеличение задержки доставки
Z
господа
а кто-то юзает https://github.com/gorilla/websocket ?
сколько коннектов выдерживает при активном общении клиентов между собой ?
у меня на 2к коннектах которые раз в 10 секунд шлют сообщение которое потом рестранслируется остальным проц уходит в 99% нагрузки,pprof говорит что основная нагрузка идет на syscall.Syscall
а кто-то юзает https://github.com/gorilla/websocket ?
сколько коннектов выдерживает при активном общении клиентов между собой ?
у меня на 2к коннектах которые раз в 10 секунд шлют сообщение которое потом рестранслируется остальным проц уходит в 99% нагрузки,pprof говорит что основная нагрузка идет на syscall.Syscall
А сискол что?
ВС
или буферизовать более верхнеуровнево сообщения (сбрасывать буфер либо по достижении определенного размера, либо по таймауту)
DP
но в целом порядок примерно такой да, 2к клиентов шлют друг другу сообщения
по чути такой себе чат
по чути такой себе чат
Это много. Надо агрегировать сообщения, слать пачками
D
Это много. Надо агрегировать сообщения, слать пачками
сообщения пишутся в канал горутины на отправку каждому клиента
как только приходит сообщение то горутина выгребает все что есть в канале и высылает одной пачкой
как только приходит сообщение то горутина выгребает все что есть в канале и высылает одной пачкой
D
можно покрутить размер ReadBufferSize, WriteBufferSize, чтобы уменьшить число системных вызовов, но цена этому будет увеличение задержки доставки
спасибо, погляжу
подумываю взять мейлрушный вебсокет сервер, вроде как, они держат 3 млн соединений
подумываю взять мейлрушный вебсокет сервер, вроде как, они держат 3 млн соединений
ВС
можно встать select-ом на 2 канала: с сообщениями и с time.After
при получении сообщения из 1-го append-ить его в слайс (и если там >N элементов, отправлять их), при срабатывании time.After просто отправлять все сообщения
при получении сообщения из 1-го append-ить его в слайс (и если там >N элементов, отправлять их), при срабатывании time.After просто отправлять все сообщения