使用java应用程序实现kyberNetwork中Defi代币交易

本教程将向您展示如何轻松地使用Java应用程序访问KyberNetwork以进行代币交易。

本教程实现了主要的交易场景:

1. 将以太坊转换为其他代币


2. 将其他代币转换为以太坊


3. 不同代币之间的转换

关于Kyber Network和KyberDAO

KyberNetwork是一个无须信任的去中心化交易所,它可以促进加密资产间的即时转换/兑换。

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

使用java应用程序实现kyberNetwork中Defi代币交易

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文件。


使用java应用程序实现kyberNetwork中Defi代币交易

查看钱包文件中创建的以太坊地址,然后转移一些以太坊到该地址上。

· 您可以使用Ropsten水龙头创建以太坊测试币:https://faucet.ropsten.be/
· 检查您的地址、交易和任何其他区块链信息,使用https://ropsten.etherscan.io/
· 在我们的教程应用程序中,需要为钱包选择密码才能加载必要的凭据。

准备步骤:创建infura测试节点帐户

要将Kyber交换交易写入以太坊区块链,您需要一个infura测试节点帐户.

· 在infura上设置帐户
· 创建一个新项目,您将使用Infura秘密代币(Project Secret)连接到Ropsten Test网络。

使用java应用程序实现kyberNetwork中Defi代币交易

准备步骤:复制github目录并创建一个secret目录

· 使用本教程复制github目录:https://github.com/talfco/clb-kyber-java-tutorial
· 在clb-kyber-java-tutorial中创建一个secret目录,然后复制wallet.json文件。
· 创建secret.properties文件并添加钱包密码和infura代币添加条目。

使用java应用程序实现kyberNetwork中Defi代币交易

运行教程应用程序

只需输入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. 您将看到由我们的三个功能触发的三笔交易


使用java应用程序实现kyberNetwork中Defi代币交易

您现在也是Ropsten网络上DAI和BAT代币的所有者。将来,您可以使用这个简单的java应用程序生成任何类型的测试代币(只要kyber测试网络支持它)

使用java应用程序实现kyberNetwork中Defi代币交易

例如下面的屏幕截图是来自eth2token转换(购买了2个dai代币)的详细事务信息。现在,您可以深入了解并研究与此交易相关的kyber合约。

使用java应用程序实现kyberNetwork中Defi代币交易

实施方面-Kyber API功能设计为web3j模块

本教程是我对Ethereum的第一篇Java编程文章,我发现Ethereum网络的一个不错的Java库。Web3实验室的web3j是一个著名的例子。它主要侧重于智能合约(主要受到Kyber Restful API的保护),并将具有必要的工具包来加载钱包凭证和签署交易,这在Kyber Restful API中也发挥着作用。


使用java应用程序实现kyberNetwork中Defi代币交易

引入的java类和接口继承自web3j的核心类,并以类似的方式实现。这让我一方面可以利用来自web3j的大量代码;另一方面,使用web3j的开发人员将发现类似的模式。

使用java应用程序实现kyberNetwork中Defi代币交易

为了符合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中并开始使用它。您将认识到在以太坊网络上执行和交换代币事务是多么容易一件事。

关键词: kyberNetwork  Defi  

该内容来自于互联网公开内容,非区块链原创内容,如若转载,请注明出处:https://htzkw.com/archives/28407

联系我们

aliyinhang@gmail.com