So führen Sie den TCP-Server aus, bis er gestoppt wird

Question

Beispiel https://github.com/spring-projects/spring-integration-samples/tree/master/basic/tcp-client-server ist großartig, um eine TCP-Server-Anwendung zu erstellen. Es ist einfach und läuft auf JVM. Es benötigt keinen Anwendungsserver.

Beispiel verwendet Befehlszeileneingabe, um das Programm auszuführen. Ich möchte, dass der Server Daten nur vom Socket-Port und nicht über die Befehlszeile akzeptiert. Wenn ich die Eingabe der Befehlszeile entferne, wird der Haupt-Thread beendet und das Programm akzeptiert keine Eingabe mehr vom Port. Ich muss den Hauptfaden die ganze Zeit laufen lassen.

ich einige etwas wie dieses denke:

boolean isGatewayStopped = false; 
    while (!isGatewayStopped) { 
     try { 
      Thread.sleep(5000); 
      isGatewayStopped = getGatewayStatus(); 
     } catch (InterruptedException e) { 
      e.printStackTrace(); 
     } 
    } 

Ich habe zwei Fragen:

1. ist es eine saubere Art und Weise weiterhin der Haupt-Thread laufen zu machen?

2. Woher weiß man, dass das Gateway gestoppt ist? Wenn der Benutzer TCP-Daten als "Quit" sendet, kann das Gateway gestoppt werden. Gibt es eine Möglichkeit zu wissen, dass Gateway gestoppt ist?

Dank

Answer 1

Eine andere Lösung ist wie folgt:

public static void main(String[] args) throws Exception { 
     ConfigurableApplicationContext ctx = SpringApplication.run(Application.class, args); 
     System.out.println("Hit 'Enter' to terminate"); 
     System.in.read(); 
     ctx.close(); 
} 

Sie die ApplicationContext starten und für den Anschlag von der Konsole Eingang warten.

EDIT

Für den Fall, wenn Sie möchten Programm über ein Ereignis in der Anwendung zu stoppen, Sie ApplicationListener und warten auf die Barriere vor bestehenden vom main registrieren:

CountDownLatch exitLatch = new CountDownLatch(1); 
ctx.addApplicationListener(ContextClosedEvent e -> exitLatch.countDown()) 
exitLatch.await(); 

Jetzt sollten Sie nur eine Logik in Ihrer Anwendung finden, um dort ctx.stop() anzurufen.

Answer 2

Sie können wait() auf dem Gateway-Thread aus dem Hauptthread rufen Sie den Haupt-Thread warten, bis Gateway-Thread beendet zu machen. Sie müssen notify() vom Gateway-Thread (wenn es anhalten sollte) aufrufen, um anzuzeigen, dass es fertig ist und warten, dass Threads weiterlaufen sollen (in diesem Fall wird main ausgeführt und beendet). Ein Beispiel kann found here sein.

Oder (eine andere Lösung für eine sehr einfache Anwendung), können Sie versuchen, so etwas wie folgenden Daten aus einem Hauptverfahren zu lesen und das Programm zu stoppen, wenn die Daten auf einen Befehl gleich lesen, das Programm zu stoppen:

class Server 
{ 
    static Executor pool = Executors.newFixedThreadPool(5); 

    public static void main(String[] args) throws IOException 
    { 
     ServerSocket serverSocket = new ServerSocket(9000); 
     while (true) 
     { 
     final Socket s = serverSocket.accept(); 
     Runnable r = new Runnable() 
         { 
         @Override 
         public void run() 
         { 
          // read data from socket 's' here 
          // call System.exit() if command is to stop. 
         } 
         }; 
     pool.execute(r); 
     } 
    }