波斯马BOSSMA Information Technology

前一篇文章介绍了在Windows下安装Cassandra的步骤，这一篇文章将介绍在.NET平台下使用C#通过Thrift访问Cassandra。Thrift是Facebook使用的一个跨语言通信工具，提供了很多语言版本的支持。

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的使用。

关键字: Cassandra nosql thrift