Я недавно начал использовать драйвер Datastax Java для нашего варианта использования Cassandra ... Мы будем использовать драйвер Datastax Java для чтения / записи в Cassandra ...
Я успешно могу создать соединение Cassandra с помощью драйвера Datastax Java ... Но мне интересно, есть ли какие-либо другие настройки, которые я должен использовать в производственной среде, чтобы получить лучшую производительность с помощью драйвера Datastax Java при подключении к Cassandra?
/**
* Creating Cassandra connection using Datastax driver
*
*/
private DatastaxConnection() {
try{
builder = Cluster.builder();
builder.addContactPoint("some-node");
// Can anybody explain me what does below piece of code do?
builder.poolingOptions().setCoreConnectionsPerHost(
HostDistance.LOCAL,
builder.poolingOptions().getMaxConnectionsPerHost(HostDistance.LOCAL));
// And also what does below piece of code is doing?
cluster = builder
.withRetryPolicy(DowngradingConsistencyRetryPolicy.INSTANCE)
.withReconnectionPolicy(new ConstantReconnectionPolicy(100L))
.build();
StringBuilder s = new StringBuilder();
Set<Host> allHosts = cluster.getMetadata().getAllHosts();
for (Host h : allHosts) {
s.append("[");
s.append(h.getDatacenter());
s.append("-");
s.append(h.getRack());
s.append("-");
s.append(h.getAddress());
s.append("]");
}
System.out.println("Cassandra Cluster: " + s.toString());
session = cluster.connect("testdatastaxks");
} catch (NoHostAvailableException e) {
} catch (Exception e) {
}
}
Мои главные приоритеты: -
- Отфильтруйте узлы Cassandra на основе локального центра обработки данных. Таким образом, в пуле соединений будут только узлы Cassandra локального центра обработки данных.
- И получите максимальную производительность при использовании Java-драйвера Datastax с некоторыми настройками.
Я знаю, что некоторые настройки могут отличаться в разных средах, но могут быть некоторые настройки, которым все должны следовать, чтобы получить оптимальную производительность при установлении соединений Cassandra с использованием драйвера Datastax Java.
Как и в случае с Astyanax, когда я использовал ранее, вам нужно было использовать TOKEN_AWARE ...
Значит, должны быть какие-то лучшие настройки или рекомендуемые при использовании Java-драйвера Datastax?