方法1"/>
Fiscobcos发起交易方法1
Fiscobcos发起交易方法1–智能合约生成Java类调用
环境: solidity 0.8.0, fisco节点 V3.2, java SDK V3.2, WeBASE V3.0.2
1 智能合约编译成java类
编写一套溯源智能合约,在Remix上通过验证。搬移到console/contracts/trace进行编译生成java文件。
contract2java.sh solidity -h 查看用法
-s 指定编译目录或源文件,
-o 指定输出目录
-p 指定包路径
编译好的java类中自带abi、bin参数, 因此不再需要单独的abi、bin文件。
root@tom:/fiscoV3.2/console/contracts/trace# ls
BatchCodeFactory.sol IBatchCode.sol IUserAuthorization.sol TraceCode.sol UserAuthorizationFactory.sol
BatchCode.sol ITraceCode.sol Merchants.sol TraceDataFactory.sol UserAuthorization.sol
Goods.sol ITraceData.sol TraceCodeFactory.sol TraceData.sol Users.sol
root@tom:/fiscoV3.2/console/contracts/trace#cd ../..
root@tom:/fiscoV3.2/console# bash contract2java.sh solidity -s contracts/trace/ -o ./sdk -p org.fisco.bcos.trace.contract*** Compile solidity Users.sol***
INFO: Compile for solidity Users.sol success.
*** Convert solidity to java for Users.sol success ****** Compile solidity Merchants.sol***
INFO: Compile for solidity Merchants.sol success.
*** Convert solidity to java for Merchants.sol success ****** Compile solidity Goods.sol***
INFO: Compile for solidity Goods.sol success.
*** Convert solidity to java for Goods.sol success ****** Compile solidity BatchCodeFactory.sol***
INFO: Compile for solidity BatchCodeFactory.sol success.
*** Convert solidity to java for BatchCodeFactory.sol success ****** Compile solidity UserAuthorizationFactory.sol***
INFO: Compile for solidity UserAuthorizationFactory.sol success.
*** Convert solidity to java for UserAuthorizationFactory.sol success ****** Compile solidity ITraceCode.sol***
INFO: Compile for solidity ITraceCode.sol success.
*** Convert solidity to java for ITraceCode.sol success ****** Compile solidity TraceDataFactory.sol***
INFO: Compile for solidity TraceDataFactory.sol success.
*** Convert solidity to java for TraceDataFactory.sol success ****** Compile solidity ITraceData.sol***
INFO: Compile for solidity ITraceData.sol success.
*** Convert solidity to java for ITraceData.sol success ****** Compile solidity TraceCodeFactory.sol***
INFO: Compile for solidity TraceCodeFactory.sol success.
*** Convert solidity to java for TraceCodeFactory.sol success ****** Compile solidity IBatchCode.sol***
INFO: Compile for solidity IBatchCode.sol success.
*** Convert solidity to java for IBatchCode.sol success ****** Compile solidity TraceData.sol***
INFO: Compile for solidity TraceData.sol success.
*** Convert solidity to java for TraceData.sol success ****** Compile solidity BatchCode.sol***
INFO: Compile for solidity BatchCode.sol success.
*** Convert solidity to java for BatchCode.sol success ****** Compile solidity UserAuthorization.sol***
INFO: Compile for solidity UserAuthorization.sol success.
*** Convert solidity to java for UserAuthorization.sol success ****** Compile solidity TraceCode.sol***
INFO: Compile for solidity TraceCode.sol success.
*** Convert solidity to java for TraceCode.sol success ****** Compile solidity IUserAuthorization.sol***
INFO: Compile for solidity IUserAuthorization.sol success.
*** Convert solidity to java for IUserAuthorization.sol success ***root@tom:/fiscoV3.2/console#
root@tom:/fiscoV3.2/console# cd sdk
root@tom:/fiscoV3.2/console/sdk# ls
org#java类文件
root@tom:/fiscoV3.2/console/sdk# cd org/fisco/bcos/trace/contract/
root@tom:/fiscoV3.2/console/sdk/org/fisco/bcos/trace/contract# ls
BatchCodeFactory.java IBatchCode.java IUserAuthorization.java TraceCode.java UserAuthorizationFactory.java
BatchCode.java ITraceCode.java Merchants.java TraceDataFactory.java UserAuthorization.java
Goods.java ITraceData.java TraceCodeFactory.java TraceData.java Users.java
root@tom:/fiscoV3.2/console/sdk/org/fisco/bcos/trace/contract##生成的abi、bin文件
root@tom:/fiscoV3.2/console/contracts/sdk/abi# ls
Asset.abi Crypto.abi HelloWorld.abi KVTableTest.abi TableTest.abi UserAuthorization.abi
BatchCode.abi DelegateCallTest.abi IBatchCode.abi Merchants.abi TraceCode.abi UserAuthorizationFactory.abi
BatchCodeFactory.abi EntryWrapper.abi ITraceCode.abi ShaTest.abi TraceCodeFactory.abi Users.abi
Cast.abi EventSubDemo.abi ITraceData.abi sm TraceData.abi
CastTest.abi Goods.abi IUserAuthorization.abi Table.abi TraceDataFactory.abi/fiscoV3.2/console/contracts/sdk/bin#
2 java类安装使用
在java工程中创建好工作目录, 分别拷贝到对应目录。
src/main/java/org/fisco/bcos/trace/contract
resources/contract/abi --可省略
resources/contract/bin --可省略
3 对于接口文件中的结构体类型修正
在智能合约接口类中定义了一个结构体,通过合约继承方式在合约中使用。这种写法编译出的java文件需要修正一下:
IBatchCode.sol
// SPDX-License-Identifier: MITpragma solidity ^0.8.0;interface IBatchCode {struct BatchCodeData {string batchCode; //批次码int status; //current status, default=0}function addOne(string memory batchCode, int status) external; function getLength() external view returns(uint);function getAll() external view returns(BatchCodeData[] memory);function getOne(uint index) external view returns(BatchCodeData memory);function getData(uint page, uint rows) external view returns(BatchCodeData[] memory);
}
编译出来的是BatchCode.java文件,内部结构体定义如下,需要我们手动删除下面的黄色划线内容“IBatchCode."。
同时,IBatchCode.java文件无需使用,我们不用import。
public static class IBatchCode.BatchCodeData extends DynamicStruct {public String batchCode;public BigInteger status;public IBatchCode.BatchCodeData(Utf8String batchCode, Int256 status) {super(batchCode,status);this.batchCode = batchCode.getValue();this.status = status.getValue();}public IBatchCode.BatchCodeData(String batchCode, BigInteger status) {super(new Utf8String(batchCode),new Int256(status));this.batchCode = batchCode;this.status = status;}
}
4 加载用户私钥
发起交易需要指定用户私钥,可以从webase-web平台–“私钥管理”导出用户私钥pem文件,再添加到代码工程account目录中:
[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-RVhJnQZc-1682324423616)(./img/1-4-1-Image.png)]
加载用户私钥文件:
public void loadUserAccount(String filePath){// 通过client获取CryptoSuite对象CryptoSuite cryptoSuite = client.getCryptoSuite();// 加载pem账户文件cryptoSuite.loadAccount("pem", filePath, null);cryptoKeyPair = cryptoSuite.getCryptoKeyPair();// 获取账户地址String accountAddress = cryptoKeyPair.getAddress();System.out.println("accountAddress is "+accountAddress);
}
5 构造合约类对象
可以使用deploy或者load函数初始化合约对象,两者使用场景不同,前者适用于初次部署合约,后者在合约已经部署并且已知合约地址时使用。
// 部署合约
Asset asset = Asset.deploy(client, cryptoKeyPair);
// 加载合约地址
Asset asset = Asset.load(contractAddress, client, cryptoKeyPair);
6 发起合约交易,读取收据
//用owner添加管理员地址
public void addAdmin() throws Exception {loadUserAccount("account/owner_key_0x700f37e5c89d9a91922dd5fe77ddc9eec9d23966.pem");contractAddress = "0x4c02c975a36137d3d4b68484aadbce89414d73a0";BatchCodeFactory batchCodeFactory = BatchCodeFactory.load(contractAddress, client, cryptoKeyPair);TransactionReceipt receipt = batchCodeFactory.addAdmin("0xa0b0d1cd6a783c0cd2f06613de0795356f4bb858");System.out.println("Receipt = "+ receipt);
}
7 读取合约数据
通过合约对象读取数据,是对节点发起的查询动作,不会在链上产生一笔交易。
//读取批次码合约地址
public String getBatchCode(String goodsId) throws Exception {//client加载owner私钥loadUserAccount("account/admin_key_0xa0b0d1cd6a783c0cd2f06613de0795356f4bb858.pem");contractAddress = "0x4c02c975a36137d3d4b68484aadbce89414d73a0";BatchCodeFactory batchCodeFactory = BatchCodeFactory.load(contractAddress, client, cryptoKeyPair);String batchCode = batchCodeFactory.getBatchCode(goodsId);System.out.println("batchCode = "+ batchCode);return batchCode;
}
8 填写各种入参类型
一般的输入参数int, uint都被转换成BigInter类型。
bool、string都支持。
9 返回结构体类型
这个版本是测试成功的,可以接收到完整的结构体对象
//读取结构体
public IBatchCode.BatchCodeData getOne(String goodsId, int index) throws Exception {//client加载owner私钥loadUserAccount("account/admin_key_0xa0b0d1cd6a783c0cd2f06613de0795356f4bb858.pem");contractAddress = "0x4c02c975a36137d3d4b68484aadbce89414d73a0";BatchCodeFactory batchCodeFactory = BatchCodeFactory.load(contractAddress, client, cryptoKeyPair);IBatchCode.BatchCodeData ret = batchCodeFactory.getOne(goodsId, BigInteger.valueOf(index));System.out.println("ret = "+ JSON.toJSONString(ret));return null;
}
struct BatchCodeData {string batchCode; //批次码uint status; //current status, default=0
}
ret = {"batchCode":"2023001","componentType":"org.fisco.bcos.sdk.v3.codec.datatypes.Type","componentTypes":[{"typeAsString":"string","value":"2023001"},{"bitSize":256,"typeAsString":"int256","value":0}],"fixed":false,"status":0,"typeAsString":"(string,int256)","value":[{"$ref":"$ponentTypes[0]"},{"$ref":"$ponentTypes[1]"}]}
10 异步调用
查询数据类函数:
在java类代码中都是使用executeCallWithSingleValueReturn,这是执行call调用并返回结果,是一个同步调用方法,立即得到返回结果。
public IBatchCode.BatchCodeData getOne(String goodsId, BigInteger index) throwsContractException {final Function function = new Function(FUNC_GETONE,Arrays.<Type>asList(new Utf8String(goodsId),new Uint256(index)),Arrays.<TypeReference<?>>asList(new TypeReference<IBatchCode.BatchCodeData>() {}));return executeCallWithSingleValueReturn(function, IBatchCode.BatchCodeData.class);
}
发起异步交易
流程:首先发起交易,得到交易hash。然后通过回调函数对象等待链上交易返回值。
参考文章:.html
4.1 定义回调类
#回调对象类标准写法:
class TransactionCallbackMock extends TransactionCallback {private TransactionReceipt transactionReceipt;private ReentrantLock reentrantLock = new ReentrantLock();private Condition condition;public TransactionCallbackMock() {condition = reentrantLock.newCondition();}public TransactionReceipt getResult() {try {reentrantLock.lock();while (transactionReceipt == null) {condition.awaitUninterruptibly();}return transactionReceipt;} finally {reentrantLock.unlock();}}@Overridepublic void onResponse(TransactionReceipt transactionReceipt) {try {reentrantLock.lock();this.transactionReceipt = transactionReceipt;condition.signal();} finally {reentrantLock.unlock();}}
}
发起异步调用:
public void addOneBatchCodeAsync(String goodsId, String batchCode, int status) throws Exception {//client加载owner私钥loadUserAccount("account/admin_key_0xa0b0d1cd6a783c0cd2f06613de0795356f4bb858.pem");contractAddress = "0x4c02c975a36137d3d4b68484aadbce89414d73a0";BatchCodeFactory batchCodeFactory = BatchCodeFactory.load(contractAddress, client, cryptoKeyPair);TransactionCallbackMock callbackMock = new TransactionCallbackMock();String ret = batchCodeFactory.addOneBatchCode(goodsId, batchCode, BigInteger.valueOf(status), callbackMock);System.out.println("ret = "+ ret);Thread.sleep(2000);// 异步等待获取回执TransactionReceipt receipt = callbackMock.getResult();System.out.println("receipt = "+ receipt);
}
上面代码中的ret 就是交易hash,等待一段时间或者在其他线程中就可以读取交易回执。
Code, BigInteger.valueOf(status), callbackMock);System.out.println("ret = "+ ret);Thread.sleep(2000);// 异步等待获取回执TransactionReceipt receipt = callbackMock.getResult();System.out.println("receipt = "+ receipt);
}
更多推荐
Fiscobcos发起交易方法1
发布评论