thufir

try stream

Jul 1st, 2014
187
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
text 1.95 KB | None | 0 0
  1. package net.bounceme.dur.driver;
  2.  
  3. import java.io.IOException;
  4. import java.io.ObjectInputStream;
  5. import java.io.ObjectOutputStream;
  6. import java.net.ServerSocket;
  7. import java.net.Socket;
  8. import java.net.SocketException;
  9. import java.util.Properties;
  10. import java.util.logging.Level;
  11. import java.util.logging.Logger;
  12.  
  13. public class Server {
  14.  
  15. private static final Logger log = Logger.getLogger(Server.class.getName());
  16. private final RecordQueue recordsQueue = new RecordQueue();
  17.  
  18. public static void main(String[] args) {
  19. Properties props = PropertiesReader.getProps();
  20. int portNumber = Integer.parseInt(props.getProperty("port"));
  21. while (true) {
  22. try {
  23. new Server().inOut(portNumber);
  24. } catch (SocketException se) {
  25. Logger.getLogger(Server.class.getName()).log(Level.FINE, "spammy", se);
  26. } catch (IOException ioe) {
  27. Logger.getLogger(Server.class.getName()).log(Level.WARNING, null, ioe);
  28. } catch (ClassNotFoundException cnf) {
  29. Logger.getLogger(Server.class.getName()).log(Level.SEVERE, null, cnf);
  30. }
  31. }
  32. }
  33.  
  34. public void inOut(int portNumber) throws IOException, ClassNotFoundException, java.net.SocketException {
  35. recordsQueue.populate();
  36. MyRecord recordFromServer = recordsQueue.pop();
  37. ServerSocket serverSocket = new ServerSocket(portNumber);
  38. Socket socket = serverSocket.accept();
  39. MyRecord recordFromClient = null;
  40. try (ObjectOutputStream objectOutputStream = new ObjectOutputStream(socket.getOutputStream()))
  41. (ObjectInputStream objectInputStream = new ObjectInputStream(socket.getInputStream())) {
  42. recordFromClient = (MyRecord) objectInputStream.readObject();
  43. objectOutputStream.writeObject(recordFromServer);
  44. }
  45. }
  46. log.info(recordFromClient.toString());
  47. }
  48. }
Add Comment
Please, Sign In to add comment