SocketChannel এর মাধ্যমে TCP Connection তৈরি করা

Java NIO (New Input/Output) API ব্লকিং এবং নন-ব্লকিং I/O অপারেশন পরিচালনা করার জন্য শক্তিশালী সমাধান প্রদান করে। বিশেষ করে TCP connections এ, Java NIO এর মাধ্যমে আপনি Blocking এবং Non-blocking কনেকশন পরিচালনা করতে পারেন, যা অ্যাপ্লিকেশনটির পারফরম্যান্স এবং স্কেলেবিলিটি বাড়াতে সাহায্য করে।

এই লেখায় আমরা TCP কনেকশনের ক্ষেত্রে Blocking এবং Non-blocking কনেকশনের ধারণা এবং তাদের মধ্যে পার্থক্য বিস্তারিতভাবে আলোচনা করব।

Blocking TCP Connections

Blocking TCP Connection হল একটি প্রথাগত I/O মডেল যেখানে একটি থ্রেড একটি TCP কনেকশনে ডেটা পাঠানোর বা গ্রহণ করার সময় পুরোপুরি থেমে থাকে (ব্লক হয়ে থাকে) যতক্ষণ না সেই অপারেশন সম্পন্ন হয়। এই ধরনের কনেকশনে, যখন একটি থ্রেড একটির পর এক I/O অপারেশন সম্পন্ন করতে থাকে, তখন পরবর্তী অপারেশন শুরু করার আগে আগেরটি সম্পন্ন হওয়া পর্যন্ত থ্রেডটি অপেক্ষা করে।

Blocking TCP Connection এর কার্যপ্রণালী

• থ্রেড ব্লকিং: TCP কনেকশনের উপর একটি অপারেশন (যেমন, ডেটা পাঠানো বা গ্রহণ) করার সময় থ্রেডটি থেমে থাকে। অর্থাৎ, ডেটা পাঠানোর বা গ্রহণের জন্য পরবর্তী কার্যকলাপ করতে হবে না যতক্ষণ না বর্তমান অপারেশন সম্পন্ন হয়।
• পারফরম্যান্স: ব্লকিং মডেল সোজা এবং সহজ হতে পারে, তবে এতে একাধিক কনেকশনের জন্য একাধিক থ্রেড পরিচালনা করতে হয়, যার ফলে থ্রেডের ব্যবস্থাপনা জটিল হতে পারে এবং পারফরম্যান্স কম হতে পারে।

Blocking TCP Connection উদাহরণ

import java.io.*;
import java.net.*;

public class BlockingTCPServer {
    public static void main(String[] args) throws IOException {
        ServerSocket serverSocket = new ServerSocket(8080);
        System.out.println("Server started, waiting for client connection...");

        Socket socket = serverSocket.accept(); // Blocking call
        System.out.println("Client connected!");

        BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
        PrintWriter out = new PrintWriter(socket.getOutputStream(), true);

        String message = in.readLine(); // Blocking call
        System.out.println("Received: " + message);

        out.println("Hello Client!"); // Send response to client

        socket.close();
        serverSocket.close();
    }
}

এখানে, accept() এবং readLine() মেথড দুটি ব্লকিং অপারেশন। ক্লায়েন্টের সাথে সংযোগ স্থাপন এবং ডেটা পড়ার জন্য থ্রেডটি ব্লক হয়ে থাকে।

Non-blocking TCP Connections

Non-blocking TCP Connection হল এমন একটি কনেকশন যেখানে একটি থ্রেড ব্লক না হয়ে অন্যান্য কাজ করতে পারে, এমনকি যখন এটি TCP কনেকশনে ডেটা পাঠানোর বা গ্রহণ করার জন্য অপেক্ষা করছে। নন-ব্লকিং মডেলে, I/O অপারেশনগুলি অবিলম্বে ফেরত দেয়, এবং থ্রেডকে অন্য কাজ করতে দেয় যতক্ষণ না I/O অপারেশন সম্পন্ন হয়। Java NIO তে এই ধরনের কাজের জন্য SocketChannel ব্যবহার করা হয়।

Non-blocking TCP Connection এর কার্যপ্রণালী

• থ্রেড ব্লকিং না হওয়া: নন-ব্লকিং কনেকশনে, যখন ডেটা পাঠানো বা গ্রহণ করার জন্য অপারেশনটি করা হয়, তখন থ্রেডটি অপেক্ষা না করে অন্য কাজ করতে পারে।
• পারফরম্যান্স: নন-ব্লকিং মডেল বিশেষ করে অ্যাপ্লিকেশনগুলির জন্য উপকারী যেখানে একাধিক TCP কনেকশনের সাথে যোগাযোগ করতে হয়। এটি থ্রেড ব্যবস্থাপনা সহজ করে এবং উচ্চ পারফরম্যান্স এবং স্কেলেবিলিটি নিশ্চিত করে।

Non-blocking TCP Connection উদাহরণ

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

public class NonBlockingTCPServer {
    public static void main(String[] args) throws IOException {
        ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();
        serverSocketChannel.bind(new InetSocketAddress(8080));
        serverSocketChannel.configureBlocking(false);  // Set non-blocking mode

        System.out.println("Non-blocking server started, waiting for client connection...");

        Selector selector = Selector.open();
        serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT);

        while (true) {
            if (selector.select() > 0) {  // Non-blocking select
                for (SelectionKey key : selector.selectedKeys()) {
                    if (key.isAcceptable()) {
                        SocketChannel socketChannel = serverSocketChannel.accept();
                        socketChannel.configureBlocking(false); // Set non-blocking mode
                        socketChannel.register(selector, SelectionKey.OP_READ);
                        System.out.println("Client connected!");
                    } else if (key.isReadable()) {
                        SocketChannel socketChannel = (SocketChannel) key.channel();
                        ByteBuffer buffer = ByteBuffer.allocate(256);
                        int bytesRead = socketChannel.read(buffer);  // Non-blocking read
                        if (bytesRead != -1) {
                            buffer.flip();
                            while (buffer.hasRemaining()) {
                                System.out.print((char) buffer.get());
                            }
                        }
                    }
                }
                selector.selectedKeys().clear();
            }
        }
    }
}

এখানে, select() মেথডটি একটি নন-ব্লকিং অপারেশন এবং যখন কোন নতুন সংযোগ আসে বা ডেটা আসে তখন সেগুলি পরবর্তী কাজে ব্যবহৃত হয়। থ্রেডটি কখনওই ব্লক হয় না এবং অন্য কাজ করতে পারে।

Blocking এবং Non-blocking TCP Connections এর মধ্যে পার্থক্য

Blocking এবং Non-blocking TCP connections Java NIO তে দুটি গুরুত্বপূর্ণ কনসেপ্ট যা TCP/IP যোগাযোগ পরিচালনার জন্য ব্যবহৃত হয়।

• Blocking Connections সাধারণত ছোট বা সিম্পল অ্যাপ্লিকেশনগুলির জন্য উপযুক্ত, যেখানে একক থ্রেডে কাজ সম্পাদিত হয় এবং একের পর এক কাজ করা হয়।
• Non-blocking Connections বৃহৎ স্কেল, উচ্চ পারফরম্যান্স অ্যাপ্লিকেশনগুলির জন্য উপযুক্ত, যেখানে একাধিক কনেকশনের সাথে দ্রুত যোগাযোগ এবং পারফরম্যান্স উন্নত করা হয়।

Java NIO এর মাধ্যমে Non-blocking I/O ব্যবহার করলে আপনার অ্যাপ্লিকেশনটি আরও স্কেলেবল, কার্যকর এবং রিসোর্স ব্যবহার কম হয়, বিশেষ করে যখন একাধিক TCP কনেকশনের মাধ্যমে ডেটা আদান-প্রদান করতে হয়।