package Server; import java.util.*; import java.net.*; import java.io.*; public class ChatServer { public static Scanner reader = new Scanner(System.in); public static int portNum = 1001; public static void main(String[] args) throws IOException { String phrase; ServerSocket Service; try { Service = new ServerSocket(portNum); } catch (IOException e) { System.err.println("Failed listening on port " + portNum + " (" + e + ")"); return; } Socket Soc = null; try { Soc = Service.accept(); while (true) { DataInputStream input = new DataInputStream( Soc.getInputStream() ); //InputStreamReader inputTemp = new InputStreamReader(Soc.getInputStream()); //BufferedReader input = new BufferedReader(inputTemp); phrase = input.readLine(); // FIXME: more then 1 line //System.out.println("Acc"); OutputStreamWriter outTemp = new OutputStreamWriter(Soc.getOutputStream()); BufferedWriter output = new BufferedWriter(outTemp); phrase = "<" + phrase + ">"; System.out.println(phrase); output.write(phrase, 0, phrase.length()); output.newLine(); output.flush(); //System.out.println("Done"); } } catch (IOException e) { if (Soc != null) Soc.close(); System.out.println(e); Service.close(); } } }