java - 谷歌 Spanner 单例重新连接故障

Question

我正在创建一个 SpannerSingleton，以便在应用程序的生命周期内保持连接。 我对连接持久性感兴趣...如果存在 session /连接问题，如何重新创建 session ？

一个想法是，如果超过 90% 的池已耗尽，则生成一个新连接，将 setMaxSessions 增加到更高的数字。就像指数退避的反面一样？但是我在哪里/如何才能做到这一点？我在客户端库中找不到任何可以让我监视池状态或客户端计数的内容。

我选择了bill-pugh-singleton因为这似乎是一个不错的选择...

这是我所拥有的:

public class SpannerSingleton {

    private static Spanner spanner;
    private static SpannerOptions options;

    private static SessionPoolOptions sessionPoolOps = SessionPoolOptions
            .newBuilder()
            .setMaxSessions(1000)  // 1000 concurrent queries
            .setMinSessions(100)  // keep 100 alive
            .setMaxIdleSessions(100)  // how many to keep from being idle and closed
            .build(); 

    private SpannerSingleton() {
        try {
            options = SpannerOptions
                    .newBuilder()
                    .setSessionPoolOption(sessionPoolOps)
                    .build();

            spanner = options.getService();

        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    private static class SingletonHelper{
        private static final Spanner CONNECTION = new SpannerSingleton().spanner;
    } 

    public static synchronized Spanner getSpanner() {
        return SingletonHelper.CONNECTION;
    }

}

我使用工厂模式来制作 dbClient

public SpannerFactory {

    private static Spanner spanner = SpannerSingleton.getSpanner();
    private static DatabaseId dbId;

    public static DatabaseClient getConnection(String instance) {
        if (Util.isEmpty(instance)) return null;

        if ("mickey".equalsIgnoreCase(instance)) {
            dbId = DatabaseId.of(spanner.getOptions().getProjectId(), "instance1", "mickey");
        }

        if ("mouse".equalsIgnoreCase(instance)) {
            dbId = DatabaseId.of(spanner.getOptions().getProjectId(), "instance1", "mouse");
        }

        return spanner.getDatabaseClient(dbId);

    }
}

我想添加的是检查连接池以查看我们距离饥饿有多近，然后重新创建它自己......我可能想太多了，但是如果连接中断会发生什么？

Answer 1

客户端库应该负责维护健康的 session 池，用户不必明确担心 session /连接。

如 java 客户端中所述，如果您正确设置 MaxSessions - 客户端将负责维护这么多 session 。

在较高层次上，流程如下:

If currentSessions < MaxSessions {
   if !idleSessions.empty()
        use an idle session.
   else
        CreateNewSession.
} else {
   Block/Fail based on action chosen in : ActionOnExhaustion.
}

如果您想避免在请求处理过程中 CreateSession 产生少量开销，建议的一个选项是保持 minSessions 和 maxSessions 与您的并发 TPS 要求，以便一开始我们就有那么多 session 可供使用。

有关 session 监控、保持空闲 session Activity 等其他详细信息:请参阅文档:https://cloud.google.com/spanner/docs/sessions