我将hdp2.5与hbase 1.1.2.2.5.3.0-37和phoenix-4.7.0.2.5.3.0-37一起使用。
两者都已启动并运行,能够从phoenix创建查询hbase数据。
Class.forName("org.apache.phoenix.queryserver.client.Driver");
conn = DriverManager.getConnection("jdbc:phoenix:thin:url=http://hostname:8765;serialization=PROTOBUF");
在上面的连接字符串中,它只使用一个查询服务器地址。但是,我有多个phoenix查询服务器正在运行。我想使用知道如何在字符串中指定多个查询服务器地址。
如果我指定多个查询服务器,我将获得故障转移机制。
例如:如果当前为我的请求提供服务的查询服务器出了问题,是否有一种机制可以重定向到另一个运行正常的查询服务器。
在源代码中,它只有一个 getConnectionUrl()
如下所示。
public static String getConnectionUrl(String protocol, String hostname, int port, String serialization) {
String urlFmt = Driver.CONNECT_STRING_PREFIX + "url=%s://%s:%s;serialization=%s";
return String.format(urlFmt, protocol, hostname, port, serialization);
}
请让我知道,如何使用多个查询服务器和故障转移机制如何。
暂无答案!
目前还没有任何答案,快来回答吧!