Тузиков Александр, ИТМО DWS, Stage 6 #217
Conversation
# Conflicts: # src/main/java/ru/vk/itmo/test/tuzikovalexandr/Server.java # src/main/java/ru/vk/itmo/test/tuzikovalexandr/ServerImpl.java # src/main/java/ru/vk/itmo/test/tuzikovalexandr/ServiceImpl.java
![codeclimate[bot]](https://avatars.githubusercontent.com/in/9403?s=60&v=4){kind=small}
| import java.nio.charset.StandardCharsets; | ||
| import java.util.Iterator; | ||
|
|
||
| public class StreamResponse extends Response { |
There was a problem hiding this comment.
если были на разборе 6го этапа, то наверное уже поняли что в этом решении вы потенциально все данные можете запихать в память, если с сетью какие-то проблемы
Тут надо обратить внимание на то что под капотом у sesion.write() и попробовать реализовать иенно асинхронную запись
There was a problem hiding this comment.
То есть надо было оставаться на том же алгоритме, что и у one.nio? Что мы можем не до конца сразу все записать, а вернуться к этому потом?
There was a problem hiding this comment.
да, надо запоминать сколько мы записали, а далее по событию о том что сеть опять готова на запись - записать остальное
| byte[] entrySize = Integer.toHexString(keyInBytes.length + valueInBytes.length + Constants.NEW_LINE.length) | ||
| .getBytes(StandardCharsets.UTF_8); | ||
|
|
||
| byte[] resultValue = new byte[keyInBytes.length + valueInBytes.length + Constants.NEW_LINE.length |
There was a problem hiding this comment.
ну и достаточно много лишних аллокаций, которых можно было бы избежать.
Есть два варианта:
- Использовать какие-то пулы буфферов
- Попробовать писать в сокет прямо из MemorySegment-a
There was a problem hiding this comment.
Да, по аллокациям вообще ужас получился, страшно смотреть. Буду пробовать исправлять
|
поправьте конфликт пожалуйста чтобы смежить |
# Conflicts: # src/main/java/ru/vk/itmo/test/tuzikovalexandr/ServiceImpl.java
Отчет в директории result/stage6 report.md
Хотел реализовать с использованием processWrite, но что-то не работало ничего(