?

幾家做seo無恥公司名單

?

http://www.byywee.com?
http://www.cosdiv.com

?

通過在自已網站加入別人網站連接，這種網站專門對新開通的網站做連接,從而達到宣傳他們目的，

?

http://www.renrenaj.com/about/copyright.html

1、下載Thrift

兩個文件:

thrift-0.7.0.tar.gz

Thrift compiler for Windows

2、獲取Thrift.dll

解壓后，找到源代碼：

thrift-0.7.0\lib\csharp\src，在Visual Studio中打開Thrift.csproj，重新編譯生成dll。

3、生成C#代碼

將thrift-0.7.0.exe復制到Cassandra安裝目錄的interface目錄中。

在命令提示符工具中進入interface目錄，執行以下命令：

    thrift-0.7.0.exe --gen csharp cassandra.thrift
  

完畢后會在這個目錄中生成一個文件夾:gen-csharp。

4、獲取Apache.Cassandra.dll

新建一個類庫項目，把這些文件加到這個項目中，編譯生成一個dll文件。

別忘了添加引用上邊生成的Thrift.dll文件。

5、編寫測試程序

在Visual Studio中創建一個項目，這里以用戶令牌為例，給出兩個方法：

（1）、插入數據

    public string SetUserToken()

        {

            string keySpaceName = "UserTokenSpace";

            string columnFamilyName = "UserToken";

            string columnName = "Token";

            string key = "1001";

            string token = "we9g872m9f5l";

            Encoding utf8Encoding = Encoding.UTF8;

            long timeStamp = DateTime.Now.Ticks;



            TTransport frameTransport = null;

            try

            {

                // 通過Thrift建立到Cassandra的連接

                frameTransport = new TFramedTransport(new TSocket("localhost", 9160));

                TProtocol protocol = new TBinaryProtocol(frameTransport);

                TProtocol frameProtocol = new TBinaryProtocol(frameTransport);

                Cassandra.Client client = new Cassandra.Client(protocol, frameProtocol);

                frameTransport.Open();



                // 先刪除已經創建的KeySpace，以便于測試

                try

                {

                    client.system_drop_keyspace(keySpaceName);

                }

                catch

                {

                }



                // KeySpace 定義

                KsDef ks = new KsDef()

                {

                    Name = keySpaceName,

                    Replication_factor = 1,

                    Strategy_class = "org.apache.cassandra.locator.SimpleStrategy",



                    // Column Family 定義

                    Cf_defs = new List<CfDef>() {

                        new CfDef(){

                                        Name = columnFamilyName,

                                        Keyspace = keySpaceName,

                                        Comparator_type = "BytesType",



                                        // Column 定義

                                        Column_metadata = new List<ColumnDef>(){

                                            new ColumnDef(){

                                                Index_name = columnName,

                                                Index_type = IndexType.KEYS,

                                                Name = utf8Encoding.GetBytes("Token"),

                                                Validation_class = "BytesType"

                                            }

                                        }

                                    }

                    }

                };



                // 添加KeySpace

                client.system_add_keyspace(ks);



                //設置當前KeySpace

                client.set_keyspace(keySpaceName);



                // 要插入數據的路徑

                ColumnParent tokenColumnParent = new ColumnParent()

                {

                    Column_family = columnFamilyName

                };



                // 要插入數據的Column

                Column tokenColume = new Column()

                {

                    Name = utf8Encoding.GetBytes(columnName),

                    Value = utf8Encoding.GetBytes(token),

                    Timestamp = timeStamp

                };



                //插入數據

                client.insert(utf8Encoding.GetBytes(key), tokenColumnParent, tokenColume, ConsistencyLevel.ONE);

            }

            finally

            {

                if (frameTransport != null)

                {

                    frameTransport.Close();

                }

            }



            return token;

        }
  

（2）、獲取數據

    public static string GetUserToken(string userId)

        {

            string keySpaceName = "UserTokenSpace";

            string columnFamilyName = "UserToken";

            string columnName = "Token";

            System.Text.Encoding utf8Encoding = System.Text.Encoding.UTF8;

            long timeStamp = DateTime.Now.Millisecond;



            TTransport frameTransport = null;

            try

            {

                // 通過Thrift建立到Cassandra的連接

                frameTransport = new TFramedTransport(new TSocket("localhost", 9160));

                TProtocol protocol = new TBinaryProtocol(frameTransport);

                TProtocol frameProtocol = new TBinaryProtocol(frameTransport);

                Cassandra.Client client = new Cassandra.Client(protocol, frameProtocol);

                frameTransport.Open();



                // 設置當前KeySpace

                client.set_keyspace(keySpaceName);



                // 查找路徑

                ColumnPath nameColumnPath = new ColumnPath()

                {

                    Column_family = columnFamilyName,

                    Column = utf8Encoding.GetBytes(columnName)

                };



                // 獲取Column

                ColumnOrSuperColumn returnedColumn = client.get(utf8Encoding.GetBytes(userId), nameColumnPath, ConsistencyLevel.ONE);

                return utf8Encoding.GetString(returnedColumn.Column.Value);

            }

            catch

            {

            }

            finally

            {

                // 別忘了關閉連接

                if (frameTransport != null)

                {

                    frameTransport.Close();

                }

            }



            return string.Empty;

        }
  

?

使用ThriftAPI進行數據操作還是很繁瑣的，nosql的操作規范沒有sql那么好啊，不過效率肯定有保證。接下來的文章會介紹一些高級API的使用。

在.NET平臺下使用C#通過Thrift訪問Cassandra