google spanner 单例在故障时重新连接

Question

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

一个想法是生成一个新连接，如果超过 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

客户端库应该负责维护健康的会话池，用户不必明确地担心 sessions/connections。

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

在高层次上，流程如下：

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 要求，以便在开始时我们有那么多会话可以使用。

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

google spanner 单例在故障时重新连接

google spanner singleton reconnect on fault

java

google-cloud-platform

google-cloud-spanner