first commit #1
first commit #1
Conversation
mylocal/Server/Client.java
Outdated
| while (true) { | ||
|
|
||
| message = in.nextLine(); | ||
| byte[] dataSend = ByteBuffer.allocate(message.length() + MAKING_UP_SPACE_FOR_ACK_SEQ).put(message.getBytes(StandardCharsets.UTF_8)).array(); |
There was a problem hiding this comment.
message.length() выдает длину в символах юникода, а ByteBuffer.allocate принимает аргументом размер в байтах. Из за этого вылетит ошибка переполнения буфера в тех случаях, когда в строке встречаются символы, которые в UTF-8 кодируются не одним байтом (например, кириллица).
Нужно вынести message.getBytes(StandardCharsets.UTF_8) в отдельную переменную, затем вместо message.length() использовать длину этого массива.
mylocal/Server/Client.java
Outdated
| private static final String ACK_EQUALS = ", ACK="; | ||
| public static void main(String[] args) throws IOException { | ||
| InetAddress inetAddress = InetAddress.getLocalHost(); | ||
| DatagramSocket client = new DatagramSocket(); |
There was a problem hiding this comment.
Сокет нужно закрывать, по-хорошему в try-with-resources.
mylocal/Server/Client.java
Outdated
|
|
||
| public class Client { | ||
| private static final byte STARTER=1; | ||
| private static final int SET_SEQ =2; |
There was a problem hiding this comment.
Исправь форматирование, нажми ctrl+alt+l хотя бы.
mylocal/Server/Client.java
Outdated
| dataSend[dataSend.length - SET_SEQ] = SEQ; | ||
| dataSend[dataSend.length - SET_ACK] = ACK; | ||
| DatagramPacket pktSend = new DatagramPacket(dataSend, dataSend.length, inetAddress, PORT); | ||
| client.send(pktSend); |
There was a problem hiding this comment.
Всё ещё client.send(pktSend) два раза в коде, а мог бы быть один. Внеси в цикл.
mylocal/Server/Client.java
Outdated
|
|
||
| byte[] buf = new byte[SIZE_BUF]; | ||
| DatagramPacket reply = new DatagramPacket(buf, buf.length); | ||
| for (int i = STARTER_COUNT; i <= REPEAT_SENDS; i++) { |
There was a problem hiding this comment.
Тут даже IDE подсвечивает, что условие цикла не имеет смысла. Твой цикл всегда завершается изнутри, либо по break, либо по System.exit().
Тогда это либо должен быть ещё один while(true) (не советую), либо условие должно работать. Для этого можно, скажем, вынести переменную i наружу и дать ей имя, затем уже после цикла проверять, не равна ли она максимуму и выбрасывать ошибку.
mylocal/Server/Client.java
Outdated
|
|
||
| byte[] buf2; | ||
| buf2 = reply.getData(); | ||
| String answer = new String(buf2); |
There was a problem hiding this comment.
Дублирование кода между Client и Server. Можно в какой-нибудь Util класс вынести.
mylocal/Server/Server.java
Outdated
| private static final boolean FLAG_FALSE=false; | ||
| public static void main(String[] args) throws IOException { | ||
| try (DatagramSocket server = new DatagramSocket(PORT, InetAddress.getLocalHost())) { | ||
|
|
There was a problem hiding this comment.
Однозначно не хватает хотя бы базового рукопожатия. Я прощу, что seq и ack не имеют здесь смысла, кроме длины, но пусть будет хотя бы проверка того, что общение между клиентом и сервером вообще возможно до того, как мы начнем отправлять основные пакеты.
No description provided.