Чтение массива байтов (сервер-клиент)

@MrDead · Регистрация: 04.03.2014

Студворк — интернет-сервис помощи студентам

Всем привет. Столкнулся вот с такой задачей. В общем есть клиент-серверное приложение. Сервер отсылает данные клиенту через сокет, также клиент посылает данные серверу. Передача происходит по протоколу tcp, но как всем известно, передача пакетов может происходить частями и поэтому их надо склеивать. В общем то, сервер посылает клиенту пакет такого вида [длина4байта][тип2байта][дата]. Клиент всё нормально читает и разбирает. Там у меня получилось склеивать частицы пакетов.(клиент не на java). Но вот что с чтением пакетов и склеивание их со стороны сервера(когда клиент посылает данные, приходят такого же вида [длина4байта][тип2байта][дата]), вот тут начинаются проблемы. Что-то не догоню никак, какой буфер создавать для записи данных. Есть такой вот код. Все операции по чтению происходят

Java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
int offset;
offset = thisInput.read(_buffer, buffer_length, Client.MAX_BUFFER_SIZE);
                     try {
                        decode(_buffer);
                         
                     }
                     catch(Exception e) {
                         continue;
                     }
 
 
 private void decode(byte[] buff) throws Exception
 {
     if(_stateDecode == LENGTH)
     {
         
         length = (int)ByteBuffer.allocate(4).put(buff, position, 4).getInt(0);
        _stateDecode = TYPE;
        
     }else if(_stateDecode == TYPE)
     {
         _type = (short)ByteBuffer.allocate(2).put(buff, position, 2).getShort(0);
         _stateDecode = DATA;
        
     }else if(_stateDecode == DATA)
     {
        
//?????????????
        
     }
     decode(buff);
    
 }

Вот что писать мне, когда чтение доходит до DATA? На другом языке, создается класс наследованный от ByteArray

ActionScript 3
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
//Код, который идет после DATA на другом языке
_data = new PacketByteArray();
_data.writeBytes(buff, buff.position, length);
 
_data.position = 0;
buff.position += length;
 
_stateDecode = LENGTH;
//Тут собирается сообщение
var message:String = _data.toString();
 
if (buff.bytesAvailable === 0)
{
buff.clear();
throw new EOFError();
}
 
}
decode(buff);

Собственно, подскажите, как сделать подобную аналогию, но только на Java? Очень нужно, а с этими байтами и пакетами я плоховато разбираюсь.

@korvin_ · 03.02.2016, 20:58

Не по теме:

Господи, что за ужасный код...

Сообщение от MrDead

Что-то не догоню никак, какой буфер создавать для записи данных.

Java
1
2
3
byte[] data = new byte[length];
System.arraycopy(buff, position, data, 0, length);
String message = new String(data, "UTF-8");

Например.

Но я так и не понял _buffer — это уже склееные данные или нет. Если нет, то поля длинна и тип есть в каждом пакете одного сообщения или что?

@MrDead · 04.02.2016, 00:33 **[ТС]**

korvin_, В _buffer заносятся только что пришедшие данные. Можно сказать, что он общий для всех и из него судя по всему склеиваются пришедшие данные.

длинна и тип есть в каждом пакете одного сообщения

Именно так. Чтобы склеить пакеты, нужно получается создавать новый байт массив и если мы в нем смогли прочитать длинну и тип, значит пакет готов и можно прочитать заложенную в него информацию.

Добавлено через 2 часа 0 минут
В общем спасибо большое за подсказку. Поправил код немного. В общем то переписал полностью обработку полученных данных. Так то работает, правда попарится пришлось немного, но как всегда выручил дебаггер)) При ряде тестов, вроде бы теперь и сервер не переполняет буффер и все нормально доходит до него)

Добавлено через 1 час 7 минут
И да. Не постесняюсь спросить, в чем, собственно ужас у вас вызвал код?

@korvin_ · 04.02.2016, 03:37

Сообщение от MrDead

И да. Не постесняюсь спросить, в чем, собственно ужас у вас вызвал код?

Кроме адового форматирования, использования нестандартного стиля именования (snake_case), разделяемого состояния (stateDecode, position), рекурсии decode (где выход, кстати? Видимо, в кейсе DATA?) и базового класса Exception вместо специфических классов ошибок и ненужных кастов (int), (short)?

В общем, я бы написал как-то так:

Java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
import java.io.UnsupportedEncodingException;
import java.nio.ByteBuffer;
import java.util.Arrays;
import java.util.Collection;
 
public final class Packet {
 
    private static final byte[] EMPTY_DATA = {};
    private static final Packet EMPTY_PACKET = new Packet((short)0, null);
    private static final int LENGTH_SIZE = 4;
    private static final int TYPE_SIZE = 2;
    private static final int HEADER_SIZE = LENGTH_SIZE + TYPE_SIZE;
    
    private final short type;
    private final byte[] data;
    
    private Packet(final short type, final byte[] data) {
        this.type = type;
        this.data = data == null ? EMPTY_DATA : data;
    }
    
    public int getLength() {
        return data.length;
    }
    
    public int getFullLength() {
        return data.length + HEADER_SIZE;
    }
    
    public short getType() {
        return type;
    }
    
    public byte[] getData() {
        return Arrays.copyOf(data, data.length); // defensive copy
    }
    
    public String getDataString(final String charset) throws UnsupportedEncodingException {
        return new String(data, charset);
    }
    
    public void copyDataTo(final byte[] dest, final int destPos, final int pos, final int len) {
        System.arraycopy(this.data, pos, dest, destPos, len);
    }
    
    public void copyAllDataTo(final byte[] dest, final int destPos) {
        copyDataTo(dest, destPos, 0, this.data.length);
    }
    
    public static Packet read(final byte[] src, final int offset) {
        final ByteBuffer bb = ByteBuffer
                .allocate(HEADER_SIZE)
                .put(src, offset, LENGTH_SIZE)
                .put(src, offset+LENGTH_SIZE, TYPE_SIZE);
        final int length = bb.getInt(0);
        final short type = bb.getShort(LENGTH_SIZE);
        final byte[] data = new byte[length];
        System.arraycopy(src, offset+LENGTH_SIZE, data, 0, length);
        return new Packet(type, data);
    }
    
    public static Packet merge(final Collection<Packet> packets) {
        if (packets == null || packets.isEmpty()) {
            return EMPTY_PACKET;
        }
        final int totalLength = packets.stream().mapToInt(Packet::getLength).sum();
        final byte[] data = new byte[totalLength];
        int offset = 0;
        short type = 0;
        for (final Packet p : packets) {
            type = p.getType();
            p.copyAllDataTo(data, offset);
            offset = p.getLength();
        }
        return new Packet(type, data);
    }
}

Там, конечно, ещё нужны всякие проверки на отрицательные значения оффсетов и длин, а также на переполнения int и выходы за границы, но это ты как-нибудь сам. Да и вообще я тут некоторые вещи наванговал, т.к. не знаю, как ты там читаешь данные с сокета и объединяешь пакеты одного сообщения.

Новые блоги и статьи Все статьи Все блоги /
Расчёт переходных процессов в цепи постоянного тока igorrr37 16.01.2026 / * Дана цепь постоянного тока с R, L, C, k(ключ), U, E, J. Программа составляет систему уравнений по 1 и 2 законам Кирхгофа, решает её и находит токи на L и напряжения на C в установ. режимах до и. . .	Восстановить юзерскрипты Greasemonkey из бэкапа браузера damix 15.01.2026 Если восстановить из бэкапа профиль Firefox после переустановки винды, то список юзерскриптов в Greasemonkey будет пустым. Но восстановить их можно так. Для этого понадобится консольная утилита. . .	Изучаю kubernetes lagorue 13.01.2026 А пригодятся-ли мне знания kubernetes в России?	Сукцессия микоризы: основная теория в виде двух уравнений. anaschu 11.01.2026 https:/ / rutube. ru/ video/ 7a537f578d808e67a3c6fd818a44a5c4/
WordPad для Windows 11 Jel 10.01.2026 WordPad для Windows 11 — это приложение, которое восстанавливает классический текстовый редактор WordPad в операционной системе Windows 11. После того как Microsoft исключила WordPad из. . .	Classic Notepad for Windows 11 Jel 10.01.2026 Old Classic Notepad for Windows 11 Приложение для Windows 11, позволяющее пользователям вернуть классическую версию текстового редактора «Блокнот» из Windows 10. Программа предоставляет более. . .	Почему дизайн решает? Neotwalker 09.01.2026 В современном мире, где конкуренция за внимание потребителя достигла пика, дизайн становится мощным инструментом для успеха бренда. Это не просто красивый внешний вид продукта или сайта — это. . .	Модель микоризы: классовый агентный подход 3 anaschu 06.01.2026 aa0a7f55b50dd51c5ec569d2d10c54f6/ O1rJuneU_ls https:/ / vkvideo. ru/ video-115721503_456239114

Чтение массива байтов (сервер-клиент)

Решение