技術共有

한어Русский языкEnglishFrançaisIndonesianSanskrit日本語DeutschPortuguêsΕλληνικάespañolItalianoSuomalainenLatina

マシンがオフラインになると、多くの問題に直面します。登録センターからマシンをオフラインにするにはどうすればよいでしょうか?リソースをクリーンアップして解放するにはどうすればよいですか?クライアントは、サービス リストを取得するときにローカル キャッシュも使用します。ローカル キャッシュを適時に更新するにはどうすればよいですか?

サーバー マシンを正常にシャットダウンするには、ShutdownHook を使用する必要があります。これは、シャットダウン フックを追加するのと同じです。このフックは、JVM のシャットダウン時 (つまり、プログラムの終了時) に呼び出され、リソースとクリーンアップを行うスレッドです。正常にシャットダウンします。

   public void clearAll() {
        log.info("addShutdownHook for clearAll");
        // 添加了一个关闭钩子，这个钩子是一个线程，它在JVM关闭时（即程序结束时）被调用，清理资源，优雅下机
        Runtime.getRuntime().addShutdownHook(new Thread(() -> {
            try {
                InetSocketAddress inetSocketAddress = new InetSocketAddress(InetAddress.getLocalHost().getHostAddress(), NettyRpcServer.PORT);
                CuratorUtils.clearRegistry(CuratorUtils.getZkClient(), inetSocketAddress);
            } catch (UnknownHostException ignored) {
            }
            // 操作完整、优雅，便于释放连接资源，便于自定义清理逻辑
            ThreadPoolFactoryUtil.shutDownAllThreadPool();
        }));
    }

フック スレッドでは、以下に示すように、登録センターからノードを削除するロジックを記述する必要があります。

  // RPC Server端 本机所注册服务的缓存
  private static final Set<String> REGISTERED_PATH_SET = ConcurrentHashMap.newKeySet();
 
  public static void clearRegistry(CuratorFramework zkClient, InetSocketAddress inetSocketAddress) {
        REGISTERED_PATH_SET.stream().parallel().forEach(p -> {
            try {
                // 是本机在ZK注册的节点
                if (p.endsWith(inetSocketAddress.toString())) {
                    // 根据路径名删除节点
                    zkClient.delete().forPath(p);
                }
            } catch (Exception e) {
                log.error("clear registry for path [{}] fail", p);
            }
        });
        log.info("All registered services on the server are cleared:[{}]", REGISTERED_PATH_SET.toString());
    }

登録センター ZK でノードを削除した後、スレッド プール リソースを解放する必要があります。

  public static void shutDownAllThreadPool() {
        log.info("call shutDownAllThreadPool method");
        THREAD_POOLS.entrySet().parallelStream().forEach(entry -> {
            ExecutorService executorService = entry.getValue();
            // 停止接收新的任务，但已提交的任务会继续执行
            executorService.shutdown();
            log.info("shut down thread pool [{}] [{}]", entry.getKey(), executorService.isTerminated());
            try {
                // 等待线程池中的任务在指定的时间内完成。如果在指定时间内线程池未能终止，会抛出 InterruptedException
                executorService.awaitTermination(10, TimeUnit.SECONDS);
            } catch (InterruptedException e) {
                log.error("Thread pool never terminated");
                // 指定时间内线程池未能终止，立即停止所有正在执行的任务
                executorService.shutdownNow();
            }
        });
    }

スレッド プールを閉じるロジックをカスタマイズすることで、よりエレガントにスレッド プール リソースの解放を実現できます。新しいタスクの受け付けを停止し、一定の待機時間内に送信されたタスクの実行を継続することができます。待機時間を超えると、スレッド プールは強制的に終了されます。