基于以太坊平台建立的去中心化金融应用kyberNetwork解析

本教程将向您展示如何轻松地使用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中并开始使用它。您将认识到在以太坊网络上执行和交换代币事务是多么容易一件事。
来源： 区块链研究实验室