如何使用fabric-sdk-go在Hyperledger Fabric中异步或批量发送交易

如何解决如何使用fabric-sdk-go在Hyperledger Fabric中异步或批量发送交易

我想在fabric chaincode上做很多txs，如何在async或batch中调用它？
虽然我只发现 channelClient.Execute channelClient.Query 方法，它一个一个发送 txs 并等待 tx 在块中提交。

解决方法

在单个客户端中，在代码中，事务似乎是一项一项提交的，但如果您从广义上查看网络拓扑，则并非如此。

我会根据面料的交易流程进行说明。

1. 多个客户端同时向多个对等方请求背书，并返回背书结果。
2. 背书交易，即背书同时传递给orderer，orderer确定交易顺序，进行区块打包，提交给peer。
3. 换句话说，交易被收集在排序节点中并存储在区块中。事实上，交易包含在块体中。

• 通过增加块的批处理时间可以很容易地观察到这个过程。
• BatchTimeout 可以在 Orderer 项下定义为 configtx.yaml 文件中通道的设置值。 fabric/sampleconfig/configtx.yaml

---

如果您的问题是一次从单个客户端请求多个事务，您可以通过 javascript 中的异步请求轻松实现如下。 代码部分修改了 fabric-samples/fabcar/invoke.js。

使用Promise.all()

/*
 * Copyright IBM Corp. All Rights Reserved.
 *
 * SPDX-License-Identifier: Apache-2.0
 */

'use strict';

const { Gateway,Wallets } = require('fabric-network');
const fs = require('fs');
const path = require('path');

async function main(tx_params) {
    try {
        // load the network configuration
        const ccpPath = path.resolve(__dirname,'..','test-network','organizations','peerOrganizations','org1.example.com','connection-org1.json');
        let ccp = JSON.parse(fs.readFileSync(ccpPath,'utf8'));

        // Create a new file system based wallet for managing identities.
        const walletPath = path.join(process.cwd(),'wallet');
        const wallet = await Wallets.newFileSystemWallet(walletPath);
        console.log(`Wallet path: ${walletPath}`);

        // Check to see if we've already enrolled the user.
        const identity = await wallet.get('appUser');
        if (!identity) {
            console.log('An identity for the user "appUser" does not exist in the wallet');
            console.log('Run the registerUser.js application before retrying');
            return;
        }

        // Create a new gateway for connecting to our peer node.
        const gateway = new Gateway();
        await gateway.connect(ccp,{ wallet,identity: 'appUser',discovery: { enabled: true,asLocalhost: true } });

        // Get the network (channel) our contract is deployed to.
        const network = await gateway.getNetwork('mychannel');

        // Get the contract from the network.
        const contract = network.getContract('fabcar');

        // Submit the specified transaction.
        // createCar transaction - requires 5 argument,ex: ('createCar','CAR12','Honda','Accord','Black','Tom')
        // changeCarOwner transaction - requires 2 args,ex: ('changeCarOwner','Dave')
        await contract.submitTransaction(...tx_params);

        console.log(tx_params + ' Transaction has been submitted');

        // Disconnect from the gateway.
        await gateway.disconnect();

    } catch (error) {
        console.error(`Failed to submit transaction: ${error}`);
        process.exit(1);
    }
}

const tx1_params = ['createCar','Tom'];
const tx2_params = ['createCar','CAR13','Hyundai','Genesis','Gray','Myeongkil'];
const tx3_params = ['createCar','CAR14','Porsche','Macan','Blue','Dave'];

main(tx1_params);
main(tx2_params);
main(tx3_params);

• 结果：标准输出

Wallet path: /Users/kmk/Project/src/github.com/hyperledger/fabric-samples/fabcar/javascript/wallet
Wallet path: /Users/kmk/Project/src/github.com/hyperledger/fabric-samples/fabcar/javascript/wallet
Wallet path: /Users/kmk/Project/src/github.com/hyperledger/fabric-samples/fabcar/javascript/wallet
createCar,CAR13,Hyundai,Genesis,Gray,Myeongkil Transaction has been submitted
createCar,CAR12,Honda,Accord,Black,Tom Transaction has been submitted
createCar,CAR14,Porsche,Macan,Blue,Dave Transaction has been submitted

• 订购者日志

# 3 endorsments
# -> into 1 block
2020-12-30 02:15:08.948 UTC [comm.grpc.server] 1 -> INFO 096 streaming call completed grpc.service=orderer.AtomicBroadcast grpc.method=Broadcast grpc.peer_address=172.30.0.1:49302 grpc.peer_subject="CN=fabric-common" grpc.code=OK grpc.call_duration=7.792537ms
2020-12-30 02:15:08.953 UTC [comm.grpc.server] 1 -> INFO 097 streaming call completed grpc.service=orderer.AtomicBroadcast grpc.method=Broadcast grpc.peer_address=172.30.0.1:49304 grpc.peer_subject="CN=fabric-common" grpc.code=OK grpc.call_duration=6.326148ms
2020-12-30 02:15:08.967 UTC [comm.grpc.server] 1 -> INFO 098 streaming call completed grpc.service=orderer.AtomicBroadcast grpc.method=Broadcast grpc.peer_address=172.30.0.1:49306 grpc.peer_subject="CN=fabric-common" grpc.code=OK grpc.call_duration=2.909602ms
2020-12-30 02:15:10.943 UTC [orderer.consensus.etcdraft] propose -> INFO 099 Created block [20],there are 0 blocks in flight channel=mychannel node=1
2020-12-30 02:15:10.946 UTC [orderer.consensus.etcdraft] writeBlock -> INFO 09a Writing block [20] (Raft index: 22) to ledger channel=mychannel node=1