FabricJavaSDKExamples

Fabric JAVA SDK测试样例

一、调用链码说明(不使用Fabric-CA模块)

1.1 测试代码结构说明

├── pom.xml
├── doc                                    # 运行结果图片
├── cc                                     # 使用Go实现的链码
├── src
│   ├── main
│   │   ├── java
│   │   │   └── ijarvis
│   │   │       └── intelliq
│   │   │           ├── FabricApp.java     # 初始化Fabric Client对象以及连接组织信息
│   │   │           ├── LedgerRecord.java  # 链码中数据结构Bean
│   │   │           └── SampleUser.java    # 抽象超级账本中用户信息(实际就是MSP下user文件夹中生成的用户身份文件)
│   │   └── resources
│   │       └── log4j.xml  
│   └── test
│       ├── java
│       │   └── ijarvis
│       │       └── intelliq
│       │           └── AppTest.java       # Junit测试代码文件
│       └── resources
│           ├── crypto-config              # 测试环境下所有证书以及MSP文件集合
│           │   ├── ordererOrganizations
│           │   │   └── example.com
│           │   └── peerOrganizations
│           │       ├── org1.example.com
│           │       └── org2.example.com
│           └── log4j.xml

由于调用链码调用初始化需要初始化fhclient等等一系列的对象，所以建议使用Junit运行代码。

1.2、核心代码说明

使用SDk调用链码主要的步骤是：

1、初始化HFClient
2、实例化已经实现接口User的类加载已有的证书文件以及连接用户的私钥文件
3、调用client.setUserContext(peer0org1);方法更新client的配置文件
4、通过client获取通道对象(channel)，客户端设置发起交易需要使用的Orderer以及Peer对象
5、通过channel对象设置调用链码的名称参数等等信息发起调用链码

package ijarvis.intelliq.Fabric;
// 省略相关的包导入
public class SampleUser implements User {
    private final String certFolder;
    private final String userName;
    public SampleUser(String certFolder, String userName) {
        this.certFolder = certFolder;
        this.userName = userName;
    }
    //省略相关Set和Get方法
    
    /**
    * 
    * 重要实现方法，不使用CA需要自己实现如何加载私钥以及证书信息
    */
    @Override
    public Enrollment getEnrollment() {
        return new Enrollment() {

            @Override
            public PrivateKey getKey() {
                try {
                    return loadPrivateKey(Paths.get(certFolder, "/keystore/ea2db84973c9c54436c47d7e10b9b63420f654ecd7c541fab14646e976294393_sk"));
                } catch (Exception e) {
                    return null;
                }
            }
            @Override
            public String getCert() {
                try {
                    return new String(Files.readAllBytes(Paths.get(certFolder, "/signcerts/Admin@org1.example.com-cert.pem")));
                } catch (Exception e) {
                    return "";
                }
            }
        };
    }
    
    //测试代码所以固定写死相关的MSPID
    @Override
    public String getMspId() {
        return "Org1MSP";
    }
    /***
     * 实现加载证书服务
     */
    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;
    }
}

1.3、其他说明

如果觉得所给测试用例代码不够明确，可以参考官方网站此处的代码示例本代码只是将官方代码进行简化方便做实验以及测试。

二、使用CA Server调用链码

与不通过CA模块调用的链码相比其实只差一个步骤，在不使用CA模块时构造SampleUser时我们要自己实现getEnrollment的方法，在该方法中需要我们自定义去加载私钥以及证书字节，但是有了CA模块后我们只需要在构建Sampleuser时调用

user1.setEnrollment(hfcaClient.enroll(user1.getName(), "admin"));

即可实现从CA中获取到私钥以及证书，发起ECer交易。详细的测试可以参见代码src/test/java/ijarvis/intelliq/FabricCA/FabricCATestUseCAServer.java

三、链码操作

本节主要介绍测试环境中链码的安装部署与实例化操作，希望通过该方法可以快速的验证测试链码环境中的问题

# 安装链码
Shell> peer chaincode install -n epointchaincodecommon   -p epointchaincodecommon -v 0.1
# 实例化链码操作
Shell> peer chaincode instantiate -o orderer.example.com:7050  -C $CHANNEL_NAME  -c '{"Args":["init"]}' -P "OR  ('Org1MSP.member','Org2MSP.member')" -n epointchaincodecommon -v 0.1
# 调用插入KV操作链码
Shell> peer chaincode invoke -o orderer.example.com:7050   -C $CHANNEL_NAME -n epointchaincodecommon -v 0.1 -c '{"Args":["addkv","liuwenru","刘文儒"]}'
# 调用更新KV操作链码
Shell> peer chaincode invoke -o orderer.example.com:7050   -C $CHANNEL_NAME -n epointchaincodecommon -v 0.1 -c '{"Args":["updatekv","liuwenru","刘美丽"]}'
# 调用查询KV操作链码
Shell> peer chaincode invoke -o orderer.example.com:7050   -C $CHANNEL_NAME -n epointchaincodecommon -v 0.1 -c '{"Args":["query","liuwenru"]}'
# 根绝给定的Key查询该账本中所有的历史操作
Shell> peer chaincode invoke -o orderer.example.com:7050   -C $CHANNEL_NAME -n epointchaincodecommon -v 0.1 -c '{"Args":["queryhistory","liuwenru"]}'
# 调用删除链码操作，注意，此删除操作只会删除账本中当前的值，对于账本中的历史值是不会删除的
Shell> peer chaincode invoke -o orderer.example.com:7050   -C $CHANNEL_NAME -n epointchaincodecommon -v 0.1 -c '{"Args":["delkv","liuwenru"]}'

四、调用结果展示

Guotian-Dev/FabricJavaSDKExamples

ErrorLooks like something went wrong!

About

Resources

Uh oh!

Stars

Watchers

Forks

Releases

Packages 0

Languages

Error
Looks like something went wrong!

Packages