RMI Client এবং Server এর মধ্যে Database Connectivity

Java RMI (Remote Method Invocation) ব্যবহার করে একটি ডিস্ট্রিবিউটেড সিস্টেম তৈরি করা যায়, যেখানে ক্লায়েন্ট RMI সার্ভারের মাধ্যমে ডাটাবেসের সাথে সংযোগ স্থাপন করে। এখানে RMI Server ডাটাবেস সংযোগ পরিচালনা করে এবং RMI Client ডাটাবেস অপারেশন (যেমন ডাটা পড়া, লেখা) অনুরোধ করে।

RMI Architecture with Database Connectivity

1. RMI Server:
   • ডাটাবেসের সাথে সংযুক্ত।
   • ক্লায়েন্টের অনুরোধ অনুযায়ী ডাটাবেস থেকে ডাটা পড়া বা লেখা পরিচালনা করে।
2. RMI Client:
   • RMI সার্ভারের রিমোট মেথড কল করে।
   • সার্ভার থেকে রিটার্ন করা ফলাফল গ্রহণ করে।

প্রয়োজনীয় স্টেপগুলো

১. Interface তৈরি (Remote Interface)

Remote Interface সার্ভারের রিমোট মেথড সংজ্ঞায়িত করে।

২. Server Implementation

সার্ভার ক্লাস Remote Interface ইমপ্লিমেন্ট করে এবং ডাটাবেস অপারেশন পরিচালনা করে।

৩. RMI Registry চালু করা

RMI সার্ভারকে RMI Registry-তে রেজিস্টার করতে হবে।

৪. Client Implementation

ক্লায়েন্ট সার্ভার থেকে মেথড কল করে এবং ডাটাবেস অপারেশনের ফলাফল গ্রহণ করে।

কোড উদাহরণ

১. Remote Interface

import java.rmi.Remote;
import java.rmi.RemoteException;
import java.util.List;

public interface DatabaseService extends Remote {
    List<String> getAllRecords() throws RemoteException;
    boolean insertRecord(String record) throws RemoteException;
}

২. Server Implementation

import java.rmi.RemoteException;
import java.rmi.server.UnicastRemoteObject;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.ArrayList;
import java.util.List;

public class DatabaseServiceImpl extends UnicastRemoteObject implements DatabaseService {

    private static final String URL = "jdbc:mysql://localhost:3306/mydb";
    private static final String USER = "root";
    private static final String PASSWORD = "password";
    private Connection connection;

    public DatabaseServiceImpl() throws RemoteException {
        super();
        try {
            connection = DriverManager.getConnection(URL, USER, PASSWORD);
        } catch (Exception e) {
            e.printStackTrace();
            throw new RemoteException("Database connection failed!");
        }
    }

    @Override
    public List<String> getAllRecords() throws RemoteException {
        List<String> records = new ArrayList<>();
        try {
            String query = "SELECT * FROM records";
            PreparedStatement stmt = connection.prepareStatement(query);
            ResultSet rs = stmt.executeQuery();
            while (rs.next()) {
                records.add(rs.getString("data"));
            }
        } catch (Exception e) {
            e.printStackTrace();
            throw new RemoteException("Error fetching records.");
        }
        return records;
    }

    @Override
    public boolean insertRecord(String record) throws RemoteException {
        try {
            String query = "INSERT INTO records(data) VALUES (?)";
            PreparedStatement stmt = connection.prepareStatement(query);
            stmt.setString(1, record);
            return stmt.executeUpdate() > 0;
        } catch (Exception e) {
            e.printStackTrace();
            throw new RemoteException("Error inserting record.");
        }
    }
}

৩. Server Main Class

import java.rmi.registry.LocateRegistry;
import java.rmi.registry.Registry;

public class RMIServer {
    public static void main(String[] args) {
        try {
            DatabaseService service = new DatabaseServiceImpl();
            Registry registry = LocateRegistry.createRegistry(1099);
            registry.rebind("DatabaseService", service);
            System.out.println("RMI Server is running...");
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

৪. Client Implementation

import java.rmi.registry.LocateRegistry;
import java.rmi.registry.Registry;
import java.util.List;

public class RMIClient {
    public static void main(String[] args) {
        try {
            Registry registry = LocateRegistry.getRegistry("localhost", 1099);
            DatabaseService service = (DatabaseService) registry.lookup("DatabaseService");

            // Fetch records
            List<String> records = service.getAllRecords();
            System.out.println("Records from database:");
            for (String record : records) {
                System.out.println(record);
            }

            // Insert a new record
            boolean isInserted = service.insertRecord("New Record");
            System.out.println("Record inserted: " + isInserted);

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

ডাটাবেস সেটআপ (MySQL)

1. ডাটাবেস তৈরি করুন:

   CREATE DATABASE mydb;
   

2. টেবিল তৈরি করুন:

   CREATE TABLE records (
       id INT AUTO_INCREMENT PRIMARY KEY,
       data VARCHAR(255) NOT NULL
   );
   

3. ডাটাবেস ব্যবহারকারী তৈরি করুন:

   CREATE USER 'root'@'localhost' IDENTIFIED BY 'password';
   GRANT ALL PRIVILEGES ON mydb.* TO 'root'@'localhost';
   FLUSH PRIVILEGES;
   

Workflow

1. RMI Server ডাটাবেসের সাথে সংযোগ স্থাপন করে।
2. RMI Client getAllRecords() বা insertRecord() মেথড কল করে।
3. Server মেথডটি প্রক্রিয়া করে ডাটাবেসের উপর কাজ সম্পন্ন করে।
4. Server ফলাফল ক্লায়েন্টে রিটার্ন করে।

সুবিধা

1. ডিস্ট্রিবিউটেড সিস্টেম: ক্লায়েন্ট এবং সার্ভার আলাদা JVM-এ চলে।
2. পুনর্ব্যবহারযোগ্য কোড: একবার সার্ভার সেটআপ করলে, একাধিক ক্লায়েন্ট ব্যবহার করতে পারে।
3. ডাটাবেস নিরাপত্তা: ক্লায়েন্ট সরাসরি ডাটাবেস অ্যাক্সেস না করে RMI ব্যবহার করে।

চ্যালেঞ্জ এবং সমাধান

1. Latency: ক্লায়েন্ট-সার্ভার নেটওয়ার্ক লেটেন্সি হতে পারে। সমাধান: সার্ভারের কার্যক্ষমতা অপ্টিমাইজ করুন।
2. Security: RMI কল সুরক্ষিত করুন। সমাধান: SSL/TLS ব্যবহার করে নিরাপদ সংযোগ নিশ্চিত করুন।
3. Exception Handling: RemoteException সঠিকভাবে হ্যান্ডেল করুন।

Java RMI ব্যবহার করে ক্লায়েন্ট এবং সার্ভারের মধ্যে ডাটাবেস কানেক্টিভিটি বাস্তবায়ন সহজ এবং কার্যকর। এটি ডিস্ট্রিবিউটেড সিস্টেম তৈরি করতে এবং ক্লায়েন্ট-সার্ভার আর্কিটেকচার উন্নত করতে সহায়ক। উপরোক্ত উদাহরণগুলো অনুসরণ করে RMI-এর মাধ্যমে ডাটাবেস অপারেশন সফলভাবে পরিচালনা করা যায়।