Fluxurile Java pun la dispozitie modalitatea prin care doua sau mai multe procese pot comunica fara a avea informatii unul despre celalalt. Mai mult, prin fluxuri este posibila comunicarea intre doua sau mai multe fire de executie ale aceleiasi aplicatii. Fluxurile sunt secvente de octeti (8 biti).

Proces producator ? flux de iesire ? Proces consumator

Proces consumator ? flux de intrare ? Proces producator

• fluxurile sunt unidirectionale, de la producator la consumator t9x22xs
• fiecare flux are un singur proces producator si un singur proces consumator
• intre doua procese pot exista oricate fluxuri, orice proces putand fi atat producator si consumator in acelasi timp, dar pe fluxuri diferite
• consumatorul si producatorul nu comunica direct printr-o interfata de flux ci prin intermediul codului Java de tratare a fluxurilor
Importanta : ajuta la citirea scrierea informatiilor in dispozitive de intrare/iesire, fisiere, baze de date, etc.

Toate interfetele pentru fluxuri implementeaza un set de metode de baza, comune tuturor categoriilor de fluxuri. Metodele standard pentru lucrul cu fluxuri se gasesca in pachetul java.io.

Fluxuri de intrare

BufferedInputStream citeste datele dintr-un buffer
ByteArrayInputStream citeste octetii de date intr-o matrice de octeti
DataInputStream citeste dintr-un flux de intrare obiecte, nu siruri de octeti
FileInputStream citeste date dintr-un fisier
FilterInputStream
InputStream
LineNumberInputStream
PipedInputStream
PushBackInputStream
SequenceInputStream
StringBufferInputStream

A. Metode care functioneaza cu toate fluxurile de intrare :
• read() - citeste date dintr-un flux de intrare
• skip() - ignora unele date din fluxul de intrare
• markAvailable() - testeaza daca metoda mark() este disponibila pentru fluxul de intrare respectiv
• close() - inchide un flux de intrare
B. Metode a caror functionare nu este garantata pentru toate fluxurile de intrare :
• available() - determina cantitatea de date disponibile intr-un flux de intrare
• mark() - marcheaza in fluxul de intrare un punct la care se poate reveni ulterior
• reset() - revine la un punct dpecificat in fluxul de intrare

Read int read (); int read (bytest buffer) int read (bytest buffer, int offset, int length)

Skip long skip (long numar_octeti)
Exemplu: public long skipRecords(int num) S int recordSize a 512 ; long retCode a 0 ; try S
//sare peste num inregistrari retCode a MyStream.skip(num * recordSize);
//calc nr. de inregistrari peste care a sarit if retCode > 0 S retCode /a recordSize ;
T catch (IOException e) S
System.out.println.(“Eroare de intrare/iesire!”);
T return (retCode);
T

Close - inchide un flux de intrare (Java inchide automat fluxurile la terminarea aplicatiei) void close();
Exemplu: public long closeStream() S try MyStream.close() catch (IOException e) S
System.out.println(“Eroare la inchiderea fluxului”);
T
T

Available - determina daca o anumita cantitate de date poate fi citita fara blocarea fluxului de intrare. int available()
Returneaza nr. de octeti ce pot fi cititi din fluxul de intrare fara blocare.
Exemplu: public boolean isRecordReady() S int recordSize a 512 ; boolean ret a false ; try S if (MyStream.available() >a recordSize) ret a true;
T catch (IOException e) S ... T return ret;
T

Fluxuri de iesire

Clase pentru fluxuri de iesire :
• FileOuputStream
• BufferedOutputStream
• ByteArrayOutputStream
• DataOutputStream
• FilterOutputStream
• OutputStream
• PipedOutputStream
• PrintStream
Metode pentru fluxurile de iesire
• write() - scrie date intr-un flux de iesire
• flush() - forteaza scrierea datelor intr-un canal de redirectare
• close() - inchide un flux de iesire

Write int write (); int write (bytest buffer) int write (bytest buffer, int offset, int length)

Flush - forteaza scrierea catre dispozitivul de iesire a datelor stocate in zona tampon pentru un flux de iesire. void flush();

Close - inchide un flux de iesire (Java inchide automat fluxurile la terminarea aplicatiei) void close();

RECOMANDARE: Operatiile read/write se recomanda a fi facute in fire de executie separate care sa nu blocheze programul.

import java.io.*; public class TestFlux S

public static void main(String argsst) S
FileInputStream s,sursa; //s este flux de intrare
FileOutputStream dest; //dest este flux de iesire int octet; try S sursa a new FileInputStream(argss0t); try S dest a new FileOutputStream(argss1t); octet a 0;
//citesc fisierul caracter cu caracter
while (octet !a -1) S try S octet a sursa.read(); dest.write(octet);
System.out.print((char)octet);
T catch (IOException e) S
System.out.println("Eroare de intrare/iesire");
System.exit(2);
T
T //while
T//try catch (IOException e) S
System.out.println("Fisierul " + argss1t + " nu a putut fi creat !");
System.exit(2);
T

T//try catch (FileNotFoundException e) S
System.out.println("Fisierul " + argss0t + " nu a fost gasit !");
System.exit(1);
T

T//main
T//class