cassandra学习笔记4--Cassandra Java客户端3

Hector

Hector是基于Thrift Java API包装的一个Java客户端，提供一个更加高级的一个抽象。

程序范例

import static me.prettyprint.cassandra.utils.StringUtils.bytes;
import static me.prettyprint.cassandra.utils.StringUtils.string;

import org.apache.cassandra.thrift.Column;
import org.apache.cassandra.thrift.ColumnPath;

import me.prettyprint.cassandra.service.CassandraClient;
import me.prettyprint.cassandra.service.CassandraClientPool;
import me.prettyprint.cassandra.service.CassandraClientPoolFactory;
import me.prettyprint.cassandra.service.Keyspace;
import me.prettyprint.cassandra.service.PoolExhaustedException;

public class ExampleClient {  
 public static void main(String[] args) throws IllegalStateException, PoolExhaustedException,Exception {
  //setting pool
  CassandraClientPool pool = CassandraClientPoolFactory.INSTANCE.get();   
  //setting client
  CassandraClient client = pool.borrowClient("localhost", 9160);   
  //keyspaceName and columnFamily
  String keyspaceName = "Keyspace1";
  String columnFamily = "Standard1";
  //key Name
  String key = "逖靖寒的世界";
  //这里可以设置均衡
  // A load balanced version would look like this:   
  // CassandraClient client = pool.borrowClient(new String[] {"cas1:9160", "cas2:9160", "cas3:9160"});    
  try {     
   //get keySpace
   Keyspace keyspace = client.getKeyspace(keyspaceName);  
   //create columnPath
   ColumnPath columnPath = new ColumnPath(columnFamily);
   columnPath.setColumn("网址".getBytes("UTF8"));
   //insert
   keyspace.insert(key, columnPath, bytes(" http://gpcuster.cnblogs.com"));       // read 
   //get single column
   Column col = keyspace.getColumn("逖靖寒的世界", columnPath);   
   //print name and value
   System.out.println("name: " + string(col.getName()));    
   System.out.println("value: " + string(col.getValue()));    
   } finally {     
    // return client to pool. do it in a finally block to make sure it's executed     
    pool.releaseClient(client);   
   }
 }
}

优点

1 提供连接池。

2 提供错误处理：当操作失败的时候，Hector会根据系统信息（token map）自动连接另一个Cassandra Service。

3 编程接口容易使用。

4 支持JMX。

缺点

1 不支持多线程的环境。

2 keyspace封装过多（数据校验和数据重新封装），如果进行大量的数据操作，这里的消耗需要考虑。

3 错误处理不够人性化：如果所有的Cassandra Service都非常繁忙，那么经过多次操作失败后，最终的结果失败。

总结

Hector已经是一个基本足够使用的Java客户端了，但是还是缺乏一些相关的功能，比如：

1 线程安全。

2 支持自动的多线程查询和插入，提高操作效率。

3 人性化的错误处理机制。

4 避免过多的封装。