rmi

Η εφαρμογή RMI που θα αναπτυχθεί είναι μια απλή 'μηχανή υπολογισμών': ο διακομιστής RMI δέχεται από τους πελάτες υπολογιστικές εργασίες, τις εκτελεί και επιστρέφει τα αποτελέσματα. Ο κώδικας του διακομιστή περιλαμβάνει μια απομακρυσμένη διεπαφή και μια κλάση απομακρυσμένων αντικειμένων. Η διεπαφή ορίζει τις μεθόδους που μπορεί να καλέσει ο πελάτης. Ουσιαστικά είναι αυτό που 'βλέπει' ο πελάτης από το απομακρυσμένο αντικείμενο. Η κλάση παρέχει την υλοποίηση των μεθόδων και των σχετικών αντικειμένων.

Σχεδιασμός Απομακρυσμένης Διεπιφάνειας

Στο πυρήνα της μηχανής υπολογισμών βρίσκεται ένα πρωτόκολλο για την υποβολή, εκτέλεση και επιστροφή των υπολογιστικών εργασιών. Το πρωτόκολλο αυτό εκφράζεται μέσω της απομακρυσμένης διεπιφάνειας.

Η μηχανή υπολογισμού δεν 'γνωρίζει' εκ των προτέρων την υπολογιστική εργασία που θα εκτελέσει. Ο πελάτης καθορίζει την υπολογιστική εργασία. Ο διακομιστής διαθέτει την υπολογιστική του υποδομή για την εκτέλεση της εργασίας και την επικοινωνιακή του υποδομή για την επικοινωνία με το πελάτη.

Η απομακρυσμένη διεπιφάνεια ορίζεται στο compute.Compute:
package compute;

import java.rmi.Remote;
import java.rmi.RemoteException;

public interface Compute extends Remote {
    <T> T executeTask(Task<T> t) throws RemoteException;
}
Η διεπιφάνεια Compute ορίζεται ως απομακρυσμένη, δηλαδή μπορεί να κληθεί από άλλη JVM, μέσω της δήλωσης extends java.rmi.Remote. Οποιοδήποτε αντικείμενο υλοποιεί αυτή τη διεπιφάνεια ορίζεται ως απομακρυσμένο αντικείμενο.

Η μέθοδος executeTask είναι η μοναδική μέθοδος-μέλος της απομακρυσμένης διεπιφάνειας, άρα είναι μια απομακρυσμένη μέθοδος. Γι' αυτό το λόγο δηλώνεται throws java.rmi.RemoteException. Αυτή η εξαίρεση προκαλείται από το RMI αν κατά την κλήση απομακρυσμένης μεθόδου προκύψει σφάλμα επικοινωνίας.

Η μέθοδος executeTask στη διεπιφάνεια Compute υλοποιεί τη διεπιφάνεια compute.Task. Η διεπιφάνεια compute.Task ουσιαστικά ορίζει ένα γενικευμένο τύπο υπολογιστικής εργασίας που θα εκτελέσει ο διακομιστής. Η μοναδική μέθοδος-μέλος της διεπιφάνειας είναι η execute:
package compute;

public interface Task<T> {
    T execute();
}
H μέθοδος execute δεν έχει παραμέτρους εισόδου-εφαρμόζεται απλά επί ενός αντικειμένου- και δεν προκαλεί εξαιρέσεις. Σημειώστε οτι η διεπιφάνεια compute.Task δεν έχει δήλώση extends java.rmi.Remote, επομένως δεν ορίζεται ως απομακρυσμένη. Αυτό σημαίνει οτι δεν είναι άμεσα ορατή από την εφαρμογή του πελάτη, και δε χρειάζεται να δηλωθεί με throws java.rmi.RemoteException.

Η διεπιφάνεια Task δέχεται μια παράμετρο γενικευμένου τύπου, τη T, που είναι ο τύπος που επιστρέφει ο υπολογισμός. Η μέθοδος execute επιστρέφει την αποτέλεσμα τύπου T.

Με τη σειρά της, η μέθοδος Compute.executeTask δέχεται ως παράμετρο ένα αντικείμενο που υλοποιεί τη διεπιφάνεια Task καθώς και ένα στιγμιότυπο του γενικευμένου τύπου επιστροφής <Τ>.

Ένα απομακρυσμένο αντικείμενο που υλοποιεί την διεπιφάνεια Compute μπορεί να εκτελέσει οποιαδήποτε υπολογιστική εργασία αρκεί να υλοποιείται μέσω κλάσεων που υλοποιούν τη διεπιφάνεια Task. Οι κλάσεις αυτές μπορεί να περιέχουν οποιαδήποτε δεδομένα και μεθόδους είναι απαραίτητα για την εκτέλεση της υπολογιστικής εργασίας.

Επειδή τα αντικείμενα που υλοποιούν τη διεπιφάνεια Task είναι γραμμένα σε Java, οι υλοποήσεις τους μπορούν να μεταφορτωθούν από τη JVM του πελάτη στη JVM του διακομιστή, δηλαδή της 'υπολογιστικής μηχανής'. Με αυτό το τρόπο οι πελάτες μπορούν να 'μάθουν' στο διακομιστή νέες υπολογιστικές εργασίες, οι οοίες δεν έχουν ρητά εγκατασταθεί στο διακομιστή, αλλά μεταφέρονται κατά την εκτέλεση της εφαρμογής RMI.

Το RMI μεταφέρει τις τιμές των απομακρυσμένων αντικείμενων (pass by value). Γι' αυτό το σκοπό χρησιμοποιεί τον μηχανισμό σειριοποίησης αντικειμένων (object serialization) της Java. Ένα αντικείμενο θεωρείται σειριοποιήσιμο αν η κλάση του δηλωθεί με implements java.io.Serializable. Επομένως οι κλάσεις που θα υλοποιήσουν τη διεπιφάνεια Task θα πρέπει να υλοποιούν και τη διεπιφάνεια Serializable.

Υλοποίηση Απομακρυσμένης Διεπιφάνειας

Εδώ θα συζητήσουμε την υλοποίηση της κλάσης της υπολογιστικής μηχανής. Γενικά, μια κλάση που υλοποιεί μια απομακρυσμένη διεπιφάνεια πρέπει να κάνει τουλάχιστο τα εξής:

Δήλωση των απομακρυσμένων διεπιφανειών

Ορισμός ενός κατασκευαστή για κάθε απομακρυσμένο αντικείμενο

Υλοποίηση των απομακρυσμένων μεθόδων-μελών των απομακρυσμένων διεπαφών

Ένας διακομιστής RMI πρέπει να δημιουργήσει τα απομακρυσμένα αντικείμενα, να τα εξάγει (export) στο περιβάλλον εκτέλεσης και να ενημερώσει το μητρώο RMI, ώστε να μπορούν να δεχτούν απομακρυσμένες κλήσεις. Οι λειτουργίες αρχικοποίησης αυτή μπορεί είτε να περιλαμβάνεται στην υλοποίηση του απομακρυσμένου αντικειμένου είτε να αποτελεί ξεχωριστή διαδικασία. Η διαδικασία αρχικοποίησης πρέπει να κάνει τα ακόλουθα:

Δημιουργία και εγκατάσταση διαχειριστή ασφάλειας

Δημιουργία απομακρυσμένων αντικειμένων

Εξαγωγή και καταχώρηση απομακρυσμένων αντικειμένων

Η κλάση engine.ComputeEngine υλοποιεί την απομακρυσμένη διεπιφάνεια Compute και περιλαμβάνει και τη διαδικασία αρχικοποίηση main της 'υπολογιστικής μηχανής' :

package engine;

import java.rmi.RemoteException;
import java.rmi.registry.LocateRegistry;
import java.rmi.registry.Registry;
import java.rmi.server.UnicastRemoteObject;
import compute.Compute;
import compute.Task;

public class ComputeEngine implements Compute {

    public ComputeEngine() {
        super();
    }

    public <T> T executeTask(Task<T> t) {
        return t.execute();
    }

    public static void main(String[] args) {
        if (System.getSecurityManager() == null) {
            System.setSecurityManager(new SecurityManager());
        }
        try {
            String name = "Compute";
            Compute engine = new ComputeEngine();
            Compute stub =
                (Compute) UnicastRemoteObject.exportObject(engine, 0);
            Registry registry = LocateRegistry.getRegistry();
            registry.rebind(name, stub);
            System.out.println("ComputeEngine bound");
        } catch (Exception e) {
            System.err.println("ComputeEngine exception:");
            e.printStackTrace();
        }
    }
}
Ο κώδικας συζητείται στις παραγράφους που ακολουθούν.

Δήλωση των Απομακρυσμένων Αντικειμένων που Υλοποιούνται
Η κλάση υλοποίησης της 'υπολογιστικής μηχανής' δηλώνεται ως:
public class ComputeEngine implements Compute
Η κλάση υλοποιεί την απομακρυσμένη διεπιφάνεια compute.Compute, επομένως μπορεί να κληθεί ως απομακρυσμένο αντικείμενο.
Κατασκευαστής Απομακρυσμένων Αντικειμένων
Η κλάση ComputeEngine έχει ένα απλό κατασκευαστή που δε δέχεται ορίσματα. Ο κώδικας είναι ο εξής:
public ComputeEngine() {
    super();
}
Ο κατασκευαστής απλά καλεί ένα γενικευμένο κατασκευαστή χωρίς ορίσματα, της κλάσης Object. Η κλήση αυτή θα γινόταν ακόμη και αν ο κατασκευαστής ComputeEngine είχε παραληφθεί εντελώς.
Υλοποιήσεις Απομακρυσμένων Μεθόδων
Η κλάση ενός απομακρυσμένου αντικειμένου παρέχει υλοποιήσεις για κάθε απομακρυσμένη μέθοδο που ορίζεται στις απομακρυσμένες διεπιφάνειες. Η διεπιφάνεια Compute περιέχει μόνο μια απομακρυσμένη μέθοδο, την executeTask, που υλοποιείται ως εξής:
public <T> T executeTask(Task<T> t) {
    return t.execute();
}
Αυτή η μέθοδος υλοποιεί το πρωτόκολλο επικοινωνίας του απομακρυσμένου αντικειμένου ComputeEngine και των πελατών. Κάθε πελάτης περνά στο αντικείμενο ComputeEngine ένα αντικείμενο Task το οποίο αποτελεί μια συγκεκριμένη υλοποίηση της μεθόδου execute της διεπιφάνειας του αντικειμένου Task. Το αντικείμενο ComputeEngine εκτελεί την υπολογιστική εργασία και επιστρέφει το αποτέλεσμα της μεθόδου execute στον πελάτη.
Πέρασμα Παραμέτρων στο RMI

Οι παράμετροι (ορίσματα, επιστροφές) πρός και από τις απομακρυσμένες μεθόδους μπορούν να είναι σχεδόν οποιουδήποτε τύπου, όπως τοπικά αντικείμενα, απομακρυσμένα αντικείμενα και βασικοί τύποι δεδομένων. Πιο συγκεκριμένα, οποιαδήποτε οντότητα οποιουδήποτε τύπου μπορεί να χρησιμοποιοηθεί ως παράμετρος, αρκεί αυτή η οντότητα να είναι στιγμιότυποενός βαικού τύπου, ενός απομακρυσμένου αντικειμένου ή ενός σειριοποιήσιμου (serializable) αντικειμένου, δηλαδή αντικειμένου που υλοποιεί τη διεπιφάνεια java.io.Serializable.
Μερικοί τύποι αντικειμένων δεν ανήκουν στις παραπάνω κατηγορίες. Πρόκειται κυρίως για αντικείμενα, όπως νήματα ή περιγραφείς αρχείων, που περιέχουν πληροφορία που αφορά συγκεκριμένο χώρο διευθύνσεων. Από την άλλη πλευρά πολλές βαικές κλάσεις, όπως τα πακέτα java.lang και java.util, υλοποιούν τη διεπιφάνεια Serializable.

Οι κανόνες περάσματος παραμέτρων είναι οι εξής:

Τα απομακρυσμένα αντικείμενα περνούν ουσιαστικά με αναφορά (by reference). Η αναφορά ενός απομακρυσμένου αντικειμένου είναι ένα στέλεχος (stub), που είναι ένας πληρεξούσιος στη πλευρά του πελάτη που υλοποιεί όλες τις απομακρυσμένες διεπιφάνειες που υλοποιεί το απομακρυσμένο αντικείμενο.

Τα τοπικά αντικείμενα περνούν με αντιγραφή (by copy), μέσω σειριοποίησης αντικειμένων. Εξ' ορισμού, όλα τα πεδία ενός αντικειμένου αντιγράφονται, εκτός από τα static ή transient.

Το πέρασμα με αναφορά ενός απομακρυσμένου αντικειμένου, σημαίνει οτι οποιεσδήποτε αλλαγές συμβαίνουν στο αντικείμενο, μέσω της κλήσης απομακρυσμένης μεθόδου, εφαρμόζονται στο πρωτότυπο απομακρυσμένο αντικείμενο. Βέβαια, μόνο οι απομακρυσμένες διεπαφές του απομακρυσμένου αντικειμένου είναι διαθέσιμες στον πελάτη. Οι μέθοδοι που είναι ορισμένες ως μη-απομακρυσμένες δεν είναι ορατές στο πελάτη.

Για παράδειγμα, αν περάσετε μια αναφορά σε στιγμιότυπο της κλάσης ComputeEngine, ο πελάτης θα έχει πρόσβαση μόνο στη μέθοδο executeTask, αλλά δεν θα μπορεί να δεί τον κατασκευαστή αντικειμένων της κλάσης ComputeEngine, τη μέθοδο main της κλάσης, ή την υλοποίηση άλλων μεθόδων της κλάσης java.lang.Object.

In the parameters and return values of remote method invocations, objects that are not remote objects are passed by value. Thus, a copy of the object is created in the receiving Java virtual machine. Any changes to the object's state by the receiver are reflected only in the receiver's copy, not in the sender's original instance. Any changes to the object's state by the sender are reflected only in the sender's original instance, not in the receiver's copy.

Υλοποίηση Μεθόδου main του Διακομιστή

Η πιο σύνθετη μέθοδος στην υλοποίηση της κλάσης ComputeEngine είναι η μέθοδος main. Η μέθοδος main ξεκινά ένα αντικείμενο της κλάσης ComputeEngine και γι' αυτό απαιτείται αρχικοποίηση και άλλες ρυθμίσεις του διακομιστή. Δεν πρόκειται για απομακρυσμένη μέθοσο. Επειδή η μέθοδος main είναι δηλωμένη static, είναι μάλλον συνδεδεμένη με τη κλάση ComputeEngine συνολικά παρά με το αντικείμενο που ξεκινά.

Εγκατάσταση Διαχειριστή Ασφάλειας
Η πρώτη εργασία της μεθόδου main είναι η εγκατάσταση ενός διαχειριστή ασφάλειας, που προστατεύει τους πόρους του συστήματος από κακόβουλο κώδικα που πιθανώς να εκτελεστεί στη JVM του διακομιστή, μέσω της 'υπολογιστικής μηχανής'. Ο διαχειριστής ασφάλειας διασφαλίζει οτι ο κώδικας που θα μεταφορτωθεί θα υπακούει σε συγκεκριμενες πολιτικές ασφάλειας.

Ο διαχειριστής ασφάλειας καθορίζει αν ο κώδικας που μεταφορτώθηκε έχει πρόσβαση στο τοπικό σύστημα αρχείων ή μπορεί να εκτελέσει άλλες προνομιακές λειτουργίες. Αν ένα πρόγραμμα RMI δεν εγκαταστήσει διαχειριστή ασφάλειας, το RMI δεν θα μεταφορτώσει κλάσεις (παρά μόνο από το τοπικό class path) για αντικείμενα που είναι παράμετροι σε κλήσεις απομακρυσμένων μεθόδων.
Ο παρακάτω κώδικας εγκαθιστά τον διαχειριστή ασφάλειας:
if (System.getSecurityManager() == null) {
    System.setSecurityManager(new SecurityManager());
}
Δημιουργία, Εξαγωγή και Καταχώρηση Απομακρυσμένων Αντικειμένων
Στη συνέχεια η μέθοδος main δημιουργεί ένα απομακρυσμένο αντικείμενο της κλάσης ComputeEngine και το εξάγει στο σύστημα εκτέλεσης του RMI:
Compute engine = new ComputeEngine();
Compute stub =
    (Compute) UnicastRemoteObject.exportObject(engine, 0);
Η static μέθοδος UnicastRemoteObject.exportObject εξάγει το απομακρυσμένο αντικείμενο ώστε να μπορεί να δέχεται κλήσεις των απομακρυσμένων μεθόδων του από πελάτες. Το δεύτερο όρισμα, τύπου int, καθορίζει τη θύρα TCP port που θα χρησιμοποιήσει το σύστημα εκτέλεσης RMI για να 'ακούει' τις εισερχόμενες κλήσεις. Συνήθως θέτουμε μηδέν, αφήνοντας την απόφαση στο σύστημα εκτέλεσης του RMI ή στο λειτουργικό σύστημα. Όμως θα μπορούσαμε να θέσουμε ένα συγκεκριμένο αριθμό. Αν η κλήση της μεθόδου exportObject επιστρέψει με επιτυχία, το απομακρυσμένο αντικείμενο κλάσης ComputeEngine είναι έτοιμο να επεξεργαστεί εισερχόμενες απομακρυσμένες κλήσεις.

H μέθοδος exportObject επιστρέφει ένα στέλεχος του απομακρυσμένου αντικειμένου. Σημειώστε οτι τόσο η new όσο και η exportObject έχουν τύπο επιστροφής Compute, όχι ComputeEngine, γιατί το απομακρυσμένο αντικείμενο είναι μεν της κλάσης ComputeEngine αλλά υλοποιεί μόνο την απομακρυσμένη διεπιφάνεια.

Η μέθοδος main μέσω της δομής try/catch συλλαμβάνει εξαιρέσεις τύπου RemoteException που μπορεί να παράγει η exportObject. Σε ένα διαφορετικό χειρισμό, χωρίς τη δομή try/catch, η μέθοδος RemoteException θα έπρεπε να δηλωθεί στη φράση throws της μεθόδου main. Η εξαίρεση RemoteException μπορεί να προκληθεί αν παρουσιαστούν προβλήματα στους δικτυακούς πόρους, όπως για παράδειγμα αν η θύρα που επιλέγουμε είναι δεσμευμένη.

Για να μπορέσει ο πελάτης να αποστείλει μια κλήση μεθόδου στο απομακρυσμένο αντικείμενο του διακομιστή, θα πρέπει να γνωρίζει μια αναφορά σε αυτό το αντικείμενο. Η αναφορά στο απομακρυσμένο αντικείμενο συνήθως προκύπτει ως επιστροφή μιας κλήσης μεθόδου. Η επιστροφή μπορεί να περιέχει είτε την ίδια την αναφορά ή μια δομή δεδομένων που περιέχει αναφορές.

Το RMI υποστηρίζει ένα ειδικό τύπο απομακρυσμένου αντικειμένου, το μητρώο RMI (RMI registry), που επιτρέπει την εύρεση των αναφορών σε απομακρυσμένα αντικείμενα. Το μητρώο RMI είναι μια απλή υπηρεσία ονομασίας απομακρυσμένων αντικειμένων που επιτρέπει τους πελάτες να λαμβάνουν αναφορές σε απομακρυσμένα αντικείμενα με βάση το όνομα. Συνήθως το μητρώο χρησιμοποιείται για τον εντοπισμό του πρώτου απομακρυσμένου αντικειμένου, το οποίο στη συνέχεια παραπέμπει πιθανώς σε άλλα απομακρυσμένα αντικείμενα.

Η απομακρυσμένη διεπιφάνεια java.rmi.registry.Registry είναι το API για τη καταχώρηση και αναζήτηση απομακρυσμένων αντικειμένων στο μητρώο RMI. Η κλάση java.rmi.registry.LocateRegistry παρέχει στατικές μεθόδους για τη σύνθεση απομακρυσμένων αναφορών σε ένα μητρώο που βρίσκεται σε συγκεκριμένη υποδοχή δικτύου (διέυθυνση IP και θύρα). Εφ'όσον ένα απομακρυσμένο αντικείμενο κατχωρηθεί στο μητρώο RMI του διακομιστή, οι πελάτες μπορούν να το αναζητήσουν στο μηρώο με το όνομά του (το οποίο πρέπει να γνωρίζουν), να λάβουν την απομακρυσμένη αναφορά (που περιλαμβάνει όλες τις πληροφορίες επικοινωνίας) και να τη χρησιμοποιήσουν για να καλέσουν απομακρυσμένες μεθόδους επ' αυτού του αντικειμένου.

Στο κώδικα της μεθόδου main βλέπουμε οτι κατ'αρχή ορίζεται ένα όνομα για την 'υπολογιστική μηχανή':
String name = "Compute";
Στη συνέχεια, αφού εντοπιστεί το μητρώο RMI του διακομιστή, το όνομα καταχωρείται στο μητρώο -σε συνδυασμό με το αντίστοιχο στέλεχος του απομακρυσμένου αντικειμένου που έχει δημιουργηθεί:
Registry registry = LocateRegistry.getRegistry();
registry.rebind(name, stub);
Η κλήση της μεθόδου rebind αποτελεί μια απομακρυσμένη κλήση στο τοπικό μητρώο RMI. Ως απομακρυσμένη -τυπικά- κλήση, μπορεί να προκαλέσει RemoteException, που συλλαμβάνεται από τη δομή catch στο τέλος της μεθόδου main.

Για τη κλήση της μεθόδου Registry.rebind σημειώστα τα παρακάτω:

Η κλήση LocateRegistry.getRegistry χωρίς παραμέτρους αναζητά μητρώο RMI στο τοπικό σύστημα (localhost) και στη προπειλεγμένη θύρα 1099. Αν θέλετε μπορείτε να δηλώσετε άλλη θύρα, αφού η μέθοδος δέχεται μια παράμετρο int).

Για λόγους ασφαλείας, μια εφαρμογή μπορεί να καλέσει τις μεθόδους bind, unbind,ή rebind μόνο σε μητρώο ΡΜΙ στο τοπικό σύστημα. Αυτή η πολιτική αποτρέπει μια απομακρυσμένη εφαρμογή να τροποποιήσει το μητρώο του διακομιστή. Η κλήση της μεθόδου lookup, μπορεί να γίνει από τοπικές ή απομακρυσμένες εφαρμογές.

Στο μητρώο RMI καταχωρείται το στέλεχος και όχι το απομακρυσμένο αντικείμενο καθ' αυτό. Έτσι, όταν ένας πελάτης αναζητά ένα απομακρυσμένο αντικείμενο με το όνομά του, του επιστρέφεται ένα αντίγραφο του στελέχους του απομακρυσμένου αντικειμένου. Με αυτό το τρόπο η απομακρυσμένη κλήση αντικειμένου είναι μια κλήση με αναφορά.

Με την επιτυχή καταχώρηση στο μητρώο RMI, η μέθοδος main εμφανίζει ένα μήνυμα που δηλώνει οτι ο διακομιστής είναι έτοιμος να επεξεργαστεί εισερχόμενα αιτήματα και τερματίζει. Δεν είναι απαραίτητο να υπάρχει κάποιο είδος βρόχου αναμονής και επεξεργασίας εισερχομένων αιτημάτων. Το αντικείμενο ComputeEngine δεν θα τερματιστεί ούτε θα θεωρηθεί garbage, όσο υπάρχει τουλάχιστο μια αναφορά σε αυτό από κάποια τοπική ή απομακρυσμένη JVM. Από τη στιγμή που το μητρώο RMI περιέχει μια αναφορά στο αντικείμενο ComputeEngine, η συνθήκη ικανοποιείται και το σύστημα εκτέλεσης του RMI διατηρεί 'εν ζωή' τη διεργασία του αντικειμένου ComputeEngine. Το αντικείμενο θα τερματιστεί μόνο αν διαγραφεί η καταχώρησή του από το μητρώο RMI και δεν υπάρχουν πελάτες με ενεργές απομακρυσμένες αναφορές σε αυτό.

Το τελευταίο τμήμα κώδικα στη μέθοδο main συλλαμβάνει τυχόν εξαιρέσεις. Ο μόνος τύπος εξαίρεσης είναι ο RemoteException που μπορεί να προκληθεί από τις κλήσεις UnicastRemoteObject.exportObject και rebind. Και στις δύο περιπτώσεις το πρόγραμμα απλά εμφανίζει τα σχετικά μηνύματα σφάλματος και τερματίζει.

package client;

import java.rmi.registry.LocateRegistry;
import java.rmi.registry.Registry;
import java.math.BigDecimal;
import compute.Compute;

public class ComputePi {
public static void main(String args[]) {
if (System.getSecurityManager() == null) {
System.setSecurityManager(new SecurityManager());
}
try {
String name = "Compute";
Registry registry = LocateRegistry.getRegistry(args[0]);
Compute comp = (Compute) registry.lookup(name);
Pi task = new Pi(Integer.parseInt(args[1]));
BigDecimal pi = comp.executeTask(task);
System.out.println(pi);
} catch (Exception e) {
System.err.println("ComputePi exception:");
e.printStackTrace();
}
}
}

package client;

import compute.Task;
import java.io.Serializable;
import java.math.BigDecimal;

public class Pi implements Task<BigDecimal>, Serializable {

private static final long serialVersionUID = 227L;

/** constants used in pi computation */
private static final BigDecimal FOUR =
BigDecimal.valueOf(4);

/** rounding mode to use during pi computation */
private static final int roundingMode =
BigDecimal.ROUND_HALF_EVEN;

/** digits of precision after the decimal point */
private final int digits;

/**
* Construct a task to calculate pi to the specified
* precision.
*/
public Pi(int digits) {
this.digits = digits;
}

/**
* Calculate pi.
*/
public BigDecimal execute() {
return computePi(digits);
}

/**
* Compute the value of pi to the specified number of
* digits after the decimal point. The value is
* computed using Machin's formula:
*
* pi/4 = 4*arctan(1/5) - arctan(1/239)
*
* and a power series expansion of arctan(x) to
* sufficient precision.
*/
public static BigDecimal computePi(int digits) {
int scale = digits + 5;
BigDecimal arctan1_5 = arctan(5, scale);
BigDecimal arctan1_239 = arctan(239, scale);
BigDecimal pi = arctan1_5.multiply(FOUR).subtract(
arctan1_239).multiply(FOUR);
return pi.setScale(digits,
BigDecimal.ROUND_HALF_UP);
}
/**
* Compute the value, in radians, of the arctangent of
* the inverse of the supplied integer to the specified
* number of digits after the decimal point. The value
* is computed using the power series expansion for the
* arc tangent:
*
* arctan(x) = x - (x^3)/3 + (x^5)/5 - (x^7)/7 +
* (x^9)/9 ...
*/
public static BigDecimal arctan(int inverseX,
int scale)
{
BigDecimal result, numer, term;
BigDecimal invX = BigDecimal.valueOf(inverseX);
BigDecimal invX2 =
BigDecimal.valueOf(inverseX * inverseX);

numer = BigDecimal.ONE.divide(invX,
scale, roundingMode);

result = numer;
int i = 1;
do {
numer =
numer.divide(invX2, scale, roundingMode);
int denom = 2 * i + 1;
term =
numer.divide(BigDecimal.valueOf(denom),
scale, roundingMode);
if ((i % 2) != 0) {
result = result.subtract(term);
} else {
result = result.add(term);
}
i++;
} while (term.compareTo(BigDecimal.ZERO) != 0);
return result;
}
}

cd /home/clientuser/src
javac -cp /home/clientuser/public_html/classes/compute.jar
client/ComputePi.java client/Pi.java
mkdir /home/clientuser/public_html/classes/client
cp client/Pi.class
/home/clientuser/public_html/classes/client

java -cp /home/serveruser/src:/home/serveruser/public_html/classes/compute.jar
-Djava.rmi.server.codebase=http://zaphod/~serveruser/classes/compute.jar
-Djava.rmi.server.hostname=zaphod.some.place
-Djava.security.policy=server.policy
engine.ComputeEngine

java -cp /home/clientuser/src:/home/clientuser/public_html/classes/compute.jar
-Djava.rmi.server.codebase=http://ford/~clientuser/classes/
-Djava.security.policy=client.policy
client.ComputePi zaphod.some.place 45.

Κατανεμημένα Αντικείμενα με Java RMI

Πλεονεκτήματα Δυναμικής Φόρτωσης Κώδικα

Απομακρυσμένα: Διεπιφάνειες, Αντικείμενα και Μέθοδοι

Ανάπτυξη Κατανεμημένων Εφαρμογών με RMI

Υλοποίηση Διακομιστή RMI

Σχεδιασμός Απομακρυσμένης Διεπιφάνειας

Υλοποίηση Απομακρυσμένης Διεπιφάνειας

Δήλωση των Απομακρυσμένων Αντικειμένων που Υλοποιούνται

Κατασκευαστής Απομακρυσμένων Αντικειμένων

Υλοποιήσεις Απομακρυσμένων Μεθόδων

Πέρασμα Παραμέτρων στο RMI

Υλοποίηση Μεθόδου `main` του Διακομιστή

Εγκατάσταση Διαχειριστή Ασφάλειας

Δημιουργία, Εξαγωγή και Καταχώρηση Απομακρυσμένων Αντικειμένων

Υλοποίηση Πελάτη RMI

Mεταγλώττιση της Εφαρμογής RMI

Εκτέλεση Εφαρμογής RMI

Eκκίνηση μητρώου RMI

Ρυθμίσεις class paths

Ρυθμίσεις διαχειριστή ασφαλείας

Ρυθμίσεις μεταφόρτωσης κλάσεων

Κατανεμημένα Αντικείμενα με Java RMI

Πλεονεκτήματα Δυναμικής Φόρτωσης Κώδικα

Απομακρυσμένα: Διεπιφάνειες, Αντικείμενα και Μέθοδοι

Ανάπτυξη Κατανεμημένων Εφαρμογών με RMI

Υλοποίηση Διακομιστή RMI

Σχεδιασμός Απομακρυσμένης Διεπιφάνειας

Υλοποίηση Απομακρυσμένης Διεπιφάνειας

Δήλωση των Απομακρυσμένων Αντικειμένων που Υλοποιούνται

Κατασκευαστής Απομακρυσμένων Αντικειμένων

Υλοποιήσεις Απομακρυσμένων Μεθόδων

Πέρασμα Παραμέτρων στο RMI

Υλοποίηση Μεθόδου main του Διακομιστή

Εγκατάσταση Διαχειριστή Ασφάλειας

Δημιουργία, Εξαγωγή και Καταχώρηση Απομακρυσμένων Αντικειμένων

Υλοποίηση Πελάτη RMI

Mεταγλώττιση της Εφαρμογής RMI

Εκτέλεση Εφαρμογής RMI

Eκκίνηση μητρώου RMI

Ρυθμίσεις class paths

Ρυθμίσεις διαχειριστή ασφαλείας

Ρυθμίσεις μεταφόρτωσης κλάσεων

Υλοποίηση Μεθόδου `main` του Διακομιστή