如何通過Java SDK接入時時股票數據
iTick Java SDK
Java 语言版本的 iTick API SDK，提供基础、股票、指数、期货、基金、外汇、加密货币数据的 REST API 查询和 WebSocket 实时数据订阅功能。
官网地址：https://itick.org
功能特性
- 支持 REST API 查询基础、股票、指数、期货、基金、外汇、加密货币数据
- 支持 WebSocket 实时数据订阅
- 自动重连机制
- 心跳保持连接
- 回调式事件处理
安装
Maven
在您的 pom.xml 中添加以下依赖：
<dependency>
<groupId>io.github.itick</groupId>
<artifactId>sdk</artifactId>
<version>0.1.0</version>
</dependency>
Gradle
在您的 build.gradle 中添加以下依赖：
implementation 'io.github.itick:sdk:0.1.0'
从源码构建
cd java
mvn clean install
快速开始
初始化客户端
import io.github.itick.sdk.Client;
public class Example {
public static void main(String[] args) {
String token = "your_api_token";
Client client = new Client(token);
}
}
REST API 使用
外汇数据查询
// 获取外汇实时成交
var tick = client.getForexTick("GB", "EURUSD");
System.out.println(tick);
// 获取外汇实时报价
var quote = client.getForexQuote("GB", "EURUSD");
System.out.println(quote);
// 获取外汇实时盘口
var depth = client.getForexDepth("GB", "EURUSD");
System.out.println(depth);
// 获取外汇历史K线
var kline = client.getForexKline("GB", "EURUSD", 2, 10, null);
for (var k : kline) {
System.out.println(k);
}
股票数据查询
// 获取股票实时成交
var tick = client.getStockTick("US", "AAPL");
System.out.println(tick);
// 获取股票实时报价
var quote = client.getStockQuote("US", "AAPL");
System.out.println(quote);
// 获取股票实时盘口
var depth = client.getStockDepth("US", "AAPL");
System.out.println(depth);
// 获取股票历史K线
var kline = client.getStockKline("US", "AAPL", 2, 10, null);
for (var k : kline) {
System.out.println(k);
}
加密货币数据查询
// 获取加密货币实时成交
var tick = client.getCryptoTick("BA", "BTCUSDT");
System.out.println(tick);
// 获取加密货币实时报价
var quote = client.getCryptoQuote("BA", "BTCUSDT");
System.out.println(quote);
// 获取加密货币实时盘口
var depth = client.getCryptoDepth("BA", "BTCUSDT");
System.out.println(depth);
// 获取加密货币历史K线
var kline = client.getCryptoKline("BA", "BTCUSDT", 2, 10, null);
for (var k : kline) {
System.out.println(k);
}
WebSocket 使用
SDK 提供了增强的 WebSocket 功能，包括自动重连和心跳保持，用户无需手动管理连接状态。
设置回调函数
// 设置消息处理器
client.setMessageHandler(message -> {
System.out.println("Received WebSocket message: " + message);
});
// 设置错误处理器
client.setErrorHandler(error -> {
System.err.println("WebSocket error: " + error.getMessage());
});
// 设置打开处理器
client.setOpenHandler(() -> {
System.out.println("WebSocket connected");
});
// 设置关闭处理器
client.setCloseHandler(() -> {
System.out.println("WebSocket closed");
});
连接和订阅
// 连接外汇 WebSocket
client.connectForexWebSocket();
// 发送订阅消息
client.sendWebSocketMessage("{\"action\": \"subscribe\", \"codes\": [\"EURUSD\"]}");
// 等待接收消息
Thread.sleep(5000);
// 检查连接状态
System.out.println("WebSocket connected: " + client.isWebSocketConnected());
// 关闭 WebSocket
client.closeWebSocket();
其他 WebSocket 连接
// 连接股票 WebSocket
client.connectStockWebSocket();
// 连接加密货币 WebSocket
client.connectCryptoWebSocket();
WebSocket 功能说明
自动重连
SDK 内置自动重连机制，当网络异常或连接断开时，会自动尝试重新连接：
- 重连间隔：5 秒
- 最大重连次数：10 次
- 重连成功后自动恢复订阅
心跳保持
SDK 自动维护 WebSocket 连接的心跳：
- 心跳间隔：30 秒
- 自动发送 ping 消息保持连接活跃
连接状态检查
// 检查 WebSocket 是否连接
boolean connected = client.isWebSocketConnected();
完整示例
import io.github.itick.sdk.Client;
public class Main {
public static void main(String[] args) {
try {
// 初始化客户端
String token = "your_api_token";
Client client = new Client(token);
// 设置 WebSocket 消息处理器
client.setMessageHandler(message -> {
System.out.println("Received WebSocket message: " + message);
});
// 设置 WebSocket 错误处理器
client.setErrorHandler(error -> {
System.err.println("WebSocket error: " + error.getMessage());
});
// 测试 REST API
System.out.println("Testing forex tick...");
var tick = client.getForexTick("GB", "EURUSD");
System.out.println(tick);
// 测试 WebSocket
System.out.println("\nTesting WebSocket...");
client.connectForexWebSocket();
// 发送订阅消息
client.sendWebSocketMessage("{\"action\": \"subscribe\", \"codes\": [\"EURUSD\"]}");
// 等待接收消息
Thread.sleep(5000);
// 检查连接状态
System.out.println("WebSocket connected: " + client.isWebSocketConnected());
// 关闭 WebSocket
client.closeWebSocket();
} catch (Exception e) {
e.printStackTrace();
}
}
}
系统要求
- Java 11 或更高版本
- Maven 3.6 或更高版本（用于构建）
依赖项
- OkHttp 4.10.0 - HTTP 客户端
- Java-WebSocket 1.5.3 - WebSocket 客户端
- Gson 2.10.1 - JSON 解析
文档
详细 API 文档请参考：https://docs.itick.org