Java NIO (New Input/Output) API এবং Multithreading দুটি গুরুত্বপূর্ণ টেকনোলজি, যা একে অপরের সাথে একত্রে কাজ করতে পারে এবং উচ্চ পারফরম্যান্স ও স্কেলেবল অ্যাপ্লিকেশন তৈরিতে সহায়তা করে। Java NIO তে Non-blocking I/O এবং Selectors ব্যবহারের মাধ্যমে আপনি একাধিক I/O অপারেশন একযোগে পরিচালনা করতে পারেন, এবং যখন এটি Multithreading এর সাথে একত্রিত হয়, তখন এটি আরও বেশি কার্যকরী এবং দক্ষ হয়ে ওঠে।
এই টিউটোরিয়ালে, আমরা দেখব কিভাবে Java NIO এবং Multithreading একত্রে ব্যবহার করে স্কেলেবল এবং হাই পারফরম্যান্স নেটওয়ার্ক অ্যাপ্লিকেশন তৈরি করা যায়।
Java NIO তে Non-blocking I/O একটি মূল বৈশিষ্ট্য, যা অনেক I/O অপারেশন একসাথে চালাতে সক্ষম করে। এই ফিচারটি Multithreading এর সাথে একত্রে কাজ করলে, আপনি একাধিক থ্রেডের মাধ্যমে একযোগে কাজ করতে পারেন এবং প্রোগ্রামের পারফরম্যান্স অনেক বাড়িয়ে দিতে পারেন।
Selectors এবং SocketChannel এর মতো Java NIO এর কম্পোনেন্ট ব্যবহার করে, আপনি একাধিক ক্লায়েন্টের সাথে যোগাযোগ পরিচালনা করতে পারেন এবং থ্রেডিং ব্যবস্থার মাধ্যমে এই যোগাযোগ দ্রুত করতে পারেন।
Java NIO তে Non-blocking I/O এবং Selectors ব্যবহার করে, আপনি একাধিক ক্লায়েন্টের সাথে একই সময়ে যোগাযোগ করতে পারেন। এখানে একটি থ্রেড একাধিক ক্লায়েন্টের সাথেই নেটওয়ার্কে ডেটা আদান-প্রদান করতে সক্ষম। এই পদ্ধতিতে থ্রেড একটি কনটেক্সটে ব্লক না হয়ে, ডেটা রিড/রাইট অপারেশন একযোগে সম্পন্ন করতে পারে।
Multithreading এবং NIO একত্রে ব্যবহার করলে একটি অ্যাপ্লিকেশন অধিক কার্যকরী হয়ে ওঠে। যখন একাধিক থ্রেড চলমান থাকে এবং নেটওয়ার্ক অপারেশন একযোগে পরিচালিত হয়, তখন সার্ভার আরও বেশি ক্লায়েন্ট হ্যান্ডল করতে সক্ষম হয় এবং এইভাবে সার্ভারের পারফরম্যান্স বৃদ্ধি পায়।
যখন একটি থ্রেড একটি I/O অপারেশন সম্পন্ন না হওয়া পর্যন্ত অপেক্ষা করে, তখন অন্য থ্রেডগুলো অন্যান্য কাজ সম্পাদন করতে পারে। Multithreading ব্যবহারের মাধ্যমে সার্ভার ওয়েট টাইম কমিয়ে দ্রুত একাধিক কাজ সম্পন্ন করতে সক্ষম হয়।
নিচে একটি উদাহরণ দেওয়া হলো যেখানে Java NIO এবং Multithreading ব্যবহার করে একটি নেটওয়ার্ক সার্ভার তৈরি করা হয়েছে। এই সার্ভারটি একাধিক ক্লায়েন্টের সাথে একযোগে কাজ করতে সক্ষম।
import java.nio.*;
import java.nio.channels.*;
import java.net.*;
import java.io.*;
public class MultiThreadedServer {
public static void main(String[] args) throws IOException {
// পোর্ট নম্বর
int port = 12345;
// ServerSocketChannel তৈরি
ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();
serverSocketChannel.bind(new InetSocketAddress(port));
serverSocketChannel.configureBlocking(false);
// Selector তৈরি
Selector selector = Selector.open();
serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT);
System.out.println("Server started on port " + port);
while (true) {
selector.select(); // Ready channels চেক করা
// Selector থেকে নির্বাচিত কীগুলির প্রক্রিয়া
for (SelectionKey key : selector.selectedKeys()) {
if (key.isAcceptable()) {
// নতুন ক্লায়েন্ট সংযোগ গ্রহণ
SocketChannel socketChannel = serverSocketChannel.accept();
socketChannel.configureBlocking(false);
socketChannel.register(selector, SelectionKey.OP_READ);
System.out.println("Client connected: " + socketChannel.getRemoteAddress());
}
if (key.isReadable()) {
// ক্লায়েন্ট থেকে ডেটা পড়া
SocketChannel socketChannel = (SocketChannel) key.channel();
ByteBuffer buffer = ByteBuffer.allocate(256);
int bytesRead = socketChannel.read(buffer);
if (bytesRead == -1) {
socketChannel.close();
System.out.println("Client disconnected.");
} else {
buffer.flip();
System.out.println("Message from client: " + new String(buffer.array(), 0, buffer.limit()));
}
}
}
selector.selectedKeys().clear();
}
}
}
এখানে, ServerSocketChannel এবং Selector ব্যবহার করে সার্ভার তৈরি করা হয়েছে যা একাধিক ক্লায়েন্টের সাথে একযোগে যোগাযোগ করে এবং Multithreading ব্যবহার করা হয়নি, কারণ Selector এবং Non-blocking I/O একযোগে কাজ করছে।
import java.nio.*;
import java.nio.channels.*;
import java.net.*;
import java.io.*;
public class MultiThreadedServerWithThread {
public static void main(String[] args) throws IOException {
int port = 12345;
// ServerSocketChannel তৈরি
ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();
serverSocketChannel.bind(new InetSocketAddress(port));
serverSocketChannel.configureBlocking(false);
// Selector তৈরি
Selector selector = Selector.open();
serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT);
System.out.println("Server started on port " + port);
while (true) {
selector.select();
for (SelectionKey key : selector.selectedKeys()) {
if (key.isAcceptable()) {
SocketChannel socketChannel = serverSocketChannel.accept();
socketChannel.configureBlocking(false);
socketChannel.register(selector, SelectionKey.OP_READ);
System.out.println("Client connected: " + socketChannel.getRemoteAddress());
// নতুন ক্লায়েন্টের জন্য নতুন থ্রেড তৈরি
new ClientHandler(socketChannel).start();
}
}
selector.selectedKeys().clear();
}
}
}
class ClientHandler extends Thread {
private SocketChannel socketChannel;
public ClientHandler(SocketChannel socketChannel) {
this.socketChannel = socketChannel;
}
@Override
public void run() {
try {
ByteBuffer buffer = ByteBuffer.allocate(256);
int bytesRead = socketChannel.read(buffer);
if (bytesRead == -1) {
socketChannel.close();
System.out.println("Client disconnected.");
} else {
buffer.flip();
System.out.println("Message from client: " + new String(buffer.array(), 0, buffer.limit()));
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
এখানে, সার্ভারটি একটি নতুন ClientHandler থ্রেড তৈরি করে, যা প্রতিটি ক্লায়েন্টের জন্য আলাদা কাজ পরিচালনা করে, ফলে একাধিক ক্লায়েন্টের সাথে একযোগে কাজ করা সম্ভব হয়।
Java NIO এবং Multithreading একসাথে ব্যবহার করে আপনি উচ্চ পারফরম্যান্স এবং স্কেলেবল নেটওয়ার্ক অ্যাপ্লিকেশন তৈরি করতে পারেন। Non-blocking I/O এবং Selector ব্যবহার করে আপনি একাধিক ক্লায়েন্টের সাথে একযোগে যোগাযোগ করতে পারেন এবং Multithreading এর মাধ্যমে প্রতিটি ক্লায়েন্টের সাথে আলাদা কাজ পরিচালনা করতে পারেন, যা সার্ভারের পারফরম্যান্স উন্নত করতে সহায়ক। Java NIO এবং Multithreading এর এই সংমিশ্রণ আপনাকে অধিক কার্যকরী এবং স্কেলেবল নেটওয়ার্ক সার্ভার তৈরি করতে সহায়তা করে।
Java NIO (Non-blocking I/O) এবং Multithreading একসাথে ব্যবহৃত হলে খুব শক্তিশালী এবং দক্ষ I/O অপারেশন সম্পাদন করা সম্ভব। Java NIO নন-ব্লকিং I/O মডেল ব্যবহার করে ডেটা প্রক্রিয়া করে এবং Multithreading এর মাধ্যমে একাধিক কাজ সমান্তরালে (parallel) করা যায়, যার ফলে অ্যাপ্লিকেশনটির পারফরম্যান্স এবং স্কেলেবিলিটি অনেক বৃদ্ধি পায়।
এখানে আমরা দেখব কিভাবে Java NIO এবং Multithreading এর সংমিশ্রণ ব্যবহার করে একাধিক সংযোগ পরিচালনা করা যায়, বিশেষ করে SocketChannel এবং ServerSocketChannel এর মাধ্যমে নেটওয়ার্ক I/O পরিচালনা করা হয়।
Selector একটি গুরুত্বপূর্ণ উপাদান, যা একাধিক I/O চ্যানেলের ওপর নজর রাখে এবং একাধিক নেটওয়ার্ক অপারেশন পরিচালনা করে। যখন কোনো চ্যানেলে ডেটা আসে, তখন তা সিলেক্টর দ্বারা চিহ্নিত হয় এবং সংশ্লিষ্ট থ্রেড বা প্রোগ্রাম তা গ্রহণ করে।এখানে আমরা একটি সিম্পল TCP Server এবং TCP Client উদাহরণ দেখব যেখানে Java NIO এবং Multithreading ব্যবহার করে একাধিক ক্লায়েন্ট সংযোগ পরিচালনা করা হবে। ServerSocketChannel ব্যবহার করে সার্ভার ক্লায়েন্টের সংযোগ গ্রহণ করবে এবং প্রতিটি সংযোগের জন্য একটি নতুন থ্রেড তৈরি করা হবে।
import java.io.*;
import java.nio.*;
import java.nio.channels.*;
import java.net.*;
import java.util.concurrent.*;
public class MultiThreadedNIOEchoServer {
private static final int PORT = 8080;
private static final ExecutorService threadPool = Executors.newFixedThreadPool(10); // Thread pool for handling multiple clients
public static void main(String[] args) {
try (ServerSocketChannel serverSocketChannel = ServerSocketChannel.open()) {
serverSocketChannel.bind(new InetSocketAddress(PORT));
serverSocketChannel.configureBlocking(false);
System.out.println("Server started on port " + PORT);
while (true) {
// Accept client connections in non-blocking mode
SocketChannel socketChannel = serverSocketChannel.accept();
if (socketChannel != null) {
System.out.println("New client connected: " + socketChannel.getRemoteAddress());
// Handle the client connection in a new thread
threadPool.submit(() -> handleClient(socketChannel));
}
}
} catch (IOException e) {
e.printStackTrace();
}
}
private static void handleClient(SocketChannel socketChannel) {
try {
ByteBuffer buffer = ByteBuffer.allocate(256);
while (socketChannel.read(buffer) != -1) {
buffer.flip();
while (buffer.hasRemaining()) {
socketChannel.write(buffer);
}
buffer.clear(); // Clear the buffer for the next read
}
socketChannel.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
এখানে:
ExecutorService এর মাধ্যমে পরিচালিত হচ্ছে। ExecutorService একাধিক থ্রেডের মাধ্যমে ক্লায়েন্ট সংযোগগুলোর সাথে যোগাযোগ পরিচালনা করে।SocketChannel ব্যবহার করে প্রতিটি ক্লায়েন্টের সঙ্গে ডেটা পাঠানো এবং গ্রহণ করা হচ্ছে।import java.io.*;
import java.nio.*;
import java.nio.channels.*;
import java.net.*;
public class NIOClient {
private static final String SERVER_ADDRESS = "localhost";
private static final int SERVER_PORT = 8080;
public static void main(String[] args) {
try (SocketChannel socketChannel = SocketChannel.open()) {
socketChannel.connect(new InetSocketAddress(SERVER_ADDRESS, SERVER_PORT));
String message = "Hello, NIO Server!";
ByteBuffer buffer = ByteBuffer.wrap(message.getBytes());
// Send message to server
while (buffer.hasRemaining()) {
socketChannel.write(buffer);
}
buffer.clear();
// Receive echo message from server
socketChannel.read(buffer);
buffer.flip();
while (buffer.hasRemaining()) {
System.out.print((char) buffer.get());
}
System.out.println();
} catch (IOException e) {
e.printStackTrace();
}
}
}
এখানে:
SocketChannel.open() ব্যবহার করে ক্লায়েন্ট সার্ভারের সাথে সংযোগ স্থাপন করছে।ByteBuffer ব্যবহার করে প্রেরণ করা হচ্ছে।socketChannel.read() ব্যবহার করা হচ্ছে।ServerSocketChannel.configureBlocking(false) ব্যবহার করে নন-ব্লকিং মোডে কনফিগার করা হয়েছে, যাতে সার্ভার কোনো সংযোগের জন্য ব্লক না হয় এবং অন্য ক্লায়েন্টদের সাথে যোগাযোগ করতে পারে।ExecutorService.submit() এর মাধ্যমে পরিচালিত হচ্ছে। এইভাবে, একাধিক ক্লায়েন্টের জন্য সার্ভার পৃথক থ্রেডে কাজ করে এবং প্রতিটি ক্লায়েন্টকে একটি নির্দিষ্ট সময়ের মধ্যে প্রক্রিয়া করতে সক্ষম।Java NIO এবং Multithreading এর সংমিশ্রণ উচ্চ পারফরম্যান্স নেটওয়ার্কিং এবং I/O অপারেশন পরিচালনা করার জন্য একটি শক্তিশালী পদ্ধতি। NIO এর non-blocking I/O এবং Selector ব্যবহার করে আপনি একাধিক সংযোগ পরিচালনা করতে পারেন, এবং Multithreading ব্যবহার করে একাধিক ক্লায়েন্টের জন্য সার্ভার কার্যকরভাবে কাজ করতে পারে। এই পদ্ধতি Java অ্যাপ্লিকেশনগুলির জন্য স্কেলেবিলিটি এবং কার্যকারিতা বাড়াতে সাহায্য করে, বিশেষ করে যেখানে বৃহৎ সংখ্যক ক্লায়েন্টদের সাথে একযোগে কাজ করতে হয়।
Java NIO (New I/O) একটি শক্তিশালী API যা Non-blocking I/O অপারেশন এবং Multithreading সমর্থন করে। Non-blocking I/O এবং Multithreading একত্রে ব্যবহার করলে একাধিক I/O অপারেশনকে একসাথে কার্যকরভাবে পরিচালনা করা সম্ভব হয়, যার ফলে উচ্চ কার্যক্ষমতা এবং স্কেলেবিলিটি নিশ্চিত হয়।
Java NIO তে Non-blocking I/O এর মাধ্যমে একটি থ্রেড একাধিক I/O অপারেশন সম্পাদন করতে পারে, তবে সেটি ব্লক হবে না, অর্থাৎ থ্রেডটি কোনো I/O অপারেশন সম্পন্ন না হওয়া পর্যন্ত অপেক্ষা করবে না। এটি একটি থ্রেডকে অন্যান্য কাজ করতে সক্ষম করে, যেমন নেটওয়ার্ক অ্যাপ্লিকেশন তৈরি করা, যেখানে একাধিক ক্লায়েন্টের সাথে কাজ করতে হয়।
এখানে, আমরা দেখব কিভাবে Java NIO তে Non-blocking I/O এবং Multithreading একসাথে কাজ করে।
Non-blocking I/O এমন একটি মেকানিজম যেখানে থ্রেড কোন I/O অপারেশন (যেমন ফাইল রিডিং, নেটওয়ার্ক ডেটা রিসিভ করা) সম্পন্ন না হওয়া পর্যন্ত ব্লক হয় না। এর মানে হল যে যখন কোনো I/O অপারেশন চলছে, তখন থ্রেডটি অন্য কাজ করতে পারে, এবং যখন I/O অপারেশন সম্পন্ন হবে, তখন সেই থ্রেডটি তার ফলাফল গ্রহণ করতে সক্ষম হবে।
Java NIO তে Selectors, Channels, এবং Buffers ব্যবহার করে Non-blocking I/O অপারেশন বাস্তবায়ন করা হয়।
Multithreading হল একাধিক থ্রেডের মাধ্যমে একযোগে একাধিক কাজ সম্পাদন করা। Java তে Multithreading ব্যবহার করে বিভিন্ন কাজকে সমান্তরালে বা parallelভাবে পরিচালনা করা যায়, যা অ্যাপ্লিকেশনকে দ্রুত এবং দক্ষ করে তোলে। Non-blocking I/O এবং Multithreading এর সম্মিলিত ব্যবহার Java NIO এর মধ্যে সিস্টেম রিসোর্সের কার্যকর ব্যবহার নিশ্চিত করে।
Java NIO তে Selectors ব্যবহার করে একাধিক I/O অপারেশন সমান্তরালে চালানো যায়, এবং Multithreading ব্যবহার করে আমরা প্রতিটি I/O অপারেশন আলাদা থ্রেডে পরিচালনা করতে পারি। এর ফলে একাধিক ক্লায়েন্ট বা সংযোগের সাথে দ্রুত কাজ করা যায়।
এখানে আমরা একটি উদাহরণ দেখব যেখানে Non-blocking I/O এবং Multithreading ব্যবহার করে একটি সার্ভার তৈরি করা হবে, যা একাধিক ক্লায়েন্টের সাথে একযোগে যোগাযোগ করবে। Selector ব্যবহৃত হবে, যা একাধিক SocketChannel থেকে ডেটা পড়বে।
import java.io.IOException;
import java.nio.ByteBuffer;
import java.nio.channels.*;
import java.net.InetSocketAddress;
public class NonBlockingServer implements Runnable {
private Selector selector;
private ServerSocketChannel serverSocketChannel;
public NonBlockingServer() throws IOException {
// Create a selector
selector = Selector.open();
// Create a ServerSocketChannel
serverSocketChannel = ServerSocketChannel.open();
serverSocketChannel.bind(new InetSocketAddress("localhost", 8080));
serverSocketChannel.configureBlocking(false); // Set the server to non-blocking
serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT); // Register server to listen for accept
}
@Override
public void run() {
try {
while (true) {
// Select channels that are ready for I/O
selector.select();
// Get selected keys (channels that are ready for I/O)
for (SelectionKey key : selector.selectedKeys()) {
if (key.isAcceptable()) {
// Accept client connections
SocketChannel clientChannel = serverSocketChannel.accept();
clientChannel.configureBlocking(false);
clientChannel.register(selector, SelectionKey.OP_READ);
} else if (key.isReadable()) {
// Read data from client
SocketChannel clientChannel = (SocketChannel) key.channel();
ByteBuffer buffer = ByteBuffer.allocate(256);
int bytesRead = clientChannel.read(buffer);
if (bytesRead == -1) {
clientChannel.close();
} else {
buffer.flip();
while (buffer.hasRemaining()) {
System.out.print((char) buffer.get());
}
}
}
selector.selectedKeys().remove(key);
}
}
} catch (IOException e) {
e.printStackTrace();
}
}
public static void main(String[] args) throws IOException {
NonBlockingServer server = new NonBlockingServer();
Thread serverThread = new Thread(server);
serverThread.start(); // Run the server in a separate thread
}
}
serverSocketChannel.configureBlocking(false) ব্যবহার করা হয়েছে, যা সার্ভারকে নন-ব্লকিং I/O মোডে সেট করে।import java.io.IOException;
import java.nio.ByteBuffer;
import java.nio.channels.SocketChannel;
import java.net.InetSocketAddress;
public class ClientThread implements Runnable {
private SocketChannel socketChannel;
public ClientThread() throws IOException {
// Open a SocketChannel and connect to the server
socketChannel = SocketChannel.open();
socketChannel.configureBlocking(false);
socketChannel.connect(new InetSocketAddress("localhost", 8080));
}
@Override
public void run() {
try {
while (!socketChannel.finishConnect()) {
// Wait for the connection to be established
}
String message = "Hello from the client!";
ByteBuffer buffer = ByteBuffer.wrap(message.getBytes());
// Write the message to the server
socketChannel.write(buffer);
socketChannel.close();
} catch (IOException e) {
e.printStackTrace();
}
}
public static void main(String[] args) throws IOException {
ClientThread client = new ClientThread();
Thread clientThread = new Thread(client);
clientThread.start(); // Run the client in a separate thread
}
}
socketChannel.configureBlocking(false) ব্যবহার করা হয়েছে, যা ক্লায়েন্টকে নন-ব্লকিং মোডে সেট করে।Java NIO এর Non-blocking I/O এবং Multithreading এর মাধ্যমে আপনি একাধিক I/O অপারেশন এবং সংযোগ দক্ষভাবে পরিচালনা করতে পারেন। Selectors, SocketChannel, এবং ServerSocketChannel এর সাহায্যে আপনি নেটওয়ার্কে একাধিক ক্লায়েন্টের সাথে যোগাযোগ করতে পারবেন, এবং থ্রেডিং ব্যবহারের মাধ্যমে একাধিক কাজ সমান্তরালে কার্যকরভাবে সম্পাদন করতে পারবেন।
এই প্রযুক্তি high-performance এবং scalable সার্ভার তৈরি করতে সহায়ক, যেখানে একাধিক ক্লায়েন্টের সংযোগ পরিচালনা করা হয়, এবং থ্রেডগুলোর মধ্যে সমন্বয় সহজে করা যায়।
Java NIO (New Input/Output) একটি শক্তিশালী API যা উচ্চ পারফরম্যান্স I/O অপারেশন পরিচালনা করতে সহায়ক। Multithreading এর মাধ্যমে Java NIO আরও কার্যকরী হতে পারে, কারণ এটি একাধিক থ্রেডের মাধ্যমে বিভিন্ন I/O অপারেশন সমান্তরালে (parallel) পরিচালনা করতে সক্ষম।
NIO এবং Multithreading Integration এর মাধ্যমে, আমরা একাধিক থ্রেড ব্যবহার করে ফাইল সিস্টেম, নেটওয়ার্ক, বা অন্যান্য I/O অপারেশনগুলি দ্রুত এবং কার্যকরীভাবে সম্পাদন করতে পারি।
এই লেখায় আমরা Java NIO এবং Multithreading এর সংমিশ্রণ দেখব এবং একটি বাস্তব উদাহরণ প্রদর্শন করব যা SocketChannel, Selector, এবং Thread ব্যবহারের মাধ্যমে একাধিক ক্লায়েন্টকে একযোগভাবে হ্যান্ডেল করবে।
Java NIO সাধারণত Non-blocking I/O পরিচালনা করতে ব্যবহৃত হয়, এবং Multithreading এর মাধ্যমে একাধিক I/O অপারেশন একযোগে পরিচালনা করা যায়, যা অ্যাপ্লিকেশনের স্কেলেবিলিটি এবং পারফরম্যান্স বৃদ্ধি করে।
এটি বিশেষ করে নেটওয়ার্কিং অ্যাপ্লিকেশন বা সার্ভার ডিজাইন করতে সহায়ক, যেখানে একাধিক ক্লায়েন্টের সাথে যোগাযোগ করা হয়। Multithreading এর মাধ্যমে একাধিক ক্লায়েন্টের সঙ্গে একই সময়ে যোগাযোগ করার জন্য বিভিন্ন থ্রেড ব্যবহার করা যায়।
এখানে একটি উদাহরণ দেখানো হয়েছে যেখানে NIO (Non-blocking I/O) এবং Multithreading ব্যবহার করে একটি সিম্পল Echo Server তৈরি করা হয়েছে। এই সার্ভার একাধিক ক্লায়েন্টের সাথে সংযোগ স্থাপন করবে এবং তাদের পাঠানো বার্তা ফিরে পাঠাবে (Echo করবে)। এখানে SocketChannel এবং Selector ব্যবহৃত হয়েছে, যা নেটওয়ার্ক অপারেশন পরিচালনা করবে এবং Multithreading দ্বারা একাধিক ক্লায়েন্টকে হ্যান্ডেল করা হবে।
import java.io.IOException;
import java.nio.*;
import java.nio.channels.*;
import java.net.*;
import java.util.Iterator;
public class NIOEchoServer {
public static void main(String[] args) throws IOException {
// সার্ভার সকেট চ্যানেল তৈরি করা
ServerSocketChannel serverSocketChannel = ServerSocketChannel.open();
serverSocketChannel.bind(new InetSocketAddress(8080));
serverSocketChannel.configureBlocking(false); // Non-blocking mode
// Selector তৈরি করা
Selector selector = Selector.open();
// সার্ভার সকেট রেজিস্টার করা
serverSocketChannel.register(selector, SelectionKey.OP_ACCEPT);
System.out.println("Server started and waiting for connections...");
// একাধিক ক্লায়েন্টকে হ্যান্ডেল করার জন্য থ্রেড তৈরি
while (true) {
if (selector.select() > 0) { // Non-blocking select
Iterator<SelectionKey> keys = selector.selectedKeys().iterator();
while (keys.hasNext()) {
SelectionKey key = keys.next();
keys.remove();
if (key.isAcceptable()) {
handleAccept(key); // নতুন ক্লায়েন্টের জন্য সংযোগ গ্রহণ
} else if (key.isReadable()) {
handleRead(key); // ক্লায়েন্ট থেকে ডেটা পড়া
}
}
}
}
}
// ক্লায়েন্ট সংযোগ গ্রহণ করা
private static void handleAccept(SelectionKey key) throws IOException {
ServerSocketChannel serverChannel = (ServerSocketChannel) key.channel();
SocketChannel clientChannel = serverChannel.accept();
clientChannel.configureBlocking(false); // Non-blocking mode
clientChannel.register(key.selector(), SelectionKey.OP_READ); // Read operation
System.out.println("New client connected: " + clientChannel.getRemoteAddress());
}
// ক্লায়েন্ট থেকে ডেটা পড়া এবং একে রিপ্লে করা (Echo)
private static void handleRead(SelectionKey key) throws IOException {
SocketChannel clientChannel = (SocketChannel) key.channel();
ByteBuffer buffer = ByteBuffer.allocate(256);
int bytesRead = clientChannel.read(buffer); // Non-blocking read
if (bytesRead == -1) {
clientChannel.close(); // ক্লায়েন্ট যদি সংযোগ বন্ধ করে দেয়
System.out.println("Client disconnected.");
return;
}
buffer.flip();
while (buffer.hasRemaining()) {
clientChannel.write(buffer); // Echo back to client
}
buffer.clear();
}
}
select() মেথডটি ব্লক না হয়ে অপেক্ষা করবে যতক্ষণ না কোনো ইভেন্ট ঘটে।Java NIO এবং Multithreading Integration দ্বারা আমরা দ্রুত, স্কেলেবল এবং উচ্চ পারফরম্যান্স I/O অ্যাপ্লিকেশন তৈরি করতে পারি। NIO-এর নন-ব্লকিং অপারেশন এবং Multithreading এর সংমিশ্রণ একাধিক থ্রেডের মাধ্যমে একযোগে অনেক কনেকশন পরিচালনা করতে সক্ষম, যা নেটওয়ার্ক সার্ভার, ফাইল সিস্টেম, অথবা অন্যান্য I/O ভিত্তিক অ্যাপ্লিকেশনগুলির জন্য অপরিহার্য। এই প্রযুক্তির ব্যবহার অ্যাপ্লিকেশনটির পারফরম্যান্স এবং স্কেলেবিলিটি যথেষ্ট উন্নত করে।
Read more
or
