Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- package net.bounceme.dur.driver;
- import java.io.IOException;
- import java.io.ObjectInputStream;
- import java.io.ObjectOutputStream;
- import java.net.ServerSocket;
- import java.net.Socket;
- import java.net.SocketException;
- import java.util.Properties;
- import java.util.logging.Level;
- import java.util.logging.Logger;
- public class Server {
- private static final Logger log = Logger.getLogger(Server.class.getName());
- private final RecordQueue recordsQueue = new RecordQueue();
- public static void main(String[] args) {
- Properties props = PropertiesReader.getProps();
- int portNumber = Integer.parseInt(props.getProperty("port"));
- while (true) {
- try {
- new Server().inOut(portNumber);
- } catch (SocketException se) {
- Logger.getLogger(Server.class.getName()).log(Level.FINE, "spammy", se);
- } catch (IOException ioe) {
- Logger.getLogger(Server.class.getName()).log(Level.WARNING, null, ioe);
- } catch (ClassNotFoundException cnf) {
- Logger.getLogger(Server.class.getName()).log(Level.SEVERE, null, cnf);
- }
- }
- }
- public void inOut(int portNumber) throws IOException, ClassNotFoundException, java.net.SocketException {
- recordsQueue.populate();
- MyRecord recordFromServer = recordsQueue.pop();
- ServerSocket serverSocket = new ServerSocket(portNumber);
- Socket socket = serverSocket.accept();
- MyRecord recordFromClient = null;
- try (ObjectOutputStream objectOutputStream = new ObjectOutputStream(socket.getOutputStream()))
- (ObjectInputStream objectInputStream = new ObjectInputStream(socket.getInputStream())) {
- recordFromClient = (MyRecord) objectInputStream.readObject();
- objectOutputStream.writeObject(recordFromServer);
- }
- }
- log.info(recordFromClient.toString());
- }
- }
Add Comment
Please, Sign In to add comment