编写连接到cassandra 的客户端过程(C++例子)

最近开发项目需要一个高速存储日志的系统,经过讨论暂时决定用cassandra作为存储

 

cassandra 下载地址在 http://cassandra.apache.org/  关于其他信息大家懂的.不懂问谷歌

 

我目前下载的是apache-cassandra-0.6.5-bin.tar.gz 版本 

 

因为工作系统在window xp 下面 所以 解压出来进入bin目录,找到cassandra.bat 点击启动

 

(linux下 输入 ./cassandra 启动)

 

如果启动出错 那么就需要自己修改 cassandra.bat(或在 cassandra)文件,

 

下面面这句是启动的语句,自己可以在之前添加echo,看看各自的输出参数,

 

"%JAVA_HOME%\bin\java" %JAVA_OPTS% %CASSANDRA_PARAMS% -cp %CASSANDRA_CLASSPATH% "%CASSANDRA_MAIN%"

 

比如echo %CASSANDRA_CLASSPATH% 

 

服务器编译好的类文件 放在 lib 目录下,所以 %CASSANDRA_CLASSPATH% 必须包含有lib路径

 

服务器启动完,我们根据官方给出例子 http://wiki.apache.org/cassandra/ThriftExamples

 

看到无论是PHP,JAVA,等其他语言都需要用到Thrift 编译生成出对应的接口文件 

 

从这里下载 Thrift  http://incubator.apache.org/thrift/  根据自己系统下载 (安装过程你们懂的)

 

安装完后 去到cassandra\interface 目录 输入 thrift-0.5.0.exe -gen cpp cassandra.thrift

(没有的文件需要自己拷贝过来) 

 

其他语言生成 比如java thrift-0.5.0.exe -gen java cassandra.thrift (如果生成不成功,可以去到linux下尝试)

 

生成结束后把 包含 Cassandra 文件名的文件拷贝的自己工程的cassandra目录下

 

还有把thrift 需要用到lib文件也拷贝到自己工程thrift目录下.(没有目录自己新建)

 

自己编辑makefile.am文件加入需要包含的cassandra文件,还有configure.in文件

 

中间不断地make 会提示缺乏一些定义,自己根据提示加上(编译过程可能比较烦躁,中间可以切换看MM)

 

C++下面使用方法

 

boost::shared_ptr<TTransport>  ts = (boost::shared_ptr<TTransport>)new TSocket(cassandra_rpc_thrift_address,cassandra_rpc_thrift_port );

 

boost::shared_ptr<TTransport> tr = (boost::shared_ptr<TTransport>)new TBufferedTransport(ts,1024,1024);

 

boost::shared_ptr<TProtocol> proto = (boost::shared_ptr<TProtocol> ) new TBinaryProtocol(tr);

 

cassandraclient = new CassandraClient(proto);

 

try

{

tr->open();

}

catch (TTransportException e)

{

log->debug("TTransportException %s\n",e.what());

}

catch (...)

{

log->debug("open other error!");

}

 

 

ColumnPath path;

path.column_family = "Standard1";

path.super_column = "";

path.column = "login_log";

path.__isset.column = true;

std::string keyspace = "Keyspace1";

std::string key = "login";

std::string value = "account login";

int64_t timestamp = time(NULL);

try

{

cassandraclient->insert(keyspace,key,path,value,timestamp,ZERO);

}

catch( apache::thrift::TApplicationException e)

{

log->debug("TApplicationException %s\n",e.what());

 

}

catch(org::apache::cassandra::InvalidRequestException ire)

{

log->debug("InvalidRequestException %s\n",ire.what());

}

catch(org::apache::cassandra::UnavailableException ue)

{

log->debug("UnavailableException %s\n",ue.what());

}

catch(org::apache::cassandra::TimedOutException te)

{

log->debug("TimedOutException %s",te.what());

}

catch(...)

{

log->debug("send_insert error!");

 

 

}

 

 

黄金分割

================================================================

 

cassandra_rpc_thrift_address //cassandra  服务器地址

cassandra_rpc_thrift_port // thrift 端口地址 一般是9160 配置文件可以修改

 

path.column_family = "Standard1"; //这个相当于数据库的表名,也必须在配置文件设置好

path.__isset.column = true; // 这个在C++下面必须设置(其他语言没有)

std::string keyspace = "Keyspace1";//这个相当于数据库名,必须在配置文件里面设置好

 

 

以上自己查看cassandra的配置文件用法,如果以上没有设置正确会出现非法请求.

 

(原创不多,难免有错误之处,多多包含)