作为长期混迹在合约市场的老韭菜来说,已不能满足与手动下单来亏钱,必须得通过脚本来加速,为了达到这个目的就产生了项目。目前封装的主要是合约的API接口,不支持现货交易。
Features
- 抽象出了交易所合约的通用接口
- 支持的交易所:binance, okex, kucoin
- 支持 Rest接口 和 WebSocket
How to install
- 克隆下仓库代码执行
mvn install
- maven依赖添加到自己的项目
xml
<dependency>
<groupId>org.herman</groupId>
<artifactId>exchange-sdk</artifactId>
<version>1.0-SNAPSHOT</version>
</dependency>
How to use
FutureRestApiClient
: 主要抽象出了合约的RestApi接口FutureSubscriptionClient
: 主要抽象出了合约的WebSocket接口FutureApiInternalFactory
: 封装了创建各个交易所FutureRestApiClient和FutureSubscriptionClient的工具类
Examples
- 使用rest接口查询出Binance的标记价格
java
final FutureRestApiClient restApiClient = FutureApiInternalFactory
.getInstance()
.createBinanceFutureRestApiClient(Constants.Future.BINANCE_REST_API_BASE_URL, "xxx", "xxx");
final List<MarkPrice> markPrice = restApiClient.getMarkPrice("BTCUSDT");
System.out.println(markPrice);
输出:
[MarkPrice[symbol=BTCUSDT,markPrice=57738.69215152,time=1723775413000]]
- 使用WebSocket监听Binance的标记价格
java
final FutureSubscriptionClient subscriptionClient = FutureApiInternalFactory
.getInstance()
.createBinanceFutureSubscriptionClient(Constants.Future.BINANCE_WS_API_BASE_URL, "xxx", "xxx");
subscriptionClient.subscribeMarkPriceEvent("BTCUSDT",
markPriceEvent -> {
//订阅成功后的回调
System.out.println(markPriceEvent);
},
e -> {
//异常后的执行逻辑
e.printStackTrace();
}
);