Thrift.Transport.TTransportException：无法写入空的OutputStream

Question

我在做与卡桑德拉和节俭图书馆一些工作。我知道这些都是非常早期的图书馆，在某些时候会（毫无疑问）的变化。

我一直在使用下面的链接与设置帮助我的C＃代码写入和读取，并从我的卡珊德拉服务器（这是我在我的本地VirtualBox的一个Ubuntu Server实例已经运行）。我已经证实，琐碎的读/写功能的工作原理。

其中我在（使用与卡桑德拉附带的thrift.definition文件，该文件生成对我来说）被执行以下方法的问题：

public void send_get_count(string keyspace, string key, ColumnParent column_parent, ConsistencyLevel consistency_level)

下面是我的设置代码：

TTransport _transport;
TProtocol _protocol;
Cassandra.Client _client;

public Test()
{
    _transport = new TSocket("192.168.56.101", 9160);
    _protocol = new TBinaryProtocol(_transport);
    _client = new Cassandra.Client(_protocol);
}

我的调用代码看起来像这样：

public void GetAllBlogEntries()
    {
        var timestamp = DateTime.Now.Millisecond;
        var keyspace = "Keyspace1";

        var utf8Encoding = System.Text.Encoding.UTF8;

        var columnParent = new ColumnParent() {Column_family = "BlogEntries"};
        var predicate = new SlicePredicate()
        {
            Slice_range = new SliceRange()
                          {
                              Start = new byte[0],
                              Finish = new byte[0],
                              Count = 10,
                              Reversed = false
                          }
        };

        var results = _client.get_range_slice(keyspace, columnParent, predicate, "", "", 5, ConsistencyLevel.ONE);

        foreach(var slice in results)
        {
            Console.WriteLine("Found Key: {0}", slice.Key);
            foreach(var resultColumn in slice.Columns)
            {
                var column = resultColumn.Column;
                Console.WriteLine("\tName: {0}, value: {1}",
                                  utf8Encoding.GetString(column.Name),
                                  utf8Encoding.GetString(column.Value));                        
            }
        }
    } 

该方法的第一行是我在哪里得到我的例外：

oprot_.WriteMessageBegin(new TMessage("get_count", TMessageType.Call, seqid_));

这里是异常：

Thrift.Transport.TTransportException：无法写入空的OutputStream 在Thrift.Transport.TStreamTransport.Write（字节[] buf中，的Int32断，的Int32 LEN） 在Thrift.Protocol.TBinaryProtocol.WriteI32（的Int32 I32） 在Thrift.Protocol.TBinaryProtocol.WriteMessageBegin（TMessage消息） 在Apache.Cassandra.Cassandra.Client.send_get_range_slice（字符串密钥空间，ColumnParent column_parent，SlicePredicate谓词，字符串start_key，字符串finish_key，的Int32 ROW_COUNT，ConsistencyLevel consistency_level）在Cassandra.cs：线341 在Apache.Cassandra.Cassandra.Client.get_range_slice（字符串密钥空间，ColumnParent column_parent，SlicePredicate谓词，字符串start_key，字符串finish_key，的Int32 ROW_COUNT，ConsistencyLevel consistency_level）在Cassandra.cs：线335 在CassandraDemo.Models.Test.GetAllBlogEntries（）在test.cs中：线212 在CassandraDemo.Tests.Models.TestTest.Test_GetAllBlogEntries_Success（）在TestTest.cs：管线42

任何想法？

Answer 1

您需要调用open（）上的传输。