代码拉取完成，页面将自动刷新
This is Huobi Java SDK, This is a lightweight Java library, you can import to your Java project and use this SDK to query all market data, trading and manage your account.
The SDK supports both synchronous and asynchronous RESTful API invoking, and subscribe the market data from the Websocket connection.
The SDK is compiled by Java8
For Beta version, please import the source code in java IDE (idea or eclipse)
The example code is in huobi-api-sdk/java/src/test/java/com/huobi/client/examples.
In your Java project, you can follow below steps:
SyncRequestClient syncClient = SyncRequestClient.create();
// Get the timestamp from Huobi server and print on console
long timestamp = syncClient.getExchangeTimestamp();
System.out.println(timestamp);
// Get the latest btcusdt‘s candlestick data and print the highest price on console
List<Candlestick> candlestickList =
syncClient.getLatestCandlestick("btcusdt", CandlestickInterval.DAY1, 20);
for (Candlestick item : candlestickList) {
System.out.println(item.getHigh());
}
Please NOTE:
All timestamp which is got from SDK is the Unix timestamp based on UTC.
Huobi API supports 2 types of invoking.
We recommend developers to use request method to trade, withdraw and loan, to use subscription method to access the market related data.
There are 2 clients for request method, SyncRequestClient and AsyncRequestClient. One client for subscription method, SubscriptionClient.
SyncRequestClient: It is a synchronous request, it will invoke the Huobi API via synchronous method, all invoking will be blocked until receiving the response from server.
AsyncRequestClient: It is an asynchronous request, it will invoke the Huobi API via asynchronous method, all invoking will return immediately, instead of waiting the server's response. So you must implement the onResponse() method inRequestCallback interface. As long as receiving the response of the server, callback method you defined will be called. You can use the lambda expression to simplify the implementation, see Asynchronous usage for detail.
SubscriptionClient: It is the subscription, it is used for subscribing any market data update and account change. It is asynchronous, so you must implement onUpdate() method in SubscriptionListener interface. The server will push any update for the client. if client receive the update, the onUpdate() method will be called. You can use the lambda expression to simplify the implementation, see Subscription usage for detail.
You can assign the API key and Secret key when you create the client. See below:
SyncRequestClient syncClient = SyncRequestClient.create(
"xxxxxxxx-xxxxxxxx-xxxxxxxx-xxxxx",
"xxxxxxxx-xxxxxxxx-xxxxxxxx-xxxxx");
AsyncRequestClient asyncClient = AsyncRequestClient.create(
"xxxxxxxx-xxxxxxxx-xxxxxxxx-xxxxx",
"xxxxxxxx-xxxxxxxx-xxxxxxxx-xxxxx");
SubscriptionClient subscriptionClient = SubscriptionClient.create(
"xxxxxxxx-xxxxxxxx-xxxxxxxx-xxxxx",
"xxxxxxxx-xxxxxxxx-xxxxxxxx-xxxxx");
The API key and Secret key are used for authentication.
Some APIs related with account, trading, deposit and withdraw etc require the authentication. We can name them after private interface.
The APIs only return the market data that don't need the authentication. We can name them after public interface.
If you want to invoke both public interface and private interface. You must apply API Key and Secret Key from Huobi and put them into the client you created.
If the authentication cannot pass, the invoking of private interface will fail.
If you want to invoke public interface only. You can create the client as follow:
SyncRequestClient syncClient = SyncRequestClient.create();
AsyncRequestClient asyncClient = AsyncRequestClient.create();
SubscriptionClient subscriptionClient = SubscriptionClient.create();
To support huobi cloud, you can specify the custom host.
RequestOptions or SubscriptionOptions.See below example
// Set custom host for request
RequestOptions options = new RequestOptions();
options.setUrl("https://www.xxx.yyy/");
SyncRequestClient syncClient = SyncRequestClient.create(
"xxxxxxxx-xxxxxxxx-xxxxxxxx-xxxxx",
"xxxxxxxx-xxxxxxxx-xxxxxxxx-xxxxx",
options);
AsyncRequestClient asyncClient = AsyncRequestClient.create(
"xxxxxxxx-xxxxxxxx-xxxxxxxx-xxxxx",
"xxxxxxxx-xxxxxxxx-xxxxxxxx-xxxxx",
options);
// Set custom host for subscription
SubscriptionOptions options = new SubscriptionOptions();
options.setUri("wss://www.xxx.yyy");
SubscriptionClient subscriptionClient = SubscriptionClient.create(
"xxxxxxxx-xxxxxxxx-xxxxxxxx-xxxxx",
"xxxxxxxx-xxxxxxxx-xxxxxxxx-xxxxx",
options);
If you do not set yout custom host, below default host will be used:
For request: https://api.huobi.pro
For subscription: wss://api.huobi.pro
To invoke the interface by synchronous, you can create the SyncRequestClient by calling SyncRequestClient.create(), and call the API directly.
SyncRequestClient syncClient = SyncRequestClient.create();
// Get the best bid and ask for btcusdt, print the best ask price and amount on console.
BestQuote bestQuote = client.getBestQuote("btcusdt");
System.out.println(bestQuote.getAskPrice());
System.out.println(bestQuote.getAskAmount());
To invoke the interface by asynchronous, you can create the AsyncRequestClient by calling AsyncRequestClient.create(), and call the API which implement the callback by yourself. You will get a resultset after the asynchronous invoking completed, call succeeded() to check whether the invoking succeeded or not, then call getData() to get the server's response data.
AsyncRequestClient asyncClient = AsyncRequestClient.create();
// Get the price depth for btcusdt, print bid price and ask price in first level.
asyncClient.getPriceDepth("btcusdt", 5, (priceDepthResult) -> {
if (priceDepthResult.succeeded() {
System.out.println(priceDepthResult.getData().getBids().get(0).getPrice());
System.out.println(priceDepthResult.getData().getAsks().get(0).getPrice());
}
});
To receive the subscribed data, you can create the SubscriptionClient by calling SubscriptionClient.create(). When subscribing the event, you should define your listener. See below example:
SubscriptionClient subscriptionClient = HuobiClientFactory.createSubscriptionClient();
// Subscribe the trade update for btcusdt.
subscriptionClient.subscribeTradeEvent("btcusdt", (tradeEvent) -> {
System.out.println(event.getSymbol());
for (Trade trade : tradeEvent.getTradeData()) {
System.out.println(trade.getPrice());
}
});
The subscription method supports multi-symbol string. Each symbol should be separated by a comma.
subscriptionClient.subscribeTradeEvent("btcusdt,ethusdt", (tradeEvent) -> {
......
});
In error case, such as you set the invalid symbol to getBestQuote(). The HuobiApiException will be thrown. See below example:
try {
SyncRequestClient syncClient = service.createSyncRequestClient();
// Set the invaild symbol
BestQuote bestQuote = client.getBestQuote("abcdefg");
System.out.println(bestQuote.getAskPrice());
System.out.println(bestQuote.getAskAmount());
} catch (HuobiApiException e) {
System.err.println(e.getErrorCode());
System.err.println(e.getMessage());
}
If the invoking failed, you can get the HuobiApiException in the resultset. See below example:
asyncClient.getPriceDepth("btcusdt", 5, (priceDepthResult) -> {
if (priceDepthResult.succeeded() {
System.out.println(priceDepthResult.getData().getBids().get(0).getPrice());
System.out.println(priceDepthResult.getData().getAsks().get(0).getPrice());
} else {
System.err.println(e.getErrorCode());
System.err.println(e.getMessage());
}
});
If you want to check the error, you should implement your SubscriptionErrorHandler. See below example:
subscriptionClient.subscribeTradeEvent("btcusdt",
(tradeEvent) -> {
System.out.println(event.getSymbol());
for (Trade trade : tradeEvent.getTradeData()) {
System.out.println(trade.getPrice());
}
},
(e) -> {
System.err.println(e.getErrorCode());
System.err.println(e.getMessage());
}
});
Any error made during subscription will be output to a log file, If you do not define your SubscriptionErrorHandler, the error will be output to log file only.
//Synchronous
long timestamp = syncClient.getExchangeTimestamp();
System.out.println(timestamp);
//Asynchronous
asyncClient.getExchangeTimestamp((timestampResult) -> {
if (timestampResult.succeeded()) {
System.out.println(timestampResult.getData())
}
});
//Synchronous
ExchangeInfo info = syncClient.getExchangeInfo();
for (String currency : info.getCurrencies()) {
System.out.println(currency);
}
//Asynchronous
asyncClient.getExchangeInfo((result) -> {
if (result.succeeded()) {
for (String currency : result.getData().getCurrencies()) {
System.out.println(currency);
}
}
});
//Synchronous
List<Candlestick> candlestickList = syncClient.getLatestCandlestick(
"btcusdt", CandlestickInterval.DAY1, 20);
for (Candlestick candlestick : candlestickList) {
System.out.println(candlestick.getHigh());
}
//Asynchronous
asyncClient.getCandlestick("btcusdt", CandlestickInterval.DAY1, 20, (candlestickResult) ->
{
if (candlestickResult.succeeded()) {
for (Candlestick candlestick : candlestickResult.getData()) {
System.out.println(candlestick.getHigh());
}
}
});
//Synchronous
PriceDepth depth = syncClient.getPriceDepth("btcusdt", 5);
for (DepthEntry entry : depth.getBids()) {
System.out.println(entry.getPrice());
}
//Asynchronous
asyncClient.getPriceDepth("btcusdt", 5, (depthResult) -> {
for (DepthEntry entry : depthResult.getData().getBids()) {
System.out.println(entry.getPrice());
}
}
//Synchronous
Trade trade = syncClient.getLastTrade("btcusdt");
System.out.println(trade.getPrice());
//Asynchronous
asyncClient.getLastTrade("btcusdt", (tradeResult) -> {
if (tradeResult.succeeded()) {
System.out.println(tradeResult.getData().getPrice());
}
});
//Synchronous
BestQuote bestQuote = syncClient.getBestQuote("btcusdt");
System.out.println(bestQuote.getBidPrice());
System.out.println(bestQuote.getAskPrice());
//Asynchronous
asyncClient.getBestQuote("btcusdt", (bestQuoteResult) -> {
if (bestQuoteResult.succeeded()) {
System.out.println(bestQuoteResult.getData().getBidPrice());
System.out.println(bestQuoteResult.getData().getAskPrice());
}
});
//Synchronous
List<Trade> tradeList = syncClient.getHistoricalTrade("btcusdt", 5);
System.out.println(tradeList.get(0).getPrice());
//Asynchronous
asyncClient.getHistoricalTrade("btcusdt", 5, (tradeResult) -> {
if (tradeResult.succeeded()) {
for (Trade trade : tradeResult.getData()) {
System.out.println(trade.getPrice());
}
}
});
//Synchronous
TradeStatistics statistics = syncClient.get24HTradeStatistics("btcusdt");
System.out.println(statistics.getOpen());
//Asynchronous
asyncClient.get24HTradeStatistics("btcusdt", (statisticsResult) -> {
if (statisticsResult.succeeded()) {
System.out.println(statisticsResult.getData().getHigh());
}
});
Authentication is required.
//Synchronous
Account balance = syncClient.getAccountBalance(AccountType.SPOT);
System.out.println(balance.getBalance("btc").get(0).getBalance());
//Asynchronous
asyncClient.getAccountBalance(AccountType.SPOT, (accountResult) -> {
if (accountResult.succeeded()) {
System.out.println(accountResult.getData().getBalance("btc").get(0).getBalance());
}
});
Authentication is required.
//Synchronous
WithdrawRequest request = new WithdrawRequest("xxxxxxx", new BigDecimal(0.1), "btc");
long id = syncClient.withdraw(request);
System.out.println(id);
//Asynchronous
WithdrawRequest request = new WithdrawRequest("xxxxxxx", new BigDecimal(0.1), "btc");
asyncClient.withdraw(request, (withdrawResult) -> {
if (withdrawResult.succeeded())
System.out.println(withdrawResult.getData());
});
Authentication is required.
//Synchronous
syncClient.cancelWithdraw("btc", id);
//Asynchronous
asyncClient.cancelWithdraw("btc", id, (withdrawResult) -> {
if (withdrawResult.succeeded()) {}
});
Authentication is required.
//Synchronous
List<Withdraw> withdrawList = syncClient.getWithdrawHistory("btc", id, 10);
System.out.println(withdrawList.get(0).getAmount());
List<Deposit> depositList = syncClient.getDepositHistory("btc", id, 10);
System.out.println(depositList.get(0).getAmount());
//Asynchronous
asyncClient.getWithdrawHistory("btc", id, 10, (withdrawResult) -> {
if (withdrawResult.succeeded()) {
System.out.println(withdrawResult.getData().get(0).getAmount());
}
});
asyncClient.getDepositHistory("btc", id, 10, (depositResult) -> {
if (depositResult.succeeded()) {
System.out.println(depositResult.getData().get(0).getAmount());
}
});
Authentication is required.
//Synchronous
NewOrderRequest request = new NewOrderRequest(
"btcusdt", AccountType.SPOT, OrderType.SELL_MARKET, new BigDecimal(0.1), null);
long id = syncClient.createOrder(request);
System.out.println(id);
//Asynchronous
NewOrderRequest request = new NewOrderRequest(
"btcusdt", AccountType.SPOT, OrderType.SELL_MARKET, new BigDecimal(0.1), null);
asyncClient.createOrder(request, (orderResult) -> {
if (orderResult.succeeded()) {
System.out.println(orderResult.getData());
}
});
Authentication is required.
//Synchronous
syncClient.cancelOrder("btcusdt", id);
//Asynchronous
asyncClient.cancelOrder("btcusdt", id, (cancelResult) -> {
if (cancelResult.succeeded()) {}
});
Authentication is required.
//Synchronous
CancelOpenOrderRequest request = new CancelOpenOrderRequest("btcusdt", AccountType.SPOT);
BatchCancelResult result = syncClient.cancelOpenOrders(request);
System.out.println(result.getSuccessCount());
//Asynchronous
CancelOpenOrderRequest request = new CancelOpenOrderRequest("btcusdt", AccountType.SPOT);
asyncClient.cancelOpenOrders("btcusdt", (cancelResult) -> {
if (cancelResult.succeeded()) {
System.out.println(cancelResult.getData().getSuccessCount());
}
});
Authentication is required.
//Synchronous
Order order = syncClient.getOrder(id);
System.out.println(order.getPrice());
//Asynchronous
asyncClient.getOrder("btcusdt", id, (orderResult) -> {
if (orderResult.succeeded()) {
System.out.println(orderResult.getData().getPrice());
}
});
Authentication is required.
//Synchronous
HistoricalOrdersRequest request =
new HistoricalOrdersRequest("btcusdt", OrderState.SUBMITTED);
List<Order> orderList = syncClient.getHistoricalOrders(request);
System.out.println(orderList.get(0).getPrice());
//Asynchronous
HistoricalOrdersRequest request =
new HistoricalOrdersRequest("btcusdt", OrderState.SUBMITTED);
asyncClient.getHistoricalOrders(request, (orderResult) ->{
if (orderResult.succeeded()) {
System.out.println(orderResult.getData().get(0).getPrice());
}
});
Authentication is required.
//Synchronous
long id = syncClient.applyLoan("btcusdt", "btc", new BigDecimal(10.0));
System.out.println("id");
//Asynchronous
asyncClient.applyLoan("btcusdt", "btc", new BigDecimal(10.0), (loanResult) -> {
if (loanResult.succeeded()) {
System.out.println(loanResult.getData());
}
});
Authentication is required.
//Synchronous
long id = syncClient.repayLoan(id, new BigDecimal(10.0));
System.out.println("id");
//Asynchronous
asyncClient.applyLoan("btcusdt", "btc", new BigDecimal(10.0), (loanResult) -> {
if (loanResult.succeeded()) {
System.out.println(loanResult.getData());
}
});
Authentication is required.
//Synchronous
LoanOrderRequest request = new LoanOrderRequest("btcusdt");
List<Loan> loanList = syncClient.getLoanHistory(request);
System.out.println(loanList.get(0).getLoanAmount());
//Asynchronous
LoanOrderRequest request = new LoanOrderRequest("btcusdt");
asyncClient.getLoanHistory("btcusdt", (loanResult) -> {
if (loanResult.succeeded()) {
System.out.println(loanResult.getData().get(0).getLoanAmount());
}
});
// Subscribe the trade update for btcusdt.
subscriptionClient.subscribeTradeEvent("btcusdt", (tradeEvent) -> {
System.out.println(event.getSymbol());
for (Trade trade : tradeEvent.getTradeData()) {
System.out.println(trade.getPrice());
}
});
###Subscribe candlestick/KLine update
// Subscribe candlestick update for btcusdt.
subscriptionClient.subscribeCandlestickEvent("btcusdt", (candlestickEvent) -> {
System.out.println(candlestickEvent.getSymbol());
});
Authentication is required.
// Subscribe order update
subscriptionClient.subscribeOrderUpdateEvent("btcusdt", (orderEvent) -> {
System.out.println(orderEvent.getData().getPrice());
});
Authentication is required.
// Subscribe account change.
subscriptionClient.subscribeAccountEvent(BalanceMode.AVAILABLE, (accountEvent) -> {
for (AccountChange change : accountEvent.getData()) {
System.out.println(change.getAccountType());
System.out.println("Balance: " + change.getBalance());
}
});
You can cancel all subscription by calling unsubscribeAll().
subscriptionClient.unsubscribeAll();
此处可能存在不合适展示的内容，页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容，可点击提交进行申诉，我们将尽快为您处理。
马建仓 AI 助手