-
Notifications
You must be signed in to change notification settings - Fork 0
/
Client.java
90 lines (65 loc) · 2.01 KB
/
Client.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
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
package client;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import java.util.Scanner;
import main.Const;
public class Client {
private BufferedReader in;
private PrintWriter out;
private Socket socket;
public Client() {
Scanner scan = new Scanner(System.in);
System.out.println("IP Adresse (Localhost 127.0.0.1).");
System.out.println("Format: xxx.xxx.xxx.xxx");
String ip = scan.nextLine();
try {
socket = new Socket(ip, Const.Port);
in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
out = new PrintWriter(socket.getOutputStream(), true);
System.out.println("Имя в чате");
out.println(scan.nextLine());
Resender resend = new Resender();
resend.start();
String str = "";
while (!str.equals("exit")) {
str = scan.nextLine();
out.println(str);
}
resend.setStop();
} catch (Exception e) {
e.printStackTrace();
} finally {
close();
}
}
private void close() {
try {
in.close();
out.close();
socket.close();
} catch (Exception e) {
System.err.println("Error!");
}
}
private class Resender extends Thread {
private boolean stoped;
public void setStop() {
stoped = true;
}
@Override
public void run() {
try {
while (!stoped) {
String str = in.readLine();
System.out.println(str);
}
} catch (IOException e) {
System.err.println("Error");
e.printStackTrace();
}
}
}
}