如何从Java连接到正在运行的BigTable模拟器

Question

我正在尝试使用gcloud beta仿真器中的bigtable仿真器。我启动模拟器，获取主机名（localhost）和端口（在本例中为8885）

gcloud beta模拟器bigtable启动

执行中：/ usr / local / Caskroom / google-cloud-sdk / latest / google-cloud-sdk
/ platform / bigtable-emulator / cbtemulator –host = localhost –port =
8885

我正在尝试从Java测试客户端连接到仿真器，这是我提供的：

Configuration conf = BigtableConfiguration.configure(projectId, instanceId);

if(!Strings.isNullOrEmpty(host)){
    conf.set(BigtableOptionsFactory.BIGTABLE_HOST_KEY, host);
    conf.set(BigtableOptionsFactory.BIGTABLE_PORT_KEY, Integer.toString(port));
}
connection = BigtableConfiguration.connect(configuration);
try (Table table = connection.getTable("tName")){
    table.put(<Put instance>);
}

当我执行测试代码时，我得到：

16:36:37.369 [bigtable-batch-pool-1] INFO com.google.cloud.bigtable.grpc.async.AbstractRetryingRpcListener - Retrying failed call. Failure #1, got: Status{code=UNAVAILABLE, description=null, cause=java.net.ConnectException: Connection refused: localhost/0:0:0:0:0:0:0:1:8885}
java.net.ConnectException: Connection refused: localhost/0:0:0:0:0:0:0:1:8885

我正在使用图书馆： com.google.cloud.bigtable:bigtable-hbase-1.2:0.9.1

知道我在做什么错吗？

谢谢 ！

Answer 1

您需要设置一个附加的配置属性：

conf.set(BigtableOptionsFactory.BIGTABLE_USE_PLAINTEXT_NEGOTIATION, true);

另外，从日志消息中看，它似乎正在尝试连接到IPv6地址，我认为这不起作用。仔细检查这host是一个有效的IPv4地址。

Java客户端将在不久的将来使此操作变得更容易。