NodeJS + socket.io + mongoDB. Где утечка памяти?

Question

[Максим Болтик]

Есть простой эхо сокет сервер реализованный на nodejs и socket.io.
Каждое сообщение принятое сокет сервером пишется в mongoDB.
При тестировании сокет сервера утилитой websocket-bench, создается 3000 одновременных соединений, которые шлют по одному сообщению каждую секунду, начинает линейно расти память до бесконечности.
При 2000 соединений и 2000 сообщений в секунду проблемы нет.
Запуск сокет сервера с --nouse-idle-notification и --expose-gc + вызов GC вручную, результатов не дает.
Сокет сервер запущен в один поток.
Это утечка памяти или сокет сервер таким образом не справляется с нагрузкой? Если утечка, то подскажите пожалуйста где.
Ссылка на гитхаб с кодом сокет сервера https://github.com/MaxBoltik/echo-socket-server/bl...

Comments

[Илья Шатохин]

"var message = {};" за пределами асинхронного события "socket.on('message')" - выстрел в ногу.

[Максим Болтик]

Илья Шатохин: Это оказывает влияние на утечку?

[Илья Шатохин]

Максим Болтик: Вряд ли. Но просто потом в базе можно получить совсем не то, что ожидали.

[Илья Шатохин]

Максим Болтик: и, да, какая версию node используется?

[Максим Болтик]

Илья Шатохин: С логической ошибкой полностью согласен. Node v5.9.1. Пробовал разные.

[Илья Шатохин]

Максим Болтик: хм, тогда не подскажу, последний раз утечку socket.io наблюдал на 0.12 ноде, на 4ой и 5ой у нас проблем нет.

[Максим Болтик]

Илья Шатохин: А какая у вас нагрузка на на один поток ноды, сообщений/сек.

[Илья Шатохин]

Максим Болтик: не замерял, но точно не тысячи участников в секунду, все намного скромнее (всего лишь несколько человек онлайн постоянно).

Answer 1

[Сергей Протько]

вызов GC вручную

И как это могло бы помочь интересно.

сокет сервер таким образом не справляется с нагрузкой?

если там есть внутри буфер сообщений на отправку - то вполне может просто не успевать отправлять сообщеньки.

Comments

[Максим Болтик]

Не совсем понимаю про "буфер сообщений на отправку". Можете глянуть исходник, там 40 строк?

[Сергей Протько]

Максим Болтик: это надо исходники socket-io смотреть.

[Сергей Протько]

Максим Болтик: да, у socket-io а точнее в тамошней обертке над сокетами есть writeBuffer, можно в эту сторону смотреть.

Answer 2

[Дмитрий Беляев]

Утечка в массиве CLIENTS, он не очищается никогда
причина socket.on('disconnect') у socket.io сделано через одно место, как и сам socket.io
если быть совсем точным, этого события не произойдет, пока Вы не попытаетесь что-то записать в сокет

Comments

[Максим Болтик]

Каждую секунду, сокет сервер в консоли сообщает данные о CLIENTS, а так же количестве сообщений и использовании памяти. И на сколько я видел, массив CLIENTS очищается. Может быть был такой баг в ранних версиях socket.io?