<!--web3j-->
<dependency>
<groupId>org.web3j</groupId>
<artifactId>core</artifactId>
<version>3.4.0</version>
</dependency>
<dependency>
<groupId>org.web3j</groupId>
<artifactId>geth</artifactId>
<version>3.4.0</version>
</dependency>
<dependency>
<groupId>org.web3j</groupId>
<artifactId>abi</artifactId>
<version>3.4.0</version>
</dependency>
contract:
ctAddr: "************************************" #游戏合约地址
startAddr: "************************************" #顶级节点地址
sendAddr: "************************************" #授权地址
sendAddrPk: "************************************"
gasPrice: 5000000000 # Gas Price越高,交易优先级越高,打包交易速度越快。
gasLimit: 1500000 # Gas Limit 是用户愿意为执行某个操作或确认交易支付的最大Gas量(最少21,000)
isAddGas: false #是否启用按当前市价进行加权矿工费用
addGas: 2000000000 #所增加费用
url: "https://mainnet.infura.io/d75c50732022222222222222222222" #正式网 or 测试网
import org.web3j.abi.datatypes.Type;
import java.math.BigInteger;
import java.util.List;
/**
* @Datetime: 2020/6/23 10:35
* @Author:
* @title
*/
public interface IBaseWeb3j {
/**
* 执行合约打包
*
* @param fromAddr 支付地址
* @param fromPrivateKey 支付地址私钥
* @param hashVal 合约地址
* @param month 合约方法
* @param gasPrice 旷工费用
* @param inputParameters 方法参数
* @return hash
*/
String transact(String fromAddr, String fromPrivateKey, String hashVal, String month, BigInteger gasPrice, BigInteger gasLimit, List<Type> inputParameters);
}
import com.alibaba.fastjson.JSONObject;
import com.blockchain.server.contractGzhz.web3j.IBaseWeb3j;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
import org.web3j.abi.FunctionEncoder;
import org.web3j.abi.TypeReference;
import org.web3j.abi.datatypes.Bool;
import org.web3j.abi.datatypes.Function;
import org.web3j.abi.datatypes.Type;
import org.web3j.crypto.Credentials;
import org.web3j.crypto.RawTransaction;
import org.web3j.crypto.TransactionEncoder;
import org.web3j.protocol.Web3j;
import org.web3j.protocol.core.DefaultBlockParameterName;
import org.web3j.protocol.core.methods.response.*;
import org.web3j.protocol.http.HttpService;
import org.web3j.utils.Numeric;
import java.math.BigInteger;
import java.util.ArrayList;
import java.util.List;
/**
* @Datetime: 2020/6/23 10:36
* @Author:
* @title
*/
@Component
public class BaseWeb3jImpl implements IBaseWeb3j {
private static final Logger LOG = LoggerFactory.getLogger(BaseWeb3jImpl.class);
static Web3j web3j;
@Value("${contract.url}")
private String URL;
@Value("${contract.addGas}")
private BigInteger addGas;
@Value("${contract.isAddGas}")
private boolean isAddGas;
public String transact(String fromAddr, String fromPrivateKey, String hashVal, String month, BigInteger gasPrice, BigInteger gasLimit, List<Type> inputParameters) {
EthSendTransaction ethSendTransaction = null;
BigInteger nonce = BigInteger.ZERO;
String hash = null;
try {
if(web3j == null){
web3j = Web3j.build(new HttpService(URL));
}
EthGetTransactionCount ethGetTransactionCount = web3j.ethGetTransactionCount(
fromAddr,
DefaultBlockParameterName.PENDING
).send();
//根据配置是否开启根据实时市场gas费用,增加指定gas费用,加快打包速率
if(isAddGas){
BigInteger gas = web3j.ethGasPrice().send().getGasPrice();
LOG.info("获取到的gasPrice{}",gas);
gasPrice = addGas.add(gas);
}
//返回指定地址发生的交易数量。
nonce = ethGetTransactionCount.getTransactionCount();
List outputParameters = new ArrayList();
TypeReference<Bool> typeReference = new TypeReference<Bool>() {
};
outputParameters.add(typeReference);
LOG.info("付给矿工的gasPrice为:{}",gasPrice);
Function function = new Function(
month,
inputParameters,
outputParameters);
String encodedFunction = FunctionEncoder.encode(function);
Credentials credentials = Credentials.create(fromPrivateKey);
RawTransaction rawTransaction = RawTransaction.createTransaction(nonce, gasPrice, gasLimit, hashVal,
encodedFunction);
byte[] signedMessage = TransactionEncoder.signMessage(rawTransaction, credentials);
String hexValue = Numeric.toHexString(signedMessage);
ethSendTransaction = web3j.ethSendRawTransaction(hexValue).sendAsync().get();
hash = ethSendTransaction.getTransactionHash();
LOG.info(JSONObject.toJSONString(ethSendTransaction));
} catch (Exception e) {
if (null != ethSendTransaction) {
LOG.info("失败的原因:" + ethSendTransaction.getError().getMessage());
LOG.info("参数:fromAddr = " + fromAddr);
LOG.info("参数:month = " + month);
LOG.info("参数:gasPrice = " + gasPrice);
LOG.info("参数:gasLimit = " + gasLimit);
LOG.info("参数:inputParameters = " + JSONObject.toJSONString(inputParameters));
}
e.printStackTrace();
}
return hash;
}
import com.blockchain.server.contractGzhz.service.SettlementService;
import com.blockchain.server.contractGzhz.web3j.IBaseWeb3j;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;
import org.web3j.abi.datatypes.Type;
import java.math.BigInteger;
import java.util.Arrays;
import java.util.Date;
import java.util.List;
/**
* @Datetime: 2020/6/23 11:47
* @Author:
* @title
*/
@Component
public class SettlementServiceImpl {
private static final Logger LOG = LoggerFactory.getLogger(SettlementServiceImpl.class);
/*合约地址*/
@Value("${contract.ctAddr}")
private String ctAddr;
/*初始地址*/
@Value("${contract.startAddr}")
private String startAddr;
/*发币地址*/
@Value("${contract.sendAddr}")
private String sendAddr;
/*发币地址私钥*/
@Value("${contract.sendAddrPk}")
private String sendAddrPk;
@Value("${contract.gasLimit}")
private BigInteger CT_GAS_LIMIT;
@Value("${contract.gasPrice}")
private BigInteger CT_GAS_PRICE;
@Autowired
IBaseWeb3j iBaseWeb3j;
/**
调用服务
**/
public void test() {
try {
List<Type> inputParameters = Arrays.asList( );
iBaseWeb3j.transact(sendAddr,sendAddrPk,ctAddr,"month_name", CT_GAS_PRICE, CT_GAS_LIMIT,inputParameters);
}catch (Exception ex){
LOG.error("发生异常",ex);
}
}
https://www.ethgasstation.info/txPoolReport.php