public class Server {
 
    private ServerSocket server;
    private Socket socket;
    private ObjectOutputStream oos;
    private DataOutputStream dos;
    private DataInputStream dis;
    private HashMap<String, ArrayList<String>> drinkar = new HashMap<String, ArrayList<String>>();
    private int port;
    
    public Server(int port){
     this.port = port;
     Thread connectThread = new Thread( new Connect() );
     connectThread.start();
    }
 
    private class Connect implements Runnable {
    
    public void run() {
     
     try {
            server = new ServerSocket(port);
        System.out.println("Server running");
        while (true) {
         socket = server.accept();
                Thread clientThread = new Thread( new TalkToClient( socket ) );
          clientThread.start();
                System.out.println("someone connected");
        }
            } catch (IOException ex) {
                Logger.getLogger(Server.class.getName()).log(Level.SEVERE, null, ex);
            }
     try {
      server.close();
      } catch( Exception e ) {}
     }
    }
 
    
    private class TalkToClient implements Runnable{
     
     private Socket socket;
  public TalkToClient( Socket socket ) {
  this.socket = socket;
  }
 
    public void run() {
 
        String clientMsg;
        try {
          dis = new DataInputStream(socket.getInputStream());
            while ((clientMsg = dis.readUTF()) != null) {
                if (clientMsg.length() > 0) {
                    dos = new DataOutputStream(socket.getOutputStream());
                    dos.writeUTF("read");
                    drinkar = Mysql.getDrinks(clientMsg);
                    sendNames();
                }
            }
        } catch (Exception e) {
            System.out.println(e);
        }
        
    }
 
    }
 
    public void sendNames() {

        try {
            oos = new ObjectOutputStream(socket.getOutputStream());
            oos.writeObject(drinkar);
        } catch (IOException ex) {
            Logger.getLogger(Server.class.getName()).log(Level.SEVERE, null, ex);
        }
    }
 
    public static void main(String[] args) {
        new Server(4444);
    }
}