-
Notifications
You must be signed in to change notification settings - Fork 0
/
MyClass.java
79 lines (72 loc) · 2.12 KB
/
MyClass.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
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.sql.Connection;
import java.util.ArrayList;
import java.util.Collections;
import java.util.List;
public class MyClass
{
// private static List<Socket> connections = Collections.synchronizedList(new ArrayList<Socket>());
static ServerSocket ss;
static Socket s;
static void readMes()
{
try
{
BufferedReader br = new BufferedReader(new InputStreamReader(s.getInputStream()));
System.out.println(br.readLine());
}
catch (Exception e){System.out.println("error");}
}
static void writeMes(String message)
{
try
{
BufferedWriter bw = new BufferedWriter(new OutputStreamWriter((s.getOutputStream())));
bw.write(message, 0, message.length());
bw.newLine();
bw.flush();
}
catch (Exception e){}
}
public static void main(String[] args)
{
try
{
ss = new ServerSocket(1022);
//while(true){
Socket s = ss.accept();
//connections.add(s);
//}
//s = ss.accept();
}
catch (Exception e){}
Thread t = new Thread() {
public void run() {
System.out.println("i'm heeereee");
BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
readMes();
try
{
while (true) {
writeMes(br.readLine());
// readMes();
}
} catch (Exception e){}
}
};
Thread t2 = new Thread(){
public void run(){
System.out.println("tututu");
while (true){
readMes();}
}
};
t.start();
t2.start();
}
}