VPF::class to byte[] - Форум программистов

Ak47black

Дата 20.5.2010, 20:43 (ссылка)

(нет голосов)

Загрузка ...

Эксперт

Профиль
Группа: Завсегдатай
Сообщений: 2205
Регистрация: 2.12.2005

Репутация: нет
Всего: 0

Здравствуйте.
Вот такая ситуация
есть класс

Код


    public class TransportPacket
    {
        byte port;
        byte flag;
        short size;
        byte[] data;
    }

ищу функцию, которая-бы переводила-бы переменную структуры в byte[].
Как лучше сделать?

Другими словами делаю модель сетевых протоколов и мне нужно сначала заполнить структуру TransportPacket, а потом получить byte[] из этой структуры что-бы передать нижнему уровню.

dobrolub

Дата 20.5.2010, 20:59 (ссылка)

(нет голосов)

Загрузка ...

Опытный

Профиль
Группа: Участник
Сообщений: 385
Регистрация: 18.12.2009
Где: Vancouver, Canada

Репутация: 11
Всего: 16

hessian – удобный бинарный протокол. рекомендую. http://hessian.caucho.com/

Ak47black

Дата 20.5.2010, 21:07 (ссылка)

(нет голосов)

Загрузка ...

Эксперт

Профиль
Группа: Завсегдатай
Сообщений: 2205
Регистрация: 2.12.2005

Репутация: нет
Всего: 0

Не я смысле сам пишу модель smile

Добавлено через 58 секунд
Мне просто надо найти функцию на которую я подаю структуру [+ размер] и получаю byte[].

Добавлено через 4 минуты и 13 секунд
Хотя в принципе я могу сам это всё дело написать.
Я просто хотел-бы узнать что уже есть стандартное.

pathfinder

Дата 20.5.2010, 21:22 (ссылка)

(нет голосов)

Загрузка ...

Шустрый

Профиль
Группа: Участник
Сообщений: 120
Регистрация: 3.3.2010

Репутация: 2
Всего: 10

Стандартно для этого применяются ObjectOutputStream(Object -> byte[]) и ObjectInputStream(byte[] -> Object)

Только объекты обязательно должны быть помечены как сериализуемые, для этого достаточно указать, что класс реализует интерфейс Serializable.

Единственное что останется сделать - это реализовать OutputStream и InputStream.

Т.е. Object -> byte[] будет выглядеть так

Код


OutputStreamImpl os = new OutputStreamImpl(); // реализует интерфейс OutputStream
ObjectOutputStream oos = new ObjectOutputStream(os);
oos.writeObject(somePacket);
oos.flush();

Это сообщение отредактировал(а) pathfinder - 20.5.2010, 21:25

Ak47black

Дата 20.5.2010, 21:37 (ссылка)

(нет голосов)

Загрузка ...

Эксперт

Профиль
Группа: Завсегдатай
Сообщений: 2205
Регистрация: 2.12.2005

Репутация: нет
Всего: 0

А вот так как-то получится у меня сделать?

Код


    public abstract class Packet implements Serializable
    {
        short size;
    }

    public class TransportPacket extends Packet implements Serializable
    {
        byte port;
        byte flag;
        byte[] data;
    }

И сама функция

Код


    public byte[] getBytes(Packet packet)
    {
        byte[] outdata = new byte[packet.size];
        System.arraycopy(packet, 0, outdata, 0, packet.size);
        return outdata;
    }

При выполнении
вот тут

Код


System.arraycopy(packet, 0, outdata, 0, packet.size);

получаю

Цитата

java.lang.ArrayStoreException

Функцию вызываю с

Код


packet.port = 20;
packet.flag = 1;
packet.size = 4;
packet.data = null;

Добавлено через 4 минуты и 27 секунд
По идее

Цитата

packet.port = 1 byte
packet.flag = 1 byte
packet.size = 2 byte
packet.data = 0 byte
--------------------------
всего = 4 bytes

Это сообщение отредактировал(а) Ak47black - 20.5.2010, 21:40

pathfinder

Дата 20.5.2010, 22:04 (ссылка)

(нет голосов)

Загрузка ...

Шустрый

Профиль
Группа: Участник
Сообщений: 120
Регистрация: 3.3.2010

Репутация: 2
Всего: 10

Все решение задачи заключается в реализации OutputStream, например вот так

Код


public class MyOutputStream {
    
    public MyOutputStream(int bufferSize) {
        buffer = new byte[bufferSize];
    }
    
    public void flush() {}
    
    public void close() {}
    
    public void write(byte[] b) {
        write(b, 0, b.length);
    }
    
    public void write(byte[] b, int off, int len) {
        canWrite(len);
        System.arraycopy(b, off, buffer, offset, len);
        offset += len;
    }
    
    public void write(int b) {
        canWrite(1);
        buffer[offset] = (byte) b;
        offset ++;
    }
    
    public void reset() {
        offset = 0;
    }
    
    public int bytesWroteSinceLast() {
        return offset;
    }
    
    public byte[] getWroteBytes() {
        byte[] b = new byte[offset];
        System.arraycopy(buffer, 0, b, 0, offset);
        return b;
    }
    
    void canWrite(int len) {
        if (offset + len > buffer.length) {
            throw new IllegalStateException("Buffer is overflow");
        }
    }
    
    /* DATA */
    byte[] buffer;
    int offset;
}

пользоваться этим вот так

Код


MyOutputStream os = new MyOutputStream(1024);
ObjectOutputStream oos = new ObjectOutputStream(os);

os.reset();
oos.writeObject(somePacket);
oos.flush();

byte[] barray = os.getWroteBytes();

Это сообщение отредактировал(а) pathfinder - 20.5.2010, 22:10

Ak47black

Дата 20.5.2010, 22:07 (ссылка)

(нет голосов)

Загрузка ...

Эксперт

Профиль
Группа: Завсегдатай
Сообщений: 2205
Регистрация: 2.12.2005

Репутация: нет
Всего: 0

Ну я хотел-бы всётаки сделать с моим кодом что-то.
Ведь по идее он почти рабочий. (так со стандартным я теперь вижу что труднее)

Это сообщение отредактировал(а) Ak47black - 20.5.2010, 22:09

pathfinder

Дата 20.5.2010, 22:16 (ссылка)

(нет голосов)

Загрузка ...

Шустрый

Профиль
Группа: Участник
Сообщений: 120
Регистрация: 3.3.2010

Репутация: 2
Всего: 10

В Java нельзя ссылку на объект интерпритировать как указатель на область памяти. System.arraycopy нельзя рассматривать как аналог функции memcopy.

Через ObjectOutputStream удобнее сразу же писать Socket.

Ak47black

Дата 20.5.2010, 22:25 (ссылка)

(нет голосов)

Загрузка ...

Эксперт

Профиль
Группа: Завсегдатай
Сообщений: 2205
Регистрация: 2.12.2005

Репутация: нет
Всего: 0

Не ну тут наверно как-то всеравно можно без ObjectOutputStream обойтись. Мне же только всеволищь нужно получить byte[]

COVD

Дата 20.5.2010, 22:35 (ссылка)

(нет голосов)

Загрузка ...

Эксперт

Профиль
Группа: Завсегдатай
Сообщений: 1655
Регистрация: 26.7.2005

Репутация: 17
Всего: 43

Код


import java.nio.ByteBuffer;

public class TransportPacket {
   
        byte port;
        byte flag;
        short size;
        byte[] data;

        public byte[] getBytes(){
            int capacity = 1 + 1 + 2 + data.length;
            ByteBuffer byteBuffer = ByteBuffer.allocate(capacity);
            byteBuffer.put(port);
            byteBuffer.put(flag);
            byteBuffer.putShort(size);
            byteBuffer.put(data);            
            return byteBuffer.array();
        }
        public static TransportPacket parseBytes(byte[] bytes){
            int capacity = bytes.length;
            ByteBuffer byteBuffer = ByteBuffer.allocate(capacity);
            byteBuffer.put(bytes);
            byteBuffer.flip();
            
            TransportPacket transportPacket = new TransportPacket();

            transportPacket.port = byteBuffer.get();
            transportPacket.flag = byteBuffer.get();
            transportPacket.size = byteBuffer.getShort();
            
            byte[] data = new byte[byteBuffer.remaining()];
            byteBuffer.get(data);
            transportPacket.data = data;
            
            return transportPacket;
        }    
}

Это сообщение отредактировал(а) COVD - 20.5.2010, 22:38

Ak47black

Дата 20.5.2010, 22:41 (ссылка)

(нет голосов)

Загрузка ...

Эксперт

Профиль
Группа: Завсегдатай
Сообщений: 2205
Регистрация: 2.12.2005

Репутация: нет
Всего: 0

Не у Вас не универсальная функция
Я просто будут делать классы для пакетов имеющие разные переменные, но все наследующие класс Packet который имеет поле size.

pathfinder

Дата 20.5.2010, 22:45 (ссылка)

(нет голосов)

Загрузка ...

Шустрый

Профиль
Группа: Участник
Сообщений: 120
Регистрация: 3.3.2010

Репутация: 2
Всего: 10

ObjectOutputStream это стандартный способ.

Ak47black

Дата 20.5.2010, 22:48 (ссылка)

(нет голосов)

Загрузка ...

Эксперт

Профиль
Группа: Завсегдатай
Сообщений: 2205
Регистрация: 2.12.2005

Репутация: нет
Всего: 0

Хорошо, а кто-нибудь может ещё как-то подправить мой код что-бы он работал?

pathfinder

Дата 20.5.2010, 22:50 (ссылка)

(нет голосов)

Загрузка ...

Шустрый

Профиль
Группа: Участник
Сообщений: 120
Регистрация: 3.3.2010

Репутация: 2
Всего: 10

Извиняюсь вопрос не понял. Способ COVD-а классный.

Ak47black

Дата 20.5.2010, 22:54 (ссылка)

(нет голосов)

Загрузка ...

Эксперт

Профиль
Группа: Завсегдатай
Сообщений: 2205
Регистрация: 2.12.2005

Репутация: нет
Всего: 0

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

Это сообщение отредактировал(а) Ak47black - 20.5.2010, 22:55

pathfinder

Дата 20.5.2010, 23:05 (ссылка)

(нет голосов)

Загрузка ...

Шустрый

Профиль
Группа: Участник
Сообщений: 120
Регистрация: 3.3.2010

Репутация: 2
Всего: 10

Ну дык в каждом классе и реализовывать метод предложенный COVD-ом

Ak47black

Дата 21.5.2010, 11:16 (ссылка)

(нет голосов)

Загрузка ...

Эксперт

Профиль
Группа: Завсегдатай
Сообщений: 2205
Регистрация: 2.12.2005

Репутация: нет
Всего: 0

А что-то пахожее как в C++ в jave нету?

pathfinder

Дата 21.5.2010, 11:35 (ссылка)

(нет голосов)

Загрузка ...

Шустрый

Профиль
Группа: Участник
Сообщений: 120
Регистрация: 3.3.2010

Репутация: 2
Всего: 10

Нету.

В паскале(практически так же как и в C) можно ссылку(указатель) на экземпляр структуры(класса) рассматривать как просто указатель на массив байтов размером со структуру(класс), и на этом оснавании не парится с сериализацией объектов(т.е. представлении их в виде непрерывной последовательности байт). В Java нету указателей(в том смысле что нельзя указатель рассматривать как ссылку на массив байтов), т.е. если есть скажем ссылка на объект object = new SomeObject(...), "размер" которого пусть будет равным 10 байтам, мы не можем написать что типа ((byte[]*)object)[5] и получить шестой байт, как это можно делать в языках поддерживающих указатели, а соответсвенно и прямую работу с памятью. Именно поэтому в Java приходится вручную сериализовывать объект.

Это сообщение отредактировал(а) pathfinder - 21.5.2010, 11:36

Ak47black

Дата 21.5.2010, 20:06 (ссылка)

(нет голосов)

Загрузка ...

Эксперт

Профиль
Группа: Завсегдатай
Сообщений: 2205
Регистрация: 2.12.2005

Репутация: нет
Всего: 0

pathfinder, я попробовал запустить Ваш код, но вижу
вот тут

Код


ObjectOutputStream oos = new ObjectOutputStream(os);

Цитата

cannot find symbol
symbol: constructor ObjectOutputStream(test.main.MyOutputStream)

А если делаю что-то похожее
например

Код


    public static byte[] getBytes(Packet packet){
        ByteArrayOutputStream dataStream = new ByteArrayOutputStream();
        ObjectOutputStream objectStream;
        try{
            objectStream = new ObjectOutputStream(dataStream);
            dataStream.reset();
            objectStream.writeObject(packet);
            objectStream.flush();
        }
        catch (Exception e) {
            e.printStackTrace();
        }

        byte[] datum = dataStream.toByteArray();
        return dataStream.toByteArray();
    }

то при пакете

Цитата

packet.port = 20;
packet.flag = 1;
packet.size = 4;
packet.data = null;

получаю размер данных тут

Код


byte[] datum = dataStream.toByteArray();

Аш 817 байт, что явно нетак.

Добавлено @ 20:06
Сами структуры

Код


public interface Structures
{
    public abstract class Packet
    {
        short size;
    }

    public class TransportPacket extends Packet
    {
        byte port;
        byte flag;
        byte[] data;
    }

}

Добавлено @ 20:08
Возможно-ли с таким подходом получить 4 байта, где

Цитата

packet.port = 1 byte
packet.flag = 1 byte
packet.size = 2 byte

?

Это сообщение отредактировал(а) Ak47black - 21.5.2010, 20:09

pathfinder

Дата 21.5.2010, 20:59 (ссылка)

(нет голосов)

Загрузка ...

Шустрый

Профиль
Группа: Участник
Сообщений: 120
Регистрация: 3.3.2010

Репутация: 2
Всего: 10

Для MyOutputStream забыл указать что он реализует интерфейс OutputStream )

По поводу размера - при сериализации средствами ObjectOutputStream(да и любыми другими) в массив добовляются дополнительные данные, что-бы можно было произвести десериализацию(магический заголовок, размер, наименование класса и тп), конкретно какие именно дополнительные данные добовляются надо смотреть в спецификации(тока она от версии к версии JVM может менятся).

Ak47black

Дата 21.5.2010, 21:19 (ссылка)

(нет голосов)

Загрузка ...

Эксперт

Профиль
Группа: Завсегдатай
Сообщений: 2205
Регистрация: 2.12.2005

Репутация: нет
Всего: 0

pathfinder,
ну в принципе понятно тогда.
Вроде теперь понимаю, что тема "мутная". Ну незнаю, думаю тогда врятли у меня получится сделать так удачно как это можно сделать в C/C+.... smile

pathfinder

Дата 21.5.2010, 21:42 (ссылка)

(нет голосов)

Загрузка ...

Шустрый

Профиль
Группа: Участник
Сообщений: 120
Регистрация: 3.3.2010

Репутация: 2
Всего: 10

Если пропускная способность канал вещь не критичная то использование ObjectOutputStream/ObjectInputStream оправдано и достаточно просто. Протокол вообще пишется на 1-2-3.

Как пример.

Код



public class QueryList {

    public static final int LOGIN_QUERY = 1;

}

public class CommonQuery implements Serializable {

    public int queryID; 
    
    protected CommonQuery(int queryID) {
        this.queryID = queryID;
    }

}

public class LoginQuery extends CommonQuery {

    public String user;
    public String password;
    
    public LoginQuery(String user, String password) {
        super(QueryList.LOGIN_QUERY);
        this.user = user;
        this.password = password;
    }

}

/* *** НА СТОРОНЕ КЛИЕНТА ******************************************* */
// инициализируются при подключении к серверу  ...
ObjectInputStream ois = new ObjectInputStream(socket.getInputStream());
ObjectOutputStream oos = new ObjectOutputStream(socket.getOutputStream());

// выполнение запроса к серверу
oos.writeObject(new LoginQuery(...));
CommonResult result = (CommonResult) ois.readObject();
if (result.queryID == QueryList.LOGIN_QUERY) {
    // обработка результата
} else {
    // ошибка протокола, запрос был Login, а релультат левый какой-то
}

/* *** НА СТОРОНЕ СЕРВЕРА ******************************************* */
ObjectInputStream ois = new ObjectInputStream(socket.getInputStream());
ObjectOutputStream oos = new ObjectOutputStream(socket.getOutputStream());

try {
    CommonQuery query = (CommonQuery) ois.readObject();
    switch (query.queryID) {
        case QueryList.LOGIN:
            LoginQuery loginQuery = (LoginQuery) query;
            // обрабатываем логин, формируем результат
            oos.writeObject( /* результат */ );
            break;
    }
} catch (Exception ex) {
    // обработка 
}

Ak47black

Дата 21.5.2010, 22:10 (ссылка)

(нет голосов)

Загрузка ...

Эксперт

Профиль
Группа: Завсегдатай
Сообщений: 2205
Регистрация: 2.12.2005

Репутация: нет
Всего: 0

Эмм... я только просто немного нето пищу.
А так в принципе я узнал то что хотел.
pathfinder, Спасибо Вам за помощь.

0 Пользователей читают эту тему (0 Гостей и 0 Скрытых Пользователей)
0 Пользователей:
« Предыдущая тема \| Java: Общие вопросы \| Следующая тема »