-
Notifications
You must be signed in to change notification settings - Fork 0
/
TCPClient.java
66 lines (61 loc) · 1.97 KB
/
TCPClient.java
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
/*
* Decompiled with CFR 0_123.
*/
import java.beans.XMLDecoder;
import java.io.BufferedReader;
import java.io.ByteArrayInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.ObjectInputStream;
import java.io.PrintStream;
import java.io.PrintWriter;
import java.io.Reader;
import java.net.Socket;
public class TCPClient
implements Runnable {
static Canvas canvas = null;
Socket s = null;
protected BufferedReader stdin;
protected PrintWriter stdout;
protected PrintWriter stderr;
public TCPClient(String host, int port, Canvas canvas) throws Exception {
TCPClient.canvas = canvas;
this.s = new Socket(host, port);
this.stdin = new BufferedReader(new InputStreamReader(this.s.getInputStream()));
}
public Canvas getCanvas() {
return canvas;
}
@Override
public void run() {
do {
try {
do {
if (this.s == null) {
continue;
}
TCPClient.decode(this.s.getInputStream());
} while (true);
}
catch (IOException e) {
System.out.println("Connection faled!");
continue;
}
catch (ClassNotFoundException e) {
System.out.println("Connection faled!");
continue;
}
} while (true);
}
public static void decode(InputStream inputStream) throws IOException, ClassNotFoundException {
ObjectInputStream in = new ObjectInputStream(inputStream);
String xmlString = (String)in.readObject();
XMLDecoder decoder = new XMLDecoder(new ByteArrayInputStream(xmlString.getBytes()));
String action = (String)decoder.readObject();
DShapeModel mod = (DShapeModel)decoder.readObject();
mod.setColorRGB();
decoder.close();
canvas.handleChanges(action, mod);
}
}