最近开发项目需要一个高速存储日志的系统,经过讨论暂时决定用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的配置文件用法,如果以上没有设置正确会出现非法请求.
?
(原创不多,难免有错误之处,多多包含)
?
?
?
?
?
?
?
?
?
?
?
?
?
?
相关文章
