如何使TCP服务器运行到停止

Question

样品https://github.com/spring-projects/spring-integration-samples/tree/master/basic/tcp-client-server非常适合构建TCP服务器应用程序。它很简单，可以在JVM上运行。它不需要任何应用服务器。

示例使用命令行输入来运行程序。我希望服务器仅从套接字端口而不是通过命令行接受数据。如果删除命令行输入，主线程将完成，程序将不再接受来自端口的输入。我必须始终保持主线程运行。

我在想这样的事情：

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

我有两个问题：

>

有没有一种干净的方法可以让主线程继续运行？

如何知道网关已停止？如果用户以“退出”的形式发送TCP数据，则可以停止网关。有没有办法知道网关已停止？

谢谢

Answer 1

您可以从主线程调用网关线程上的etc（）以使主线程等待网关线程完成。您需要从网关线程（当它应该停止时）调用通知（）来指示它已经完成并且等待线程应该继续运行（在这种情况下，main将运行并退出）。可以在这里找到一个例子。

或者（一个非常简单的应用程序的不同解决方案），您可以尝试以下方法从主方法读取数据，并在读取的数据等于停止程序的命令时停止程序：

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);
      }
   }

Answer 2

另一种解决方案是这样的：

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();
}

您启动Application ationContext并等待控制台输入的停止。

编辑

对于要通过应用程序中的事件停止程序的情况，您可以注册ApplicationListener，并在从主界面存在之前等待屏障：

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

现在，您应该在应用程序中提出一些逻辑来调用ctx。停止（）。