1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
|
in = sock.getInputStream();
BufferedInputStream bis = new BufferedInputStream(in);
int byteLu;
while ((byteLu = bis.read(buffer)) >= 0) {
int s1 = (int) (Math.random() * 4);
int s2 = (int) (Math.random() * 4);
while (s2 == s1) {
s2 = (int) (Math.random() * 4);
}
String nom_paquet = fileName + seq;
sock1 = new Socket(t[s1][0], Integer.parseInt(t[s1][1]));
new PrintWriter(sock1.getOutputStream(),
true).println("put "+nom_paquet);
sock2 = new Socket(t[s2][0], Integer.parseInt(t[s2][1]));
new PrintWriter(sock2.getOutputStream(),
true).println("put "+nom_paquet);
BufferedOutputStream bout1 = new
BufferedOutputStream(sock1.getOutputStream());
BufferedOutputStream bout2 = new
BufferedOutputStream(sock2.getOutputStream());
bout1.write(buffer, 0, byteLu);
bout1.flush();
bout1.close();
bout2.write(buffer, 0, byteLu);
bout2.flush();
bout2.close();
sock1.close();
sock2.close();
diffuser(nom_paquet,Integer.parseInt(t[s1][1]),Integer.parseInt(t[s2]
[1]));
seq++;
}
in.close(); |
