java - 如何为 Google Cloud Bigtable 进行连接池

Question

是否存在内置库或者是否需要实现自定义库？

我尝试在这里检查，但不确定如何从这里继续:Bigtable connection pool

我已经尝试了下面的代码，但不太确定如何从这里开始:

import com.google.cloud.bigtable.config.BigtableOptions;
import com.google.cloud.bigtable.config.CredentialOptions;
import com.google.cloud.bigtable.grpc.BigtableSession;
import com.google.cloud.bigtable.grpc.io.ChannelPool;
import com.mahindra.digisense.config.AppConfig;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.security.GeneralSecurityException;

@Component
public class BigTableConnectionPoolingExample {

    @Autowired
    private AppConfig.BigTableConfig bigTableConfig;

    private void bigTableConnectionPooling() throws IOException, GeneralSecurityException {
        CredentialOptions credentialOptions = CredentialOptions.jsonCredentials(new FileInputStream(new File(bigTableConfig.getCredentialsJson())));
        BigtableOptions.Builder builder = new BigtableOptions.Builder();
        builder.setCredentialOptions(credentialOptions);
        ChannelPool.ChannelFactory channelFactory = (ChannelPool.ChannelFactory) BigtableSession.createChannelPool(bigTableConfig.getInstanceId(), builder.build());
        ChannelPool channelPool = new ChannelPool(channelFactory,3);
    }
}

这里是another Stack Overflow question ，没有答案。

Answer 1

正如 Solomon Duskis 所指出的，我们鼓励新人在 google-cloud-java 中开始使用惯用的 Bigtable 客户端。 。该客户端适合生产使用，但我们尚未最终确定客户端 API，因此我们可能会进行向后不兼容的更改。

如果您使用 Cloud Bigtable Client 中的 HBase 客户端repo 中，有一些选项可以调整下面使用的数据通道的数量以及每个 channel 的运行中 RPC 的数量。但我们建议您首先分析您的应用程序，因为您应该能够实现良好的性能并使集群饱和，而无需手动调整这些参数的默认值。