AO
Ну и с точки зрения openapi это тоже полная дичь
Size: a a a
2020 March 19
А
Кто то знает готовые движки на джава для создания онлайн чата(только для пользователей)?
C
Кто то знает готовые движки на джава для создания онлайн чата(только для пользователей)?
есть видеочат 🤔
K
Всем привет. В приложении oom, притом всю память съедает ThreadPoolExecutor. Само приложение получает данные из раббит и пересылает их по вебсокет(spring 5). Как можно определить кто виновник?) ссылка на скрин - https://ibb.co/S7fpPDt
VI
Всем привет. В приложении oom, притом всю память съедает ThreadPoolExecutor. Само приложение получает данные из раббит и пересылает их по вебсокет(spring 5). Как можно определить кто виновник?) ссылка на скрин - https://ibb.co/S7fpPDt
а ThreadPoolExecutor ограничен количеством?
VI
но по скрину выглядит, как будто вы забиваете массив до отказа, просто пихая в него без остановки
VI
тут что угодно по памяти упадет
K
а ThreadPoolExecutor ограничен количеством?
я его явно нигде не использую, только в качестве настройки по пингу вебсокета :
@Override
public void configureMessageBroker(MessageBrokerRegistry config) {
ThreadPoolTaskScheduler pingScheduler = new ThreadPoolTaskScheduler();
pingScheduler.initialize();
config.enableSimpleBroker(SOCKET_BROKER).setHeartbeatValue(new long[]{1000, 0}).setTaskScheduler(pingScheduler);
config.setApplicationDestinationPrefixes(SOCKET_APPLICATION_DESTINATION);
}
AO
У вас просто тредпул видимо не успевает разгребать таски
VI
я его явно нигде не использую, только в качестве настройки по пингу вебсокета :
@Override
public void configureMessageBroker(MessageBrokerRegistry config) {
ThreadPoolTaskScheduler pingScheduler = new ThreadPoolTaskScheduler();
pingScheduler.initialize();
config.enableSimpleBroker(SOCKET_BROKER).setHeartbeatValue(new long[]{1000, 0}).setTaskScheduler(pingScheduler);
config.setApplicationDestinationPrefixes(SOCKET_APPLICATION_DESTINATION);
}
т.е. новый тредпул на каждый пинг?
просто кусок кода ни о чем, кроме этого, ни сказал
просто кусок кода ни о чем, кроме этого, ни сказал
K
это я с теста скинул, так там 50 сек стоит
VI
ну "пул" как бы намекает, что надо не стартовать новый, а использовать из пула уже созданные
а тут чет как-то не оч
а тут чет как-то не оч
K
я как то не очень понимаю как точно тут определить кто генерит эти пулы. Этот setHeartbeatValue или может SimpMessagingTemplate когда сообщения шлет юзеру
DS
Всем привет. В приложении oom, притом всю память съедает ThreadPoolExecutor. Само приложение получает данные из раббит и пересылает их по вебсокет(spring 5). Как можно определить кто виновник?) ссылка на скрин - https://ibb.co/S7fpPDt
Добавь флаги при запуске -XX:+HeapDumpOnOutOfMemoryError -XX:HeapDumpPath=<file-or-dir-path>
А когда упадет идешь смотреть, что же там такое большое
А когда упадет идешь смотреть, что же там такое большое
VS
Всем привет. В приложении oom, притом всю память съедает ThreadPoolExecutor. Само приложение получает данные из раббит и пересылает их по вебсокет(spring 5). Как можно определить кто виновник?) ссылка на скрин - https://ibb.co/S7fpPDt
Нужно на этом LinkedBlockingQueue нажать правой кнопкой, и потом retained set
VS
А по-хорошему, нужно бы очередь заменить на очередь ограниченного размера. Тогда при превышении его будут лететь иксепшны «занято, приходите позже»
K
А по-хорошему, нужно бы очередь заменить на очередь ограниченного размера. Тогда при превышении его будут лететь иксепшны «занято, приходите позже»
я пришел к выводу, что у меня на каждый входящий message в вебсокет, создается org.springframework.messaging.support.ExecutorSubscribableChannel$SendTask судя по дампу. и они остаются висеть
VI
я пришел к выводу, что у меня на каждый входящий message в вебсокет, создается org.springframework.messaging.support.ExecutorSubscribableChannel$SendTask судя по дампу. и они остаются висеть
Я про это выше говорил