5

Apache Avro を使用してデータをシリアライズしたいと考えています。クライアントは C++ で作成され、サーバーは Java で作成されています。

  1. 私のサーバーのJavaコードは次のようになります。

    Schema scm = new Schema.Parser().parse("....shcema String.....");
ByteArrayInputStream inputStream = new ByteArrayInputStream(record.array());
Decoder coder = new DecoderFactory().directBinaryDecoder(inputStream, null);
GenericDatumReader<GenericRecord> reDatumReader = new GenericDatumReader<GenericRecord>(scm);
try {
    GenericRecord result = (GenericRecord)reDatumReader.read(null, coder);
            //here! the result "name", "num_groups" is empty!
    System.out.println(result.get("name")+"   "+result.get("num_groups"));
} catch (IOException e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
}

  2. そして私のクライアントコード:

    std::string schemaDescript ="....shcema String.....";

std::stringstream rsStream(schemaDescript);
avro::ValidSchema rSchema;
avro::compileJsonSchema(rsStream, rSchema);
avro::EncoderPtr encoder = avro::binaryEncoder();
std::auto_ptr<avro::OutputStream> oStream = avro::memoryOutputStream();
encoder->init(*oStream);   
avro::GenericDatum rData(rSchema);
avro::GenericRecord sReord = rData.value<avro::GenericRecord>();
sReord.setFieldAt(0, avro::GenericDatum("i am nice"));
sReord.setFieldAt(1, avro::GenericDatum(1));
sReord.setFieldAt(2, avro::GenericDatum(12));
sReord.setFieldAt(3, avro::GenericDatum(13));

avro::GenericWriter gwriter(rSchema, encoder);
gwriter.write(rData);
oStream->flush();

std::auto_ptr<avro::InputStream> inSt = avro::memoryInputStream(*oStream);
avro::StreamReader instReader(*inSt);

size_t outputLen = oStream->byteCount();
uint8_t* theByteData = new uint8_t[outputLen];
instReader.hasMore();
instReader.readBytes(theByteData, outputLen);

をサーバーに送信するtheByteDataと、コードは機能しますが (例外はありません)、結果は空です。何が問題なのか教えてもらえますか?

そして、なぜ Java では key: で値を取得するのですかresult.get("name")? しかし、C++ では index: で値を取得しますrecord.fieldAt(0).value<string>()。文字列キーで値を取得できない場合、インデックスを文字列キーに一致させる方法は?

4

2 に答える 2