[AMORO-1957] Support liveness port testing for standby instance

ams/server/src/main/java/com/netease/arctic/server/ArcticManagementConf.java

@@ -49,6 +49,12 @@ public class ArcticManagementConf {
           .defaultValue("admin")
           .withDescription("The administrator password");
 
+  public static final ConfigOption<Integer> LIVENESS_PROBE_TCP_PORT =
+      ConfigOptions.key("liveness-probe-tcp-port")
+          .intType()
+          .defaultValue(-1)
+          .withDescription("livenessProbe tcp port of the server.");
+
   public static final ConfigOption<Long> REFRESH_EXTERNAL_CATALOGS_INTERVAL =
       ConfigOptions.key("refresh-external-catalogs.interval")
           .longType()

ams/server/src/main/java/com/netease/arctic/server/ArcticServiceContainer.java

@@ -67,6 +67,8 @@
 import java.io.IOException;
 import java.net.InetAddress;
 import java.net.InetSocketAddress;
+import java.net.ServerSocket;
+import java.net.Socket;
 import java.nio.file.Files;
 import java.nio.file.Paths;
 import java.util.ArrayList;
@@ -92,6 +94,7 @@
   private TServer tableManagementServer;
   private TServer optimizingServiceServer;
   private Javalin httpServer;
+  private Thread livenessProbeThread;
 
   public ArcticServiceContainer() throws Exception {
     initConfig();
@@ -103,6 +106,7 @@
       ArcticServiceContainer service = new ArcticServiceContainer();
       while (true) {
         try {
+          service.startLivenessProbe();
           service.waitLeaderShip();
           service.startService();
           service.waitFollowerShip();
@@ -176,6 +180,9 @@
       terminalManager.dispose();
       terminalManager = null;
     }
+    if (livenessProbeThread != null) {
+      livenessProbeThread.interrupt();
+    }
     optimizingService = null;
   }
 
@@ -455,6 +462,32 @@
     }
   }
 
+  private void startLivenessProbe() {
+    int port = serviceConfig.getInteger(ArcticManagementConf.LIVENESS_PROBE_TCP_PORT);
+    if (port > 0) {
+      this.livenessProbeThread =
+          new ThreadFactoryBuilder()
+              .setDaemon(true)
+              .setNameFormat("LivenessProbe-thread-%d")
+              .build()
+              .newThread(
+                  () -> {
+                    try (ServerSocket serverSocket = new ServerSocket(port)) {
+                      LOG.info("LivenessProbe listening on port: " + port);
+                      while (true) {
+                        try (Socket ignored = serverSocket.accept()) {
+                          // do nothing
+                        }
+                      }
+                    } catch (Exception e) {
+                      LOG.error("LivenessProbe start error", e);
+                      throw new RuntimeException(e);
+                    }
+                  });
+      livenessProbeThread.start();
+    }
+  }
+
   @VisibleForTesting
   public TableService getTableService() {
     return this.tableService;

dist/src/main/arctic-bin/conf/config.yaml

@@ -3,6 +3,7 @@ ams:
   admin-password: admin
   server-bind-host: "0.0.0.0"
   server-expose-host: "127.0.0.1"
+  liveness-probe-tcp-port: -1
 
   thrift-server:
     max-message-size: 104857600 # 100MB