Kā izveidot savu serializācijas protokolu?

Lai izveidotu savu serializācijas protokolu Java, ir jādefinē datu formāts un jāievieš lasīšanas/ierakstīšanas loģika.

1. Definēt datu formātu: Izlemiet, kā objekti tiks attēloti baitu formātā. Tas var būt binārs formāts (kompakti, bet mazāk lasāms) vai teksta formāts (vairāk lasāms). Piemēram, var izmantot garuma prefiksu pirms laukiem.

2. Implementēt lasīšanu un rakstīšanu:

   • Izveidot klasi MySerializer (vai līdzīgu), kas saturēs metodes serialize un deserialize.
   • Metode serialize pieņems objektu un OutputStream, ierakstot objekta baitus sērijā atbilstoši noteiktajam formātam.
   • Metode deserialize pieņems InputStream un atjaunos objektu no baitiem.

3. Marķēt klases serializācijai: Klases, kuras nepieciešams serializēt, jāapgūst ar mehānismu, lai ar to sadarboties. Tas var būt:

   • Serializable interfeisa īstenošana (bet tad tiks izmantots standarta Java mehānisms).
   • Lietotāja definēti metodi writeObject un readObject (līdzīgi kā readObject un writeObject standarta serializācijā, bet ar savu parakstu).
   • Anotāciju izmantošana, lai norādītu laukus, kas jāserializē, un to kārtību.

4. Atsauces apstrāde: Apsveriet, kā tiks serializēti objekti ar cikliskām atsaucēm vai dublētām atsaucēm uz to pašu objektu. Var izmantot ID mehānismu.

5. Versiju apstrāde: Plānojiet, kā tiks veikta deserializācija no vecākas protokola versijas datiem.

Piemērs pamata realizācijai (bez sarežģītu gadījumu apstrādes):

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

public class MySerializer {

    // Raksta vesela skaitļa lauku
    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);
    }

    // Lasīs vesela skaitļa lauku
    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;
    }

    // Raksta teksta lauku (vienkāršs veids: garums + teksta baiti)
    public void writeString(OutputStream os, String value) throws IOException {
        byte[] bytes = value.getBytes("UTF-8");
        writeInt(os, bytes.length); // Raksta teksta garumu
        os.write(bytes); // Raksta teksta baitus
    }

    // Lasīs teksta lauku
    public String readString(InputStream is) throws IOException {
        int length = readInt(is); // Lasīs teksta garumu
        byte[] bytes = new byte[length];
        is.read(bytes); // Lasīs teksta baitus
        return new String(bytes, "UTF-8");
    }

    // Piemērs serializējot vienkāršu Person objektu
    public void serialize(OutputStream os, Person person) throws IOException {
        writeString(os, person.getName());
        writeInt(os, person.getAge());
    }

    // Piemērs deserializējot Person objektu
    public Person deserialize(InputStream is) throws IOException {
        String name = readString(is);
        int age = readInt(is);
        return new Person(name, age);
    }

    // Palīgklase piemēram
    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("Oriģināls: " + originalPerson.getName() + ", " + originalPerson.getAge());
        System.out.println("Deserializēts: " + deserializedPerson.getName() + ", " + deserializedPerson.getAge());
    }
}

Savu protokolu izstrāde prasa rūpīgu plānošanu un daudzus faktorus, piemēram, veiktspēju, kompakti, versijām un sarežģītu datu struktūru apstrādi. Bieži tiek izmantotas jau esošas bibliotēkas (ProtoBuf, Kryo, Avro) vietā, lai izveidotu protokolu no jauna.