本教程将向您展示如何轻松地使用Java应用程序访问KyberNetwork以进行代币交易。
本教程实现了主要的交易场景:
1. 将以太坊转换为其他代币
2. 将其他代币转换为以太坊
3. 不同代币之间的转换
关于Kyber Network和KyberDAO
KyberNetwork是一个无须信任的去中心化交易所,它可以促进加密资产间的即时转换/兑换。
kyberNetwork是基于以太坊平台建立的去中心化金融应用。
KyberNetwork支持兑换以太坊代币,类似于传统的外汇交易,还支持兑换其他法定货币。主要的区别在于根本不涉及任何中心交易所!KyberNetwork的基础代币是以太坊(ETH),而不是任何法定货币。
作为“ KyberDAO”社区实验的一部分,该网络于6月启动了其基于DAOstack的DAO(在Aragon平台上进行了首次实验之后),并为其提供了约17,000 KNC(约合4500美元)的资金。社区中的任何人都可以提交提案,并提出资金申请,以获取部分或全部赠款(请参见公告)。
从接口的角度来看,KyberNetwork除了提供直接的智能合约abi之外,kyberNetwork还提供了restful api,它为用户(没有太多智能合约知识)提供了与其合约交互的能力。
关于Kyber Java客户端库
现在让我们深入了解KyberNetwork的Java客户端库。首先,让我们运行Java教程应用程序。
准备步骤:在机器上安装java、git和gradle。
很明显,您的机器上安装了java和git,还要使用gradle构建环境,这样您就可以从命令行轻松运行教程代码。在您的计算机上安装所有这三个依赖项。
准备步骤:使用web3j命令创建一个ropsten测试钱包
在我们的例子中,我们必须在ropsten测试网络上创建一个测试钱包,用于我们的代币交换场景。命令行工具可以使用各种安装程序。
如果是Windows,请使用ZIP文件分发并提取到目录中,然后运行web3j.bat文件。
使用钱包工具创建一个钱包。“wallet create”将创建wallet.json文件。
查看钱包文件中创建的以太坊地址,然后转移一些以太坊到该地址上。
· 您可以使用Ropsten水龙头创建以太坊测试币:https://faucet.ropsten.be/
· 检查您的地址、交易和任何其他区块链信息,使用https://ropsten.etherscan.io/
· 在我们的教程应用程序中,需要为钱包选择密码才能加载必要的凭据。
准备步骤:创建infura测试节点帐户
要将Kyber交换交易写入以太坊区块链,您需要一个infura测试节点帐户。
· 在infura上设置帐户
· 创建一个新项目,您将使用Infura秘密代币(Project Secret)连接到Ropsten Test网络。
准备步骤:复制github目录并创建一个secret目录
· 使用本教程复制github目录:https://github.com/talfco/clb-kyber-java-tutorial
· 在clb-kyber-java-tutorial中创建一个secret目录,然后复制wallet.json文件。
· 创建secret.properties文件并添加钱包密码和infura代币添加条目。
运行教程应用程序
只需输入gradle run即可启动教程应用程序。
应用程序将调用三种功能:
1. 首先,它将部分测试以太币转换为两个DAI令牌(eth2token)。需要Kyber购买费率才能确定所需的以太坊的数量。
2. 其次,它将一个DAI代币转换回以太坊(token2eth)。为了确定支付的以太坊数量,需要Kyber销售率。
3. 第三,它将一个DAI代币转换为一个BAT代币(token2token)。 对于此交易,同时需要Kyber的购买率和销售率,以确定可以购买多少个BAT代币。
public static void main(String[] args) throws Exception {
Application app = new Application();
log.info(“》》》 SCENARIO: ETH2TOKEN”);
Thread.sleep(3000);
app.eth2token(“DAI”,“2”);
log.info(“》》》 SCENARIO: TOKEN2ETH”);
Thread.sleep(3000);
app.token2eth(“DAI”,“1”);
log.info(“》》》 SCENARIO: TOKEN2TOKEN”);
Thread.sleep(3000);
app.token2token(“DAI”,“BAT”,“0.5”);
}
检查控制台输出中已创建的交易哈希和其他信息。
教程生成的以太坊交易
该教程应用程序将生成3个以太坊交易,您可以通过etherscan.io Web应用程序进行结帐。
1. https://ropsten.etherscan.io/address/ 《yourTestWalletAddress》
2. 您将看到由我们的三个功能触发的三笔交易
您现在也是Ropsten网络上DAI和BAT代币的所有者。将来,您可以使用这个简单的java应用程序生成任何类型的测试代币(只要kyber测试网络支持它)
例如下面的屏幕截图是来自eth2token转换(购买了2个dai代币)的详细事务信息。现在,您可以深入了解并研究与此交易相关的kyber合约。
实施方面-Kyber API功能设计为web3j模块
本教程是我对Ethereum的第一篇Java编程文章,我发现Ethereum网络的一个不错的Java库。Web3实验室的web3j是一个著名的例子。它主要侧重于智能合约(主要受到Kyber Restful API的保护),并将具有必要的工具包来加载钱包凭证和签署交易,这在Kyber Restful API中也发挥着作用。
引入的java类和接口继承自web3j的核心类,并以类似的方式实现。这让我一方面可以利用来自web3j的大量代码;另一方面,使用web3j的开发人员将发现类似的模式。
为了符合web3j(围绕JSON-RPC接口构建),我引入了JsonRpc2_0Kyber类,该类充当协议转换器并为Kyber REST API准备请求。
Kyber Java API接口支持以下功能。
package net.cloudburo.kyber.tutorial.protocol;
import net.cloudburo.kyber.tutorial.methods.request.GasPriceRange;
import net.cloudburo.kyber.tutorial.methods.request.SingleRate;
import net.cloudburo.kyber.tutorial.methods.response.*;
import org.web3j.protocol.core.Request;
import java.math.BigInteger;
public interface KyberAPI {
public Request《?, Currencies》 currencies();
public Request《?, BuyRate》 buyRate(String id, String qty,boolean onlyOfficialReserve);
public Request《?, SellRate》 sellRate(String id, String qty, boolean onlyOfficialReserve);
public Request《?, TradeData》 tradeData(String userAddress, SingleRate rate, GasPriceRange gasPrice);
public Request《?, TradeData》 tradeData(String userAddress, SingleRate rate, GasPriceRange gasPrice, BigInteger nonce);
public Request《?, TradeData》 tradeData(String userAddress, String srcId, String dstId, Float srcQty,Float minDstQty,
GasPriceRange gasPrice, String walletId, boolean onlyOfficialReserve);
public Request《?,EnabledTokensForWallet》 enabledTokensForWallet(String userAddress);
public Request《?, EnableTokenTransfer》 enableTokenTransfer(String userAddress, String id, GasPriceRange gasPrice);
}
可以看到,主要部分是Java strong类型。JSON数据请求通过Jackson XML解析支持自动转换为Java类。
第二篇文章将深入探讨构建的客户端库的各个设计方面。
交易场景代码
结束本教程;提供了这三种情况的代码序列。 如您所见,代码非常紧凑,易读且易于理解。 如果您查看基本的web3j以太坊事务示例,您将看到代码的相似性。
场景:ETH2TOKEN
只要认识到使用kyber api交换ethereum上的代币是多么容易!
private void eth2token(String tokenSymbol, String tokenQuantity) {
Kyber3j kyber3j = Kyber3j.build(new KyberService(KyberService.KYBER_ROPSTEN));
log.info(“Connected to Kyber Network: ”+KyberService.KYBER_ROPSTEN);
// ETH2《Token》 Swap
try {
// Check if token is supported
Currencies currencies = kyber3j.currencies().send();
log.info(“Exists Currency”+tokenSymbol+“: ” + currencies.existsCurreny(tokenSymbol));
if (!checkForError(currencies) && currencies.existsCurreny(tokenSymbol)) {
// Get buy rates
BuyRate buyRate = kyber3j.buyRate(currencies.getCurrency(tokenSymbol).getId(),tokenQuantity,
false).send();
if (!checkForError(buyRate)) {
Rates rates = buyRate.getData().get(0);
SingleRate singleRate = rates.getSingleRate(0);
log.info(“Conversion Rate: ” + singleRate.getSrc_qty());
// Get tradeData
// Adjust conversion rates to 97%
singleRate.approximateReceivableToken(0.97);
TradeData tradeData = kyber3j.tradeData(credentials.getAddress(), singleRate, GasPriceRange.medium,nonce).send();
if (!checkForError(tradeData)) {
executeEthereumTransaction(tradeData.getData().get(0));
}
}
}
} catch (Exception e) { e.printStackTrace(); }
}
场景:TOKEN2ETH
private void token2eth(String tokenSymbol, String tokenQuantity){
Kyber3j kyber3j = Kyber3j.build(new KyberService(KyberService.KYBER_ROPSTEN));
log.info(“Connected to Kyber Network: ”+KyberService.KYBER_ROPSTEN);
try {
// Check if token is supported
Currencies currencies = kyber3j.currencies().send();
if (!checkForError(currencies) && currencies.existsCurreny(tokenSymbol)) {
EnabledTokensForWallet tokens = kyber3j.enabledTokensForWallet(credentials.getAddress()).send();
if (!checkForError(tokens)){
// Check if wallet is enabled for token
String tokenId = currencies.getCurrency(tokenSymbol).getId();
EnabledTokensForWallet.EnabledTokenStatus tokenStatus = tokens.getEnabledTokenStatus(tokenId);
if ( tokenStatus.isEnabled()) {
if (tokenStatus.getTxs_required() == 1) {
// Enable Token Transfer
EnableTokenTransfer tokenData = kyber3j.enableTokenTransfer(credentials.getAddress(), tokenId,
GasPriceRange.medium).send();
executeEthereumTransaction(tokenData.getData());
}
SellRate sellRate = kyber3j.sellRate(currencies.getCurrency(tokenSymbol).getId(), tokenQuantity,
false).send();
if (!checkForError(sellRate)) {
Rates rates = sellRate.getData().get(0);
SingleRate singleRate = rates.getSingleRate(0);
log.info(“Conversion Rate: ” + singleRate.getSrc_qty());
singleRate.approximateReceivableToken(0.97);
TradeData tradeData = kyber3j.tradeData(credentials.getAddress(), singleRate, GasPriceRange.medium,nonce).send();
if (!checkForError(tradeData)) {
executeEthereumTransaction(tradeData.getData().get(0));
}
}
}
}
}
} catch (Exception e){ e.printStackTrace(); }
}
场景:Token2Token
private void token2token(String tokenSymbolFrom, String tokenSymbolTo, String tokenQuantity) {
//Suppose we want to convert 100 BAT to DAI tokens, which is a token to token conversion.
// Note that ETH is used as the base pair i.e. BAT -》 ETH -》 DAI.
Kyber3j kyber3j = Kyber3j.build(new KyberService(KyberService.KYBER_ROPSTEN));
log.info(“Connected to Kyber Network: ”+KyberService.KYBER_ROPSTEN);
try {
Currencies currencies = kyber3j.currencies().send();
if (!checkForError(currencies) && currencies.existsCurreny(tokenSymbolFrom)
&& currencies.existsCurreny(tokenSymbolTo) ) {
EnabledTokensForWallet tokens = kyber3j.enabledTokensForWallet(credentials.getAddress()).send();
if (!checkForError(tokens)) {
// Check if wallet is enabled for tokens
String tokenId = currencies.getCurrency(tokenSymbolFrom).getId();
EnabledTokensForWallet.EnabledTokenStatus tokenStatus = tokens.getEnabledTokenStatus(tokenId);
if ( tokenStatus.isEnabled()) {
// Check if the sell token is already enabled to be sold by the network on behalf of this user
if (tokenStatus.getTxs_required() == 1) {
EnableTokenTransfer tokenData = kyber3j.enableTokenTransfer(credentials.getAddress(), tokenId,
GasPriceRange.medium).send();
executeEthereumTransaction(tokenData.getData());
} else if (tokenStatus.getTxs_required() == 2) {
// TODO Implement validation
log.error(“Not implemented for getTxs_required = 2”);
}
} else {
log.error(“Curreny not supported”);
return;
}
// Get Sell Rate in ETH: 《fromTokenQuantity》 -》 ETH ?
SellRate sellRate = kyber3j.sellRate(currencies.getCurrency(tokenSymbolFrom).getId(), tokenQuantity,
false).send();
if (!checkForError(sellRate)) {
Rates rates = sellRate.getData().get(0);
SingleRate singleRateFromToken = rates.getSingleRate(0);
Float sellQty = singleRateFromToken.getDst_qty();
log.info(tokenSymbolFrom+“ Sell Rate: ” + singleRateFromToken.getSrc_qty());
// Get Buy Rate for 1 toToken: ETH ? -》 1 《toToken》
BuyRate buyRate = kyber3j.buyRate(currencies.getCurrency(tokenSymbolTo).getId(),“1”,
false).send();
if (!checkForError(buyRate)) {
rates = buyRate.getData().get(0);
SingleRate singleRateToToken = rates.getSingleRate(0);
Float buyQty = singleRateToToken.getSrc_qty();
Float expectedAmountWithoutSlippage = sellQty / buyQty; // * Float.valueOf(tokenQuantity);
Float expectedAmountWithSlippage = expectedAmountWithoutSlippage * 0.97f;
singleRateFromToken.setDst_id(singleRateToToken.getDst_id());
singleRateFromToken.setDst_qty(expectedAmountWithSlippage);
TradeData tradeData = kyber3j.tradeData(credentials.getAddress(), singleRateFromToken, GasPriceRange.medium, nonce).send();
if (!checkForError(tradeData)) {
executeEthereumTransaction(tradeData.getData().get(0));
}
}
}
}
}
} catch (Exception e){e.printStackTrace();}
}
最后一点
我希望本教程对您有用,将代码加载到java ide中并开始使用它。您将认识到在以太坊网络上执行和交换代币事务是多么容易一件事。
来源: 区块链研究实验室
评论
查看更多