-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathServer.java.bak
63 lines (53 loc) · 1.9 KB
/
Server.java.bak
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
import java.io.DataOutputStream;
import java.io.IOException;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
import java.lang.ClassNotFoundException;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Random;
import java.util.Scanner;
/**
* This class implements java Socket server
* @author pankaj
*
*/
public class Server {
//static ServerSocket variable
private static ServerSocket server;
//socket server port on which it will listen
private static int port = 6789;
public static void main(String args[]) throws ClassNotFoundException {
//create the socket server object
//keep listens indefinitely until receives 'exit' call or program terminates
int i =0;
Thread thread = null;
try {
server = new ServerSocket(port);
while(true){
System.out.println("Waiting for the client request");
Socket socket = server.accept();
ObjectInputStream ois = new ObjectInputStream(socket.getInputStream());
String message = (String) ois.readObject();
System.out.println("Message Received: " + message);
Random rand = new Random();
int Ports = rand.nextInt(9000)+1000;
Echothread echoThread = new Echothread(Ports);
thread = new Thread(echoThread);
thread.start();
ObjectOutputStream oos = new ObjectOutputStream(socket.getOutputStream());
oos.writeObject(""+newPort);
ois.close();
oos.close();
socket.close();
i++;
}
} catch (IOException ex) {
try {
server.close();
} catch (IOException e) {
System.err.println("ERROR closing socket: " + e.getMessage());
}
}
}
}