当前位置：首页 > news >正文

使用Java对接印度股票市场API开发指南

news 2025/8/27 6:24:05

以下是一篇使用Java对接印度股票数据API的技术博客：

使用Java对接印度股票市场API开发指南

StockTV API提供全面的印度股票市场数据接口，本文详细介绍如何使用Java实现对接，包含核心接口调用和实时数据推送。

一、环境准备

1. 添加依赖

<!-- Apache HttpClient -->
<dependency><groupId>org.apache.httpcomponents</groupId><artifactId>httpclient</artifactId><version>4.5.13</version>
</dependency><!-- Jackson JSON处理器 -->
<dependency><groupId>com.fasterxml.jackson.core</groupId><artifactId>jackson-databind</artifactId><version>2.13.0</version>
</dependency><!-- WebSocket客户端 -->
<dependency><groupId>org.java-websocket</groupId><artifactId>Java-WebSocket</artifactId><version>1.5.3</version>
</dependency>

2. 获取API Key

联系官方获取Key：https://t.me/CryptoRzz

二、核心API实现

1. HTTP请求工具类

import org.apache.http.client.methods.HttpGet;
import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.HttpClients;
import org.apache.http.util.EntityUtils;public class ApiClient {private static final String BASE_URL = "https://api.stocktv.top";private static final String API_KEY = "YOUR_API_KEY"; // 替换为实际Keypublic static String get(String path, Map<String, String> params) throws Exception {// 构建请求URLStringBuilder urlBuilder = new StringBuilder(BASE_URL + path);urlBuilder.append("?key=").append(API_KEY);params.forEach((k, v) -> urlBuilder.append("&").append(k).append("=").append(v));try (CloseableHttpClient httpClient = HttpClients.createDefault()) {HttpGet request = new HttpGet(urlBuilder.toString());return EntityUtils.toString(httpClient.execute(request).getEntity());}}
}

2. 获取印度股票列表

import com.fasterxml.jackson.databind.JsonNode;
import com.fasterxml.jackson.databind.ObjectMapper;public class StockService {private static final ObjectMapper mapper = new ObjectMapper();// 获取NSE交易所股票public static JsonNode getNseStocks() throws Exception {Map<String, String> params = new HashMap<>();params.put("countryId", "14");     // 印度params.put("exchangeId", "46");    // NSE交易所params.put("pageSize", "100");String response = ApiClient.get("/stock/stocks", params);return mapper.readTree(response);}// 解析示例public static void main(String[] args) throws Exception {JsonNode data = getNseStocks().get("data");data.get("records").forEach(stock -> {System.out.println("股票代码: " + stock.get("symbol").asText());System.out.println("最新价格: " + stock.get("last").asDouble());});}
}

3. 获取实时K线数据

public class KlineService {// 获取15分钟K线public static JsonNode get15mKlines(int pid) throws Exception {Map<String, String> params = new HashMap<>();params.put("pid", String.valueOf(pid));params.put("interval", "PT15M");String response = ApiClient.get("/stock/kline", params);return mapper.readTree(response);}// 使用示例public static void main(String[] args) throws Exception {JsonNode klines = get15mKlines(7310); // 股票IDklines.get("data").forEach(k -> {System.out.println("时间: " + new Date(k.get("time").asLong()));System.out.println("开盘价: " + k.get("open").asDouble());});}
}

4. 获取指数数据

public class IndexService {// 获取印度主要指数public static JsonNode getIndiaIndices() throws Exception {Map<String, String> params = new HashMap<>();params.put("countryId", "14");String response = ApiClient.get("/stock/indices", params);return mapper.readTree(response);}// 解析示例public static void main(String[] args) throws Exception {JsonNode indices = getIndiaIndices().get("data");indices.forEach(index -> {if ("NSEI".equals(index.get("symbol").asText())) {System.out.println("Nifty 50: " + index.get("last").asDouble());}});}
}

三、WebSocket实时数据推送

import org.java_websocket.client.WebSocketClient;
import org.java_websocket.handshake.ServerHandshake;import java.net.URI;public class StockWebSocket extends WebSocketClient {public StockWebSocket() {super(URI.create("wss://ws-api.stocktv.top/connect?key=" + API_KEY));}@Overridepublic void onOpen(ServerHandshake handshake) {System.out.println("连接已建立");// 发送初始订阅消息send("{\"action\":\"subscribe\",\"pids\":[7310,41602]}");}@Overridepublic void onMessage(String message) {// 解析实时行情JsonNode data = mapper.readTree(message);System.out.println("股票ID: " + data.get("pid").asText());System.out.println("最新价格: " + data.get("last_numeric").asText());}@Overridepublic void onClose(int code, String reason, boolean remote) {System.out.println("连接关闭: " + reason);}@Overridepublic void onError(Exception ex) {ex.printStackTrace();}// 使用示例public static void main(String[] args) {new StockWebSocket().connect();}
}

四、高级功能实现

1. 涨跌排行榜

public class TopStocksService {// 获取涨幅榜public static JsonNode getTopGainers() throws Exception {Map<String, String> params = new HashMap<>();params.put("countryId", "14");params.put("type", "1"); // 1=涨幅榜String response = ApiClient.get("/stock/updownList", params);return mapper.readTree(response);}
}

2. IPO新股日历

public class IpoService {// 获取即将上市的IPOpublic static JsonNode getUpcomingIpos() throws Exception {Map<String, String> params = new HashMap<>();params.put("countryId", "14");params.put("type", "1"); // 1=即将上市String response = ApiClient.get("/stock/getIpo", params);return mapper.readTree(response);}
}

五、最佳实践建议

连接管理

// 使用连接池提高性能
PoolingHttpClientConnectionManager cm = new PoolingHttpClientConnectionManager();
cm.setMaxTotal(100); // 最大连接数
cm.setDefaultMaxPerRoute(20); // 每个路由最大连接数

异常处理

try {JsonNode data = getStockData();
} catch (Exception e) {// 处理API限流(429)等错误if(e instanceof HttpResponseException) {int code = ((HttpResponseException)e).getStatusCode();if(code == 429) {Thread.sleep(1000); // 等待1秒后重试}}
}

数据缓存

// 使用Guava缓存
LoadingCache<Integer, JsonNode> stockCache = CacheBuilder.newBuilder().maximumSize(1000).expireAfterWrite(10, TimeUnit.SECONDS) // 10秒缓存.build(new CacheLoader<Integer, JsonNode>() {public JsonNode load(Integer pid) {return getStockData(pid);}});

六、完整项目结构

src/
├── main/
│   ├── java/
│   │   ├── api/
│   │   │   ├── ApiClient.java      # HTTP请求工具
│   │   │   ├── StockService.java   # 股票接口
│   │   │   ├── IndexService.java   # 指数接口
│   │   │   └── KlineService.java   # K线接口
│   │   ├── ws/
│   │   │   └── StockWebSocket.java # WebSocket客户端
│   │   └── App.java                # 主程序
│   └── resources/
└── test/                           # 单元测试