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.util.ArrayList;
- import java.util.List;
- 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 (java.net.SocketException se) {
- Logger.getLogger(Server.class.getName()).log(Level.FINE, "whhh", se);
- } catch (IOException ioe) {
- Logger.getLogger(Server.class.getName()).log(Level.SEVERE, null, ioe);
- } catch (ClassNotFoundException cnf) {
- Logger.getLogger(Server.class.getName()).log(Level.INFO, null, cnf);
- }
- }
- }
- private List<MyRecord> dummyRecords() {
- MyRecord record = null;
- List<MyRecord> records = new ArrayList<>();
- for (int i = 0; i < 9; i++) {
- record = new MyRecord(i, "foo");
- records.add(record);
- log.info(record.toString());
- }
- return records;
- }
- public void inOut(int portNumber) throws IOException, ClassNotFoundException {
- ServerSocket serverSocket = new ServerSocket(portNumber);
- Socket socket = serverSocket.accept();
- ObjectInputStream objectInputStream = new ObjectInputStream(socket.getInputStream());
- ObjectOutputStream objectOutputStream = new ObjectOutputStream(socket.getOutputStream());
- log.info("...connected...waiting for data...");
- MyRecord recordFromClient = (MyRecord) objectInputStream.readObject();
- objectOutputStream.writeObject(recordFromClient);
- objectOutputStream.flush();
- objectInputStream.close();
- objectOutputStream.close();
- log.info(recordFromClient.toString());//never logs
- System.out.println("never gets here");
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment