-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathroundrobin.java
More file actions
51 lines (42 loc) · 1.45 KB
/
roundrobin.java
File metadata and controls
51 lines (42 loc) · 1.45 KB
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
package com.myfirstjava.program;
import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.LinkedList;
public class roundrobin {
//public static Socket[] servers = new Socket [3];
public static int server_index = 0;
public static void main(String args[]) {
LinkedList<Socket> s = new LinkedList<Socket>();
try {
int portNumber = 5500;
ServerSocket serverSocket = new ServerSocket(portNumber);
Socket conn = serverSocket.accept();
InputStream in = conn.getInputStream();
OutputStream out = conn.getOutputStream();
DataInputStream din=new DataInputStream(in);
DataOutputStream dout=new DataOutputStream(out);
s.add(new Socket("127.0.0.1",12345));
s.add(new Socket("127.0.0.1",5000));
s.add(new Socket("127.0.0.1",4040));
server_index++;
if (server_index >= s.size()) {
server_index = 0;
}
Socket selected = s.get(server_index);
//selected.out.writeInt(32);
/*for (int i = 0; s.size() <= 3; i++) {
Socket ser = s.get(i);
servers[i] = ser;
}*/
//System.out.println(s.size());
// System.out.println(servers);
//create linkedlist to store the connections other servers
//list.add(new Socket(!ip","port")
//BufferedInputStream bin=new BufferedInputStream(in);
//BufferedReader br = new BufferedReader(isr);
}catch (Exception e) {
System.err.println(e.getMessage());
}
}
}