java cassandra连接池_Cassandra Java驱动程序的最佳设置只能写入本地数据中心

我最近开始为我们的Cassandra用例使用Datastax

Java驱动程序…我们将使用Datastax Java驱动程序读取/写入Cassandra …

我成功地可以使用Datastax Java驱动程序创建Cassandra连接…但是我想知道,在生产环境中是否还有其他设置可以使用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 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节点.

>在使用Datastax java驱动程序时,可以获得最佳的性能,并具有一定的设置.

我知道某些设置可能会在不同的环境中有所不同,但是在使用Datastax Java驱动程序进行Cassandra连接时,可能需要遵循一些设置来获得最佳性能.

就像在Astyanax早期使用的一个例子,那就是你需要使用TOKEN_AWARE …

所以应该有一些最好的设置,或者推荐使用Datastax java驱动程序？

java cassandra连接池_Cassandra Java驱动程序的最佳设置只能写入本地数据中心相关推荐

java cassandra连接池_java操作cassandra（连接池）
package com.chu.cassandratest; import java.util.concurrent.Semaphore; import java.util.concurrent.Ti ...
java数据源是什么_《java数据源—连接池》
<java数据源-连接池> 1.数据源的分类:直接数据源.连接池数据源. 2.连接池.数据源.JNDI a.数据源:Java中的数据源就是连接到数据库的一条路径,数据源中并无真正的数据,它 ...
连接池在java中的使用
1. 在项目的实际开发中,连接数据库一般都会使用两种方式. (1) 使用JDBC直接连接数据库,其他程序每访问一次数据库,访问程序直接跟数据库打交道,建立一次数据库连接,用完在释放连接资源. (2) ...
用JAVA SOCKET编程，读服务器几个字符，再写入本地显示
Server: package cn.itcast.framework.socket;import java.io.BufferedReader; import java.io.IOException ...
java mysql连接池配置_Java数据库连接池的几种配置方法(以MySQL数据库为例)
一.Tomcat配置数据源: 前提:需要将连接MySQL数据库驱动jar包放进Tomcat安装目录中common文件夹下的lib目录中 1.方法一:在WebRoot下面建文件夹META-INF,里面建 ...
[数据库druid连接池实现]--Java版本
前言之前有介绍一篇关于自定义的数据库链接池实现,但是质量并不高.而且遭到博友的一脸嫌弃!确实,拿出来的东西就应该保证是正确的,或者质量高,否则很容易就误导了他人,显得TMD也不道德,所以今天专门重写 ...
java 线程连接池_java程序实现线程连接池功能
下面是以前学java 的时候写的一个实现,没有考虑很多,比如同步处理等等.懒得改,你就看看吧. package com.wangjia.tools; import java.io.Serializab ...
java weblogic连接池,Weblogic JNDI 方式连接连接池（工作中遇到的问题）
背景描述工作中客户的代码中没有alter session set nls_date_format = 'YYYY-MM-DD HH24:MI:SS',这个sql,可是agent每条请求平均抓了60次 ...
Java hdfs连接池_Java使用连接池管理Hdfs连接
记录一下Java API 连接hadoop操作hdfs的实现流程(使用连接池管理). 以前做过这方面的开发,本来以为不会有什么问题,但是做的还是坑坑巴巴,内心有些懊恼,记录下这烦人的过程,警示自己切莫 ...

java cassandra连接池_Cassandra Java驱动程序的最佳设置只能写入本地数据中心

java cassandra连接池_Cassandra Java驱动程序的最佳设置只能写入本地数据中心相关推荐

最新文章

热门文章