詳解NoSQL數(shù)據(jù)庫Apache Cassandra的配置
在這里我們將介紹的是NoSQL數(shù)據(jù)庫Apache Cassandra的配置與相關問題?，F(xiàn)在數(shù)據(jù)庫市場對于NoSQL的關注度日益升高，我們也該看到未來數(shù)據(jù)庫技術的變革。
上次說了安裝的問題，可以參考《VirtualBox 虛擬機 Debian系統(tǒng)上安裝Cassandra步驟及遇到的問題》。當然，在windows下也可以使用，但是要設置JAVA_HOME參數(shù)，然后啟動目錄bin里的cassandra.bat。編輯cassandra.bat看到
- if NOT DEFINED CASSANDRA_HOME set CASSANDRA_HOME=%CD%
改成
- if NOT DEFINED CASSANDRA_HOME set CASSANDRA_HOME=F:\apache-cassandra-0.5.1
“F:\apache-cassandra-0.5.1”是我的安裝目錄。
一、cassandra的單節(jié)點服務器配置
先說下cassandra的配置，還是講Linux下的。需要配置的文件一共有三個，當然，也可以使用默認配置。
這個三個文件分別是：
bin/cassandra.in.sh
conf/log4j.properties
conf/storage-conf.xml
其中，log4j.properties是日志的配置，其它兩個是配置的運行環(huán)境。
cassandra.in.sh文件一般不需要調(diào)整，當然，加入你沒有使用alternatives調(diào)整java的默認環(huán)境，而你又需要使用jre6.0,這種情況下，可以設置cassandra.in.sh中
- #JAVA_HOME=/usr/local/jdk6
為
JAVA_HOME=/usr/local/jre6 #這里是你的jre解壓縮的路徑
log4j.properties的配置網(wǎng)上講的很多，就不說了。
storage-conf.xml的配置是最重要的。
第一個是Keyspaces，這個默認只設置了Keyspace1，可以增加另外的Keyspaces?？蛻舳苏{(diào)用需要使用這個名字。
Keyspace節(jié)點中的KeysCachedFraction設置的鍵索引的內(nèi)存大小。說明上也寫了，假如鍵的數(shù)量較少，長度較長，可以增加這個值。而設置為0，則是禁用。
接下來是設置ColumnFamily，這里配置的名稱，在客戶端調(diào)用時候也要是有。另外還指定了列的類型。
ReplicationFactor設置了副本的數(shù)目，這個是在分布式部署中有用，保持數(shù)據(jù)的冗余，以至于某幾臺服務壞掉，能保證數(shù)據(jù)完整。
CommitLogDirectory以及接下來的幾行都是設置目錄的，這個就不說了。
Seeds也是和分部署主從服務器部署方式有關的，本文不準備講這個。
ThriftAddress是比較重要的，這個是設置客戶端訪問的，而ThriftPort是設置訪問的端口。接下來的部分是和性能有關的，這些說明可以仔細閱讀。貧道對下面的設置也理解不深入，就不獻丑了。
二、如何編程訪問cassandra
從http://incubator.apache.org/cassandra/找了好久，找到了http://github.com/rantav/hector （java）。這個是一個訪問cassandra的包裝。很遺憾的是，我使用這個包裝訪問時候，讀取一個Key的值需要7～8秒！??！暈倒。我開始以為是虛擬機的原因，結(jié)果部署到其他兩臺linux服務器上還是一樣。當然這些機器和我的機器都不在同一個網(wǎng)段，我不知道這點是不是會對性能有很大的影響。后來，我放到自己機器上，以及把寫好的程序當?shù)滥繕藱C器上，讀取速度變成了20MS每條。性能相差也太大了。一個是速度慢得和螞蟻一樣，而第二次則是坐上烏龜了。
其它語言的訪問包裝可以在http://wiki.apache.org/cassandra/ClientExamples 這里找到。當然，沒有C#的。
三、用C#和Java訪問cassandra
cassandra用到了另外一個好用的東西：thrift。這個東東可以在http://www.thrift-rpc.org/下載。
具體在http://www.thrift-rpc.org/?p=thrift.git;a=shortlog;h=refs/misc/instant，一般點第一個snapshot就行了，這是最新的。版本幾個小時更新一個，太牛叉了。
下載完后，搞到Linux上，解壓。進入目錄后進行安裝。
- #chmod +x * //設置執(zhí)行權限
- #./bootstrap.sh
- #./configure
- #make
- #make install
安裝好了，接下來，開始生成操作。
切換到cassandra的interface目錄。
然后，使用/home/xieping/thrift/ompiler/cpp/thrift -gen csharp cassandra.thrift 命令生成。運行該命令后，在interface目錄增加了gen-csharp目錄。把它搞到你的機器，然后，切換到/home/xieping/thrift/lib/csharp目錄。把src目錄搞下來。打開Thrift.csproj文件，右鍵Thrift項目，設置編譯符號為NET_2_0。新建個C#項目，把gen-csharp目錄下的東西添加進去，然后，引用Thrift項目，就可以寫以下代碼調(diào)用：
- using System;
- using Thrift.Transport;
- using Thrift.Protocol;
- using Apache.Cassandra;namespace TestCa {
- class Program {
- static void Main(string[] args)
- {
- TTransport transport = new TSocket("192.168.93.30", 9160);
- TProtocol protocol = new TBinaryProtocol(transport);
- Cassandra.Client client = new Cassandra.Client(protocol);
- transport.Open();
- System.Text.Encoding utf8Encoding = System.Text.Encoding.UTF8;
- long timeStamp = DateTime.Now.Millisecond;
- ColumnPath nameColumnPath = new ColumnPath() {
- Column_family = "Standard1",
- Column = utf8Encoding.GetBytes("name")
- };
- client.insert("Keyspace1",
- "1", nameColumnPath,
- utf8Encoding.GetBytes("測試輸入1"),
- timeStamp,
- ConsistencyLevel.ONE);
- client.insert("Keyspace1",
- "2",
- nameColumnPath,
- utf8Encoding.GetBytes("測試輸入2"),
- timeStamp,
- ConsistencyLevel.ONE);
- ColumnOrSuperColumn returnedColumn = client.get("Keyspace1", "1", nameColumnPath, ConsistencyLevel.ONE);
- Console.WriteLine("Keyspace1/Standard1 列值: 鍵: {0}, 值: {1}",
- utf8Encoding.GetString(returnedColumn.Column.Name),
- utf8Encoding.GetString(returnedColumn.Column.Value));
- transport.Close();
- Console.ReadKey();
- } }}
而Java的就變成
/home/xieping/thrift/ompiler/cpp/thrift -gen java cassandra.thrift
java相應的代碼
- import static me.prettyprint.cassandra.utils.StringUtils.bytes;
- import java.io.UnsupportedEncodingException;
- import org.apache.cassandra.service.Cassandra;
- import org.apache.cassandra.service.ColumnOrSuperColumn;
- import org.apache.cassandra.service.ColumnPath;
- import org.apache.cassandra.service.ConsistencyLevel;
- import org.apache.cassandra.service.InvalidRequestException;
- import org.apache.cassandra.service.NotFoundException;
- import org.apache.cassandra.service.TimedOutException;
- import org.apache.cassandra.service.UnavailableException;
- import org.apache.thrift.TException;
- import org.apache.thrift.protocol.TBinaryProtocol;
- import org.apache.thrift.protocol.TProtocol;
- import org.apache.thrift.transport.*;public class Program {
- public class s{
- }
- /** * @param args
- * @throws Exception
- */
- public static void main(String[] args) throws Exception {
- Long startTime = System.currentTimeMillis();
- for(int i = 0;i < 10000;i++){
- run();
- }
- Long endTime = System.currentTimeMillis(); System.out.println("程序運行到此處計算機當前毫秒數(shù) " + startTime);
- System.out.println("程序共計運行 "+ (endTime-startTime)+" 毫秒");
- }
- static void run() throws InvalidRequestException, UnavailableException, TimedOutException, TException, NotFoundException, UnsupportedEncodingException{ TTransport transport = new TSocket("192.168.93.30",9160);
- TProtocol protocol = new TBinaryProtocol(transport);
- Cassandra.Client client = new Cassandra.Client(protocol);
- transport.open();
- Long timeStamp = System.currentTimeMillis();
- ColumnPath nameColumnPath = new ColumnPath("Standard1",null,bytes("name"));
- client.insert("Keyspace1",
- "1", nameColumnPath,
- bytes("測試數(shù)據(jù)1"), timeStamp, ConsistencyLevel.ONE);
- client.insert("Keyspace1",
- "2", nameColumnPath,
- bytes("測試數(shù)據(jù)2"), timeStamp, ConsistencyLevel.ONE);
- ColumnOrSuperColumn returnedColumn = client.get("Keyspace1", "1", nameColumnPath, ConsistencyLevel.ONE);
- System.out.println(String.format("key:%s;value:%s",
- new String(returnedColumn.column.name), new String(returnedColumn.column.value,"utf-8")));
- transport.close();
- } }
- 云計算使關系數(shù)據(jù)庫逐漸落伍
- 2009年云數(shù)據(jù)庫的開發(fā)和應用前景
- 關系數(shù)據(jù)庫的末日是否已經(jīng)來臨
- 超越關系型數(shù)據(jù)庫 pureXML技術應用及展望
- 新興數(shù)據(jù)庫打破整個舊規(guī)則
- 探尋關系數(shù)據(jù)庫和ORM的最佳替代者
