【ETH钱包开发03】交易（Transaction）
在之前的文章中，讲解了创建、导出、导入钱包。
【ETH钱包开发01】创建、导出钱包
【ETH钱包开发02】导入钱包
本文主要讲解以太坊转账相关的一些知识。交易分为ETH转账和ERC-20 Token转账，本篇先讲一下ETH转账。
发起交易的2种方式
1、解锁账户发起交易。钱包keyStore文件保存在geth节点上，用户发起交易需要解锁账户，适用于中心化的交易所。
2、钱包文件离线签名发起交易。钱包keyStore文件保存在本地，用户使用密码+keystore的方式做离线交易签名来发起交易，适用于dapp，比如钱包。
本文主要讲一下第二种方式，也就是钱包离线签名转账的方式。
钱包文件签名的方式发起交易
交易流程
1、通过keystore加载转账所需的凭证Credentials
2、创建一笔交易RawTransaction
3、使用Credentials对象对交易签名
4、发起交易
/**
* 发起一笔交易（自定义参数）
*
* @param from 发起人钱包地址
* @param to 转入的钱包地址
* @param value 转账金额，单位是wei
* @param privateKey 钱包私钥
* @param gasPrice 转账费用
* @param gasLimit
* @param data 备注的信息
* @throws IOException
* @throws CipherException
* @throws ExecutionException
* @throws InterruptedException
*/
public EthSendTransaction transfer(String from,
String to,
BigInteger value,
String privateKey,
BigInteger gasPrice,
BigInteger gasLimit,
String data) throws IOException, CipherException, ExecutionException, InterruptedException {
//加载转账所需的凭证，用私钥
Credentials credentials = Credentials.create(privateKey);
//获取nonce，交易笔数
BigInteger nonce = getNonce(from);
//创建RawTransaction交易对象
RawTransaction rawTransaction = RawTransaction.createEtherTransaction(nonce, gasPrice, gasLimit, to, value);
//签名Transaction，这里要对交易做签名
byte[] signMessage = TransactionEncoder.signMessage(rawTransaction, credentials);
String hexValue = Numeric.toHexString(signMessage);
//发送交易
EthSendTransaction ethSendTransaction = web3j.ethSendRawTransaction(hexValue).sendAsync().get();
return ethSendTransaction;
}
/**
* 获取nonce，交易笔数
*
* @param from
* @return
* @throws ExecutionException
* @throws InterruptedException
*/
private BigInteger getNonce(String from) throws ExecutionException, InterruptedException {
EthGetTransactionCount transactionCount = web3j.ethGetTransactionCount(from, DefaultBlockParameterName.LATEST).sendAsync().get();
BigInteger nonce = transactionCount.getTransactionCount();
Log.i(TAG, "transfer nonce : " + nonce);
return nonce;
}
注意以下几点：
1、Credentials
这里，我是通过获取私钥的方式来加载Credentials
//加载转账所需的凭证，用私钥
Credentials credentials = Credentials.create(privateKey);
还有另外一种方式，通过密码+钱包文件keystore方式来加载Credentials
ECKeyPair ecKeyPair = LWallet.decrypt(password, walletFile);
Credentials credentials = Credentials.create(ecKeyPair);
2、nonce
nonce是指发起交易的账户下的交易笔数，每一个账户nonce都是从0开始，当nonce为0的交易处理完之后，才会处理nonce为1的交易，并依次加1的交易才会被处理。
可以通过eth_gettransactioncount 获取nonce
3、gasPrice和gasLimit
交易手续费由gasPrice 和gasLimit来决定，实际花费的交易手续费是gasUsed * gasPrice。所有这两个值你可以自定义，也可以使用系统参数获取当前两个值
关于gas，你可以参考我之前的一篇文章。
以太坊（ETH）GAS详解
gasPrice和gasLimit影响的是转账的速度，如果gas过低，矿工会最后才打包你的交易。在app中，通常给定一个默认值，并且允许用户自己选择手续费。
如果不需要自定义的话，还有一种方式来获取。获取以太坊网络最新一笔交易的gasPrice,转账的话，gasLimit一般设置为21000就可以了。
/**
* 获取当前以太坊网络中最近一笔交易的gasPrice
*/
public BigInteger requestCurrentGasPrice() throws Exception {
EthGasPrice ethGasPrice = web3j.ethGasPrice().sendAsync().get();
return ethGasPrice.getGasPrice();
}
Web3j还提供另外一种简单的方式来转账以太币,这种方式的好处是不需要管理nonce，不需要设置gasPrice和gasLimit，会自动获取最新一笔交易的gasPrice，gasLimit 为21000（转账一般设置成这个值就够用了）。
/**
* 发起一笔交易
* 使用以太钱包文件发送以太币给其他人，不能设置nonce：（推荐）
*
* @param privateKey
*/
public String transfer(String toAddress, BigDecimal value, String privateKey) throws Exception {
//转账者私钥
Credentials credentials = Credentials.create(privateKey);
TransactionReceipt transactionReceipt = Transfer.sendFunds(
web3j, credentials, toAddress,
value, Convert.Unit.ETHER).sendAsync().get();
String transactionHash = transactionReceipt.getTransactionHash();
Log.i(TAG, "transfer: " + transactionHash);
return transactionHash;
}
如何验证交易是否成功？
这个问题，我想是很多朋友所关心的吧。但是到目前为止，我还没有看到有讲解这方面的博客。
之前问过一些朋友，他们说可以通过区块号、区块哈希来判断，也可以通过Receipt日志来判断。但是经过我的一番尝试，只有BlockHash是可行的，在web3j中根据blocknumber和transactionReceipt都会报空指针异常。
原因大致是这样的：在发起一笔交易之后，会返回txHash，然后我们可以根据这个txHash去查询这笔交易相关的信息。但是刚发起交易的时候，由于手续费问题或者以太网络拥堵问题，会导致你的这笔交易还没有被矿工打包进区块，因此一开始是查不到的，通常需要几十秒甚至更长的时间才能获取到结果。我目前的解决方案是轮询的去刷BlockHash，一开始的时候BlockHash的值为0x00000000000，等到打包成功的时候就不再是0了。
这里我使用的是rxjava的方式去轮询刷的，5s刷新一次。
/**
* 开启轮询
* 根据txhash查询交易是否被打包进区块
*
* @param txHash
*/
public static void startPolling(String txHash) {
//5s刷新一次
disposable = Flowable.interval(0, 5, TimeUnit.SECONDS)
.compose(ScheduleCompat.apply())
// .takeUntil(Flowable.timer(120, TimeUnit.SECONDS))
.subscribe(new Consumer<Long>() {
@Override
public void accept(Long num) throws Exception {
Log.i(TAG, "第 : " + num + " 次轮询");
//根据blockHash来判断交易是否被打包
String blockHash = getBlockHash(txHash);
boolean isSuccess = Numeric.toBigInt(blockHash).compareTo(BigInteger.valueOf(0)) != 0;
if (isSuccess) {
getTransactionReceipt(txHash);
}
}
});
}
/**
* 停止轮询
*
* @param disposable
*/
public static void stopPolling(Disposable disposable) {
if (!disposable.isDisposed()) {
disposable.dispose();
}
}
/**
* 获取blockhash
* @param txHash
* @return
*/
public static String getBlockHash(String txHash) {
Web3j web3j = Web3jFactory.build(new HttpService("https://rinkeby.infura.io/v3/xxxx"));
try {
EthTransaction transaction = web3j.ethGetTransactionByHash(txHash).sendAsync().get();
Transaction result = transaction.getResult();
String blockHash = result.getBlockHash();
Log.i(TAG, "getTransactionResult blockHash : " + blockHash);
boolean isSuccess = Numeric.toBigInt(blockHash).compareTo(BigInteger.valueOf(0)) != 0;
if (isSuccess) {
getTransactionReceipt(txHash);
stopPolling(disposable);
}
return blockHash;
} catch (Exception e) {
e.printStackTrace();
return "";
}
}
public static void getTransactionReceipt(String transactionHash) {
Web3j web3j = Web3jFactory.build(new HttpService("https://rinkeby.infura.io/v3/xxxx"));
try {
EthGetTransactionReceipt transactionReceipt = web3j.ethGetTransactionReceipt(transactionHash).sendAsync().get();
TransactionReceipt receipt = transactionReceipt.getTransactionReceipt();
String status = receipt.getStatus();
BigInteger gasUsed = receipt.getGasUsed();
BigInteger blockNumber = receipt.getBlockNumber();
String blockHash = receipt.getBlockHash();
Log.i(TAG, "getTransactionReceipt status : " + status);
Log.i(TAG, "getTransactionReceipt gasUsed : " + gasUsed);
Log.i(TAG, "getTransactionReceipt blockNumber : " + blockNumber);
Log.i(TAG, "getTransactionReceipt blockHash : " + blockHash);
} catch (InterruptedException e) {
e.printStackTrace();
} catch (ExecutionException e) {
e.printStackTrace();
}
}
正常情况下，几十秒内就可以获取到区块信息了。
区块确认数
区块确认数=当前区块高度-交易被打包时的区块高度。
