聚币API DEMO - JAVA版

自从在币市亏损之后，下决心要赚回来，想想能不能通过机器方式进行买卖操作呢，还好各大平台都提供了对应的API，故而抽个周末时间，写个简单的程序（仅提供公用的API接口调用，不提供自己的算法，如有任何疑问，可在回答区进行提问，文主尽力帮助解答）

在这里可以获取开发的私钥，公钥：
https://www.jubi.com/api/secret/keys/
这里是官方API，稍微吐槽下，比较烂：
https://www.jubi.com/help/api.html

这个是我完成的项目结构图：

image.png

client包里面包含了两个类：

BaseClient.java
作用：提供签名需要的算法

package com.standstill.client;

import com.standstill.util.DevelopUtil;
import com.standstill.util.Log4jUtil;
import com.standstill.util.MD5Util;
import org.bouncycastle.crypto.RuntimeCryptoException;
import org.bouncycastle.jce.provider.BouncyCastleProvider;

import javax.crypto.Mac;
import javax.crypto.SecretKey;
import javax.crypto.spec.SecretKeySpec;
import javax.xml.bind.annotation.adapters.HexBinaryAdapter;
import java.security.Security;
import java.util.Iterator;
import java.util.Map;
import java.util.Set;

/**
 * Created by Standstill on 17-8-19.
 */
public class BaseClient {

    /**
     * 通过参数进行签名操作
     * @param str
     * @return
     */
    protected static String makeSign(String str){
        Log4jUtil.logger.info("加密字符串： " + str);
        try {
            Security.addProvider(new BouncyCastleProvider());
            SecretKey secretKey = new SecretKeySpec(getPrivateMD5().getBytes("UTF8"),
                    "HmacSHA256");
            Mac mac = Mac.getInstance(secretKey.getAlgorithm());
            mac.init(secretKey);
            byte[] digest = mac.doFinal(str.getBytes("UTF-8"));
            String result = new HexBinaryAdapter().marshal(digest).toLowerCase();
            Log4jUtil.logger.info("加密结果： " + result);
            return result;
        } catch (Exception e) {
            throw new RuntimeCryptoException("加密异常");
        }
    }

    /**
     * 对私钥进行MD5加密
     * @return
     */
    protected static String getPrivateMD5(){
        return MD5Util.MD5(DevelopUtil.privateKey);
    }

    /**
     * 对请求参数进行连接处理，这个地方需要注意，一些接口会有参数顺序的要求
     * @param dataMap
     * @return
     */
    protected static String combineParam(Map<String,String> dataMap){
        StringBuilder rst = new StringBuilder();
        Set<String> dataSet = dataMap.keySet();
        Iterator<String> iterator = dataSet.iterator();
        while(iterator.hasNext()){
            String key = iterator.next();

            if(rst.length() != 0) rst.append("&");
            rst.append(key).append("=").append(dataMap.get(key));
        }

        return rst.toString();
    }

    /**
     * nonce的生成算法，可以使用其他方式
     * @return
     */
    protected static String generateNonceStr(){
        long timeStamp = System.currentTimeMillis();
        long twelveTimeStamp = timeStamp % 1000000000000l;
        //warning ， 此处在 2033年会出现12为noncestr的bug
        return String.valueOf(twelveTimeStamp);
    }
}

ApiClient.java
作用：提供聚币全套的API操作（涉及到自己的私密信息，就不提供返回的json样式了，需要的可以单独找我要，或者参考官方文档）

package com.standstill.client;

import com.standstill.util.DevelopUtil;
import com.standstill.util.HttpClientUtil;
import com.standstill.util.UrlUtil;

import java.util.HashMap;
import java.util.LinkedHashMap;
import java.util.Map;

/**
 * Created by Standstill on 17-8-19.
 */
public class ApiClient extends BaseClient{

    /**
     * 结果JSON：
     * 
     * @param coin
     * @return
     */
    public static String receiveOrders(String coin){
        Map<String,String> dataMap = new HashMap<String, String>();
        dataMap.put("coin" , coin);
        return HttpClientUtil.doGet(UrlUtil.GET_COIN_ORDERS, dataMap);
    }

    /**
     * 结果JSON：
     * 
     * @param coin
     * @return
     */
    public static String receiveDepth(String coin){
        Map<String,String> dataMap = new HashMap<String, String>();
        dataMap.put("coin" , coin);
        return HttpClientUtil.doGet(UrlUtil.GET_COIN_DEPTH, dataMap);
    }

    /**
     * 结果JSON：
     * 
     * @param coin
     * @return
     */
    public static String receiveDetail(String coin){
        Map<String,String> dataMap = new HashMap<String, String>();
        dataMap.put("coin" , coin);
        return HttpClientUtil.doGet(UrlUtil.GET_COIN_DETAIL , dataMap);
    }

    /**
     * 结果JSON：
     * 
     * @return
     */
    public static String receiveAllDetail(){
        Map<String,String> dataMap = new HashMap<String, String>();
        return HttpClientUtil.doGet(UrlUtil.GET_ALL_COIN_DETAIL , dataMap);
    }

    /**
     * 结果JSON：
     * 
     * @return
     */
    public static String receiveAccount(){
        Map<String,String> dataMap = new LinkedHashMap<String, String>();
        dataMap.put("nonce" ,generateNonceStr());
        dataMap.put("key" , DevelopUtil.publicKey);
        dataMap.put("signature" , makeSign(combineParam(dataMap)));
        return HttpClientUtil.doPost(UrlUtil.GET_ACCOUNT_INFO, dataMap);
    }


    /**
     * 结果JSON：
     * 
     * @return
     */
    public static String receiveTradeList(String coin , String type ,String since){
        Map<String,String> dataMap = new LinkedHashMap<String, String>();
        dataMap.put("nonce" ,generateNonceStr());
        dataMap.put("since" ,(since == null ? "0" : since) );
        dataMap.put("coin" , coin);
        dataMap.put("type" , ("open".equals(type) ? "open" : "all"));
        dataMap.put("key" , DevelopUtil.publicKey);
        dataMap.put("signature", makeSign(combineParam(dataMap)));
        return HttpClientUtil.doPost(UrlUtil.GET_TRADE_LIST, dataMap);
    }

    /**
     * 结果JSON：
     * 
     * @return
     */
    public static String receiveTradeView(String coin , String id){
        Map<String,String> dataMap = new LinkedHashMap<String, String>();
        dataMap.put("nonce" ,generateNonceStr());
        dataMap.put("coin" , coin);
        dataMap.put("id" , id);
        dataMap.put("key" , DevelopUtil.publicKey);
        dataMap.put("signature" , makeSign(combineParam(dataMap)));
        return HttpClientUtil.doPost(UrlUtil.VIEW_TRADE , dataMap);
    }

    /**
     * 结果JSON：
     * 
     * @return
     */
    public static String postTradeCancel(String coin , String id){
        Map<String,String> dataMap = new LinkedHashMap<String, String>();
        dataMap.put("nonce" ,generateNonceStr());
        dataMap.put("coin" , coin);
        dataMap.put("id" , id);
        dataMap.put("key" , DevelopUtil.publicKey);
        dataMap.put("signature" , makeSign(combineParam(dataMap)));
        return HttpClientUtil.doPost(UrlUtil.CANCEL_TRADE , dataMap);
    }

    /**
     * 结果JSON：
     * 
     * @return
     */
    public static String postTradeAdd(String coin , String amount , String price , String type){
        Map<String,String> dataMap = new LinkedHashMap<String, String>();
        dataMap.put("nonce" ,generateNonceStr());
        dataMap.put("coin" , coin);
        dataMap.put("key" , DevelopUtil.publicKey);
        dataMap.put("amount" , amount);
        dataMap.put("price" , price);
        dataMap.put("type" , ("buy".equals(type) ? "buy" : "sell"));
        dataMap.put("signature" , makeSign(combineParam(dataMap)));
        return HttpClientUtil.doPost(UrlUtil.ADD_TRADE , dataMap);
    }

}

util里面主要是工具类

CoinUtil.java
作用：币种英文简称，有些部分被注释了，看官请自行更改

package com.standstill.util;

/**
 * Created by Standstill on 17-8-19.
 */

public enum CoinUtil {
    /*
    需要过滤掉btm + hcc ，这两个手动去操作
    过滤掉cny
     */
    btc,/*drk,*/blk,vrc,tfc,jbc,ltc,doge,xpm,ppc,wdc,vtc,max,ifc,zcc,zet,eac,fz,
    skt,plc,mtc,qec,lkc,met,ytc,hlb,game,rss,rio,ktc,pgc,mryc,mcc,eth,etc,/*dnc,*/
    gooc,xrp,nxt,lsk,xas,peb/*,nhgh*/,xsgs,ans,bts,ugt,eos,tic,ico,bcc,btk,qtum,
    elc,/*hcc,*//*btm,*/act/*,cny*/
}

DevelopUtil.java
作用：开发所用的信息，包括publicKey & privateKey，这里就不贴我的了。

ErrorUtil.java
作用：官方提供的错误信息

package com.standstill.util;

import java.util.HashMap;
import java.util.Map;

/**
 * Created by Standstill on 17-8-20.
 */
public class ErrorUtil {

    private static Map<String , String> errMap;

   static{
        errMap = new HashMap<String, String>();

        errMap.put("100" , "必选参数不能为空");
        errMap.put("101" , "非法参数");
        errMap.put("102" , "请求的虚拟币不存在");
        errMap.put("103" , "密钥不存在");
        errMap.put("104" , "签名不匹配");
        errMap.put("105" , "权限不足");
        errMap.put("106" , "请求过期(nonce错误)");
        errMap.put("200" , "余额不足");
        errMap.put("201" , "买卖的数量小于最小买卖额度");
        errMap.put("202" , "下单价格必须在 0 - 1000000 之间");
        errMap.put("204" , "成交金额不能少于 10 元");
        errMap.put("205" , "gooc限制挂单价格");
        errMap.put("203" , "订单不存在");
        errMap.put("401" , "系统错误");
        errMap.put("402" , "请求过于频繁");
        errMap.put("403" , "非开放API");
        errMap.put("404" , "IP限制不能请求该资源");
        errMap.put("405" , "币种交易暂时关闭");
    }

    public static String getErrMsg(String code){
        return errMap.get(code);
    }
}

HttpClientUtil.java
作用：https请求，主要用上doGet() + doPost() 方法，代码比较长，就不贴了，有需要的请单独联系我。

Log4jUtil.java
作用：Log信息

package com.standstill.util;

import org.apache.log4j.Logger;
import org.apache.log4j.PropertyConfigurator;

/**
 * Created by Standstill on 17-8-20.
 */
public class Log4jUtil {
    public static Logger logger = Logger.getRootLogger();
    public Log4jUtil(){
        PropertyConfigurator.configure("classpath:log4j.properties");
    }
}

以及log4j.properties文件（全是摘抄来的，手动捂脸）

### 设置###
log4j.rootLogger = debug,stdout,E,I

### 输出信息到控制抬 ###
log4j.appender.stdout = org.apache.log4j.ConsoleAppender
log4j.appender.stdout.Target = System.out
log4j.appender.stdout.layout = org.apache.log4j.PatternLayout
log4j.appender.stdout.layout.ConversionPattern = [%-5p] %d{yyyy-MM-dd HH:mm:ss,SSS} method:%l%n%m%n

### 输出INFO 级别以上的日志到=E://logs/info.log ###
log4j.appender.I = org.apache.log4j.DailyRollingFileAppender
log4j.appender.I.File = log/info.log
log4j.appender.I.Append = true
log4j.appender.I.Threshold = INFO
log4j.appender.I.layout = org.apache.log4j.PatternLayout
log4j.appender.I.layout.ConversionPattern = %-d{yyyy-MM-dd HH:mm:ss}  [ %t:%r ] - [ %p ]  %m%n

### 输出ERROR 级别以上的日志到=E://logs/error.log ###
log4j.appender.E = org.apache.log4j.DailyRollingFileAppender
log4j.appender.E.File =log/error.log
log4j.appender.E.Append = true
log4j.appender.E.Threshold = ERROR
log4j.appender.E.layout = org.apache.log4j.PatternLayout
log4j.appender.E.layout.ConversionPattern = %-d{yyyy-MM-dd HH:mm:ss}  [ %t:%r ] - [ %p ]  %m%n

MD5Util.java
作用：privateKey的MD5加密，网上一大堆，注意，需要小写

package com.standstill.util;

import java.security.MessageDigest;

public class MD5Util {
    public final static String MD5(String s) {
        char hexDigits[]={'0','1','2','3','4','5','6','7','8','9','a','b','c','d','e','f'};
        try {
            byte[] btInput = s.getBytes();
            // 获得MD5摘要算法的 MessageDigest 对象
            MessageDigest mdInst = MessageDigest.getInstance("MD5");
            // 使用指定的字节更新摘要
            mdInst.update(btInput);
            // 获得密文
            byte[] md = mdInst.digest();
            // 把密文转换成十六进制的字符串形式
            int j = md.length;
            char str[] = new char[j * 2];
            int k = 0;
            for (int i = 0; i < j; i++) {
                byte byte0 = md[i];
                str[k++] = hexDigits[byte0 >>> 4 & 0xf];
                str[k++] = hexDigits[byte0 & 0xf];
            }
            return new String(str);
        } catch (Exception e) {
            e.printStackTrace();
            return null;
        }
    }
}

ResultUtil.java
作用：处理请求结果，主要是处理请求错误的情况

package com.standstill.util;

import net.sf.json.JSONArray;
import net.sf.json.JSONObject;
import org.apache.commons.lang.StringUtils;

/**
 * Created by Standstill on 17-8-20.
 */
public class ResultUtil {

    public static Object parse(String url , String result){
        if(StringUtils.isEmpty(result)){
            Log4jUtil.logger.error("API[" + url + "]请求结果为空！");
            return null;
        }

        if(result.trim().startsWith("[")){
            return JSONArray.fromObject(result);
        }

        JSONObject object;
        try{
            object = JSONObject.fromObject(result);
        }catch (Exception e){
            e.printStackTrace();
            Log4jUtil.logger.error("API[" + url + "]请求结果解析错误！");
            return null;
        }

        if(object.containsKey("result") && !object.getBoolean("result")){
            Log4jUtil.logger.error("API[" + url + "]请求错误，原因：" + ErrorUtil.getErrMsg(object.getString("code")));
            return null;
        }else{
            return object;
        }
    }
}

SSLClient.java
作用：主要是配合HttpClientUtil使用的，需要的跟我说

UrlUtil.java
作用：API请求地址

package com.standstill.util;

/**
 * Created by dearest on 2017/8/18.
 */
    public class UrlUtil {

    public static String JUBI_HOST = "https://www.jubi.com/";

    public static String GET_COIN_DETAIL = JUBI_HOST + "/api/v1/ticker/";

    public static String GET_ALL_COIN_DETAIL = JUBI_HOST + "/api/v1/allticker/";

    public static String GET_COIN_DEPTH = JUBI_HOST + "/api/v1/depth/";

    public static String GET_COIN_ORDERS = JUBI_HOST + "/api/v1/orders/";

    public static String VIEW_TRADE = JUBI_HOST + "/api/v1/trade_view/";

    public static String GET_ACCOUNT_INFO = JUBI_HOST + "/api/v1/balance/";

    public static String GET_TRADE_LIST = JUBI_HOST + "/api/v1/trade_list/";

    public static String CANCEL_TRADE = JUBI_HOST + "/api/v1/trade_cancel/";

    public static String ADD_TRADE = JUBI_HOST + "/api/v1/trade_add/";
}

额，贴完代码不知道说什么了，希望大家关注下吧，虚心接受大家的意见和建议，以及尽力帮助大家解决开发中的问题吧，烂尾的感觉，哈哈。

最近比较喜欢Coldplay的《Yellow》，送给大家：

[Yellow - Coldplay](https://music.163.com/#/song?id=17177324)
最后编辑于 ：
©著作权归作者所有,转载或内容合作请联系作者
  • 人面猴
    序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
    沈念sama阅读 205,386评论 6赞 479
  • 死咒
    序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
    沈念sama阅读 87,939评论 2赞 381
  • 救了他两次的神仙让他今天三更去死
    文/潘晓璐 我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
    开封第一讲书人阅读 151,851评论 0赞 341
  • 道士缉凶录：失踪的卖姜人
    文/不坏的土叔 我叫张陵，是天一观的道长。 经常有香客问我，道长，这世上最难降的妖魔是什么？ 我笑而不...
    开封第一讲书人阅读 54,953评论 1赞 278
  • 港岛之恋（遗憾婚礼）
    正文 为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
    茶点故事阅读 63,971评论 5赞 369
  • 恶毒庶女顶嫁案：这布局不是一般人想出来的
    文/花漫 我一把揭开白布。 她就那样静静地躺着，像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上，一...
    开封第一讲书人阅读 48,784评论 1赞 283
  • 城市分裂传说
    那天，我揣着相机与录音，去河边找鬼。 笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。 我是一名探鬼主播，决...
    沈念sama阅读 38,126评论 3赞 399
  • 双鸳鸯连环套：你想象不到人心有多黑
    文/苍兰香墨 我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
    开封第一讲书人阅读 36,765评论 0赞 258
  • 万荣杀人案实录
    序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
    沈念sama阅读 43,148评论 1赞 300
  • 护林员之死
    正文 独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,744评论 2赞 323
  • 白月光启示录
    正文 我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,858评论 1赞 333
  • 活死人
    序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
    沈念sama阅读 33,479评论 4赞 322
  • 日本核电站爆炸内幕
    正文 年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
    茶点故事阅读 39,080评论 3赞 307
  • 男人毒药：我在死后第九天来索命
    文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 30,053评论 0赞 19
  • 一桩弑父案，背后竟有这般阴谋
    文/苍兰香墨 我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,278评论 1赞 260
  • 情欲美人皮
    我被黑心中介骗来泰国打工， 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。 一个月前我还...
    沈念sama阅读 45,245评论 2赞 352
  • 代替公主和亲
    正文 我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
    茶点故事阅读 42,590评论 2赞 343

推荐阅读更多精彩内容

  • Android - 收藏集
    Android 自定义View的各种姿势1 Activity的显示之ViewRootImpl详解 Activity...
    passiontim阅读 171,486评论 25赞 707
  • Spring Cloud
    Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具（例如配置管理，服务发现，断路器，智...
    卡卡罗2017阅读 134,598评论 18赞 139
  • 2017.9.25
    跑步地点：天津，青鸟盛地健身 跑步里程：8公里 累计里程：66公里
    种花家的小小兔子阅读 188评论 0赞 0
  • 同学聚会
    早上上班的路上，听着傅佩荣讲论语，说参加同学聚会的事情。中学的时候，他一直是班上的第一名，他有个同学一直没敢跟...
    简单123的世界阅读 119评论 0赞 0
  • 《股票作手回忆录》读书笔记
    本周推荐的这本书，几年前我就读过了，当时听说这本书是很多投资大师推荐的投资必读经典书，所以就买来阅读了，可是因为当...
    sharespeak阅读 1,545评论 4赞 10