问谷歌扳手单例故障重新连接
EN

Stack Overflow用户

提问于 2019-02-08 16:38:57

回答 1查看 166关注 0票数 1

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

一个想法是，如果超过90%的池耗尽，则生成一个新的连接，将setMaxSessions增加到更高的数量。就像指数退避的反面？但我在哪里/怎么能做到呢？我无法在客户端库中找到任何允许我监视池状态或客户机计数的内容。

我和比尔-普格-单身人士一起去的，因为这似乎是个不错的选择.

以下是我所拥有的：

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

    }
}

我想补充的是一些东西，可以检查连接池，看看我们离饥饿有多近，然后重新创建自己.我可能想太多了，但是如果连接中断会发生什么呢？

java

google-cloud-platform

google-cloud-spanner

回答 1

Stack Overflow用户

回答已采纳

发布于 2019-02-11 10:44:11

客户端库应该负责维护健康的会话池，用户不应该显式地担心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.
}