<!--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 Чем выше цена, тем выше приоритет транзакции и тем выше скорость транзакции.
gasLimit: 1500000 # Gas Limit Максимальная сумма Gas, которую пользователь готов заплатить за выполнение операции или подтверждение транзакции (минимум 21 000).
isAddGas: false #Включить ли взвешенную комиссию майнерам на основе текущей рыночной цены
addGas: 2000000000 #Повышенные комиссии
url: "https://mainnet.infura.io/d75c50732022222222222222222222" #officialсеть 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();
//В зависимости от того, включена ли конфигурация, в соответствии с рыночной стоимостью газа в реальном времени, увеличьте указанную стоимость газа, чтобы ускорить скорость пакета.
if(isAddGas){
BigInteger gas = web3j.ethGasPrice().send().getGasPrice();
LOG.info("получена цена газа{}",gas);
gasPrice = addGas.add(gas);
}
//Вернем количество транзакций, произошедших по указанному адресу.
nonce = ethGetTransactionCount.getTransactionCount();
List outputParameters = new ArrayList();
TypeReference<Bool> typeReference = new TypeReference<Bool>() {
};
outputParameters.add(typeReference);
LOG.info("Газовая цена, выплачиваемая майнерам, равна: {}",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);
LOG.info("Параметр: gasPrice = " + gasPrice);
LOG.info("Параметр: gasLimit = " + gasLimit);
LOG.info("Параметры: входные параметры = " + 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