SocketProgramming/dcclient.java at master · Code-Block-Init/SocketProgramming · GitHub

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
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
importjava.io.*;
importjava.net.*;
publicclassdcclient
{
publicstaticvoidmain(String[] args) throwsException
{
//Create a client socket
Socketsock = newSocket("127.0.0.1", 3000);
Socketsock1 = newSocket("127.0.0.1", 4000);
Socketsock2 = newSocket("127.0.0.1", 5000);
//Accepting contents from keyboard
BufferedReaderkeyRead = newBufferedReader(newInputStreamReader(System.in));
BufferedReaderkeyRead1 = newBufferedReader(newInputStreamReader(System.in));
BufferedReaderkeyRead2 = newBufferedReader(newInputStreamReader(System.in));
OutputStreamostream = sock.getOutputStream();
OutputStreamostream1 = sock1.getOutputStream();
OutputStreamostream2 = sock2.getOutputStream();
//Receiving from server
PrintWriterpwrite = newPrintWriter(ostream, true);
PrintWriterpwrite1 = newPrintWriter(ostream1, true);
PrintWriterpwrite2 = newPrintWriter(ostream2, true);
InputStreamistream = sock.getInputStream();
InputStreamistream1 = sock1.getInputStream();
InputStreamistream2 = sock2.getInputStream();
BufferedReaderreceiveRead = newBufferedReader(newInputStreamReader(istream));
BufferedReaderreceiveRead1 = newBufferedReader(newInputStreamReader(istream1));
BufferedReaderreceiveRead2 = newBufferedReader(newInputStreamReader(istream2));
System.out.println("Online Communication System");
//Main part
StringreceiveMessage, sendMessage;
StringreceiveMessage1, sendMessage1;
StringreceiveMessage2, sendMessage2;

// Decentralized server 1
System.out.print("Type 1 to start the test \n");
sendMessage = keyRead.readLine();
pwrite.println(sendMessage);
System.out.flush();
if((receiveMessage = receiveRead.readLine()) != null)
{
System.out.println(receiveMessage);
}
if((receiveMessage = receiveRead.readLine()) != null)
{
System.out.println(receiveMessage);
}
sendMessage = keyRead.readLine();
if((receiveMessage = receiveRead.readLine()) != null)
{
System.out.println(receiveMessage);
}
// Decentralized server 2
sendMessage1 = keyRead1.readLine();
pwrite1.println(sendMessage1);
System.out.flush();
if((receiveMessage1 = receiveRead1.readLine()) != null)
{
System.out.println(receiveMessage1);
}
if((receiveMessage1 = receiveRead1.readLine()) != null)
{
System.out.println(receiveMessage1);
}
sendMessage1 = keyRead1.readLine();
if((receiveMessage1 = receiveRead1.readLine()) != null)
{
System.out.println(receiveMessage1);
}
pwrite.println(sendMessage);
System.out.flush();
//Decentralized server 3
sendMessage2 = keyRead2.readLine();
pwrite2.println(sendMessage2);
System.out.flush();
if((receiveMessage2 = receiveRead2.readLine()) != null)
{
System.out.println(receiveMessage2);
}
if((receiveMessage2 = receiveRead2.readLine()) != null)
{
System.out.println(receiveMessage2);
}
sendMessage2 = keyRead2.readLine();
if((receiveMessage2 = receiveRead2.readLine()) != null)
{
System.out.println(receiveMessage2);
}
System.out.flush();
} }