Hazelcast এর জন্য Custom Serialization তৈরি করা

Hazelcast ডিস্ট্রিবিউটেড সিস্টেমে ডেটা স্টোরেজ এবং ট্রান্সফার করার জন্য Serialization ব্যবহার করে। Custom Serialization তৈরির মাধ্যমে আপনি আপনার নিজস্ব অবজেক্টের জন্য কাস্টম পদ্ধতিতে ডেটা সিরিয়ালাইজ এবং ডেসিরিয়ালাইজ করতে পারেন। এর মাধ্যমে ডেটার আকার কমানো, পারফরম্যান্স বৃদ্ধি এবং আপনার ডেটা স্ট্রাকচারের জন্য আরো কার্যকর Serialization কৌশল গ্রহণ করা সম্ভব।

Hazelcast-এর মধ্যে Custom Serialization তৈরি করতে আপনাকে কিছু নির্দিষ্ট ইন্টারফেস ইমপ্লিমেন্ট করতে হবে এবং এই প্রক্রিয়া Hazelcast-এর পোর্টেবল বা আইডেন্টিফাইড সেরিয়ালাইজেশন ব্যবস্থাকে সমর্থন করতে পারে।

Custom Serialization তৈরির জন্য পদক্ষেপ

Hazelcast-এ Custom Serialization তৈরি করার জন্য প্রধানত দুটি পদ্ধতি রয়েছে:

1. Portable Serialization (Hazelcast এর একটি উচ্চ পারফরম্যান্স সিরিয়ালাইজেশন পদ্ধতি)
2. IdentifiedDataSerializable (Hazelcast এর আরও বেশি দ্রুত Serialization পদ্ধতি)

নিচে এই দুই পদ্ধতির বিস্তারিত ব্যাখ্যা দেওয়া হল:

1. Portable Serialization

Portable Serialization Hazlecast-এর একটি দ্রুত এবং দক্ষ Serialization পদ্ধতি। এর মাধ্যমে আপনি কাস্টম অবজেক্ট সেরিয়ালাইজ এবং ডেসিরিয়ালাইজ করতে পারবেন এবং এটি বেশিরভাগ সময় প্রফেশনাল ডিস্ট্রিবিউটেড অ্যাপ্লিকেশন এর জন্য উপযুক্ত।

PortableSerialization ইন্টারফেস ইমপ্লিমেন্টেশন:

Hazelcast Portable Serialization ব্যবহারের জন্য আপনার ক্লাসে Portable ইন্টারফেসটি ইমপ্লিমেন্ট করতে হবে। এই ইন্টারফেসে writePortable() এবং readPortable() পদ্ধতি থাকে, যেগুলি সঠিকভাবে অবজেক্টের ডেটা সঞ্চয় এবং পুনরুদ্ধারের জন্য ব্যবহার করা হয়।

PortableSerialization ইমপ্লিমেন্ট করার উদাহরণ:

public class MyCustomObject implements Portable {
    private int id;
    private String name;

    public MyCustomObject() {
        // Default constructor required for Portable serialization
    }

    public MyCustomObject(int id, String name) {
        this.id = id;
        this.name = name;
    }

    @Override
    public int getFactoryId() {
        return MyCustomFactory.FACTORY_ID;
    }

    @Override
    public int getClassId() {
        return MyCustomFactory.CLASS_ID;
    }

    @Override
    public void writePortable(PortableWriter writer) throws IOException {
        writer.writeInt("id", id);
        writer.writeUTF("name", name);
    }

    @Override
    public void readPortable(PortableReader reader) throws IOException {
        id = reader.readInt("id");
        name = reader.readUTF("name");
    }

    // Getter and Setter methods
}

এখানে writePortable() এবং readPortable() পদ্ধতিগুলোর মাধ্যমে আপনি অবজেক্টের প্রপার্টি গুলো সঞ্চয় এবং পুনরুদ্ধার করেন।

Portable Factory তৈরি করা:

Hazelcast-এর Portable অবজেক্টের জন্য একটি PortableFactory ক্লাস তৈরি করা উচিত। এটি ডেটা সেরিয়ালাইজেশনের জন্য সহজ পথ সরবরাহ করে।

public class MyCustomFactory implements PortableFactory {
    public static final int FACTORY_ID = 1;
    public static final int CLASS_ID = 1;

    @Override
    public Portable create(int classId) {
        if (classId == CLASS_ID) {
            return new MyCustomObject();
        }
        return null;
    }
}

Hazelcast এর PortableFactory-টি ক্লাস আইডি (Class ID) অনুযায়ী কাস্টম অবজেক্ট তৈরি করতে ব্যবহার করে।

2. IdentifiedDataSerializable

Hazelcast-এ IdentifiedDataSerializable ইন্টারফেসটি খুবই দ্রুত এবং উচ্চ পারফরম্যান্স Serialization পদ্ধতি প্রদান করে। IdentifiedDataSerializable এর মাধ্যমে সেরিয়ালাইজেশনের জন্য কাস্টম writeData() এবং readData() পদ্ধতিগুলি ব্যবহার করা হয়।

IdentifiedDataSerializable ইমপ্লিমেন্টেশন:

public class MyCustomObject implements IdentifiedDataSerializable {
    private int id;
    private String name;

    public MyCustomObject() {
        // Default constructor
    }

    public MyCustomObject(int id, String name) {
        this.id = id;
        this.name = name;
    }

    @Override
    public int getFactoryId() {
        return MyCustomFactory.FACTORY_ID;
    }

    @Override
    public int getId() {
        return MyCustomFactory.CLASS_ID;
    }

    @Override
    public void writeData(ObjectDataOutput out) throws IOException {
        out.writeInt(id);
        out.writeUTF(name);
    }

    @Override
    public void readData(ObjectDataInput in) throws IOException {
        id = in.readInt();
        name = in.readUTF();
    }

    // Getter and Setter methods
}

IdentifiedDataSerializable Factory:

public class MyCustomFactory implements DataSerializableFactory {
    public static final int FACTORY_ID = 1;
    public static final int CLASS_ID = 1;

    @Override
    public DataSerializable create(int typeId) {
        if (typeId == CLASS_ID) {
            return new MyCustomObject();
        }
        return null;
    }
}

IdentifiedDataSerializable পদ্ধতির সুবিধা হল যে এটি অধিক দ্রুত এবং কম মেমরি ব্যবহার করে, বিশেষ করে যখন ডিস্ট্রিবিউটেড সিস্টেমে বড় পরিমাণ ডেটা প্রক্রিয়া করতে হয়।

Custom Serialization কনফিগারেশন

Hazelcast-এ Portable বা IdentifiedDataSerializable ব্যবহারের জন্য আপনাকে সঠিক Serialization Configuration করতে হবে:

Config config = new Config();
SerializationConfig serializationConfig = config.getSerializationConfig();

// Registering Custom Serialization Factory
serializationConfig.addDataSerializableFactory(MyCustomFactory.FACTORY_ID, new MyCustomFactory());
serializationConfig.addPortableFactory(MyCustomFactory.FACTORY_ID, new MyCustomFactory());

HazelcastInstance hz = Hazelcast.newHazelcastInstance(config);

এখানে SerializationConfig ব্যবহার করে আপনি Hazelcast-এ কাস্টম সেরিয়ালাইজেশন পদ্ধতি নিবন্ধন করেন।

সারাংশ

Hazelcast-এ Custom Serialization তৈরি করার মাধ্যমে আপনি আপনার ডেটা অবজেক্টগুলোর জন্য পারফরম্যান্স এবং প্রয়োজন অনুসারে সেরিয়ালাইজেশন কৌশল তৈরি করতে পারেন। Portable এবং IdentifiedDataSerializable দুটি প্রধান পদ্ধতি, যেখানে Portable আরও উন্নত এবং বৃহৎ ডিস্ট্রিবিউটেড সিস্টেমের জন্য কার্যকর, এবং IdentifiedDataSerializable দ্রুত পারফরম্যান্স এবং ছোট ডেটার জন্য উপযুক্ত। Custom Serialization ব্যবহারের মাধ্যমে আপনি Hazelcast-এ ডেটা ট্রান্সফার এবং সঞ্চয় করার জন্য আরও কাস্টমাইজড এবং কার্যকর উপায় ব্যবহার করতে পারবেন।