Hyperledger Java SDK 工作示例

Question

我目前正在研究 Hyperledger Fabric，我无法使用 Java SDK（这里谈论的是 1.0.0-beta）。是否有从连接到 Fabric 节点、进行查询等开始的工作示例？到目前为止，我通过大量谷歌搜索发现的都是 "let's-write-some-chaincode" 个示例。

Answer 1

你可以看看下面的

- Java SDK for Hyperledger Fabric 2.2。在此，文件夹“fabric-sdk-java/src/test/java/org/hyperledger/fabric/sdkintegration/”==> End2endAndBackAgainIT.java、End2endIT.java 中给出了两个文件。这可以提供帮助。

演示请参考 Youtube 频道视频：End to end Demo
对于具有 E2E 演示的一切（网络和加密）设置的结构网络：E2E Cli Setup

2020 年 6 月 7 日更新

Java SDK for Hyperledger Fabric 2.2 上方的 link 是用于与 Hyperledger Fabric 交互的低级 SDK。

如果您的目的是构建 Hyperledger Fabric 区块链客户端应用程序，那么建议使用 Hyperledger Fabric Gateway SDK for Java, a high level API. Its very simple to use, just refer to the code snippet from [2.2]. please refer to the link how to use

// code snippet from [2.2]
class Sample { 
public static void main(String[] args) throws IOException 
{ 
    // Load an existing wallet holding identities used to access the network. 
    Path walletDirectory = Paths.get("wallet"); 
    Wallet wallet = Wallets.newFileSystemWallet(walletDirectory); 
    // Path to a common connection profile describing the network. 
    Path networkConfigFile = Paths.get("connection.json"); 
    // Configure the gateway connection used to access the network.
    Gateway.Builder builder = Gateway.createBuilder() .identity(wallet, "user1").networkConfig(networkConfigFile); 

    // Create a gateway connection 
    try (Gateway gateway = builder.connect()){ 
        // Obtain a smart contract deployed on the network. 
        Network network = gateway.getNetwork("mychannel"); 
        Contract contract = network.getContract("fabcar"); 
        // Submit transactions that store state to the ledger. 
        byte[] createCarResult = contract.createTransaction("createCar").submit("CAR10", "VW", "Polo", "Grey","Mary"); 
        System.out.println(new String(createCarResult, StandardCharsets.UTF_8)); 
        // Evaluate transactions that query state from the ledger. 
        byte[] queryAllCarsResult = contract.evaluateTransaction("queryAllCars");
        System.out.println(new String(queryAllCarsResult, StandardCharsets.UTF_8)); 
    } 
    catch (ContractException | TimeoutException | InterruptedException e) { 
        e.printStackTrace(); 
    } 
}

}

API 两个 1.4 and 2.2 的文档可用。

Answer 2

这是一个示例，实现了 fabcar 的一些功能（query.js 和 invoke.js - 仅由一辆车查询并更改所有者）

我在 Windows 上使用了 Java8。如果您使用另一个 OS，请相应地更新路径。

我没有使用 json 的实现来避免额外的库（需要稍微处理证书 - 见下文）。

您将需要 fabcar 示例和运行。并且（因为 'no json'）：

将私钥（示例中的 cd96d5260ad4757551ed4a5a991e62130f8008a0bf996e4e4b84cd097a747fec-priv）放入 c:\tmp\cert\PeerAdm.priv
将 PeerAdmin 文件中的证书（json 的 "certificate" 的值，'\n' 替换为换行符）到 c:\tmp\cert\PeerAdm.cert

代码(fabrictest/fabcar/Program.java):

package fabrictest.fabcar;

import java.io.BufferedReader;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.nio.file.Files;
import java.nio.file.Path;
import java.nio.file.Paths;
import java.security.GeneralSecurityException;
import java.security.KeyFactory;
import java.security.PrivateKey;
import java.security.spec.PKCS8EncodedKeySpec;
import java.util.Collection;
import java.util.Date;
import java.util.HashSet;
import java.util.Random;
import java.util.Set;

import javax.xml.bind.DatatypeConverter;

import org.hyperledger.fabric.sdk.ChaincodeID;
import org.hyperledger.fabric.sdk.Channel;
import org.hyperledger.fabric.sdk.Enrollment;
import org.hyperledger.fabric.sdk.HFClient;
import org.hyperledger.fabric.sdk.ProposalResponse;
import org.hyperledger.fabric.sdk.QueryByChaincodeRequest;
import org.hyperledger.fabric.sdk.TransactionProposalRequest;
import org.hyperledger.fabric.sdk.User;
import org.hyperledger.fabric.sdk.security.CryptoSuite;

public class Program {

    private static HFClient client = null;

    public static void main(String[] args) throws Throwable {
        /*
         * wallet_path: path.join(__dirname, './creds'), user_id: 'PeerAdmin',
         * channel_id: 'mychannel', chaincode_id: 'fabcar', network_url:
         * 'grpc://192.168.99.100:7051', orderer: grpc://192.168.99.100:7050
         * 
         */

        // just new objects, without any payload inside
        client = HFClient.createNewInstance();
        CryptoSuite cs = CryptoSuite.Factory.getCryptoSuite();
        client.setCryptoSuite(cs);

        // We implement User interface below in code
        // folder c:\tmp\creds should contain PeerAdmin.cert (extracted from HF's fabcar
        // example's PeerAdmin json file)
        // and PeerAdmin.priv (copy from
        // cd96d5260ad4757551ed4a5a991e62130f8008a0bf996e4e4b84cd097a747fec-priv)
        User user = new SampleUser("c:\tmp\creds", "PeerAdmin");
        // "Log in"
        client.setUserContext(user);

        // Instantiate channel
        Channel channel = client.newChannel("mychannel");
        channel.addPeer(client.newPeer("peer", "grpc://192.168.99.100:7051"));
        // It always wants orderer, otherwise even query does not work
        channel.addOrderer(client.newOrderer("orderer", "grpc://192.168.99.100:7050"));
        channel.initialize();

        // below is querying and setting new owner

        String newOwner = "New Owner #" + new Random(new Date().getTime()).nextInt(999);
        System.out.println("New owner is '" + newOwner + "'\n");

        queryFabcar(channel, "CAR1");
        updateCarOwner(channel, "CAR1", newOwner, false);

        System.out.println("after request for transaction without commit");
        queryFabcar(channel, "CAR1");
        updateCarOwner(channel, "CAR1", newOwner, true);

        System.out.println("after request for transaction WITH commit");
        queryFabcar(channel, "CAR1");

        System.out.println("Sleeping 5s");
        Thread.sleep(5000); // 5secs
        queryFabcar(channel, "CAR1");
        System.out.println("all done");
    }

    private static void queryFabcar(Channel channel, String key) throws Exception {
        QueryByChaincodeRequest req = client.newQueryProposalRequest();
        ChaincodeID cid = ChaincodeID.newBuilder().setName("fabcar").build();
        req.setChaincodeID(cid);
        req.setFcn("queryCar");
        req.setArgs(new String[] { key });
        System.out.println("Querying for " + key);
        Collection<ProposalResponse> resps = channel.queryByChaincode(req);
        for (ProposalResponse resp : resps) {
            String payload = new String(resp.getChaincodeActionResponsePayload());
            System.out.println("response: " + payload);
        }

    }

    private static void updateCarOwner(Channel channel, String key, String newOwner, Boolean doCommit)
            throws Exception {
        TransactionProposalRequest req = client.newTransactionProposalRequest();
        ChaincodeID cid = ChaincodeID.newBuilder().setName("fabcar").build();
        req.setChaincodeID(cid);
        req.setFcn("changeCarOwner");
        req.setArgs(new String[] { key, newOwner });
        System.out.println("Executing for " + key);
        Collection<ProposalResponse> resps = channel.sendTransactionProposal(req);
        if (doCommit) {
            channel.sendTransaction(resps);
        }
    }

}

/***
 * Implementation of user. main business logic (as for fabcar example) is in
 * getEnrollment - get user's private key and cert
 * 
 */
class SampleUser implements User {
    private final String certFolder;
    private final String userName;

    public SampleUser(String certFolder, String userName) {
        this.certFolder = certFolder;
        this.userName = userName;
    }

    @Override
    public String getName() {
        return userName;
    }

    @Override
    public Set<String> getRoles() {
        return new HashSet<String>();
    }

    @Override
    public String getAccount() {
        return "";
    }

    @Override
    public String getAffiliation() {
        return "";
    }

    @Override
    public Enrollment getEnrollment() {
        return new Enrollment() {

            @Override
            public PrivateKey getKey() {
                try {
                    return loadPrivateKey(Paths.get(certFolder, userName + ".priv"));
                } catch (Exception e) {
                    return null;
                }
            }

            @Override
            public String getCert() {
                try {
                    return new String(Files.readAllBytes(Paths.get(certFolder, userName + ".cert")));
                } catch (Exception e) {
                    return "";
                }
            }

        };
    }

    @Override
    public String getMspId() {
        return "Org1MSP";
    }
    /***
     * loading private key from .pem-formatted file, ECDSA algorithm
     * (from some example on Whosebug, slightly changed)
     * @param fileName - file with the key
     * @return Private Key usable
     * @throws IOException
     * @throws GeneralSecurityException
     */
    public static PrivateKey loadPrivateKey(Path fileName) throws IOException, GeneralSecurityException {
        PrivateKey key = null;
        InputStream is = null;
        try {
            is = new FileInputStream(fileName.toString());
            BufferedReader br = new BufferedReader(new InputStreamReader(is));
            StringBuilder builder = new StringBuilder();
            boolean inKey = false;
            for (String line = br.readLine(); line != null; line = br.readLine()) {
                if (!inKey) {
                    if (line.startsWith("-----BEGIN ") && line.endsWith(" PRIVATE KEY-----")) {
                        inKey = true;
                    }
                    continue;
                } else {
                    if (line.startsWith("-----END ") && line.endsWith(" PRIVATE KEY-----")) {
                        inKey = false;
                        break;
                    }
                    builder.append(line);
                }
            }
            //
            byte[] encoded = DatatypeConverter.parseBase64Binary(builder.toString());
            PKCS8EncodedKeySpec keySpec = new PKCS8EncodedKeySpec(encoded);
            KeyFactory kf = KeyFactory.getInstance("ECDSA");
            key = kf.generatePrivate(keySpec);
        } finally {
            is.close();
        }
        return key;
    }
}

Answer 3

我发现这个 Java 示例比提供的链接更有用。开箱即用，它为您提供端到端测试，不会膨胀。以简单的方式 Java.

向您展示如何在没有 CLI 的情况下完成所有操作

https://github.com/venugopv/FabricJavaSDKSample

Hyperledger Java SDK 工作示例

Hyperledger Java SDK working example

java

hyperledger-fabric