Как да създадете собствен протокол за сериализация…

За да създадете собствен протокол за сериализация в Java, е необходимо да определите формат на данните и да реализирате логика за четене/запис.

Определяне на формата на данните: Решете как обектите ще бъдат представени във байтов формат. Това може да бъде бинарен формат (по-компактен) или текстов (по-лесен за четене). Например, може да използвате префикс за дължина преди полетата.
Реализиране на четене и запис:
- Създайте клас MySerializer (или подобен), който ще съдържа методите serialize и deserialize.
- Методът serialize ще приема обект и OutputStream, записвайки байтовете на обекта във потока според определения формат.
- Методът deserialize ще приема InputStream и ще възстановява обекта от байтовете.
Маркиране на класове за сериализация: Класовете, които трябва да бъдат сериализирани, трябва да имат механизъм за взаимодействие със сериализатора. Това може да бъде:
- Реализация на интерфейса Serializable (но тогава ще се използва стандартният механизъм на Java).
- Определяне на потребителски методи writeObject и readObject (аналогично на readObject и writeObject за стандартната сериализация, но със собствена сигнатура).
- Използване на анотации за указване на полетата, които трябва да бъдат сериализирани, и техния ред.
Обработка на препратки към обекти: Разгледайте как ще се сериализират обекти с циклични препратки или дублиращи се препратки към един и същи обект. Може да се използва механизъм за запазване на ID на обектите.
Обработка на версии: Предвидете как ще се извършва десериализацията на данни, сериализирани в по-стара версия на протокола.

Пример за базова реализация (без обработка на сложни случаи):

import java.io.ByteArrayInputStream;
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;

public class MySerializer {

    // Записва цяло число
    public void writeInt(OutputStream os, int value) throws IOException {
        os.write((value >>> 24) & 0xFF);
        os.write((value >>> 16) & 0xFF);
        os.write((value >>> 8) & 0xFF);
        os.write((value >>> 0) & 0xFF);
    }

    // Чете цяло число
    public int readInt(InputStream is) throws IOException {
        int value = 0;
        value = (is.read() << 24);
        value |= (is.read() << 16);
        value |= (is.read() << 8);
        value |= (is.read() << 0);
        return value;
    }

    // Записва низ
    public void writeString(OutputStream os, String value) throws IOException {
        byte[] bytes = value.getBytes("UTF-8");
        writeInt(os, bytes.length); // Записва дължината
        os.write(bytes); // Записва байтовете
    }

    // Чете низ
    public String readString(InputStream is) throws IOException {
        int length = readInt(is); // Чете дължината
        byte[] bytes = new byte[length];
        is.read(bytes); // Чете байтовете
        return new String(bytes, "UTF-8");
    }

    // Пример за сериализация на обект Person
    public void serialize(OutputStream os, Person person) throws IOException {
        writeString(os, person.getName());
        writeInt(os, person.getAge());
    }

    // Пример за десериализация на обект Person
    public Person deserialize(InputStream is) throws IOException {
        String name = readString(is);
        int age = readInt(is);
        return new Person(name, age);
    }

    // Вспомагателен клас
    public static class Person {
        private String name;
        private int age;

        public Person(String name, int age) {
            this.name = name;
            this.age = age;
        }

        public String getName() {
            return name;
        }

        public int getAge() {
            return age;
        }
    }

    public static void main(String[] args) throws IOException {
        MySerializer serializer = new MySerializer();
        Person originalPerson = new Person("Alice", 30);

        ByteArrayOutputStream baos = new ByteArrayOutputStream();
        serializer.serialize(baos, originalPerson);
        byte[] serializedData = baos.toByteArray();

        ByteArrayInputStream bais = new ByteArrayInputStream(serializedData);
        Person deserializedPerson = serializer.deserialize(bais);

        System.out.println("Original: " + originalPerson.getName() + ", " + originalPerson.getAge());
        System.out.println("Deserialized: " + deserializedPerson.getName() + ", " + deserializedPerson.getAge());
    }
}

Създаването на собствен протокол изисква внимателно планиране и вземане предвид на множество фактори като производителност, компактност, версионност и обработка на сложни структури данни. Често се използват вече съществуващи библиотеки (ProtoBuf, Kryo, Avro) вместо създаване на протокол от нулата.

Как да създадете собствен протокол за сериализация?