Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- serverSocket = new ServerSocket(portnumber);
- while(1 == saveloop)
- {
- loop = 1;
- while(1==loop)
- {
- //client connecting
- System.out.println("Waiting for clients to connect.");
- //Socket socket = serverSocket.accept();
- Socket socket = serverSocket.accept();
- clientid++;
- System.out.println("Client #" + clientid + " has connected. <" + socket.getRemoteSocketAddress().toString() + ">");
- //receive message from client
- BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
- //login
- Boolean loggedin = false;
- Boolean connection = true;
- while(!loggedin && connection)
- {
- username = "";
- password = "";
- BufferedWriter bw1 = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
- String input = br.readLine();
- if(input!= null)
- {
- username = input.substring(0, input.indexOf(";"));
- password = input.substring(input.indexOf(";") + 1, input.length());
- System.out.println(username + " ; " + password);
- if(serverusers.userVrf(username, password))
- {
- bw1.write("true");
- loggedin = true;
- System.out.println("User #" + clientid + " (" + username + ") had just logged in!");
- ips += username + " - " + socket.getRemoteSocketAddress().toString() + " " + "\n";
- saveIP(ips);
- }
- else bw1.write("false");
- bw1.newLine();
- bw1.write("" + ruins);
- bw1.newLine();
- bw1.write("" + shareLink);
- bw1.newLine();
- bw1.write("" + vernum);
- bw1.newLine();
- bw1.write("" + serverusers.getMaxRuins(username) + ";" + serverusers.getCurrentRuins(username));
- bw1.newLine();
- bw1.write("" + ruinlogs);
- bw1.newLine();
- bw1.flush();
- }
- else connection = false;
- }
- //
- if(loggedin && connection)
- {
- int tempruins = serverusers.getCurrentRuins(username);
- System.out.println("Message from client #" + clientid + " (" + username + "):" + br.readLine());
- String data = br.readLine();
- while(data != null && loop == 1)
- {
- if(data.contains("ruin stop") && username.equals("eldaruin"))
- {
- saveloop = 2;
- loop = 2;
- }
- System.out.println("Message from client #" + clientid + " (" + username + "):" + data);
- if(data.contains("#") && !data.equals("ruin stop"))
- {
- ruinlogs = data + " by - " + username + " - ^" + ruinlogs;
- ruins++;
- tempruins++;
- serverusers.addToRuinCount(username);
- }
- else ruinlogs = data + "^" + ruinlogs;
- saveChanges(ruinlogs, ruins);
- if(!username.equals("eldaruin") && tempruins == serverusers.getMaxRuins(username)) loop = 2;
- data = br.readLine();
- }
- }
- System.out.println("Client #" + clientid + " (" + username + ") disconnected. <" + socket.getRemoteSocketAddress().toString() + ">");
- }
- }}
- catch (IOException e)
- {
- // TODO Auto-generated catch block
- e.printStackTrace();
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement