Proz-S14

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 1

14. Komunikacja rozproszona

– gniazdka, RMI

14.1 Pakiet

java.net

14.2 Mechanizm gniazdek TCP

14.3 Przykład aplikacji klient-serwer

14.4 RMI – model DOA

14.5 Przykład aplikacji rozproszonej

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 2

14.1 Pakiet java.net - wprowadzenie

1) Elementy programowania sieciowego

Aplikacje programowe w Javie korzystaj

z protokółów warstwy

transportowej sieci:

„Transmission Control Protocol” (TCP) lub

„User Datagram Protocol” (UDP).

TCP

to poł

czeniowy, niezawodny protokół typu point-to-point – dane

nadchodz

w kolejno

ci wysłania.

Z TCP korzystaj

takie aplikacje, jak Hypertext Transfer Protocol

(HTTP), File Transfer Protocol (FTP), Telnet.

UDP

to bezpoł

czeniowy protokół niezale

nego przesyłania pakietów

danych (tzw. datagramy).
Korzystaj

z niego programy nie wymagaj

ce gwarantowanych

poł

cze

, np. serwer zegara, program ping.

Porty

- logiczne punkty wej

cia do aplikacji pracuj

cych na danym

komputerze, doł

czonym do sieci.

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 3

Dane przekazywane przez Internet posiadaj

adres swojego

przeznaczenia:

adres komputera -

32-bitowy adres IP

adres portu -

16-bitowy numer portu

W komunikacji według protokółu TCP, serwer zwi

zuje swoje

gniazdko

z okre

lonym portem – rejestruje si

pod okre

lonym portem. Równie

w protokóle UDP

pakiety kierowane s

do zadanego portu,

przydzielonego pewnej aplikacji.

Numery portów:

od 0 do 65535

Numery

zastrze

one

portów:

od 0 do 1023

– zarezerwowane na usługi

takie, jak HTTP, FTP, itd.

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 4

Klasy w

java.net

Komunikacj

zgodn

z tymi protokółami TCP i UDP realizuj

klasy

pakietu

java.net

URL, URLConnection, Socket, ServerSocket

(dla TCP);

DatagramPacket, DatagramSocket, MulticastSocket

(dla UDP).

2) Klasa

URL

URL (Uniform Resource Locator) to adres zasobu w Internecie. URL
ma posta

napisu specyfikuj

cego:

•

protokół

dla dost

pu do zasobu i

•

lokalizacj

zasobu.

URL

jest te

nazw

klasy w

java.net

. Obiekt klasy

URL

reprezentuje

adres URL.

Konstruktory klasy

URL

Z parametrem

typu

String

reprezentuj

cym

adres bezwzgl

dny.

Np.:

URL adresPW = new URL("http://www.pw.edu.pl/");

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 5

Z dwoma parametrami

– obiektem URL reprezentuj

cym adres

bazowy

i parametrem typu

String

reprezentuj

cym

adres wzgl

dny

Np.: dane s

dwa adresy

URL

http://www.ia.pw.edu.pl/dydaktyka/proz.html
http://www.ia.pw.edu.pl/dydaktyka/probe.html

na utworzy

obiekty klasy URL dla obu stron na podstawie

adresów wzgl

dem jednej bazy -

http://www.ia.pw.edu.pl/dydaktyka/

URL dydaktyka = new URL("http://www.ia.pw.edu.pl/dydaktyka/");
URL dydaktykaProz = new URL(dydaktyka, "proz.html");
URL dydaktykaProbe = new URL(dydaktyka, "probe.html");

korzystaj

c z konstruktora:

URL(URL bazowyURL, String wzglednyURL)

na te

utworzy

referencj

do pozycji w dokumencie

. Np.

URL dydaktykaProzProjekt = new URL(dydaktykaProz, "#PROJEKT");

3. Trzy-argumentowy konstruktor URL:

new URL("http", "www.ia.pw.edu.pl", "/dydaktyka/proz.html");

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 6

4. Cztero-argumentowy konstruktor URL uwzgl

dniaj

cy numer portu.

Np.

URL dydaktykaProz = new URL("http", "www.ia.pw.edu.pl”,80,
"dydaktyka/proz.html");

utworzy obiekt klasy

URL

dla nast

puj

cego adresu URL:

http://www.ia.pw.edu.pl:80/dydaktyka/proz.html

kontruktorów

klasy

URL

zgłosi

wyj

tek

MalformedURLException

(gdy argumenty referuj

null

lub nieznany

protokół).

try {
URL myURL = new URL(. . .)
} catch (MalformedURLException e) {

// obsługa wyjątku

. . .
}

Obiekty klasy URL

nie mog

zmieniane

po pierwszej inicjalizacji.

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 7

Podstawowe metody klasy URL

•

Metody zwracaj

ce pełny adres URL dla danego obiektu klasy

URL

String toString()
String toExternalForm().

•

Metody podaj

ce informacje o stanie obiektu URL:

getProtocol

– podaje cz

ęść

URL dotycz

protokółu;

getHost

- podaje cz

ęść

URL dotycz

adresu hosta;

getPort

- podaje cz

ęść

URL dotycz

numeru portu (liczba integer lub

warto

ść

-1 gdy port nie jest ustawiony);

getFile

- podaje cz

ęść

URL dotycz

nazwy pliku;

getRef

- podaje cz

ęść

URL dotycz

referencji w pliku dokumentu.

Przykład 14.1

. Tworzenie i korzystanie z obiektu klasy

URL

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

public class ParseURL {

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 8

public static void main(String[] args) throws Exception {
URL aURL = new URL

("http://java.sun.com:80/docs/books/"

+ "tutorial/index.html#DOWNLOADING"

);

        System.out.println("protocol = " + aURL.getProtocol());
        System.out.println("host = " + aURL.getHost());
        System.out.println("filename = " + aURL.getFile());
        System.out.println("port = " + aURL.getPort());
        System.out.println("ref = " + aURL.getRef());
    }
}

Wynik pracy programu:

protocol = http
host = java.sun.com
filename = /docs/books/tutorial/index.html
port = 80
ref = DOWNLOADING

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 9

Metody klasy URL do poł

cze

w sieci

Metoda

openStream()

Metoda zwraca obiekt strumieniowy klasy

java.io.InputStream

zwi

zany z adresem

URL

Przykład 14.2.

Wykorzystanie metody

openStream

()

do poł

czenia w

sieci. Odczyt informacji - poprzez obiekt klasy

BufferedReader

i zapis na

standardowym wyj

ciu.

import java.net.*;
import java.io.*;
public class URLReader {
    public static void main(String[] args) throws Exception {
  URL yahoo = new URL("http://www.yahoo.com/");
  BufferedReader in = new BufferedReader(

new InputStreamReader(

yahoo.openStream()));

String inputLine;

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 10

  while ((inputLine = in.readLine()) != null)
      System.out.println(inputLine);
  in.close();
    }
}

Metoda

openConnection()

Metoda zwraca obiekt klasy

URLConnection

, który mo

e by

wykorzystany do szczegółowej współpracy z adresem URL. Np.

try {

URL yahoo = new URL("http://www.yahoo.com/");
URLConnection yahooConnection = yahoo.openConnection();

} catch (MalformedURLException e) {

new URL()

nie powiodło si

. . .

}
catch (IOException e) {

openConnection()

nie powiodło si

. . .
}

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 11

3) Metody klasy

URLConnection

Przykład 14.3.

Odczyt z URL

za pomoc

obiektu klasy

URLConnection

import java.net.*;
import java.io.*;
public class URLConnectionReader {
    public static void main(String[] args) throws Exception {
        URL yahoo = new URL("http://www.yahoo.com/");
        URLConnection yc = yahoo.openConnection();

// Poł

        BufferedReader in = new BufferedReader(
                                new InputStreamReader(
                                yc.getInputStream()));

// Pobierz strumie

        String inputLine;
        while ((inputLine = in.readLine()) != null)
            System.out.println(inputLine);
        in.close();
    }
}

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 12

Adresy URL do których doł

czono

skrypty

cgi-bin

wymagaj

, aby

zapisywa

informacj

do URL

Typowy przykład

zapisu do

URL

polega na wypełnieniu przez

ytkownika zapytania podanego w postaci formatki na stronie HTML i

wysłaniu go do serwera pod adres URL. Przetwarza on zwykle skrypt

cgi-bin

po stronie serwera i odpowiada w postaci strony HTML.

Współpraca programu Javy ze skryptami cgi-bin po stronie serwera
wymaga mo

liwo

ci zapisu do

URL

przez ten program. Czyli wymaga

to realizacji nast

puj

cych kroków w rogramie:

Utworzy

obiekt typu

URL

Otworzy

poł

czenie z tym

URL

Ustawi

liwo

ci wyj

ciowe dla

URLConnection

Pobra

strumie

wyj

ciowy z poł

czenia – bedzie on

poł

czony ze standardowym strumieniem wej

ciowym

skryptu

cgi-bin

po stronie serwera.

Zapisywa

dane do strumienia wyj

ciowego.

Zamkn

ąć

strumie

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 13

Przykład 14.4.

Skrypt na naszej stronie sieci odczytuje napis ze

standardowego wej

cia

, odwraca kolejno

ść

znaków napisu i zapisuje

wynik d

o standardowego wyj

cia

. Skrypt wymaga danych wej

ciowych

w formacie

string=napis,

gdzie napis jest napisem do odwrócenia.

import java.io.*;
import java.net.*;
public class Reverse {
public static void main(String[] args) throws Exception {

if (args.length != 1) {

System.err.println("Wywołanie: java Reverse " + "napis");

System.exit(1);

}

String stringToReverse = URLEncoder.encode(args[0]);
URL url = new URL("http://java.sun.com/cgi-bin/backwards");
URLConnection connection = url.openConnection();
connection.setDoOutput(true);

// UmoŜliwić wyjście do URL

PrintWriter out = new PrintWriter(
connection.getOutputStream());

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 14

out.println("string=" + stringToReverse);

out.close();

BufferedReader in = new BufferedReader(

new InputStreamReader(

connection.getInputStream()));

String inputLine;

while ((inputLine = in.readLine()) != null)

System.out.println(inputLine);

in.close();

}
}

Komentarz do programu:
1) Przetwarzanie parametrów programu z linii komend:

if (args.length != 1) {
System.err.println("Wywołanie: java Reverse " + "napis");
System.exit(-1);
}
String stringToReverse = URLEncoder.encode(args[0]);

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 15

Ma by

tylko jeden parametr programu i kodowany on jest dla

przesłania (w tym spacje i znaki przestankowe) go do skryptu cgi-bin.

2) Utworzenie obiektu klasy URL dla skryptu na

java.sun.com

, otwarcie

URLConnection

i ustawienie poł

czenia do zapisu:

URL url = new URL("http://java.sun.com/cgi-bin/backwards");
URLConnection c = url.openConnection();
c.setDoOutput(true);

// Ustawienie do zapisu

3) Utworzenie strumienia wyj

ciowego

dla poł

czenia i utworzenie na

nim obiektu

PrintWriter

PrintWriter out = new PrintWriter(c.getOutputStream());

URL

nie zezwala nam na zapis (brak wyj

cia) to metoda

getOutputStream

zgłosi wyj

tek

UnknownServiceException

4) Zapis danych do strumienia wyj

ciowego i zamkni

cie strumienia

out.println("string=" + stringToReverse);
out.close();

Strumien wyj

ciowy klienta jest strumieniem wej

ciowym serwera –

skryptu realizuj

cego odrócenie kolejno

ci liter.

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 16

5) Odczytujemy informacj

zwrotn

ze skryptu

BufferReader in = new BufferedReader(
new InputStreamReader(c.getInputStream()));
String inputLine;
while ((inputLine = in.readLine()) != null)
System.out.println(inputLine);
in.close();

Przykład wyniku działania:

Reverse Me
reversed is:
eM esreveR

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 17

14.2 Mechanizm gniazdek TCP

komunikacji

sieciowej

wykorzystaniem

protokółu

TCP

wykorzystywane s

mechanizmy:

strumieni i

gniazdek (ang.

socket

) - udost

pniany w pakiecie

java.net.*

Programista mo

e skupi

na tym

jakie dane chce przesła

i pod

jaki adres

albo

co chce odebra

i sk

1) Gniazdka sieciowe dla

TCP: Socket i ServerSocket

bezpo

redniego komunikowania

ywany jest obiekt klasy

Socket

a do

prowadzenia nasłuchu

ServerSocket

Tworz

c gniazdko do komunikacji

typu

Socket

podajemy adres

komputera, z którym chcemy si

poł

czy

oraz numer portu, na którym

ma zosta

nawi

zane poł

czenie.

Np.:

Socket s = new Socket("localhost", 4444);

- gdy chcemy poł

czy

z komputerem lokalnym na porcie 4444;

Socket s = new Socket("SOLARIS", 4444);

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 18

- gdy chcemy poł

czy

z komputerem maj

cym nazw

SOLARIS

sieci lokalnej LAN na porcie 4444;

Socket s = new Socket("194.29.130.225", 4444);

- gdy chcemy poł

czy

z komputerem o danym adresie IP na

porcie 4444;

Socket s = new Socket("www.ia.pw.edu.pl", 4444);

- gdy chcemy poł

czy

z danym serwerem internetowym na porcie

4444.

Tworz

c gniazdko do nasłuchu

typu

ServerSocket

, podajemy tylko

numer portu, na którym ma by

prowadzony nasłuch, np.:

ServerSocket ss = new ServerSocket(4444);

Numer portu

musi zawiera

w przedziale

[0,...,65535]

. Jednak

niektóre numery portów s

zajmowane przez usługi sieciowe takie, jak

standardowe protokoły transmisji, np.: 21 przez FTP, 80 przez HTTP.
Ponadto pewnych portów u

ywaj

same systemy operacyjne.

W rezultacie u

ywanie numerów portów z przedziału

[0,...,1023]

jest

zabronione.

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 19

2) Realizacja prostej komunikacji

Przykład

14.5.a

Nawi

zanie

komunikacji

pomi

dzy

dwoma

programami. Najpierw przedstawiamy program serwera nasłuchuj

na gniazdku i odbieraj

cy pojawiaj

ce si

dane.

//Serwer.java

import java.io.*;
import java.net.*;
public class Serwer {

public static void main(String args[]) throws IOException {

ServerSocket ss = new ServerSocket(4444);

// Gniazdko nasłuchu

while(true) {

// Praca w p

tli

Socket s = ss.accept();

// Oczekiwanie na poł

czenie

DataInputStream dis = new DataInputStream(

s.getInputStream());

// Pobierz strumień

String msg = dis.readUTF();

// Odczyt danych ze strumienia

System.out.println(msg);

// Przetwarzaj dane – tu : wyprowadź

dis.close();

// Zamkni

cie strumienia

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 20

s.close();

// Zamkni

cie poł

czenia – gniazdka

}

Powy

szy program działa, jak praktycznie ka

dy serwer,

niesko

czonej p

tli

Nasłuchuje

on na

porcie 4444

, korzystaj

c z gniazdka

ServerSocket

Sam proces oczekiwania na poł

czenie realizowany jest w metodzie

accept

Gdy na wybranym porcie pojawi si

informacja o próbie uzyskania

poł

czenia, nast

puje

zako

czenie nasłuchu

utworzenia

gniazdka

Socket

. Dalej nast

puje

odczytanie strumienia podł

czonego

gniazdka, zawarto

ść

jest wypisywana na ekran, a

strumie

i gniazdo

zamykane.

Nast

pnie program serwera znowu czeka

na prób

nawi

zania

poł

czenia. Proste u

ycie p

tli niesko

czonej powoduje,

e aby go

zako

czy

, musimy u

kombinacji klawiszy

Ctrl+C

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 21

Przykład 14.5.b.

Wysłanie danych przez klienta. Program klienta

tworzy gniazdko

Socket

w celu nawi

zania poł

czenia z lokalnym

komputerem na porcie 4444. Po zaakceptowaniu poł

czenia tworzony

jest strumie

, przez który przesyłany jest obiekt typu

String

. Nast

pnie

strumie

i gniazdko s

zamykane, a program ko

czy działanie.

//Klient.java

import java.io.*;
import java.net.*;
public class Klient {
public static void main(String args[]) throws IOException {
  Socket s = new Socket("localhost", 4444);
  DataOutputStream dos = new DataOutputStream(s.getOutputStream());
  dos.writeUTF("Witaj w sieci!");

// Prze

lij napis do serwera

dos.close();

// Zamknij strumie

s.close();

// Zamknij gniazdko

}
}

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 22

Podsumowanie przykładu 14.5

Musimy najpierw skompilowa

oba programy i uruchomi

program

serwerowy. Nast

pnie w drugim okienku-konsoli uruchamiamy

program kliencki. Ka

de kolejne uruchomienie programu-klienta

spowoduje wy

wietlenie jednego napisu w programie-serwerze, co

oznacza,

e poł

czenie jest skutecznie nawi

zywane.

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 23

14.3 Przykład aplikacji klient - serwer

Aplikacje sieciowe s

tworzone w celu zdalnego wykonywania jakich

konkretnych czynno

ci b

udost

pniania usług, czy zasobów.

Zobaczmy przykład aplikacji

klient-serwer

, która - poza

nawi

zaniem

czno

- b

dzie realizowała

zdaln

obsług

trzech polece

systemowych:

•

list

- wy

wietlenie zawarto

ci bie

Ŝą

cego katalogu na serwerze;

•

get

- pobranie pliku z serwera i wy

wietlenie go na konsoli klienta;

•

exit

- zako

czenie pracy klienta.

1) Program serwera
Przykład 14.6.

Program serwera pracuje w p

tli niesko

czonej

nasłuchuj

c na

porcie 4444

i oczekuj

c na

Ŝą

dania poł

cze

klientów. Gdy takie nadchodz

- ka

demu przydzielany jest osobny

tek do obsługi.

//PlikSerwer.java

import java.io.*;

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 24

import java.net.*;

/* W

tek obsługuj

cy poł

czenie pracuje w p

tli niesko

czonej. Czyta

on ze strumienia podł

czonego do gniazdka obiekt serializowalnej

klasy programisty

Command

, a dokładniej - najpierw czyta obiekt ze

strumienia, a nast

pnie zmienia jego typ na

Command

. */

public class PlikSerwer implements Runnable {
Socket socket;
public PlikSerwer(Socket s) {
socket = s;
}
public void run() {

// Metoda dla w

tku

  try   {
   ObjectInputStream ois =
   new ObjectInputStream(socket.getInputStream());

// Strumień wejściowy

ObjectOutputStream oos =

// i wyjściowy

new ObjectOutputStream(socket.getOutputStream());
while(true) {

// P

tla niesko

czona

Command cmd = (Command)ois.readObject();

// Odczyt obiektu

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 25

/* Nast

pnie sprawdza zawarto

ść

odczytanego obiektu i w zale

od niej tworzy odpowiedni obiekt klasy programisty

Response

Tworzonemu obiektowi przekazywany jest efekt obsługi polecenia, tzn.
napis na zako

czenie pracy, lista plików w katalogu bie

Ŝą

cym serwera,

czy zawarto

ść

konkretnego pliku. */

// Obsługa komendy zako

czenia pracy klienta

    if (cmd.getCommand() == Command.EXIT)  {
        send(oos, new Response(cmd, "Do zobaczenia"));
     break;
    }

// Obsługa wy

wietlania zawarto

ci bie

Ŝą

cego katalogu serwera

else if (cmd.getCommand() == Command.LIST) {
File file = new File(".");

// Plik - aktualny katalog

send(oos, new Response(cmd, file.list()));

// Lista plików

}
else if (cmd.getCommand() == Command.GET) {

// Obsługa wy

wietlenia zawarto

ci danego pliku na serwerze

String filename = (String) cmd.getCommandArg();

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 26

     File file = new File(filename);
     byte buff [] = new byte[(int) file.length()];
     FileInputStream fis = new FileInputStream(file);
     fis.read(buff);

// Wczytaj dane z podanego pliku

fis.close();
send(oos, new Response(cmd, buff));

// Prze

lij zawarto

ść

pliku

    }
    else {  send(oos, new Response(cmd, "Nieznana komenda")); }
   }
   ois.close();

// Zamknij strumienie wej

ciowy

oos.close();

// -“- wyj

ciowy

socket.close();

// Zamknij gniazdko

  }
  catch(Exception e) {
     System.out.println(e);
  }
}

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 27

/* Obiekt zapisywany jest do strumienia wyj

ciowego – czyli resultat

przesyłany jest do klienta w obiekcie klasy

Response

. */

private void send(ObjectOutputStream oos, Response response)
         throws IOException {
      oos.writeObject(response);
      oos.flush();
}

/* Program serwera pracuje w p

tli niesko

czonej nasłuchuj

c na

porcie 4444

i oczekuj

c na

Ŝą

dania poł

cze

od klientów. Gdy takie

nadchodz

- ka

demu przydzielany jest osobny w

tek do obsługi. */

public static void main(String args[]) throws IOException {
ServerSocket ss = new ServerSocket(4444);

// Utwórz gniazdko

     System.out.println("Nasłuchiwanie na porcie 4444...");
     while(true) {
       Socket s = ss.accept();

// Oczekuje na

Ŝą

danie od klienta

System.out.println("Akceptuję połączenie z: "+s.getInetAddress());
(new Thread(new PlikSerwer(s))).start();

// Uruchom w

tek obsługi

}

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 28

}
}

2) Klasy pomocnicze w tym przykładzie

Przykład 14.7

. Opiszemy tu klas

pomocnicz

serwera

Command.

Klasa pomocnicza zawiera deklaracje stałych identyfikuj

cych

polecenia wydawane serwerowi przez klienta. Zawiera te

zmienn

okre

laj

bie

Ŝą

ce polecenie wydane serwerowi oraz metody j

obsługuj

ce. Cała klasa jest serializowana, aby jej obiekty mogły by

zapisywane do strumieni.

//Command.java

import java.io.*;
public class Command implements Serializable {
public final static int LIST = 0;
public final static int GET = 1;
public final static int EXIT = 2;
private int cmd;
private Object arg;
public Command (int cmd) {

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 29

  this.cmd = cmd;
}
public Command (int cmd, Object arg) {
  this.cmd = cmd;
  this.arg = arg;
}
public int getCommand() {
  return cmd;
}
public Object getCommandArg() {
  return arg;
}
}

Przykład 14.8.

Opiszemy teraz klas

Response

. Klasa zawiera prywatne

pole do przechowywania obiektu b

cego rezultatem realizacji

polecenia klienta. Dzi

ki serializacji obiekty tej klasy mog

przesyłane za pomoc

strumieni, tak samo jak obiekty

Command

// Response.java

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 30

import java.io.*;
public class Response implements Serializable {
private Object data;
private Command cmd;
public Response (Command cmd, Object data) {
  this.cmd = cmd;
  this.data = data;
}
public Object getData() {
  return data;
}
public Command getCommand() {
  return cmd;
}
}

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 31

3) Program klienta w tym przykładzie

Przykład 14.9.

Program klienta.

// PlikKlient.java

import java.io.*;
import java.net.*;
public class PlikKlient {
   Socket socket;
   ObjectOutputStream oos;
   ObjectInputStream ois;
public PlikKlient(String host, int port) throws IOException {
   socket = new Socket(host, port);
   oos = new ObjectOutputStream(socket.getOutputStream());
   ois = new ObjectInputStream(socket.getInputStream());
}
public void go() {
  try  {
   BufferedReader br = new BufferedReader(

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 32

new InputStreamReader(System.in));

   while(true) {
    System.out.print("Zdalny>");
    System.out.flush();
    String line = br.readLine();

// Komenda końca pracy klienta

    if (line.startsWith("exit")) {
     Command cmd = new Command(Command.EXIT);
     Response response = send(cmd);
     System.out.println(response.getData());
     System.exit(0);
    }

//Komenda wyświetlenia zawartości bieŜącego katalogu serwera

    else if (line.startsWith("list")) {
     Command cmd = new Command(Command.LIST);
     Response response = send(cmd);
     String list [] = (String []) response.getData();
     for (int i=0; i<list.length; i++) {

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 33

      System.out.println(list[i]);
     }
    }

//Komenda wyświetlenia zawartości danego pliku na serwerze

    else if (line.startsWith("get")) {
     Command cmd = new Command(Command.GET, line.substring(4));
     Response response = send(cmd);
     byte content [] = (byte []) response.getData();
     System.out.println(new String(content));
    }
    else {
     System.out.println("Nieznana komenda: "+line);
    }
   }
  }
  catch (Exception e) {
   System.out.println(e);
  }

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 34

}
private Response send(Command cmd) throws Exception {
  oos.writeObject(cmd);
  oos.flush();
  return (Response) ois.readObject();
}
public static void main(String args[]) throws IOException {
  (new PlikKlient("localhost", 4444)).go();
}
}

Program klienta odczytuje z konsoli polecenia od u

ytkownika,

zapisuje je w postaci obiektów do strumienia podł

czonego do

gniazdka pracuj

cego na porcie 4444, odczytuje ze strumienia

przychodz

ce z serwera odpowiedzi i wy

wietla je na konsoli.

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 35

4) Uruchomienie całej aplikacji

Po skompilowaniu wszystkich klas uruchamiamy serwer, a nast

pnie

klienta (lub wielu klientów) - oczywi

cie ka

dy z programów

uruchamiany jest w osobnym okienku konsoli.

Gdy oba programy znajduj

na jednym komputerze (tj. testujemy

poł

czenie na komputerze lokalnym), nie musz

umieszczone w

jednym katalogu. Jednak

e wtedy zarówno w katalogu z serwerem -

jak i z klientem - musz

znajdowa

skompilowane klasy

pomocnicze.

Po uruchomieniu obu programów mo

emy wyda

w konsoli klienta

które

z trzech obsługiwanych polece

i zobaczy

efekt jego działania.

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 36

14.4 RMI (Remote Method Invocation)

– model DOA

1) Model DOA

Mechanizm RMI wykorzystuje

model komunikacji klient-serwer

realizuje paradygmat programowania obiektowego - rozproszonego
(

DOA – distributed object application

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 37

program serwera

tworzy obiekty, udost

pnia referencje do nich

(dzi

ki ich zarejestrowaniu poprzez

rmiregistry

) i oczekuje na

wywołania metod na tych obiektach inicjowane przez klientów;

programy klientów

uzyskuj

referencj

do zdalnego obiektu i

wywołuj

na nim metody.

2) Typowy schemat współpracy klient - serwer w RMI

(A) Zdalny interfejs i zdalny obiekt

Aplikacja z u

yciem

Java RMI

składa si

z interfejsów i klas, przy czym

spodziewamy si

e implementacje metod mog

rozproszone po

ró

nych maszynach.

Zdalnym obiektem

nazywamy obiekt, którego metody mog

wywoływane z ró

nych maszyn wirtualnych Javy. Takie metody

deklarowane s

w tzw.

zdalnych interfejsach

zdalny interfejs dziedziczy po interfejsie

java.rmi.Remote

w li

cie wyj

tków ka

dej metody tego interfejsu istnieje deklaracja

wyj

tku

java.rmi.RemoteException

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 38

Serwer

zwi

zuje nazw

w rejestrze ze swoim

zdalnym obiektem,

który mo

e by

wołany zdalnie.

(B) Pobranie obiektu i wywołanie metody
Klient

odnajduje zdalny obiekt w

rejestrze

poprzez jego nazw

wywołuje

na nim

metod

interfejsu.

RMI nie kopiuje zdalnego obiektu do programu “odbiorcy” lecz
przekazuje “

namiastk

” (stub)

zdalnego obiektu – reprezentuje ona

referencj

do zdalnego obiektu. Ta referencja mo

e by

konwertowana

na dowolny

zdalny interfejs

implementowany przez klas

zdalnego

obiektu. Klasa zdalnego obiektu pełni w programie klienta rol

rednika (proxy) w przekazie danych.

Zdalnie mo

na wywoła

wył

cznie metody zdalnych interfejsów danej

klasy

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 39

li klasa obiektu

nie jest zdefiniowana

na maszynie “odbiorcy

obiektu” to RMI pobierze od „nadawcy” i prze

le ten kod.

Mechanizm RMI korzysta z istniej

cego

serwera sieciowego

dla

przekazywania

bajtkodu klas pomi

dzy klientem a serwerem

– w obie

strony.

3) Podstawowe klasy i interfejsy w

java.rmi

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 40

4) Tworzenie aplikacji rozproszonej w

RMI

Nale

zdefiniowa

komponenty aplikacji (lokalne i zdalne obiekty, zdalne

interfejsy, implementacje metod);

skompilowa

program (kompilator

javac

) i wygenerowa

„namiastki”

zdalnych obiektów (kompilator

rmic

);

udost

pni

klasy i namiastki obiektów w sieci,

uruchomi

aplikacj

(dokona

rejestracji w rejestrze zdalnych

obiektów RMI, uruchomi

serwer i klientów).

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 41

14.5

Przykład

aplikacji

rozproszonej

dynamicznie

ładowanym kodzie

Przykład 14.10.

Projekt

serwera oblicze

w oparciu o mechanizm RMI

Serwer akceptuje zadania pochodz

ce od klienta, wykonuje te zadania

i zwraca wyniki. Serwer składa sie ze zdalnego interfejsu

Compute

klasy

ComputeEngine

implementuj

cej ten interfejs, przeznaczonej dla

utworzenia zdalnego obiektu. W metodzie

main

tej klasy nast

puje

utworzenie tego obiektu, jego zarejestrowanie i ustawienie menad

era

zabezpiecze

(security manager).

Interfejsy typu “Remote Interface”

W przykładzie wyst

puj

2 interfejsy zdalne deklaruj

ce po jednej

metodzie.

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 42

Interfejs

Compute

serwera

ComputeEngine

pozwala na dostarczanie

zadania do wykonania.

package compute;
import java.rmi.Remote;
import java.rmi.RemoteException;
public interface Compute extends Remote {

Object executeTask(Task t) throws RemoteException;

}

Dziedziczenie z interfejsu

java.rmi.Remote

oznacza,

metody

dziedziczonego interfejsu mog

wołane z dowolnej

maszyny wirtualnej Javy;

obiekt z implementacj

tego interfejsu staje si

zdalnym obiektem

Zdalna

metoda

musi

deklarowa

zgłaszanie

wyj

tku

java.rmi.RemoteException

. Jest to

sprawdzalny wyj

tek

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 43

Interfejs klienta

Task

wyznacza sposób wykonania przez serwer

powierzonego zadania.

package compute;

import java.io.Serializable;

public interface Task extends Serializable {
Object execute();
}

Dziedziczenie interfejsu po

java.io.Serializable

oznacza,

e obiekt klasy

implementuj

cej ten interfejs mo

e zosta

zamieniony na strumie

bajtów i jednoznacznie zrekonstruowany z niego.

Obiekty ró

nych klas mog

zosta

przekazane do obiektu

Compute

li tylko klasy implementuj

interfejs

Task.

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 44

Implementacja zdalnego interfejsu
Klasa u

ytkownika

engine.ComputeEngine

implementuje interfejs zdalny

Compute

, a w jej metodzie

main

inicjalizowany jest obiekt tej klasy.

package engine;
import java.rmi.*;
import java.rmi.server.*;
import compute.*;

public class ComputeEngine extends UnicastRemoteObject
implements Compute {

// Konstruktor –

public ComputeEngine() throws RemoteException {
super();

// Wywoła metod

exportObject

// Konstruktor nadklasy został by wywołany – nawet przy braku

super();

}

// Metoda dla pobrania obiektu klienta do wykonania

public Object executeTask(Task t) {
return t.execute(); //

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 45

}

// Metoda

main

dla ustawienia obiektu

    public static void main(String[] args) {
      if (System.getSecurityManager() == null) {
          System.setSecurityManager(new RMISecurityManager());
        }
        String name = "//host/Compute";

// Okre

la nazw

obiektu

// zdalnego serwera

try {
Compute engine = new ComputeEngine();

// Utworzy obiekt

Naming.rebind(name, engine);

// Rejestracja obiektu zdalnego

System.out.println("Compute: związany");
} catch (Exception e) {

System.err.println("Compute: wyjątek " + e.getMessage());

            e.printStackTrace();
        }
    }

// Koniec metody

main

}

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 46

Komentarz

1) Klasa serwera implementuje zdalny interfejs:

public class ComputeEngine extends UnicastRemoteObject
implements Compute

i dziedziczy po klasie bazowej

java.rmi.server.UnicastRemoteObject

Ta klasa zapewnia podstawow

funkcjonalno

ść

zdalnego obiektu:

implementuje metody klasy

java.lang.Object

(

equals, hashCode

toString

) odpowiednio dla zdalnego obiektu;

zawiera konstruktory i metody statyczne przewidziane do

wyeksportowania zdalnego obiektu (

exportObject()

) tzn. aby zdalny

obiekt mógł odbiera

wezwania od klientów;

zapewnia poł

czenia „point-to-point” w oparciu o

gniazdka

Inna klasa dla zdalnych obiektów

java.rmi.activation.Activatable

(dla

zdalnych obiektów wywoływalnych na

Ŝą

danie).

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 47

2) Konstruktor klasy

ComputeEngine

public ComputeEngine() throws RemoteException {
super();

// Nast

puje tu te

eksportowanie obiektu

}

Nale

y zadeklarowa

zgłaszalno

ść

tku

RemoteException

, który

zostanie zgłoszony, gdy nie powiedzie si

eksport obiektu.

3) Implementacje metod interfejsów zdalnych

Klasa implementuje jedn

metod

interfejsu zdalnego

Compute

metod

executeTask

public Object executeTask(Task t) {
return t.execute();
}

Metoda wyznacza sposób komunikacji pomi

dzy obiektem klasy

ComputeEngine

a jego klientami. Klienci przekazuj

serwerowi obiekt

klasy implementuj

cej interfejs

Task

i posiadaj

cej implementacj

metody

execute

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 48

4) Klasa klienta

Do serwera mo

e by

przekazany obiekt dowolnego typu o ile jest to:

zmienna typu prostego, obiekt zdalny lub serializowalny obiekt (tzn.
jego klasa implementuje interfejs

java.io.Serializable

Sposoby przekazywania obiektów zdalnych, parametrów i wyników.
Zdalne obiekty

przekazywane s

przez

referencj

. Po stronie klienta

tworzona jest

namiastka obiektu

(stub) pełni

ca rol

proxy

(przekazuj

odwołania do rzeczywistego obiektu serwera).

Zwykłe obiekty

przekazywane s

przez

warto

ść

poprzez ich

serializacj

. W zdalnym wywołaniu metody – zwykłe obiekty

(parametry, zwracany wynik, wyj

tki) s

przekazywane przez

warto

ść

–

tworzona jest ich kopia w zdalnej wirtualnej maszynie Javy.

5) Metoda

main

Metoda

main()

klasy

ComputeEngine

nie jest elementem interfejsu, czyli

nie jest metod

wywoływaln

zdalnie.

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 49

W pierwszej kolejno

ci metoda

main()

powinna utworzy

i zainstalowa

zarz

polityki bezpiecze

stwa (

Security Manager

), w przeciwnym

razie mechanizm

RMI

nie zezwoli na ładowanie zdalnych klas.

RMI

dost

pna jest klasa

RMISecurityManager

, która realizuje

pdobn

polityk

bezpiecze

stwa, jak ta stosowana dla apletów.

if (System.getSecurityManager() == null) {
System.setSecurityManager(new RMISecurityManager());
}

Nast

pnie

utworzony

zostaje

obiekt

klasy

ComputeEngine

udost

pniony klientom na anonimowym porcie:

Compute engine = new ComputeEngine();

// Utworzenie obiektu

Mechanizm RMI zarz

dza

rejestrem zdalnych obiektów

, z którego

na pobra

referencj

do zdalnego obiektu na podstawie jego

nazwy. Rejestr ten mo

e by

wspólny dla wszystkich serwerów na

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 50

danej maszynie albo te

proces serwera mo

e posiada

odr

bny taki

rejestr.

Metody dost

pu do rejestru zdalnych obiektów wyznacza interfejs

java.rmi.Naming

(zwi

zanie, rejestracja, pobranie).

W metodzie

main

klasy

ComputeEngine

nadajemy nazw

String name = "//host/Compute";

host

to nazwa maszyny

Compute

to nazwa identyfikuj

ca obiekt zdalny w rejestrze.

i rejestrujemy obiekt

engine

klasy

ComputeEngine

w rejestrze:

Naming.rebind(name, engine);

Podczas wywołania

rebind()

e powsta

wyj

tek:

RemoteException

Parametry wywołania metody

Naming.rebind

pierwszy parametr jest typu

java.lang.String

o postaci adresu

URL

;

Np.

//host:1234/objectname

li brak jest numeru portu to przyjmuje si

domy

lny port: 1099.

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 51

Po zarejestrowaniu obiektu zdalnego i wydruku informacji o gotowo

do pracy metoda

main()

czy si

wykonywa

(

tek główny ko

czy

swoje wykonanie !).
Jednak

istnieje referencja

do obiektu przekazana innemu obiektowi –

bed

cemu rejestrem zdalnych obiektów.

Mechanizm RMI pilnuje, aby proces dla obiektu

ComputeEngine

nadal

istniał.

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 52

Przykład 14.11

Program klienta musi definiowa

zadanie, które ma

wykona

w jego imieniu serwer. W tym przykładzie klient składa si

z 2

klas:

ComputePi

– w celu pobrania obiektu serwera

Compute

;

klasa implementuj

ca interfejs

Task

i definiuj

ca zadanie.

Definicja

Task

package compute;
public interface Task extends java.io.Serializable {
Object execute();
}

Klasa klienta

client.ComputePi

package client;

import java.rmi.*;
import java.math.*;
import compute.*;

public class ComputePi {

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 53

    public static void main(String args[]) {
        if (System.getSecurityManager() == null) {
            System.setSecurityManager(new RMISecurityManager());
        }
        try {

// Nazwa serwera w formacie URL

String name = "//" + args[0] + "/Compute";

// Pobierz referencje do obiektu zdalnego serwera:

Compute comp = (Compute) Naming.lookup(name);
Pi task = new Pi(Integer.parseInt(args[1]));

// Wywołaj metod

executeTask

obiektu zdalnego

comp

// przekazuj

c zadanie do wykonania

task

BigDecimal pi = (BigDecimal) (comp.executeTask(task));
System.out.println(pi);

// Wydrukuj obliczony wynik

        } catch (Exception e) {
            System.err.println("ComputePi exception: " +
                               e.getMessage());
            e.printStackTrace();

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 54

}
}
}

Przepływ informacji pomi

dzy obiektem klienta klasy

ComputePi

rejestrem obiektów zdalnych

rmiregistry

i obiektem serwera

ComputeEngine

Komentarz
1) Klasa klienta instaluje menad

era bezpiecze

stwa

Jest to niezb

dne, gdy

RMI mo

e ładowa

kod do procesu klienta – w

tym przypadku namiastk

obiektu

ComputeEngine

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 55

Podobnie jak serwer równie

klient korzysta tu z menad

era

bezpiecze

stwa dost

pnego w systemie RMI.

2) Klient tworzy nazw

do nadzoru obiektu zdalnego typu

Compute

Pierwszy parametr z linii wywołania programu,

args[0]

, stanowi nazw

zdalnej maszyny, na której wykonuje si

object typu

Compute

Klient odwołuje si

do metody

Naming.lookup

w celu odszukania

obiektu po jego nazwie w rejestrze zdalnych obiektów zdalnego hosta.
Parametr metody (typu

String

) ma t

sam

składni

adresu URL jak

parametr metody

Naming.rebind

w przypadku rejestracji obiektu przez

serwer.

3) Klient tworzy nowy obiekt klasy

Argumentem wywołania konstruktora

jest drugi paramer z inii

wywołania programu klienta,

args[1]

, podaj

cy liczb

pozycji

dziesi

tnych dla oblicze

4) Klient wywołuje metod

executeTask

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 56

Klient wywołuje metod

executeTask

zdalnego obiektu typu

Compute

Defnicja klasy

client.Pi

, która implementuje inerfejs

Task

package client;
import compute.*;
import java.math.*;
public class Pi implements Task {

/** Stałe potrzebne dla obliczenia watości pi */

    private static final BigDecimal ZERO = BigDecimal.valueOf(0);
    private static final BigDecimal  ONE =  BigDecimal.valueOf(1);
    private static final BigDecimal FOUR = BigDecimal.valueOf(4);

/** Tryb zaokrąglania */

private static final int roundingMode = BigDecimal.ROUND_HALF_EVEN;

/** Precyzja - liczba pozycji po kropce dziesiętnej */

private int digits;

/** Konstruktor */

public Pi(int digits) {

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 57

this.digits = digits;
}

/** Oblicz pi */

    public Object execute() {
        return computePi(digits);
    }

    /** według formuły
     *          pi/4 = 4*arctan(1/5) - arctan(1/239)
     * i po rozwinięciu arctan(x) w szereg.
     */

    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,

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 58

BigDecimal.ROUND_HALF_UP);
}

    /**
     * Oblicza wartość arct tangens w radianach według wzoru:
     * 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 = ONE.divide(invX, scale, roundingMode);
        result = numer;
        int i = 1;
        do {
            numer =
                numer.divide(invX2, scale, roundingMode);

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 59

            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(ZERO) != 0);
        return result;
    }

}

Uwaga

Obiekt klasy

Compute

nie wymaga definicji klasy

dopóki obiekt klasy

nie zostanie przekazany jako argument metody

executeTask

. W tym

momencie kod klasy ładowany jest przez RMI do maszyny wirtualnej
wła

ciwej dla obiektu typu

Compute

, wołana jest metoda

execute

klasy

i wykonuje si

kod tej metody. Wynikowy obiekt typu

Object

, w tym

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 60

przypadku jest on typu

java.math.BigDecimal

, jest przekazywany

zwrotnie do klienta, w którym nast

puje wydruk tego obiektu.

Z punktu widzenia serwera – obiektu typu

ComputeEngine

– jest bez

znaczenia, co oblicza zlecona metoda. Jedyne co musi wiedzie

obiekt

klasy implementuj

cej

Compute

o przekazywanym obiekcie to to,

jego klasa posiada metod

execute

Dynamiczne ładowanie klas

Poni

szy rysunek ilustruje sk

d ładowane s

definicje klas potrzebnych

programom:

rmiregistry

, serwerowi

ComputeEngine

, i klientowi

ComputePi

podczas wykonania rozproszonej aplikacji Javy.

Gdy serwer

ComputeEngine

rejestruje (bind) swój zdalny obiekt w

rejestrze, rejestr pobiera klas

ComputeEngine_Stub

i interfejsy

Compute

Task

, od której ta klasa zale

y. Te klasy pobierane s

serwera sieciowego wła

ciwego dla

ComputeEngine

lub z systemu

plików.

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 61

Klient typu

ComputePi

ładuje klas

ComputeEngine_Stub

z serwera

sieci wła

ciwego dla

ComputeEngine

w wyniku wykonania metody

Naming.lookup

. Klient

ComputePi

dysponuje opisami interfejsów

Compute

Task

, dlatego te

ładowane s

one z jego lokalnego

katalogu klas.

Na koniec, do maszyny wirtualnej wykonuj

cej serwer

ComputeEngine

ładowany jest kod klasy

, gdy obiekt klasy

przekazywany jest w

zdalnym wywołaniu metody

executeTask

na rzecz obiektu typu

ComputeEngine

– klasa

ładowana jest z serwera sieciowego

wła

ciwego dla klienta.

14. Komunikacja rozproszona

W. Kasprzak: Programowanie zdarzeniowe

14 - 62

Kompilacja i uruchomienie aplikacji

(serwera i klientów) oraz obliczenie

warto

1) Tworzymy pliki typu JAR (Java ARchive) zawieraj

cy interfejsy

Compute

Task

dla implementacji ich przez klasy serwera i z

których korzysta program klienta.

2) Tworzymy implementacj

interfejsu

Compute

i instalujemy t

usług

na maszynie udost

pniaj

c j

klientom.

3) Twórcy programów klientów, korzystaj

c z interfejsów

Compute

Task

, zawartych w pliku JAR, mog

niezale

nie od siebie utworzy

zadanie (

Task

) i program klienta korzystaj

cego z usługi

Compute

Klasa klienta

ładowana jest na serwer podczas wykonania.

Podobnie zdalna namiastka dla

ComputeEngine

ładowana jest z

serwera na maszynie klienta podczas wykonania.
Mamy trzy pakiety:

•

compute ( interfejsy

Compute

Task

)

•

engine (klasa implementuj

ComputeEngine

i jej namiastka)

•

client (kod klienta

ComputePi

i implementacja zadania