在斯卡拉

Question

我想在斯卡拉desrialize二進制消息反序列化二進制節儉消息：

val deserializer = new TDeserializer(new TBinaryProtocol.Factory()); 
    try { 
     val obj = deserializer.deserialize(new ClientError{}, input._2.toArray) 

哪裏ClientError是從節儉文件與守財奴產生的特質。問題是，deserialize（）期望TBase對象，但TBase是一個接口。我該怎麼做呢？我是否必須創建一個實現兩者的新類？ Thx任何幫助！

Answer 1

試試這個：

def decode(bytes: Array[Byte]): ClientError = { 
    val protocolFactory = new TBinaryProtocol.Factory 
    val buffer = new TMemoryInputTransport(bytes) 
    val proto = protocolFactory.getProtocol(buffer) 
    ClientError.decode(proto) 
}