Buffers, Channels, এবং Selectors এর ধারণা

Java NIO (New I/O) হল Java এর একটি শক্তিশালী API যা I/O অপারেশনগুলো দ্রুত এবং দক্ষভাবে পরিচালনা করার জন্য ডিজাইন করা হয়েছে। Java NIO এর মূল উপাদানগুলো হলো Buffers, Channels, এবং Selectors, যা ব্লকিং I/O মডেল থেকে বের হয়ে, অ্যাসিঙ্ক্রোনাস এবং নন-ব্লকিং I/O অপারেশন করার সুযোগ প্রদান করে।

এখানে Java NIO এর এই তিনটি প্রধান উপাদান — Buffers, Channels, এবং Selectors এর ধারণা বিস্তারিতভাবে আলোচনা করা হবে।

Buffers (বাফার)

Buffer হল একটি ডেটা স্ট্রাকচার যা একটি নির্দিষ্ট ডেটা টুকরা সঞ্চয় করে। NIO তে Buffer এমন একটি অবজেক্ট যা বাইনারি ডেটা (যেমন byte, char, int) সংরক্ষণ করার জন্য ব্যবহৃত হয় এবং সেই ডেটা অপারেশন সম্পাদন করার সময় কাজ আসে।

Java NIO তে Buffer এমন একটি স্পেসিফিক ডেটা স্টোরেজ যা শুধুমাত্র একদিকে (write/read) ব্যবহার করা যায়।

Buffer এর বৈশিষ্ট্য

1. Capacity: এটি বাফারের মোট সাইজ, বা কতটুকু ডেটা বাফারটি ধারণ করতে পারে।
2. Position: এটি এমন একটি সূচক যা বাফারে পরবর্তী পঠিত বা লেখা ডেটার অবস্থান নির্দেশ করে।
3. Limit: এটি বাফারের সর্বোচ্চ সীমা, বা কতটুকু ডেটা পড়তে বা লিখতে হবে, তা নির্ধারণ করে।
4. Mark: এটি বাফারের একটি নির্দিষ্ট পজিশন মনে রাখে, যেখানে পরবর্তীতে ফিরে যেতে পারে।

Buffer এর ধরন

Java NIO তে কিছু সাধারণ Buffer এর ধরন রয়েছে:

• ByteBuffer: এটি বাইনারি ডেটা (byte) সংরক্ষণ করতে ব্যবহৃত হয়।
• CharBuffer: এটি অক্ষর (character) ডেটা সংরক্ষণ করতে ব্যবহৃত হয়।
• IntBuffer: এটি পূর্ণসংখ্যা (integer) ডেটা সংরক্ষণ করতে ব্যবহৃত হয়।
• DoubleBuffer: এটি দশমিক (double) ডেটা সংরক্ষণ করতে ব্যবহৃত হয়।

Buffer উদাহরণ:

import java.nio.ByteBuffer;

public class BufferExample {
    public static void main(String[] args) {
        // ByteBuffer তৈরি
        ByteBuffer buffer = ByteBuffer.allocate(10);
        
        // ডেটা লিখুন
        buffer.put((byte) 1);
        buffer.put((byte) 2);

        // বাফারকে পড়ার জন্য প্রস্তুত করুন
        buffer.flip();

        // ডেটা পড়ুন
        while (buffer.hasRemaining()) {
            System.out.println(buffer.get());
        }
    }
}

এখানে, flip() মেথডের মাধ্যমে বাফারটি পড়ার জন্য প্রস্তুত করা হয়েছে, এবং get() মেথডের মাধ্যমে ডেটা পড়া হচ্ছে।

Channels (চ্যানেল)

Channel হল একটি I/O উপাদান যা ডেটা পাঠানো এবং গ্রহণের জন্য ব্যবহৃত হয়। Buffer এবং Channel একসাথে কাজ করে, যেখানে Channel ডেটাকে Buffer এ লেখে বা পড়ে।

Java NIO তে Channel প্রধানত দুটি ধরনের হয়ে থাকে:

1. ReadableChannel: ডেটা পড়ার জন্য ব্যবহৃত চ্যানেল (যেমন FileChannel, SocketChannel)।
2. WritableChannel: ডেটা লেখার জন্য ব্যবহৃত চ্যানেল (যেমন FileChannel, SocketChannel)।
3. ByteChannel: এটি একটি সাধারণ চ্যানেল যা byte আকারে ডেটা পাঠাতে এবং গ্রহণ করতে ব্যবহৃত হয়।

Channel এর উদাহরণ

import java.io.RandomAccessFile;
import java.nio.channels.FileChannel;
import java.nio.ByteBuffer;

public class ChannelExample {
    public static void main(String[] args) throws Exception {
        // ফাইল থেকে ডেটা পড়তে FileChannel ব্যবহার করা
        RandomAccessFile file = new RandomAccessFile("example.txt", "rw");
        FileChannel channel = file.getChannel();
        
        // বাফারে ডেটা পড়ুন
        ByteBuffer buffer = ByteBuffer.allocate(128);
        int bytesRead = channel.read(buffer);
        
        // বাফারের ডেটা প্রসেস করা
        while (bytesRead != -1) {
            buffer.flip();
            while (buffer.hasRemaining()) {
                System.out.print((char) buffer.get());
            }
            buffer.clear();
            bytesRead = channel.read(buffer);
        }
    }
}

এখানে, FileChannel ব্যবহার করে ফাইল থেকে ডেটা পড়া হচ্ছে, এবং ByteBuffer ব্যবহার করে সেই ডেটা প্রক্রিয়া করা হচ্ছে।

Selectors (সিলেক্টর)

Selector হল একটি Java NIO এর বিশেষ উপাদান যা একাধিক চ্যানেলকে একসাথে ম্যানেজ করতে সাহায্য করে। Selector মূলত নন-ব্লকিং I/O অপারেশন পরিচালনা করার জন্য ব্যবহৃত হয়। এটি একাধিক চ্যানেল থেকে কোনটি বর্তমানে ডেটা পাঠাতে বা গ্রহণ করতে প্রস্তুত তা চিহ্নিত করতে সহায়ক।

Selector এর মাধ্যমে আপনি একাধিক চ্যানেলকে পর্যবেক্ষণ করতে পারেন, এবং এটি আপনাকে শুধুমাত্র সেই চ্যানেলগুলির সাথে কাজ করতে সাহায্য করবে যেগুলি প্রস্তুত রয়েছে।

Selector এর কাজের ধাপ

1. Registering Channels: আপনি চ্যানেলগুলিকে Selector-এ নিবন্ধিত করেন।
2. Selecting Ready Channels: Selector অপেক্ষা করে এবং সেগুলি নির্বাচন করে যেগুলি প্রস্তুত।
3. Performing I/O Operations: নির্বাচিত চ্যানেলগুলির সাথে I/O অপারেশন করা হয়।

Selector উদাহরণ:

import java.io.IOException;
import java.nio.channels.*;
import java.nio.*;
import java.net.*;

public class SelectorExample {
    public static void main(String[] args) throws IOException {
        // Selector তৈরি
        Selector selector = Selector.open();

        // স্যকেট চ্যানেল তৈরি
        ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();
        serverSocketChannel.socket().bind(new InetSocketAddress(8080));
        serverSocketChannel.configureBlocking(false);

        // Selector তে চ্যানেল নিবন্ধন
        serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT);

        while (true) {
            // প্রস্তুত চ্যানেল চেক করুন
            selector.select();

            // নির্বাচিত কীগুলির উপর কাজ করুন
            for (SelectionKey key : selector.selectedKeys()) {
                if (key.isAcceptable()) {
                    System.out.println("New client connection accepted.");
                }
            }
            selector.selectedKeys().clear();
        }
    }
}

এখানে, Selector ব্যবহার করে ServerSocketChannel এর জন্য প্রস্তুত থাকার জন্য অপেক্ষা করা হচ্ছে, এবং এটি গ্রহণযোগ্য হলে একটি মেসেজ প্রদর্শিত হচ্ছে।

Java NIO এর Buffers, Channels, এবং Selectors তিনটি গুরুত্বপূর্ণ উপাদান যা I/O অপারেশনগুলোকে আরো দ্রুত এবং দক্ষভাবে পরিচালনা করতে সাহায্য করে।

• Buffers ডেটাকে স্টোর করে, এবং প্রক্রিয়া করার জন্য একটি নির্দিষ্ট স্ট্রাকচার প্রদান করে।
• Channels ডেটা পাঠানোর এবং গ্রহণের জন্য ব্যবহৃত হয়, যেখানে Buffer ডেটাকে ধারণ করে এবং Channel সেই ডেটা প্রক্রিয়া করে।
• Selectors একাধিক চ্যানেলের প্রস্তুত অবস্থা ট্র্যাক করতে সহায়ক, যা নন-ব্লকিং I/O অপারেশনকে সহজ করে তোলে।

Java NIO এই উপাদানগুলির সাহায্যে দ্রুত I/O অপারেশন সক্ষম করে, যা পারফরম্যান্স বৃদ্ধিতে সহায়ক।

Java NIO (New Input/Output) হল Java প্ল্যাটফর্মে ফাইল ও নেটওয়ার্কে ইনপুট/আউটপুট (I/O) অপারেশনগুলির জন্য একটি উন্নত এবং কার্যকরী পদ্ধতি। Java NIO এ Buffer একটি গুরুত্বপূর্ণ উপাদান, যা ইনপুট/আউটপুট ডেটা পরিচালনার জন্য ব্যবহৃত হয়। NIO এর মূল লক্ষ্য হল বড় ডেটা সেটের সাথে উচ্চ পারফরম্যান্সে কাজ করা, এবং Buffer এই প্রক্রিয়ায় গুরুত্বপূর্ণ ভূমিকা পালন করে।

Buffer হল একটি ডেটা স্টোরেজ এলাকার (memory area) যা I/O অপারেশনগুলিতে ডেটা পড়া বা লেখা করার জন্য ব্যবহৃত হয়। NIO এর মাধ্যমে ডেটা কেবলমাত্র Buffer তে রাখা এবং পরবর্তীতে তা সরাসরি প্রক্রিয়া করা হয়, যা অধিক কার্যকর এবং দ্রুত I/O অপারেশন সম্ভব করে তোলে।

Buffer কি?

Java NIO তে Buffer একটি অবজেক্ট যা ডেটার একটি ধারাবাহিক ব্লককে ধারণ করে এবং এটি NIO I/O অপারেশনগুলিতে ব্যবহৃত হয়। সহজ ভাষায়, Buffer হল একটি মেমরি ব্লক, যেখানে ডেটা রাখা হয় এবং একে অ্যাক্সেস করে ইনপুট/আউটপুট (I/O) কার্যক্রম পরিচালিত হয়।

Java NIO তে বিভিন্ন ধরনের Buffer থাকে, যেমন:

• ByteBuffer: বাইনারি ডেটা সংরক্ষণ এবং প্রক্রিয়া করার জন্য।
• CharBuffer: অক্ষর বা ক্যারেক্টার ডেটা সংরক্ষণ করার জন্য।
• IntBuffer: পূর্ণসংখ্যা ডেটা সংরক্ষণ করার জন্য।
• DoubleBuffer: ডাবল মানের ডেটা সংরক্ষণ করার জন্য।
• FloatBuffer: ফ্লোট মানের ডেটা সংরক্ষণ করার জন্য।

Buffer-এর মধ্যে ডেটা সরানোর জন্য put() এবং get() পদ্ধতি ব্যবহার করা হয়, যা ইনপুট/আউটপুট অপারেশনের জন্য একটি ডেটা ধারক হিসেবে কাজ করে।

Buffer এর ভূমিকা

Java NIO তে Buffer এর ভূমিকা অত্যন্ত গুরুত্বপূর্ণ। Buffer ডেটা আনা এবং লেখা উভয় কাজের জন্য ব্যবহৃত হয়, এবং এটি I/O অপারেশনের গতি বৃদ্ধি করতে সাহায্য করে। এর মূল কাজ হলো:

১. ডেটা স্টোরেজ

Buffer, ইনপুট বা আউটপুট স্ট্রিম থেকে ডেটা সংগ্রহ করার জন্য একটি অস্থায়ী স্টোরেজ প্রদান করে। যখন আপনি ফাইল বা সোকেট থেকে ডেটা পড়েন, তা প্রথমে Buffer তে রাখা হয়, তারপর প্রক্রিয়া করা হয়।

২. I/O অপারেশন সহজতর করা

Buffer ব্যবহার করে, NIO এর মাধ্যমে ডেটা পড়া এবং লেখা খুব দ্রুত এবং কার্যকরভাবে করা যায়। এটি ডেটার ফ্লোকে সহজ এবং সিস্টেমের I/O অপারেশনগুলিকে আরও দক্ষ করে তোলে।

৩. ডেটা সরানোর জন্য পদক্ষেপ নির্ধারণ

Buffer একটি ইনডেক্স সিস্টেম ব্যবহার করে, যেখানে ডেটা পড়া বা লেখা হয়। এটি position, limit, এবং capacity দ্বারা পরিচালিত হয়:

• Position: বর্তমানে কোথায় অবস্থান করা হচ্ছে।
• Limit: কতটা ডেটা ব্যবহৃত হবে।
• Capacity: মোট স্টোরেজ ক্ষমতা কত।

এই তিনটি বৈশিষ্ট্য Buffer এর আকার এবং ফাংশনালিটি নির্ধারণ করে, এবং এটি ডেটা সরানোর প্রক্রিয়াকে আরও নিয়ন্ত্রিত এবং কার্যকরী করে তোলে।

৪. অ্যাসিঙ্ক্রোনাস I/O এবং NIO এর গতি বৃদ্ধি

Java NIO অ্যাসিঙ্ক্রোনাস I/O অপারেশনের জন্য পরিকল্পিত, এবং Buffer এই প্রক্রিয়ায় সহায়ক। অ্যাসিঙ্ক্রোনাস I/O এর মাধ্যমে, ডেটা সরানোর জন্য অপ্রয়োজনীয় ব্লকিং অপারেশন এড়ানো হয় এবং সিস্টেমের পারফরম্যান্স বৃদ্ধি পায়।

Buffer ব্যবহার করার উদাহরণ

এখানে একটি ByteBuffer এর ব্যবহার দেখানো হয়েছে, যেখানে ডেটা লিখা এবং পড়ার কাজ করা হচ্ছে:

import java.nio.ByteBuffer;

public class BufferExample {
    public static void main(String[] args) {
        // একটি ByteBuffer তৈরি
        ByteBuffer buffer = ByteBuffer.allocate(10);
        
        // ডেটা put করা
        buffer.put((byte) 10);
        buffer.put((byte) 20);
        
        // পজিশন রিসেট করা
        buffer.flip();  // ফ্লিপ মেথড, write -> read মোডে পরিবর্তন করে
        
        // ডেটা get করা
        System.out.println(buffer.get()); // 10
        System.out.println(buffer.get()); // 20
    }
}

এখানে, ByteBuffer তৈরি করা হয়েছে, ডেটা put() মেথডের মাধ্যমে ইনসার্ট করা হয়েছে এবং flip() মেথড দিয়ে রিড মোডে পরিবর্তন করা হয়েছে। এরপর, get() মেথডের মাধ্যমে ডেটা পড়া হয়েছে।

Java NIO তে Buffer হল একটি অত্যন্ত গুরুত্বপূর্ণ উপাদান, যা ইনপুট/আউটপুট অপারেশনগুলোকে দ্রুত এবং কার্যকরভাবে সম্পাদন করতে সহায়তা করে। Buffer এর মাধ্যমে, ডেটা সরানোর জন্য একটি কার্যকরী পদ্ধতি ব্যবহৃত হয়, যা I/O অপারেশনের গতি বৃদ্ধি করে এবং সিস্টেমের পারফরম্যান্স উন্নত করে। Java NIO এর মাধ্যমে বিভিন্ন ধরনের Buffer ব্যবহার করে বিভিন্ন ধরনের ডেটা প্রক্রিয়াকরণ এবং স্টোরেজ সহজে করা সম্ভব।

Java NIO (New I/O) Java এর একটি শক্তিশালী API যা I/O অপারেশন আরও দ্রুত, দক্ষ এবং নমনীয়ভাবে পরিচালনা করার জন্য ডিজাইন করা হয়েছে। NIO একটি নতুন স্টাইলের I/O মডেল প্রদান করে, যা সিঙ্ক্রোনাস I/O এর তুলনায় অধিক পারফরম্যান্স প্রদান করে। NIO এর মধ্যে বিভিন্ন ক্লাস ও কনসেপ্ট রয়েছে, যার মধ্যে একটি গুরুত্বপূর্ণ কনসেপ্ট হল Channel।

Channel কি?

Channel হল Java NIO এর একটি ইন্টারফেস যা ডেটা ট্রান্সফার করার জন্য ব্যবহৃত হয়, অর্থাৎ এটি সোর্স এবং ডেস্টিনেশনের মধ্যে ডেটা পাঠানোর জন্য ব্যবহৃত হয়। Channel সরাসরি ডেটা পাঠানোর জন্য একটি খোলামেলা পোর্ট সরবরাহ করে, যেখানে ডেটা একটি স্ট্রিম আকারে পাঠানো বা গ্রহণ করা হয়।

Java NIO তে Channel এবং Stream এর মধ্যে পার্থক্য হল, যেখানে Stream একটি সরল ও সিকোয়েন্সিয়াল ডেটা প্রবাহ এবং Channel বেশ কিছু উন্নত ফিচার সরবরাহ করে, যেমন একাধিক I/O অপারেশন সমর্থন এবং Non-blocking I/O।

Channel এর বৈশিষ্ট্য:

• Bidirectional: Channel ডেটা পাঠানোর পাশাপাশি গ্রহণ করতে সক্ষম।
• Non-blocking: Channel গুলি সাধারণত Non-blocking মোডে কাজ করে, অর্থাৎ ডেটা ট্রান্সফার করতে একটি থ্রেড অপেক্ষা না করে অন্য কাজ করতে পারে।
• Buffer ব্যবহার: Channel এর মাধ্যমে ডেটা পাঠানোর জন্য Buffer ব্যবহার করা হয়।

Channel এর ধরণ

Java NIO তে বিভিন্ন ধরনের Channel রয়েছে, যার মধ্যে কিছু গুরুত্বপূর্ণ হল:

1. FileChannel: ফাইল থেকে ডেটা পড়া এবং ফাইলে ডেটা লেখা।
2. DatagramChannel: UDP সোকেট যোগাযোগের জন্য ব্যবহৃত।
3. SocketChannel: TCP সোকেটের মাধ্যমে I/O অপারেশন চালানো।
4. ServerSocketChannel: TCP/IP সার্ভার অ্যাপ্লিকেশন পরিচালনা করা।
5. SelectableChannel: Non-blocking I/O এর জন্য ব্যবহৃত।

Channel কিভাবে কাজ করে?

Channel গুলি মূলত Non-blocking I/O অপারেশন সমর্থন করে, যেখানে আপনি একাধিক I/O অপারেশন পরিচালনা করতে পারেন। Channel গুলির সাথে Selector এর ব্যবহার একটি গুরুত্বপূর্ণ ভূমিকা পালন করে, কারণ এটি একাধিক Channel গুলির I/O অপারেশনকে একত্রিত করে পরিচালনা করতে সাহায্য করে। এটি একটি প্রধান কনসেপ্ট যা Multiplexing হিসেবে পরিচিত।

Channel এর মাধ্যমে ডেটা পাঠানো বা গ্রহণ করা

Java NIO তে Channel ব্যবহার করে ডেটা ট্রান্সফার করার জন্য, ডেটা পাঠানোর জন্য একটি Buffer এবং ডেটা গ্রহণের জন্য আরেকটি Buffer ব্যবহার করা হয়।

উদাহরণ: FileChannel ব্যবহার করে ফাইল থেকে ডেটা পড়া:

import java.io.FileInputStream;
import java.nio.ByteBuffer;
import java.nio.channels.FileChannel;

public class FileChannelExample {
    public static void main(String[] args) {
        try (FileInputStream fileInputStream = new FileInputStream("input.txt");
             FileChannel fileChannel = fileInputStream.getChannel()) {

            // Buffer তৈরি করা
            ByteBuffer buffer = ByteBuffer.allocate(1024);

            // FileChannel থেকে ডেটা পড়া
            while (fileChannel.read(buffer) > 0) {
                buffer.flip();  // Buffer প্রস্তুত করা পড়া ডেটা দিয়ে

                while (buffer.hasRemaining()) {
                    System.out.print((char) buffer.get());  // ডেটা আউটপুট করা
                }

                buffer.clear();  // Buffer পুনরায় ব্যবহারযোগ্য করে তোলা
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

এখানে, FileChannel ব্যবহার করে ফাইল থেকে ডেটা পড়া হচ্ছে। ByteBuffer ব্যবহার করে ডেটা স্টোর করা হচ্ছে, এবং flip(), clear() মেথডগুলি বাফারের স্টেট ম্যানেজমেন্টের জন্য ব্যবহৃত হয়।

Non-blocking Mode এর উদাহরণ

Java NIO তে Channel গুলি সাধারণত Non-blocking মোডে কাজ করে, যেখানে আপনি I/O অপারেশন সম্পাদন করার জন্য অপেক্ষা না করে অন্য কাজ করতে পারেন। এটি অনেক বেশি পারফরম্যান্স এবং কার্যকারিতা প্রদান করে।

import java.nio.channels.SocketChannel;
import java.net.InetSocketAddress;
import java.nio.ByteBuffer;

public class NonBlockingChannelExample {
    public static void main(String[] args) {
        try {
            SocketChannel socketChannel = SocketChannel.open();
            socketChannel.configureBlocking(false);  // Non-blocking মোডে সেট করা

            socketChannel.connect(new InetSocketAddress("localhost", 8080));

            while (!socketChannel.finishConnect()) {
                // কানেকশন সম্পন্ন না হওয়া পর্যন্ত অপেক্ষা করা
                System.out.println("Connecting...");
            }

            String message = "Hello, Server!";
            ByteBuffer buffer = ByteBuffer.wrap(message.getBytes());
            socketChannel.write(buffer);  // সোকেট চ্যানেলে ডেটা লেখা

            socketChannel.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

এখানে, SocketChannel একটি Non-blocking মোডে কনফিগার করা হয়েছে, যার মাধ্যমে সিস্টেম ব্লক না হয়ে অন্য কাজ করতে পারে।

Channel এর সাথে Selector ব্যবহার

Selector একটি গুরুত্বপূর্ণ কনসেপ্ট যা Java NIO তে একাধিক SelectableChannel এর I/O অপারেশনকে একত্রিত করে পরিচালনা করতে সাহায্য করে। এটি ব্যবহৃত হয় Multiplexing এর জন্য, যেখানে একাধিক সোকেট বা অন্যান্য চ্যানেলের উপর একসাথে I/O অপারেশন পরিচালনা করা যায়।

উদাহরণ:

import java.nio.channels.Selector;
import java.nio.channels.SocketChannel;
import java.nio.channels.SelectionKey;
import java.net.InetSocketAddress;

public class SelectorExample {
    public static void main(String[] args) {
        try {
            Selector selector = Selector.open();
            SocketChannel socketChannel = SocketChannel.open();
            socketChannel.configureBlocking(false);
            socketChannel.connect(new InetSocketAddress("localhost", 8080));
            
            socketChannel.register(selector, SelectionKey.OP_CONNECT);

            while (true) {
                if (selector.select() > 0) {
                    // Select করেছে, তখন কার্যকলাপ করা যায়
                    for (SelectionKey key : selector.selectedKeys()) {
                        if (key.isConnectable()) {
                            socketChannel.finishConnect();
                            System.out.println("Connected to server");
                        }
                    }
                    selector.selectedKeys().clear();
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

এখানে, Selector ব্যবহার করে একাধিক চ্যানেল থেকে নির্বাচন করা হয়েছে এবং I/O অপারেশন পরিচালনা করা হয়েছে।

Java NIO তে Channel একটি গুরুত্বপূর্ণ উপাদান যা ডেটা পাঠানো এবং গ্রহণের জন্য ব্যবহৃত হয়। এটি বিভিন্ন ধরনের চ্যানেল যেমন FileChannel, SocketChannel, DatagramChannel, এবং ServerSocketChannel সমর্থন করে। Channel গুলি মূলত Non-blocking I/O সিস্টেমের অংশ হিসেবে কাজ করে এবং Java NIO তে ডেটা ট্রান্সফার করার জন্য Buffer ব্যবহৃত হয়। Selector এর সাথে Channel গুলি একত্রিত হয়ে Multiplexing এর সুবিধা প্রদান করে, যা একাধিক I/O অপারেশন পরিচালনা করতে সাহায্য করে এবং সিস্টেমের পারফরম্যান্স উন্নত করে।

Java NIO (New I/O) একটি শক্তিশালী ফ্রেমওয়ার্ক যা Java 1.4 ভার্সনে পরিচিতি পেয়েছিল এবং এটি ইনপুট/আউটপুট অপারেশনকে আরও দক্ষভাবে পরিচালনা করার জন্য ডিজাইন করা হয়েছে। NIO ফিচারগুলি বিভিন্ন ধরনের I/O অপারেশন পরিচালনা করতে সহায়ক, যেমন ব্লকিং এবং নন-ব্লকিং I/O, বাফার এবং চ্যানেলস, এবং সিলেক্টর।

এখানে আমরা Selector এর ধারণা এবং এটি কীভাবে কাজ করে তা বিস্তারিতভাবে আলোচনা করব।

Selector এর ধারণা

Selector হল Java NIO এর একটি অত্যন্ত গুরুত্বপূর্ণ অংশ, যা নন-ব্লকিং I/O অপারেশন পরিচালনার জন্য ব্যবহৃত হয়। এটি একটি মূল কাঠামো যা একাধিক চ্যানেল (Channel) থেকে ইনপুট/আউটপুট অপারেশন পরিচালনা করতে সাহায্য করে। Selector এর মাধ্যমে আপনি একাধিক I/O চ্যানেলের উপর নজর রাখতে পারেন এবং চ্যানেলগুলি ইভেন্ট (যেমন, ডাটা রেডি হওয়া, রাইট করার জন্য প্রস্তুত হওয়া) ঘটলে সেগুলিতে প্রসেস করতে পারেন।

Selector মূলত non-blocking I/O এর সুবিধা ব্যবহার করে। যখন আপনি একাধিক চ্যানেলের সাথে কাজ করছেন, আপনি একটি থ্রেড ব্যবহার করে একাধিক চ্যানেল মনিটর করতে পারেন এবং যেগুলি প্রস্তুত, তখন সেগুলিতে কাজ করতে পারেন।

Selector এর ব্যবহার

Selector ব্যবহার করে আপনি একাধিক I/O চ্যানেল (যেমন SocketChannel, ServerSocketChannel) একসাথে মনিটর করতে পারেন। এর মাধ্যমে আপনি একাধিক ক্লায়েন্টের সাথে একযোগে কাজ করতে পারেন একটি মাত্র থ্রেড ব্যবহার করে, যা স্কেলেবিলিটি উন্নত করে এবং রিসোর্সের ব্যবহার কমায়।

Selector এর কাজ

Selector কাজ করে একটি ইভেন্ট ড্রিভেন মডেল হিসেবে, যেখানে বিভিন্ন চ্যানেলগুলির I/O স্টেট (যেমন, রিডি, রাইটেবল) পর্যবেক্ষণ করা হয় এবং যখন একটি চ্যানেল ইভেন্টে পৌঁছে, তখন সেটি প্রসেস করা হয়। এটি মূলত SelectionKey দ্বারা চ্যানেলগুলির ইভেন্ট পরিচালনা করে।

Selector এর কাজটি নিম্নলিখিত পর্যায়ে বিভক্ত:

১. চ্যানেল রেজিস্ট্রেশন (Channel Registration)

প্রথমে, আপনি একটি Selector তৈরি করবেন এবং এক বা একাধিক Channel কে এই Selector এর কাছে রেজিস্টার করবেন। প্রতিটি চ্যানেলের জন্য নির্দিষ্ট I/O অপারেশন (যেমন READ, WRITE, ACCEPT) রেজিস্টার করতে হবে।

Selector selector = Selector.open();  // Create a new selector

SocketChannel channel = SocketChannel.open(new InetSocketAddress("localhost", 8080));
channel.configureBlocking(false); // Non-blocking mode
channel.register(selector, SelectionKey.OP_READ);  // Register channel for read operation

২. SelectionKey (সিলেকশন কী)

যতবার একটি চ্যানেল Selector-এর সাথে রেজিস্টার করা হয়, ততবার একটি SelectionKey তৈরি হয়। এই কীটি চ্যানেলের রেজিস্টার করা অপারেশন এবং তার স্টেট ট্র্যাক করতে ব্যবহৃত হয়।

৩. Selector এ সিলেক্ট করা (Select)

আপনি Selector এর select() মেথড ব্যবহার করে চ্যানেলগুলিতে রেডি অপারেশন চেক করতে পারেন। এটি ব্লকিংভাবে কাজ করে এবং যখন কোন চ্যানেল I/O অপারেশন করতে প্রস্তুত হয়, তখন এটি ওই চ্যানেলটি নির্বাচন করে। এটি non-blocking I/O অ্যাপ্লিকেশন তৈরি করতে সহায়ক।

int readyChannels = selector.select();  // Blocks until at least one channel is ready

৪. Ready Channels Process করা (Process Ready Channels)

যখন একটি চ্যানেল প্রস্তুত থাকে, তখন আপনি SelectionKey থেকে এটি বের করে নির্দিষ্ট কাজটি সম্পাদন করতে পারেন (যেমন, রিড বা রাইট)। এই পদ্ধতিতে শুধুমাত্র প্রস্তুত চ্যানেলগুলির উপর কাজ করা হয়, যা পদ্ধতির পারফরম্যান্স উন্নত করে।

Set<SelectionKey> selectedKeys = selector.selectedKeys();
Iterator<SelectionKey> keyIterator = selectedKeys.iterator();

while (keyIterator.hasNext()) {
    SelectionKey key = keyIterator.next();
    keyIterator.remove();
    
    if (key.isReadable()) {
        // Process the channel for reading data
        SocketChannel readyChannel = (SocketChannel) key.channel();
        ByteBuffer buffer = ByteBuffer.allocate(1024);
        readyChannel.read(buffer);
    }
    // Similarly, handle other events like isWritable(), isAcceptable() etc.
}

৫. চ্যানেল থেকে ডাটা পাঠানো বা গ্রহণ করা

যখন আপনি একটি চ্যানেল সিলেক্ট করেন এবং এটি READ বা WRITE অপারেশন করা সক্ষম হয়, তখন আপনি সেই চ্যানেলের উপর নির্দিষ্ট কাজ যেমন ডেটা পাঠানো বা গ্রহণ করা পরিচালনা করতে পারেন।

Selector এর সুবিধা

1. একাধিক চ্যানেল পরিচালনা: একাধিক চ্যানেল থেকে ইনপুট/আউটপুট অপারেশন পরিচালনা করতে একক থ্রেড ব্যবহার করা যায়, যা স্কেলেবিলিটি বাড়ায়।
2. পারফরম্যান্স উন্নতি: নন-ব্লকিং I/O অপারেশনগুলির মাধ্যমে আপনি শুধুমাত্র প্রস্তুত চ্যানেলগুলির সাথে কাজ করবেন, যা রিসোর্সের অপচয় কমায়।
3. উচ্চ দক্ষতা: Selector ব্যাবহার করে একাধিক I/O অপারেশন নির্দিষ্ট থ্রেডের মাধ্যমে সম্পাদন করা যায়, যা অ্যাপ্লিকেশনের দক্ষতা বাড়ায়।

Selector Java NIO এর একটি অত্যন্ত গুরুত্বপূর্ণ অংশ, যা একাধিক চ্যানেল থেকে I/O অপারেশন পরিচালনা করতে সাহায্য করে। এটি non-blocking I/O এর সুবিধা ব্যবহার করে এবং একাধিক চ্যানেলকে একটি থ্রেড দিয়ে প্রক্রিয়া করার জন্য তৈরি। Selector এর মাধ্যমে আপনি উচ্চ পারফরম্যান্স এবং স্কেলেবল I/O অপারেশন সম্পাদন করতে পারবেন, যা বৃহৎ এবং মাল্টি-কনেকশন ভিত্তিক অ্যাপ্লিকেশনগুলির জন্য অত্যন্ত উপকারী।