diff options
-rw-r--r-- | src/Server/Connection.java | 73 |
1 files changed, 73 insertions, 0 deletions
diff --git a/src/Server/Connection.java b/src/Server/Connection.java new file mode 100644 index 0000000..d232616 --- /dev/null +++ b/src/Server/Connection.java @@ -0,0 +1,73 @@ +package Server; + +import java.net.*; +import java.io.BufferedWriter; +import java.io.DataInputStream; +import java.io.IOException; +import java.io.OutputStreamWriter; + +public class Connection extends Thread +{ + private Socket soc; + + public Connection (Socket soc) + { + + this.soc = soc; + } + + + private static String[] parseLine(String line) + { + String[] parsedLine = line.split("[ \t]+", 2); + return parsedLine; + + } + + @SuppressWarnings("deprecation") + public void run () + { + try + { + Client client; + CommandsTable commandsTable = new CommandsTable(); + + DataInputStream input = new DataInputStream(soc.getInputStream()); + OutputStreamWriter outTemp = new OutputStreamWriter(soc.getOutputStream()); + BufferedWriter output = new BufferedWriter(outTemp); + client = new Client(soc, output); + + while (true) + { + String[] parsedLine; + String line ; + + try { + line = input.readLine(); // FIXME: more then 1 line + } catch (java.net.SocketException e) { + break; // connection was lost / disconnected + } + if (line == null) { + System.err.println("Got null line"); + soc.close(); + break; + } + parsedLine = parseLine(line); + commandsTable.runCommand(client, parsedLine[0], parsedLine[1]); + line = soc.getPort() + ": <" + line + ">, command: <" + parsedLine[0] + ">, args: <" + parsedLine[1] + ">."; + System.out.println(line); + + // System.out.println("Done"); + } + } catch (IOException e) + { + if (soc != null) + try { + soc.close(); + } catch (IOException e1) { + e1.printStackTrace(); + } + e.printStackTrace(); + } + } +} |