2. 程式人生 > >EOS JAVA RPC呼叫(線上簽名)

EOS JAVA RPC呼叫(線上簽名)

阿新 • • 發佈：2018-12-26

開發前看一下EOS白皮書最好，先了解EOS的架構及相關歷程。有助於後續的開發。本地安裝個EOS，試一試命令。博主本人是隻本地啟動錢包wallet，其它api呼叫其它節點提供的介面。(本篇文章需要本地啟動一個錢包服務keosd或者eosio.  最新一篇文章採用離線簽名無需啟動服務https://blog.csdn.net/liu1765686161/article/details/83308819)

EOS測試網路https://tools.cryptokylin.io

1，首選需要下載eos.java.rpc.wrapper-1.0-SNAPSHOT.jar包

https://download.csdn.net/download/liu1765686161/10767940

或者檢視原始碼 https://github.com/EOSEssentials/eos-java-rpc-wrapper 

2，加入專案工程  maven的話有可能需要額外加入依賴

        <dependency>
          <groupId>com.github-eos</groupId>
          <artifactId>eos-java-rpc-wrapper</artifactId>
          <version>1.0</version>
        </dependency>
        <dependency>
            <groupId>com.squareup.retrofit2</groupId>
            <artifactId>retrofit</artifactId>
            <version>2.4.0</version>
        </dependency>
        <dependency>
            <groupId>com.squareup.retrofit2</groupId>
            <artifactId>converter-jackson</artifactId>
            <version>2.4.0</version>
        </dependency>
        <dependency>
                <groupId>com.fasterxml.jackson.core</groupId>
                <artifactId>jackson-core</artifactId>
                <version>2.6.5</version>
            </dependency>
        <dependency>
                <groupId>com.fasterxml.jackson.core</groupId>
                <artifactId>jackson-databind</artifactId>
                <version>2.6.4</version>
        </dependency>
3，開始呼叫

package com.tn.web.service.coin;
 
import java.util.Collections;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
 
import javax.annotation.PostConstruct;
 
import org.apache.commons.lang.StringUtils;
import org.slf4j.Logger;
import org.springframework.dao.DuplicateKeyException;
import org.springframework.stereotype.Service;
 
import com.alibaba.fastjson.JSONObject;
import com.tn.base.Log;
import com.tn.constant.CoinConstant;
import com.tn.util.BigDecimalUtil;
import com.tn.util.DateUtil;
import com.tn.util.JsonUtil;
 
import client.EosApiClientFactory;
import client.EosApiRestClient;
import client.domain.common.ActionTrace;
import client.domain.common.transaction.PackedTransaction;
import client.domain.common.transaction.SignedPackedTransaction;
import client.domain.common.transaction.TransactionAction;
import client.domain.common.transaction.TransactionAuthorization;
import client.domain.response.chain.AbiJsonToBin;
import client.domain.response.chain.Block;
import client.domain.response.chain.ChainInfo;
import client.domain.response.chain.transaction.PushedTransaction;
import client.domain.response.history.action.Action;
import client.domain.response.history.action.Actions;
 
/**
 * eos操作
 * @author xhl
 * @create 2017/10/27
 **/
@Service
public class CoinEosService {
    private Logger log = Log.get();
    private String walletUrl = "";//本地啟動的wallet
    //正式網路https://api-v2.eosasia.one
    private String chainUrl = "https://api-kylin.eosasia.one";//測試網路
    //建議用active賬戶
    private String ownerAccount = "";
    private String ownerAccountPublicKey = "";
    private String walletName = "";//建立的錢包名
    private String walletPassword = "";//錢包密碼
    private static final String EOS_TOKEN = "eosio.token";
    private static final String ACTION_TRANSFER = "transfer";
    
    EosApiRestClient eosApiRestClient = null;
    @PostConstruct
    public void init(){
        this.eosApiRestClient = EosApiClientFactory.newInstance(walletUrl, 
                chainUrl, chainUrl).newRestClient();
    }
    
    /**
     * 獲取賬戶交易資訊
     * index 查詢到第幾條記錄
    **/
    public boolean getActions(int index){
        try {
            //account賬戶，index:查詢到第幾條記錄，offset：每次查詢幾條資料 從0開始
            Actions actions = eosRpcService.getActions(account, index,0);
            if (actions != null) {
                List<Action> list = actions.getActions();
                if (list==null || list.size() == 0) {
                    return false;
                }
                //不可變更區塊高度
                int lastIrreversibleBlock = actions.getLastIrreversibleBlock();
                //每次處理一條資料,不需要去重
                //list = this.removeDuplicate(list);
                for (Action action : list) {
                    ActionTrace actionTrace = action.getActionTrace();
                    String account = actionTrace.getAct().getAccount();
                    if (!EOS_TOKEN.equals(account)) {
                        log.info("非EOS交易記錄：{}",account);
                        return true;
                    }
                    if (action.getBlockNum() > lastIrreversibleBlock) {
                        log.info("未確認交易：{}",account);
                        return false;
                    }
                    String name = actionTrace.getAct().getName();
                    if (!ACTION_TRANSFER.equals(name)) {
                        log.info("非EOS轉賬交易記錄：{}",account);
                        return true;
                    }
                    //{from=eosqxyx11111, to=eosqxyx22222, quantity=10.0000 EOS, memo=test}
                    log.info("交易詳情：{}",actionTrace.getAct().getData().toString());
                    JSONObject json = JSONObject.parseObject(JsonUtil.getSting(actionTrace.getAct().getData()));
                    if (!account.equals(json.getString("to"))) {
                        log.info("非充值記錄：{}",actionTrace.getTrxId());
                        return true;
                    }
                    String[] quantity = json.getString("quantity").split(" ");
                    if (!CoinConstant.COIN_EOS.equals(quantity[1])) {
                        log.info("非EOS充值記錄：{}",json.getString("quantity"));
                        return true;
                    }
                    String memo = json.getString("memo");
                    if (StringUtils.isEmpty(memo)) {
                        log.info("記錄memo為空");
                        return true;
                    }
 
                    //判斷是否存在使用者,並新增充值記錄
                    /*UserEntity user = userService.getUserById(Integer.parseInt(memo));
                    if (user == null) {
                        log.info("使用者資訊不存在：memo：{}",memo);
                        return true;
                    }
                    record.setUserId(user.getUserId());
                    rechargeParse(record);*/
                    return true;
                }
            }
        } catch (Exception e1) {
            e1.printStackTrace();
            log.error("獲取使用者交易記錄失敗:{}",e1.getMessage());
        }
        return false;
    }
 
    /**
     * 去重
     * @param list
     * @return
     */
    public List<Action> removeDuplicate(List<Action> list) {
        for (int i = 0; i < list.size() - 1; i++) {
            for (int j = list.size() - 1; j > i; j--) {
                if (list.get(j).getActionTrace().getTrxId()
                        .equals(list.get(i).getActionTrace().getTrxId())) {
                    list.remove(j);
                }
            }
        }
        return list;
    }
   
    public String getAddress(){
        return ownerAccount;
    }
    
    public double getBalance(){
        List<String> list = eosApiRestClient.getCurrencyBalance(EOS_TOKEN, ownerAccount, "EOS");
        if (list != null && list.size() > 0) {
            return Double.parseDouble(list.get(0).replaceAll(" EOS", ""));
        }
        return 0.00;
    }
    
    public String getJsonToBin(String from, String to, Double amount, String memo){
        Map<String, String> args = new HashMap<>(4);
        args.put("from", from);
        args.put("to", to);
        //amount 必須要保留4位小數，不夠補0
        args.put("quantity",  BigDecimalUtil.getFourString(amount)+" EOS");
        args.put("memo", memo);
        AbiJsonToBin data = eosApiRestClient.abiJsonToBin(EOS_TOKEN, "transfer", args);
        if (data != null) {
            return data.getBinargs();
        }
        return null;
    }
    
    /**
     * 傳送交易
     * @param fromAccount
     * @param toAccount
     * @param amount 保留4位小數點
     * @param memo
     * @return
     */
    public String send(String toAccount,double amount,String memo){
        
        String binargs = this.getJsonToBin(ownerAccount, toAccount, amount, memo);
        ChainInfo chainInfo = eosApiRestClient.getChainInfo();
        Block block = eosApiRestClient.getBlock(chainInfo.getHeadBlockId());
 
        TransactionAuthorization transactionAuthorization = new TransactionAuthorization();
        transactionAuthorization.setActor(ownerAccount);
        //傳送者許可權等級   這一步要注意賬戶和許可權要對應上
        //transactionAuthorization.setPermission("owner");
        transactionAuthorization.setPermission("active");
 
        TransactionAction transactionAction = new TransactionAction();
        transactionAction.setAccount(EOS_TOKEN);
        transactionAction.setName(ACTION_TRANSFER);
        transactionAction.setData(binargs);
        transactionAction.setAuthorization(Collections.singletonList(transactionAuthorization));
        
        //設定交易期限
        Date date = DateUtil.getStringToDate(block.getTimeStamp(),"yyyy-MM-dd'T'HH:mm:ss");
        date = DateUtil.addMin(date, 1);
        String exPiration = DateUtil.dateToString(date,"yyyy-MM-dd'T'HH:mm:ss");
 
        PackedTransaction packedTransaction = new PackedTransaction();
        packedTransaction.setRefBlockPrefix(block.getRefBlockPrefix().toString());
        packedTransaction.setRefBlockNum(block.getBlockNum().toString());
        packedTransaction.setExpiration(exPiration);
        packedTransaction.setRegion("0");
        packedTransaction.setMax_net_usage_words("0");
        packedTransaction.setActions(Collections.singletonList(transactionAction));
        //開啟錢包
        eosApiRestClient.openWallet(walletName);
        //解鎖錢包
        eosApiRestClient.unlockWallet(walletName, walletPassword);
        
        SignedPackedTransaction signedPackedTransaction = eosApiRestClient.signTransaction(packedTransaction, 
                Collections.singletonList(ownerAccountPublicKey), chainInfo.getChainId());
 
        PushedTransaction pushedTransaction= eosApiRestClient.pushTransaction("none", signedPackedTransaction);
        if (pushedTransaction != null) {
            log.info("EOS轉賬成功：transactionId:{}",pushedTransaction.getTransactionId());
            return pushedTransaction.getTransactionId();
        }else {
            log.info("EOS轉賬失敗");
        }
        return null;
    }
 
}
4，定時任務 獲取使用者交易記錄  來確認使用者充值   這是我的示例。具體可以根據自己業務來

 
    /**
     * EOS處理
     */
    private void eosJob(){
        //代表的是賬戶記錄處理到第幾條，不是區塊高度
        Integer eosIndex = coinParseService.getBlockHeight("EOS");
        log.info("EOS當前處理記錄數：{}",eosIndex);
        if (coinEosService.getActions(eosIndex)) {
            log.info("eos執行完畢");
            eosIndex += 1;
            //更新處理進度
            coinParseService.updateBlockRecord("EOS", reIndex);
        }
    }
希望能幫到大家，歡迎大家一起分享。
--------------------- 
作者：其修遠兮 
來源：CSDN 
原文：https://blog.csdn.net/liu1765686161/article/details/82180070 
版權宣告：本文為博主原創文章，轉載請附上博文連結！

相關推薦

EOS JAVA RPC呼叫(線上簽名)

開發前看一下EOS白皮書最好，先了解EOS的架構及相關歷程。有助於後續的開發。本地安裝個EOS，試一試命令。博主本人是隻本地啟動錢包wallet，其它api呼叫其它節點提供的介面。(本篇文章需要本地啟動一個錢包服務keosd或者eosio.  最新一篇文章採用離線簽名無需啟動服務

EOS JAVA 呼叫(離線簽名)

前言:  之前一篇文章是用的線上簽名,本地啟用了keosd服務,來管理使用者金鑰和資料簽名. 本篇文章,直接離線簽名,無需自己再啟動eos的相關服務. 使用者充值:需要告知使用者userId,使用者充值時備註上userId,然後後臺查詢賬戶交易記錄.判斷memo是否為使用

瑞波JAVA呼叫(離線簽名)

具體注意點請參考:https://blog.csdn.net/liu1765686161/article/details/82492937 1.需要安裝兩個jar包 https://github.com/ripple-unmaintained/ripple-lib-java 中 ri

JAVA RPC遠端呼叫伺服器實現使用者登入、註冊

先來百科掃盲 ： 什麼是 RPC（反正我也剛看的） RPC（Remote Procedure Call）—遠端過程呼叫，它是一種通過網路從遠端計算機程式上請求服務，而不需要了解底層網路技術的協議。RPC協議假定某些傳輸協議的存在，如TCP或UDP，為通訊程式之間攜帶資訊資料。在OSI

Java Web呼叫Matlab實現線上繪圖

具體操作步驟如下： 一、利用Matlab編譯jar包 （一）軟體準備： 1、本機安裝Matlab2014b win64 2、JDK1.7。據網上文章說，1.8還沒有被Matlab2014b支援，但是沒有試過。 （二）步驟： 1、編寫matlab繪圖函式 比如

XRP瑞波JAVA呼叫(離線簽名)

ripple-bouncycastle 和  ripple-core . 2. 可以編譯後放入maven倉庫,然後引用  例如: <dependency>             <groupId>com.ripple</group

BTC比特幣虛擬貨幣java通過rpc呼叫錢包

package com.tn.web.service.coin; import java.io.IOException; import java.util.*; import com.tn.entity.coin.UserCoinAddressEntity; import o

一個簡單RPC框架是如何煉成的(III)——實現帶引數的RPC呼叫

上一篇，我們制定了一個很簡單的RPC訊息 的格式，但是還遺留了兩個問題 我們並沒有實現相應的encode和decode方法，沒有基於可以跨裝置的字串傳輸，而是直接的記憶體變數傳遞。 現在的RPC request不支援帶引數的請求命令。如add(a, b), 如何在RPC訊息中描述

java中呼叫本地指令碼

java中可以呼叫本地指令碼，也可以遠端呼叫shell指令碼，但是java呼叫遠端指令碼不安全，一般不這麼做，那該怎麼呼叫呢？ 建議在本地寫個指令碼呼叫遠端指令碼，在java程式中呼叫本地指令碼，具體程式碼： private int execShell(String shellPa

RPC呼叫

1.RPC呼叫、本地呼叫和HTTP呼叫 網路呼叫一般是基於HTTP協議進行呼叫，RPC是使用TCP或者UDP協議進行呼叫，效率上回更好； 常用的RPC框架有Thrift、GRPC等； 2.RPC的呼叫時序圖     1）呼叫方呼叫Proxy請求服務，並設定非同步處

java threadlocal以及線上程池場景中的應用

  http://www.cnblogs.com/dolphin0520/p/3920407.html https://www.cnblogs.com/coshaho/p/5127135.html https://www.cnblogs.com/gscq073240/articles/6420

RPC呼叫流程（Remote Procedure Call Protocol）

網址：http://blog.jobbole.com/92290/ 要讓網路通訊細節對使用者透明，我們自然需要對通訊細節進行封裝，我們先看下一個RPC呼叫的流程： 1）服務消費方（client）呼叫以本地呼叫方式呼叫服務； 2）client stub接收到呼叫後負責將方

MySql儲存過程中傳參和不傳參以及java中呼叫程式碼

資料庫表結構 1.mysql不傳參寫儲存過程 create procedure product() -- product為儲存過程名稱 begin select * from book; end 呼叫此儲存過程為 CALL product

原始碼剖析 | 螞蟻金服 mPaaS 框架下的 RPC 呼叫歷程

背景 mPaaS-RPC 是支付寶原生的 RPC 呼叫庫。 在客戶端開發過程中，只需要簡單的呼叫庫裡封裝的函式即可完成一次資料請求過程，但是遇到異常情況往往會面對各種異常碼卻不知所云。所以這篇文章帶領大家瞭解一下 mPaaS-RPC 的呼叫過程以及各種異常碼產生的原因。 1. 使用方法 在 Andro

Jmeter之Java介面呼叫

通常用jmeter做http請求（或者其他型別）測試時，有時需要對請求的資料（或者響應的資料）進行特定的處理再進行請求，如加密、解密，需自己用java編寫一些工具類；或者需要對Java介面服務進行效能測試時，需要用到jmeter進行Java介面呼叫。以下簡單介紹下jmeter通過Java請求和B

Java JNI呼叫本地動態庫使用詳解

java native方法與JNI實現 native方法定義：               簡單地講，一個Native Method就是一個java呼叫非java程式碼的介面。一個Native Method是

java如何呼叫介面方式一

原文地址：http://www.cnblogs.com/angusbao/p/7677621.html 　　其實對於java呼叫介面進行獲取對方伺服器的資料在開發中特別常見，然而一些常用的基礎的知識總是掌握不牢，讓人容易忘記，寫下來閒的時候看看，比回想總會好一些。 　　總體而言，一些東西知識

Java api 呼叫Sqoop2進行MySQL-->Hive的資料同步

1.相關jar包 2.一些需要的引數定義在message.properties中 jdbcHiveUrl=jdbc:hive2://10.1.9.91:10000 //hive地址 jdbcHiveDriver=org.apache.hive.jdbc.Hi

機器學習weka，java api呼叫隨機森林及儲存模型

工作需要，瞭解了一下weka的java api，主要是隨機森林這一塊，剛開始學習，記錄下。 瞭解不多，直接上demo，裡面有一些註釋說明： package weka; import java.io.File; import weka.classifiers.Classifier; i

java方法呼叫流程

1.編譯器檢視物件的型別和方法名 例如，我們有一個類： public class Father { public void fun1(int a) { System.out.println("這是Father的fun1(int a)方法"); } public void