瑞波JAVA调用(离线签名)

小灰灰 2022-05-13 14:14 224阅读 0赞

具体注意点请参考:[https://blog.csdn.net/liu1765686161/article/details/82492937][https_blog.csdn.net_liu1765686161_article_details_82492937]

1.需要安装两个jar包 [https://github.com/ripple-unmaintained/ripple-lib-java][https_github.com_ripple-unmaintained_ripple-lib-java] 中

ripple-bouncycastle 和 ripple-core .

1.  可以编译后放入maven仓库,然后引用

例如:

com.ripple ripple-bouncycastle 1.0.0 com.ripple ripple-core 1.0.0 3,直接上代码

package com.tn.set.service.coin;

import java.io.IOException;  
import java.math.BigDecimal;  
import java.text.MessageFormat;  
import java.util.\*;

import org.apache.commons.codec.binary.Base64;  
import org.slf4j.Logger;  
import org.springframework.stereotype.Service;  
import org.springframework.util.StringUtils;

import com.alibaba.fastjson.JSON;  
import com.alibaba.fastjson.JSONArray;  
import com.alibaba.fastjson.JSONObject;  
import com.ripple.core.coretypes.AccountID;  
import com.ripple.core.coretypes.Amount;  
import com.ripple.core.coretypes.uint.UInt32;  
import com.ripple.core.types.known.tx.signed.SignedTransaction;  
import com.ripple.core.types.known.tx.txns.Payment;  
import com.tn.base.Log;  
import com.tn.util.BigDecimalUtil;  
import com.tn.util.DateUtil;  
import com.tn.util.HttpUtil;

/\*\*

*  XRP操作
 *  @author xhl
 *  @create 2017/10/27  
    \*\*/  
    @Service  
    public class CopyOfCoinXrpService \{
    
    private String getUrl = “[https://data.ripple.com][https_data.ripple.com]”;  
    private String postUrl = “[https://s1.ripple.com:51234][https_s1.ripple.com_51234]”;  
    private String address = “rani9PZFVtQtAjVsvQY7AGc7xZVFLjPc1Z”;  
    private String password = “”;
    
    private static final String gasFee = “100”;  
    private static final String COIN\_XRP = “XRP”;
    
    private Logger log = Log.get();
    
    private final static String RESULT = “result”;  
    private final static String SUCCESS = “success”;  
    private final static String TES\_SUCCESS = “tesSUCCESS”;
    
    private final static String METHOD\_GET\_TRANSACTION = “/v2/accounts/\{0\}/transactions”;  
    private final static String METHOD\_GET\_BALANCE = “/v2/accounts/\{0\}/balances”;
    
    private final static String METHOD\_POST\_INDEX = “ledger\_current”;  
    private final static String METHOD\_POST\_ACCOUNT\_INFO = “account\_info”;  
    private final static String METHOD\_POST\_SUBMIT = “submit”;
    
    public static void main(String args\[\]) throws Exception\{  
    CopyOfCoinXrpService XRPUtils = new CopyOfCoinXrpService();  
    // System.out.println(XRPUtils.send(“rG2pkYL2q9jDnEA7xraKH7gXLXo17Tj4tX”, 0.1));  
    // System.out.println(XRPUtils.parseTransaction(“0”));  
    System.out.println(XRPUtils.sign(“rG2pkYL2q9jDnEA7xraKH7gXLXo17Tj4tX”,1000.0));  
    \}
    
    public String getAddress()\{  
    return address;  
    \}
    
    /\*\*
    
     *  发送交易
     *  @param address
     *  @param value
     *  @return  
        \*/  
        public String send(String toAddress,double value)\{  
        String txBlob = this.sign(toAddress, value);  
        if (StringUtils.isEmpty(txBlob)) \{  
        log.error(“签名失败:\{\}”,toAddress);  
        return null;  
        \}  
        HashMap<String, Object> params = new HashMap<String, Object>();  
        params.put(“tx\_blob”, txBlob);  
        //签名  
        JSONObject json = doRequest(METHOD\_POST\_SUBMIT, params);  
        if (!isError(json)) \{  
        JSONObject result = json.getJSONObject(RESULT);  
        if (result != null) \{  
        if (TES\_SUCCESS.equals(result.getString(“engine\_result”))) \{  
        String hash = result.getJSONObject(“tx\_json”).getString(“hash”);  
        if (!StringUtils.isEmpty(hash)) \{  
        [log.info][](“转账成功：toAddress:\{\},value:\{\},hash:\{\}”,toAddress,value,hash);  
        return hash;  
        \}else \{  
        log.error(“转账失败：toAddress:\{\},value:\{\},hash:\{\}”,toAddress,value,hash);  
        \}  
        \}  
        \}  
        \}  
        return null;  
        \}
    
    /\*\*
    
     *  签名
     *  @param address
     *  @param value
     *  @return tx\_blob  
        \*/  
        public String sign(String toAddress,Double value)\{  
        value = BigDecimalUtil.mul(value, 1000000);  
        Integer vInteger = BigDecimal.valueOf(value).intValue();  
        Map<String, String> map = getAccountSequenceAndLedgerCurrentIndex();  
        Payment payment = new Payment();  
        [payment.as][](AccountID.Account, address);  
        [payment.as][](AccountID.Destination, toAddress);  
        [payment.as][](UInt32.DestinationTag, “1”);  
        [payment.as][](Amount.Amount, vInteger.toString());  
        [payment.as][](UInt32.Sequence, map.get(“accountSequence”));  
        [payment.as][](UInt32.LastLedgerSequence, map.get(“ledgerCurrentIndex”)+4);  
        [payment.as][](Amount.Fee, gasFee);  
        SignedTransaction signed = payment.sign(password);  
        if (signed != null) \{  
        return signed.tx\_blob;  
        \}  
        return null;  
        \}
    
    public Map<String, String> getAccountSequenceAndLedgerCurrentIndex()\{  
    HashMap<String, String> params = new HashMap<String, String>();  
    params.put(“account”, address);  
    params.put(“strict”, “true”);  
    params.put(“ledger\_index”, “current”);  
    params.put(“queue”, “true”);  
    JSONObject re = doRequest(METHOD\_POST\_ACCOUNT\_INFO,params);  
    if (re != null) \{  
    JSONObject result = re.getJSONObject(“result”);  
    if (SUCCESS.equals(result.getString(“status”))) \{  
    Map<String, String> map = new HashMap<String, String>();  
    map.put(“accountSequence”, result.getJSONObject(“account\_data”).getString(“Sequence”));  
    map.put(“ledgerCurrentIndex”, result.getString(“ledger\_current\_index”));  
    return map;  
    \}  
    \}  
    return null;  
    \}
    
    /\*\*
    
     *  获取用户交易序列号
     *  @return  
        \*/  
        public long getAccountSequence()\{  
        HashMap<String, String> params = new HashMap<String, String>();  
        params.put(“account”, address);  
        params.put(“strict”, “true”);  
        params.put(“ledger\_index”, “current”);  
        params.put(“queue”, “true”);  
        JSONObject re = doRequest(METHOD\_POST\_ACCOUNT\_INFO,params);  
        if (re != null) \{  
        JSONObject result = re.getJSONObject(“result”);  
        if (SUCCESS.equals(result.getString(“status”))) \{  
        return result.getJSONObject(“account\_data”).getLongValue(“Sequence”);  
        \}  
        \}  
        return 0L;  
        \}
    
    /\*\*
    
     *  获取最新序列
     *  @return  
        \*/  
        public long getLedgerIndex()\{  
        JSONObject re = doRequest(METHOD\_POST\_INDEX);  
        if (re != null) \{  
        JSONObject result = re.getJSONObject(“result”);  
        if (SUCCESS.equals(result.getString(“status”))) \{  
        return result.getLongValue(“ledger\_current\_index”);  
        \}  
        \}  
        return 0L;  
        \}
    
    /\*\*
    
     *  XRP查询余额
     *  @return  
        \*/  
        public double getBalance()\{  
        HashMap<String, String> params = new HashMap<String, String>();  
        params.put(“currency”, COIN\_XRP);  
        String re = HttpUtil.jsonGet(getUrl + MessageFormat.format(METHOD\_GET\_BALANCE, address), params);  
        [log.info][](“获取XRP余额:\{\}”,re);  
        if(!StringUtils.isEmpty(re))\{  
        JSONObject json = JSON.parseObject(re);  
        if (SUCCESS.equals(json.getString(RESULT))) \{  
        JSONArray array = json.getJSONArray(“balances”);  
        if (array != null && array.size() > 0) \{  
        //总余额  
        double balance = array.getJSONObject(0).getDoubleValue(“value”);  
        if (balance >= 20) \{  
        //可用余额 xrp会冻结20个币  
        return BigDecimalUtil.sub(balance, 20);  
        \}  
        \}  
        \}  
        \}  
        return 0.00;  
        \}
    
    public Long parseTransaction(String startTm) \{  
    HashMap<String, String> params = new HashMap<String, String>();  
    if (!StringUtils.isEmpty(startTm)) \{  
    Date d = new Date(BigDecimalUtil.longAdd(Long.parseLong(startTm), 1000L));  
    params.put(“start”, DateUtil.dateToString(d, “yyyy-MM-dd’T’HH:mm:ss”));  
    \}  
    params.put(“result”, “tesSUCCESS”);  
    params.put(“type”, “Payment”);  
    params.put(“limit”, “1”);  
    String re = HttpUtil.jsonGet(getUrl + MessageFormat.format(METHOD\_GET\_TRANSACTION, address), params);  
    if(!StringUtils.isEmpty(re))\{  
    JSONObject json = JSON.parseObject(re);  
    if (SUCCESS.equals(json.getString(RESULT))) \{  
    // marker = json.getString(“marker”);  
    JSONArray transactions = json.getJSONArray(“transactions”);  
    if (transactions != null && transactions.size() > 0) \{  
    for (Object object : transactions) \{  
    JSONObject transaction = (JSONObject)object;  
    String hash = transaction.getString(“hash”);  
    String dateString = transaction.getString(“date”);  
    Date date =DateUtil.getStringToDate(dateString,“yyyy-MM-dd’T’HH:mm:ss”);  
    JSONObject tx = transaction.getJSONObject(“tx”);  
    String destinationTag = tx.getString(“DestinationTag”);  
    if (StringUtils.isEmpty(destinationTag)) \{  
    [log.info][](“非用户充值记录”);  
    return date.getTime();  
    \}  
    String to = tx.getString(“Destination”);  
    if (!address.equals(to)) \{  
    [log.info][](“非用户充值记录,地址不一致”);  
    return date.getTime();  
    \}  
    //校验用户是否存在  
    /*UserEntity user = userService.getUserById(Integer.parseInt(destinationTag));  
    if (user == null) \{  
    [log.info][](“用户不存在：\{\}”,destinationTag);  
    return date.getTime();  
    \}*/  
    double amount = tx.getDoubleValue(“Amount”);  
    if (amount > 0 ) \{  
    amount = BigDecimalUtil.div(amount, 1000000, 6);  
    \}else \{  
    log.error(“交易金额异常：\{\}”,amount);  
    return date.getTime();  
    \}  
    //添加充值记录  
    \}  
    \}  
    \}  
    \}  
    return null;  
    \}
    
    private boolean isError(JSONObject json)\{  
    if( json == null || (!StringUtils.isEmpty(json.getString(“error”)) && json.get(“error”) != “null”))\{  
    return true;  
    \}  
    return false;  
    \}  
    private JSONObject doRequest(String method,Object… params)\{  
    JSONObject param = new JSONObject();  
    param.put(“id”,System.currentTimeMillis()+"");  
    param.put(“jsonrpc”,“2.0”);  
    param.put(“method”,method);  
    if(params != null)\{  
    param.put(“params”,params);  
    \}  
    String creb = Base64.encodeBase64String((address+":"+password).getBytes());  
    Map<String,String> headers = new HashMap<>(2);  
    headers.put(“Authorization”,"Basic "+creb);  
    String resp = “”;  
    try\{  
    resp = HttpUtil.jsonPost(postUrl,headers,param.toJSONString());  
    \}catch (Exception e)\{  
    [log.info][](e.getMessage());  
    if (e instanceof IOException)\{  
    resp = “\{\}”;  
    \}  
    \}  
    [log.info][](resp);  
    return JSON.parseObject(resp);  
    \}

\}  
希望能帮到大家，欢迎大家一起分享。

[https_blog.csdn.net_liu1765686161_article_details_82492937]: https://blog.csdn.net/liu1765686161/article/details/82492937
[https_github.com_ripple-unmaintained_ripple-lib-java]: https://github.com/ripple-unmaintained/ripple-lib-java
[https_data.ripple.com]: https://data.ripple.com
[https_s1.ripple.com_51234]: https://s1.ripple.com:51234
[log.info]: http://log.info
[payment.as]: http://payment.as