ReSQL.ru
     
powered by simpleCommunicator - 2.0.29     © 2024 Programmizd 02
Мобильная версия    Контакт    Правила    FAQ    Помощь
Map
Доб. в избранное | Игнор. тему | Прикреп. тему | Пометить прочит. / непрочит. | Фильтр
Форумы / Java [игнор отключен] [закрыт для гостей] / Spring @Async - увеличение пула в реальном времени ?
13 сообщений из 38, страница 2 из 2
  2  все
Spring @Async - увеличение пула в реальном времени ?
    #40124926
вадя
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
вадя
Участник
Андрей Панфилов,

автор, что в коте врублен http/2совсем не обязательно
...
Рейтинг: 0 / 0
06.01.2022, 05:23
| Ответить | Цитировать | Написать  
Spring @Async - увеличение пула в реальном времени ?
    #40124955
lleming
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
lleming
Участник
Андрей Панфилов
Stanislav Bashkyrtsev
Если мы приняли соединение, не верю что это сработает. Да, мы получим ошибку когда начнем писать в сокет потому что тот окажется закрытым. Но это произойдет уже в конце, когда мы провели всю работу с БД. Чтоб суметь оборвать БД запрос - это нужно в самом Томкате знать про БД (и если бы это и могло работать, то только с пулом самого томката), в общем звучит unreal.


Вы не верите только из-за того, что разработчики редко используют фичу, уже ставшую де-факто стандартом :) (Вади не хватает, он бы все здесь разрулил) Я специально проверил и повторно убедился что оно работает, а именно:
- создал сервлет с Thread.sleep()
- вызвал его из curl, жамкнул Ctrl+C - в org.apache.tomcat.util.net.SocketWrapperBase#close приехала инфа, что клиент разорвал соединение
- вызвал из браузера и закрыл браузер - в org.apache.tomcat.util.net.SocketWrapperBase#close опять же приехала инфа, что клиент разорвал соединение

однако прежде чем бросаться проверять, убедитесь, что в коте врублен http/2 и настроен ssl, и вы хорошо дунули, а то фокуса не получится. Прерывать запросы в БД после отвала клиента - это уже дело техники, нужно всего-то уметь Statement#executeXXX ассоциировать с потоком.


Хм не воспоизвелось. Правда пока еще не получилось уровень логирования у томката повысить
...
Рейтинг: 0 / 0
06.01.2022, 13:44
| Ответить | Цитировать | Написать  
Spring @Async - увеличение пула в реальном времени ?
    #40124956
lleming
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
lleming
Участник
пардон, вчера два часа просидел не мог включить логирование, нужен был свежий взгляд (для http2 отдельный нужно расскоментировать строку если вдруг кто попробует)

org.apache.coyote.http2.level = FINE
...
Рейтинг: 0 / 0
06.01.2022, 13:48
| Ответить | Цитировать | Написать  
Spring @Async - увеличение пула в реальном времени ?
    #40124958
lleming
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
lleming
Участник
вадя
Андрей Панфилов,

автор, что в коте врублен http/2
совсем не обязательно

на http1.1 ворнига о разрыве соединения нет, на http2 есть

видимо особенности http2 требуется постоянно отслеживать соединение из за мультиплекирования. в http1.1 после того запрос ушел уже неважно.

насколько помню всегда для http1.1 было что бакенд как готово ответить пишет в outputstream и тут прилетает IOException что outputstream уже закрыть из за разрыва соединения. Но я не был уверен что томкат отслеживает разрыв соединения.
...
Рейтинг: 0 / 0
06.01.2022, 13:55
| Ответить | Цитировать | Написать  
Spring @Async - увеличение пула в реальном времени ?
    #40124977
вадя
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
вадя
Участник
lleming
на http1.1 ворнига о разрыве соединения нет, на http2 есть
более детально об условиях проверки
у меня есть отработка обрыва.
...
Рейтинг: 0 / 0
06.01.2022, 15:32
| Ответить | Цитировать | Написать  
Spring @Async - увеличение пула в реальном времени ?
    #40124978
вадя
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
вадя
Участник
у меня тоакое
Код: java
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
15.
@ServerEndpoint(value = "/WS_server", configurator = WsServerConfigurator.class)
public class WS_server {

 @OnOpen
    public void OnOpen(EndpointConfig endpointConfig, Session userSession) {
....
}

 @OnClose
    public void onClose(Session userSession, CloseReason reason) {
      .....
      System.out.println("  Cod " + reason.getCloseCode().getCode() + "  " + reason.getReasonPhrase());
}

}


Код: java
1.
2.
3.
4.
5.
6.
7.
8.
9.
public class WsServerConfigurator extends ServerEndpointConfig.Configurator {
    @Override
    public void modifyHandshake(ServerEndpointConfig sec, HandshakeRequest request, HandshakeResponse response) {

       .....
      
    }

}
...
Рейтинг: 0 / 0
06.01.2022, 15:49
| Ответить | Цитировать | Написать  
Spring @Async - увеличение пула в реальном времени ?
    #40124980
lleming
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
lleming
Участник
вадя
у меня тоакое
Код: java
1.
2.
3.
4.
5.
6.
7.
8.
9.
10.
11.
12.
13.
14.
@ServerEndpoint(value = "/WS_server", configurator = WsServerConfigurator.class)
public class WS_server {

 @OnOpen
    public void OnOpen(EndpointConfig endpointConfig, Session userSession) {
....
}

 @OnClose
    public void onClose(Session userSession, CloseReason reason) {
.....
}

}


Код: java
1.
2.
3.
4.
5.
6.
7.
8.
9.
public class WsServerConfigurator extends ServerEndpointConfig.Configurator {
    @Override
    public void modifyHandshake(ServerEndpointConfig sec, HandshakeRequest request, HandshakeResponse response) {

       .....

    }

}



это websocket и тут тоже логично, нет в чистом ввиде запрос ответ, данные в обе стороны ходят и требуется постоянно отслеживать соединение (там вроде даже чтото вроде пинга предустотрено в спеке вебсокета так что можно отслеживать)
...
Рейтинг: 0 / 0
06.01.2022, 15:52
| Ответить | Цитировать | Написать  
Spring @Async - увеличение пула в реальном времени ?
    #40124991
вадя
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
вадя
Участник
lleming
требуется постоянно отслеживать соединение
это требуется для проверки физического разрыва соединения, у меня сложилось такое мнение.
...
Рейтинг: 0 / 0
06.01.2022, 17:37
| Ответить | Цитировать | Написать  
Spring @Async - увеличение пула в реальном времени ?
    #40125008
Roman Osipov
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
Roman Osipov
Гость
mayton
Андрей Панфилов
пропущено...


Я это место никогда не понимал и до сих пор не понимаю: вот если мы уже проделали некоторую полезную работу, а потом решили что нужно что-то выполнить асинхронно, а нам на submit выкидывают RejectedExecutionException - что с этим исключением делать? как его компенсировать?

100% согласен. Я-бы вообще не накладывал ограничений на длину очереди задач. Вот сколько памяти - столько пускай и растет.
Но алёрты и мониторинг на PROD должны быть выставлены в какой-то 99й процентиль очереди. Пускай
превышение очереди будет просто сигналом о другой проблеме. Например о том что пул не справляется.


Предполагаю, что ограничение на очередь задач в пуле выполняет примерно такую же роль, как ограничение на длину массива, или ограничение на деление на ноль. В норме пул задач наверное должен быть обернут логикой, не должно быть у клиентов прямого доступа к пулу и возможности неограниченно субмитить задачи в пул. И если случилось переполнение очереди задач пула, то это ошибка где-то в логике оболочки пула.
...
Рейтинг: 0 / 0
06.01.2022, 19:02
| Ответить | Цитировать | Написать  
Spring @Async - увеличение пула в реальном времени ?
    #40125014
вадя
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
вадя
Участник
вот тут
https://habr.com/ru/company/superjob/blog/598857/
некоторые "исследования" по схожей теме, хоть и о php, но есть что-то и про пул.
...
Рейтинг: 0 / 0
06.01.2022, 19:13
| Ответить | Цитировать | Написать  
Spring @Async - увеличение пула в реальном времени ?
    #40125033
PetroNotC Sharp
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
PetroNotC Sharp
Участник
Roman Osipov,

Вы не охватите все многообразие задач.
Вполне могут существовать задачи в созвездии Пса, при которых юзер кидает столько задачек, сколько ему захотелось.
По примеру архивирования файлов.
Выделите весь диск С: и нажмите архивировать.
Вы просто будете ждать бесконечно.
Но это обратная связь.
Будете умнее в след.раз.
...
Рейтинг: 0 / 0
06.01.2022, 21:27
| Ответить | Цитировать | Написать  
Spring @Async - увеличение пула в реальном времени ?
    #40125048
Фотография mayton
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
mayton
Участник
Я могу прикинуть задачу где ограничение на буферы имеет смысл. Это например ковейерная
обработка данных. Есть сет потоков. Они соединены в pipeline либо BlockingQueue либо Disruptor либо
просто самодельным буфером. Идея в том что скорость процессинга событий - неравномерная.
Где-то чтение запись в БД идет пачками. А процессинг - строго последовательно. И нам выгодно
ограничить очереди. Ведь скорость всего каравана равна скорости медленного верблюда. Но
ограничения на почтовые ящики - это просто мемори менеджмент. Мы экспериментально
подбираем такую среднюю длину очереди чтобы компенсировать выбросы скорости. И мы делаем
push в очередь блокирующим. Ничего отправитель подождет. Зато понятен лимит по памяти.
И мы сознательно идем на такое ограничение потому-что задача - фоновая. Никакой пользователь
за экраном не сидит и не ждет.
...
Рейтинг: 0 / 0
06.01.2022, 23:10
| Ответить | Цитировать | Написать  
Spring @Async - увеличение пула в реальном времени ?
    #40125079
PetroNotC Sharp
Скрыть профиль Поместить в игнор-лист Сообщения автора в теме
PetroNotC Sharp
Участник
mayton,
От таких задачек по топику рукой подать до другой архитектуры - Message oriented.
Чуть усложнил ТЗ и надо все выкинуть и переписать под выделенный сервер сообщений.
...
Рейтинг: 0 / 0
07.01.2022, 10:15
| Ответить | Цитировать | Написать  
13 сообщений из 38, страница 2 из 2
  2  все
Форумы / Java [игнор отключен] [закрыт для гостей] / Spring @Async - увеличение пула в реальном времени ?
Целевая тема:
Создать новую тему:
Автор:
Закрыть
Цитировать
Найденые пользователи ...
Разблокировать пользователей ...
Читали тему (0):
Читали форум (0):
Пользователи онлайн (0):
Польз. соглашение
NoSQL.ru, Чат Кролика       Пашэ: Рисунки, Чат       Фотоальбом: Участники, Встречи
Закрыть
start [/forum/topic.php?fid=59&gotonew=1&tid=2120269]:
 0ms
get settings:
 13ms
get forum list:
 14ms
check forum access:
 4ms
check topic access:
 4ms
track hit:
 44ms
get topic data:
 10ms
get first new msg:
 8ms
get forum data:
 3ms
get page messages:
 303ms
get tp. blocked users:
 1ms
others: 14ms
total:  418ms
созд. / загр.: 418ms
x
x
Закрыть


Просмотр
0 / 0
Close
Debug Console [Select Text]