如何解析 Envelope.Payload.Data 的 protobuf 数据？

Question

我正在使用 Hyperledger Fabric Java SDK 通过 txId 获取交易。返回对象包括交易信息。TransactionInfo txInfo = channel.queryTransactionByID(txId);Common.Envelope envelope = txInfo.getEnvelope();Common.Payload payload = Common.Payload.parseFrom(envelope.getPayload());该Payload消息包括标题和数据。我可以使用Common.Header.ChannelHeader和来解析标头Common.Header.SignatureHeader。Common.ChannelHeader channelHeader = Common.ChannelHeader.parseFrom(payload.getHeader().getChannelHeader());Common.SignatureHeader signatureHeader = Common.SignatureHeader.parseFrom(payload.getHeader().getSignatureHeader());问题是，我看不到任何消息类型来从中获取数据Payload。我的期望是，SomeMessage someMsg = SomeMessage.parseFrom(payload.getData());获取数据对象的理想方法是什么？

Answer 1

终于找到了一种将 QSCC 响应解析为 TxReadWriteSet 甚至 KVRWSet 的方法！！这是一个例子：

TransactionInfo txInfo = channel.queryTransactionByID(txId);

Common.Envelope envelope = txInfo.getEnvelope();

Common.Payload payload = Common.Payload.parseFrom(envelope.getPayload());

FabricTransaction.Transaction transaction = FabricTransaction.Transaction.parseFrom(payload.getData());

FabricTransaction.TransactionAction action = transaction.getActionsList().get(0); // 0 is a index

FabricTransaction.ChaincodeActionPayload chaincodeActionPayload = FabricTransaction.ChaincodeActionPayload.parseFrom(action.getPayload());

FabricProposalResponse.ProposalResponsePayload prp = FabricProposalResponse.ProposalResponsePayload.parseFrom(chaincodeActionPayload.getAction().getProposalResponsePayload());

FabricProposal.ChaincodeAction ca = FabricProposal.ChaincodeAction.parseFrom(prp.getExtension());

Rwset.TxReadWriteSet txrws = Rwset.TxReadWriteSet.parseFrom(ca.getResults());

TxReadWriteSetInfo txrwsInfo = new TxReadWriteSetInfo(txrws);

KvRwset.KVRWSet kvrwSet = txrwsInfo.getNsRwsetInfo(0).getRwset();

KvRwset.KVWrite kvWrite = kvrwSet.getWrites(0);

String writeVal = kvWrite.getValue().toStringUtf8();

Answer 2

从事务中获取请求数据时，我们遇到了类似的问题。

以下代码将有助于获取交易的交易请求数据

面料 SDK 版本：2.1.4

        // get transaction from transaction ID

        TransactionInfo txInfo = channel.queryTransactionByID(txId);

        // transaction is stored inside the envelope containing the payload and signature

        Common.Envelope envelope = txInfo.getEnvelope();

        // parse payload from the envelope

        Common.Payload payload = Common.Payload.parseFrom(envelope.getPayload());

        // payload contains Header and Data. We are parsing data to get the transaction

        TransactionPackage.Transaction transaction = TransactionPackage.Transaction.parseFrom(payload.getData());

        // get first action from the transaction action list. it contains input and other details

        TransactionPackage.TransactionAction action = transaction.getActionsList().get(0); // 0 is a index

        // chaincode action payload contains input parameters. So we are taking the action payload

        TransactionPackage.ChaincodeActionPayload chaincodeActionPayload = TransactionPackage.ChaincodeActionPayload.parseFrom(action.getPayload());

        // chaincode ProposalPayload contains Input and TransientMap. We are parsing actionPayload to proposalPayload

        ProposalPackage.ChaincodeProposalPayload prp = ProposalPackage.ChaincodeProposalPayload.parseFrom(chaincodeActionPayload.getChaincodeProposalPayload());

        // parse the input to chaincodeInvocationSpec so that we can unmarshal the input

        Chaincode.ChaincodeInvocationSpec chaincodeInvocationSpec = Chaincode.ChaincodeInvocationSpec.parseFrom(prp.getInput());

        // get the input and parse the arg list and get input arguments 

       chaincodeInvocationSpec.getChaincodeSpec().getInput().getArgsList().get(ChaincodeInput.ARGS_FIELD_NUMBER).toStringUtf8();

Answer 3

我找到了答案。

FabricTransaction.Transaction transaction =  FabricTransaction.Transaction.parseFrom(payload.getData());

在那之后，

FabricTransaction.TransactionAction action = transaction.getActionsList().get(index);

FabricTransaction.ChaincodeActionPayload chaincodeActionPayload = FabricTransaction.ChaincodeActionPayload.parseFrom(action.getPayload());

chaincodeActionPayload.getAction().getEndorsementsList().forEach(endorsement -> {

    // This is my current point

    ???? endorser = ????.parseFrom(endorsement.getEndorser());

});

如果我能找到更多，让我补充一下。欢迎大家补充评论。