使用Java对接印度股票市场API 实时数据、IPO和K线（Kline）的PHP对接方案

我将为您提供使用Java对接印度股票API的详细方案。根据文档内容，StockTV API支持印度股票数据，印度的countryId为14。
Java对接StockTV印度股票API

一、环境准备与基础配置

1. 添加依赖

在pom.xml中添加必要的依赖：

1. <dependencies>
2.    
3.     <dependency>
4.         <groupId>org.apache.httpcomponents</groupId>
5.         httpclient</artifactId>
6.         <version>4.5.13</version>
7.     </dependency>
8.    
9.    
10.     <dependency>
11.         <groupId>com.fasterxml.jackson.core</groupId>
12.         jackson-databind</artifactId>
13.         <version>2.15.2</version>
14.     </dependency>
15.    
16.    
17.     <dependency>
18.         <groupId>org.java-websocket</groupId>
19.         Java-WebSocket</artifactId>
20.         <version>1.5.3</version>
21.     </dependency>
22. </dependencies>

复制代码

2. 基础配置类

1. package com.stocktv.india;
3. import com.fasterxml.jackson.databind.ObjectMapper;
4. import org.apache.http.HttpEntity;
5. import org.apache.http.client.methods.CloseableHttpResponse;
6. import org.apache.http.client.methods.HttpGet;
7. import org.apache.http.impl.client.CloseableHttpClient;
8. import org.apache.http.impl.client.HttpClients;
9. import org.apache.http.util.EntityUtils;
10. import java.io.IOException;
11. import java.util.HashMap;
12. import java.util.Map;
14. public class StockTVIndiaAPI {
15.     private static final String BASE_URL = "https://api.stocktv.top";
16.     private static final String API_KEY = "您的API_KEY"; // 请替换为实际的Key
17.     private static final ObjectMapper objectMapper = new ObjectMapper();
18.     private static final int INDIA_COUNTRY_ID = 14; // 印度的countryId
19.    
20.     /**
21.      * 发送HTTP GET请求
22.      */
23.     private static String sendGetRequest(String endpoint, Map<String, String> params) throws IOException {
24.         StringBuilder urlBuilder = new StringBuilder(BASE_URL + endpoint);
25.         params.put("key", API_KEY);
26.         
27.         if (!params.isEmpty()) {
28.             urlBuilder.append("?");
29.             for (Map.Entry<String, String> entry : params.entrySet()) {
30.                 urlBuilder.append(entry.getKey())
31.                           .append("=")
32.                           .append(java.net.URLEncoder.encode(entry.getValue(), "UTF-8"))
33.                           .append("&");
34.             }
35.             urlBuilder.deleteCharAt(urlBuilder.length() - 1); // 移除最后一个&
36.         }
37.         
38.         try (CloseableHttpClient httpClient = HttpClients.createDefault()) {
39.             HttpGet httpGet = new HttpGet(urlBuilder.toString());
40.             try (CloseableHttpResponse response = httpClient.execute(httpGet)) {
41.                 HttpEntity entity = response.getEntity();
42.                 if (entity != null) {
43.                     return EntityUtils.toString(entity);
44.                 }
45.             }
46.         }
47.         return null;
48.     }
49.    
50.     /**
51.      * 解析JSON响应
52.      */
53.     private static <T> T parseResponse(String json, Class<T> clazz) throws IOException {
54.         return objectMapper.readValue(json, clazz);
55.     }
56. }

复制代码

二、核心API接口实现

1. 获取印度股票市场列表

1. package com.stocktv.india;
3. import com.fasterxml.jackson.annotation.JsonProperty;
4. import java.util.List;
5. import java.util.Map;
7. public class MarketListResponse {
8.     @JsonProperty("code")
9.     private int code;
10.    
11.     @JsonProperty("message")
12.     private String message;
13.    
14.     @JsonProperty("data")
15.     private MarketData data;
16.    
17.     // 数据类
18.     public static class MarketData {
19.         @JsonProperty("records")
20.         private List<StockRecord> records;
21.         
22.         @JsonProperty("total")
23.         private int total;
24.         
25.         @JsonProperty("size")
26.         private int size;
27.         
28.         @JsonProperty("current")
29.         private int current;
30.         
31.         @JsonProperty("pages")
32.         private int pages;
33.         
34.         // Getters
35.         public List<StockRecord> getRecords() { return records; }
36.         public int getTotal() { return total; }
37.         public int getSize() { return size; }
38.         public int getCurrent() { return current; }
39.         public int getPages() { return pages; }
40.     }
41.    
42.     // 股票记录类
43.     public static class StockRecord {
44.         @JsonProperty("id")
45.         private Long id; // pid
46.         
47.         @JsonProperty("name")
48.         private String name; // 股票名称
49.         
50.         @JsonProperty("symbol")
51.         private String symbol; // 股票代码
52.         
53.         @JsonProperty("last")
54.         private Double last; // 最新价
55.         
56.         @JsonProperty("chg")
57.         private Double chg; // 涨跌额
58.         
59.         @JsonProperty("chgPct")
60.         private Double chgPct; // 涨跌百分比
61.         
62.         @JsonProperty("high")
63.         private Double high; // 最高价
64.         
65.         @JsonProperty("low")
66.         private Double low; // 最低价
67.         
68.         @JsonProperty("volume")
69.         private Long volume; // 成交量
70.         
71.         @JsonProperty("open")
72.         private Boolean open; // 是否开市
73.         
74.         @JsonProperty("countryId")
75.         private Integer countryId; // 国家ID
76.         
77.         @JsonProperty("countryNameTranslated")
78.         private String countryNameTranslated; // 国家名称
79.         
80.         @JsonProperty("flag")
81.         private String flag; // 国家简称
82.         
83.         @JsonProperty("exchangeId")
84.         private Integer exchangeId; // 交易所ID
85.         
86.         @JsonProperty("lastClose")
87.         private Double lastClose; // 前收盘价
88.         
89.         // Getters
90.         public Long getId() { return id; }
91.         public String getName() { return name; }
92.         public String getSymbol() { return symbol; }
93.         public Double getLast() { return last; }
94.         public Double getChg() { return chg; }
95.         public Double getChgPct() { return chgPct; }
96.         public Double getHigh() { return high; }
97.         public Double getLow() { return low; }
98.         public Long getVolume() { return volume; }
99.         public Boolean getOpen() { return open; }
100.         public Integer getCountryId() { return countryId; }
101.         public String getCountryNameTranslated() { return countryNameTranslated; }
102.         public String getFlag() { return flag; }
103.         public Integer getExchangeId() { return exchangeId; }
104.         public Double getLastClose() { return lastClose; }
105.     }
106.    
107.     // Getters
108.     public int getCode() { return code; }
109.     public String getMessage() { return message; }
110.     public MarketData getData() { return data; }
111. }

复制代码

1. package com.stocktv.india;
3. import java.io.IOException;
4. import java.util.HashMap;
5. import java.util.Map;
7. public class IndiaStockService {
8.     private static final int INDIA_COUNTRY_ID = 14;
9.    
10.     /**
11.      * 获取印度股票市场列表
12.      */
13.     public static MarketListResponse getIndiaStockList(int page, int pageSize) throws IOException {
14.         Map<String, String> params = new HashMap<>();
15.         params.put("countryId", String.valueOf(INDIA_COUNTRY_ID));
16.         params.put("page", String.valueOf(page));
17.         params.put("pageSize", String.valueOf(pageSize));
18.         
19.         String response = StockTVIndiaAPI.sendGetRequest("/stock/stocks", params);
20.         return StockTVIndiaAPI.parseResponse(response, MarketListResponse.class);
21.     }
22.    
23.     /**
24.      * 示例：获取印度股票列表并打印
25.      */
26.     public static void main(String[] args) {
27.         try {
28.             MarketListResponse response = getIndiaStockList(1, 10);
29.             
30.             if (response.getCode() == 200 && response.getData() != null) {
31.                 System.out.println("印度股票列表 (共" + response.getData().getTotal() + "只股票):");
32.                 System.out.println("==================================================");
33.                
34.                 for (MarketListResponse.StockRecord stock : response.getData().getRecords()) {
35.                     System.out.printf("股票: %-30s 代码: %-10s 最新价: %8.2f 涨跌: %6.2f%%\n",
36.                             stock.getName(),
37.                             stock.getSymbol(),
38.                             stock.getLast(),
39.                             stock.getChgPct());
40.                 }
41.             } else {
42.                 System.out.println("请求失败: " + response.getMessage());
43.             }
44.         } catch (IOException e) {
45.             e.printStackTrace();
46.         }
47.     }
48. }

复制代码

2. 查询特定印度股票

1. public class QueryStockResponse {
2.     @JsonProperty("code")
3.     private int code;
4.    
5.     @JsonProperty("message")
6.     private String message;
7.    
8.     @JsonProperty("data")
9.     private List<MarketListResponse.StockRecord> data;
10.    
11.     // Getters
12.     public int getCode() { return code; }
13.     public String getMessage() { return message; }
14.     public List<MarketListResponse.StockRecord> getData() { return data; }
15. }
17. public class IndiaStockQueryService {
18.     /**
19.      * 查询印度股票（通过PID、名称或代码）
20.      */
21.     public static QueryStockResponse queryIndiaStock(Long pid, String symbol, String name) throws IOException {
22.         Map<String, String> params = new HashMap<>();
23.         
24.         if (pid != null) {
25.             params.put("id", pid.toString());
26.         }
27.         if (symbol != null && !symbol.isEmpty()) {
28.             params.put("symbol", symbol);
29.         }
30.         if (name != null && !name.isEmpty()) {
31.             params.put("name", name);
32.         }
33.         
34.         String response = StockTVIndiaAPI.sendGetRequest("/stock/queryStocks", params);
35.         QueryStockResponse result = StockTVIndiaAPI.parseResponse(response, QueryStockResponse.class);
36.         
37.         // 筛选印度股票（根据countryId=14或flag='IN'）
38.         if (result.getCode() == 200 && result.getData() != null) {
39.             List<MarketListResponse.StockRecord> filteredList = result.getData().stream()
40.                     .filter(stock -> stock.getCountryId() != null && stock.getCountryId() == INDIA_COUNTRY_ID)
41.                     .collect(Collectors.toList());
42.             
43.             // 创建新的响应对象
44.             QueryStockResponse filteredResponse = new QueryStockResponse();
45.             filteredResponse.setCode(result.getCode());
46.             filteredResponse.setMessage(result.getMessage());
47.             filteredResponse.setData(filteredList);
48.             
49.             return filteredResponse;
50.         }
51.         
52.         return result;
53.     }
54. }

复制代码

3. 获取印度K线数据

1. public class KlineData {
2.     @JsonProperty("time")
3.     private Long time; // 时间戳
4.    
5.     @JsonProperty("open")
6.     private Double open; // 开盘价
7.    
8.     @JsonProperty("high")
9.     private Double high; // 最高价
10.    
11.     @JsonProperty("low")
12.     private Double low; // 最低价
13.    
14.     @JsonProperty("close")
15.     private Double close; // 收盘价
16.    
17.     @JsonProperty("volume")
18.     private Double volume; // 成交量
19.    
20.     @JsonProperty("vo")
21.     private Double vo; // 成交额
22.    
23.     // Getters
24.     public Long getTime() { return time; }
25.     public Double getOpen() { return open; }
26.     public Double getHigh() { return high; }
27.     public Double getLow() { return low; }
28.     public Double getClose() { return close; }
29.     public Double getVolume() { return volume; }
30.     public Double getVo() { return vo; }
31. }
33. public class KlineResponse {
34.     @JsonProperty("code")
35.     private int code;
36.    
37.     @JsonProperty("message")
38.     private String message;
39.    
40.     @JsonProperty("data")
41.     private List<KlineData> data;
42.    
43.     // Getters
44.     public int getCode() { return code; }
45.     public String getMessage() { return message; }
46.     public List<KlineData> getData() { return data; }
47. }
49. public class IndiaKlineService {
50.     /**
51.      * 获取印度股票K线数据
52.      * @param pid 股票PID
53.      * @param interval 时间间隔: PT5M, PT15M, PT1H, PT5H, P1D, P1W, P1M
54.      */
55.     public static KlineResponse getIndiaStockKline(Long pid, String interval) throws IOException {
56.         Map<String, String> params = new HashMap<>();
57.         params.put("pid", pid.toString());
58.         params.put("interval", interval);
59.         
60.         String response = StockTVIndiaAPI.sendGetRequest("/stock/kline", params);
61.         return StockTVIndiaAPI.parseResponse(response, KlineResponse.class);
62.     }
63.    
64.     /**
65.      * 示例：获取日K线数据
66.      */
67.     public static void printDailyKline(Long pid) {
68.         try {
69.             KlineResponse response = getIndiaStockKline(pid, "P1D");
70.             
71.             if (response.getCode() == 200 && response.getData() != null && !response.getData().isEmpty()) {
72.                 System.out.println("K线数据 (日线):");
73.                 System.out.println("==================================================");
74.                
75.                 // 显示最近5天的数据
76.                 int count = Math.min(response.getData().size(), 5);
77.                 for (int i = response.getData().size() - count; i < response.getData().size(); i++) {
78.                     KlineData kline = response.getData().get(i);
79.                     Date date = new Date(kline.getTime());
80.                     SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
81.                     
82.                     System.out.printf("日期: %s 开:%.2f 高:%.2f 低:%.2f 收:%.2f 量:%.0f\n",
83.                             sdf.format(date),
84.                             kline.getOpen(),
85.                             kline.getHigh(),
86.                             kline.getLow(),
87.                             kline.getClose(),
88.                             kline.getVolume());
89.                 }
90.             }
91.         } catch (IOException e) {
92.             e.printStackTrace();
93.         }
94.     }
95. }

复制代码

4. 获取印度市场指数

1. public class IndicesResponse {
2.     @JsonProperty("code")
3.     private int code;
4.    
5.     @JsonProperty("message")
6.     private String message;
7.    
8.     @JsonProperty("data")
9.     private List<IndexData> data;
10.    
11.     public static class IndexData {
12.         @JsonProperty("id")
13.         private Long id;
14.         
15.         @JsonProperty("name")
16.         private String name;
17.         
18.         @JsonProperty("symbol")
19.         private String symbol;
20.         
21.         @JsonProperty("last")
22.         private Double last;
23.         
24.         @JsonProperty("chg")
25.         private Double chg;
26.         
27.         @JsonProperty("chgPct")
28.         private Double chgPct;
29.         
30.         @JsonProperty("flag")
31.         private String flag;
32.         
33.         @JsonProperty("isOpen")
34.         private Boolean isOpen;
35.         
36.         // Getters
37.         public Long getId() { return id; }
38.         public String getName() { return name; }
39.         public String getSymbol() { return symbol; }
40.         public Double getLast() { return last; }
41.         public Double getChg() { return chg; }
42.         public Double getChgPct() { return chgPct; }
43.         public String getFlag() { return flag; }
44.         public Boolean getIsOpen() { return isOpen; }
45.     }
46.    
47.     // Getters
48.     public int getCode() { return code; }
49.     public String getMessage() { return message; }
50.     public List<IndexData> getData() { return data; }
51. }
53. public class IndiaIndicesService {
54.     /**
55.      * 获取印度市场指数
56.      */
57.     public static IndicesResponse getIndiaIndices() throws IOException {
58.         Map<String, String> params = new HashMap<>();
59.         params.put("countryId", String.valueOf(INDIA_COUNTRY_ID));
60.         
61.         String response = StockTVIndiaAPI.sendGetRequest("/stock/indices", params);
62.         return StockTVIndiaAPI.parseResponse(response, IndicesResponse.class);
63.     }
64. }

复制代码

5. 获取印度IPO新股日历

1. public class IpoResponse {
2.     @JsonProperty("code")
3.     private int code;
4.    
5.     @JsonProperty("message")
6.     private String message;
7.    
8.     @JsonProperty("data")
9.     private List<IpoData> data;
10.    
11.     public static class IpoData {
12.         @JsonProperty("id")
13.         private Long id;
14.         
15.         @JsonProperty("ipoListing")
16.         private Long ipoListing; // 上市时间戳
17.         
18.         @JsonProperty("country")
19.         private String country;
20.         
21.         @JsonProperty("company")
22.         private String company;
23.         
24.         @JsonProperty("exchange")
25.         private String exchange;
26.         
27.         @JsonProperty("ipoPrice")
28.         private String ipoPrice;
29.         
30.         @JsonProperty("last")
31.         private String last;
32.         
33.         @JsonProperty("symbol")
34.         private String symbol;
35.         
36.         @JsonProperty("date")
37.         private String date;
38.         
39.         @JsonProperty("pid")
40.         private Long pid;
41.         
42.         // Getters
43.         public Long getId() { return id; }
44.         public Long getIpoListing() { return ipoListing; }
45.         public String getCountry() { return country; }
46.         public String getCompany() { return company; }
47.         public String getExchange() { return exchange; }
48.         public String getIpoPrice() { return ipoPrice; }
49.         public String getLast() { return last; }
50.         public String getSymbol() { return symbol; }
51.         public String getDate() { return date; }
52.         public Long getPid() { return pid; }
53.     }
54.    
55.     // Getters
56.     public int getCode() { return code; }
57.     public String getMessage() { return message; }
58.     public List<IpoData> getData() { return data; }
59. }
61. public class IndiaIpoService {
62.     /**
63.      * 获取印度IPO信息
64.      * @param type 1=未上市, 2=已上市
65.      */
66.     public static IpoResponse getIndiaIpo(Integer type) throws IOException {
67.         Map<String, String> params = new HashMap<>();
68.         params.put("countryId", String.valueOf(INDIA_COUNTRY_ID));
69.         
70.         if (type != null && (type == 1 || type == 2)) {
71.             params.put("type", type.toString());
72.         }
73.         
74.         String response = StockTVIndiaAPI.sendGetRequest("/stock/getIpo", params);
75.         return StockTVIndiaAPI.parseResponse(response, IpoResponse.class);
76.     }
77. }

复制代码

6. 获取印度涨跌排行榜

1. public class UpDownListResponse {
2.     @JsonProperty("code")
3.     private int code;
4.    
5.     @JsonProperty("message")
6.     private String message;
7.    
8.     @JsonProperty("data")
9.     private List<MarketListResponse.StockRecord> data;
10.    
11.     // Getters
12.     public int getCode() { return code; }
13.     public String getMessage() { return message; }
14.     public List<MarketListResponse.StockRecord> getData() { return data; }
15. }
17. public class IndiaRankService {
18.     /**
19.      * 获取印度股票排行榜
20.      * @param type 1涨幅榜 2跌幅榜 3涨停榜 4跌停榜
21.      */
22.     public static UpDownListResponse getIndiaStockRank(int type) throws IOException {
23.         Map<String, String> params = new HashMap<>();
24.         params.put("countryId", String.valueOf(INDIA_COUNTRY_ID));
25.         params.put("type", String.valueOf(type));
26.         
27.         String response = StockTVIndiaAPI.sendGetRequest("/stock/updownList", params);
28.         return StockTVIndiaAPI.parseResponse(response, UpDownListResponse.class);
29.     }
30.    
31.     /**
32.      * 示例：打印涨幅榜TOP 10
33.      */
34.     public static void printTopGainers() {
35.         try {
36.             UpDownListResponse response = getIndiaStockRank(1);
37.             
38.             if (response.getCode() == 200 && response.getData() != null) {
39.                 System.out.println("印度股票涨幅榜 TOP 10:");
40.                 System.out.println("==================================================");
41.                
42.                 int count = Math.min(response.getData().size(), 10);
43.                 for (int i = 0; i < count; i++) {
44.                     MarketListResponse.StockRecord stock = response.getData().get(i);
45.                     System.out.printf("%2d. %-30s %-10s %7.2f%%\n",
46.                             i + 1,
47.                             stock.getName(),
48.                             stock.getSymbol(),
49.                             stock.getChgPct());
50.                 }
51.             }
52.         } catch (IOException e) {
53.             e.printStackTrace();
54.         }
55.     }
56. }

复制代码

三、WebSocket实时数据（核心）

1. package com.stocktv.india.websocket;
3. import org.java_websocket.client.WebSocketClient;
4. import org.java_websocket.handshake.ServerHandshake;
5. import org.json.JSONObject;
6. import java.net.URI;
7. import java.util.ArrayList;
8. import java.util.List;
9. import java.util.Timer;
10. import java.util.TimerTask;
12. public class IndiaStockWebSocketClient extends WebSocketClient {
13.     private static final String WS_URL = "wss://ws-api.stocktv.top/connect?key=您的API_KEY";
14.     private List<Long> subscribedPids = new ArrayList<>();
15.    
16.     public IndiaStockWebSocketClient() {
17.         super(URI.create(WS_URL));
18.     }
19.    
20.     @Override
21.     public void onOpen(ServerHandshake handshakedata) {
22.         System.out.println("WebSocket连接已建立");
23.         
24.         // 连接成功后发送订阅消息
25.         if (!subscribedPids.isEmpty()) {
26.             subscribeToPids(subscribedPids);
27.         }
28.         
29.         // 启动心跳定时器
30.         startHeartbeat();
31.     }
32.    
33.     @Override
34.     public void onMessage(String message) {
35.         // 解析实时数据
36.         JSONObject data = new JSONObject(message);
37.         String pid = data.optString("pid");
38.         String lastPrice = data.optString("last_numeric");
39.         String change = data.optString("pc");
40.         String changePercent = data.optString("pcp");
41.         String volume = data.optString("turnover_numeric");
42.         
43.         System.out.printf("实时数据 - PID: %s, 最新价: %s, 涨跌额: %s, 涨跌幅: %s%%, 成交量: %s\n",
44.                 pid, lastPrice, change, changePercent, volume);
45.     }
46.    
47.     @Override
48.     public void onClose(int code, String reason, boolean remote) {
49.         System.out.println("WebSocket连接关闭: " + reason);
50.     }
51.    
52.     @Override
53.     public void onError(Exception ex) {
54.         System.err.println("WebSocket错误: " + ex.getMessage());
55.     }
56.    
57.     /**
58.      * 订阅股票PID
59.      */
60.     public void subscribeToPids(List<Long> pids) {
61.         this.subscribedPids = pids;
62.         
63.         if (isOpen()) {
64.             JSONObject subscribeMsg = new JSONObject();
65.             subscribeMsg.put("action", "subscribe");
66.             
67.             List<String> pidStrings = new ArrayList<>();
68.             for (Long pid : pids) {
69.                 pidStrings.add(pid.toString());
70.             }
71.             subscribeMsg.put("pids", pidStrings);
72.             
73.             send(subscribeMsg.toString());
74.             System.out.println("已发送订阅请求: " + subscribeMsg.toString());
75.         }
76.     }
77.    
78.     /**
79.      * 启动心跳定时器
80.      */
81.     private void startHeartbeat() {
82.         Timer timer = new Timer(true);
83.         timer.scheduleAtFixedRate(new TimerTask() {
84.             @Override
85.             public void run() {
86.                 if (isOpen()) {
87.                     send(""); // 发送空消息作为心跳
88.                     System.out.println("发送心跳...");
89.                 }
90.             }
91.         }, 0, 30000); // 每30秒发送一次心跳
92.     }
93.    
94.     /**
95.      * 使用示例
96.      */
97.     public static void main(String[] args) throws Exception {
98.         IndiaStockWebSocketClient client = new IndiaStockWebSocketClient();
99.         
100.         // 连接到WebSocket服务器
101.         client.connectBlocking(); // 阻塞连接
102.         
103.         // 等待连接建立
104.         Thread.sleep(1000);
105.         
106.         // 订阅印度股票（示例PID）
107.         List<Long> pids = new ArrayList<>();
108.         pids.add(7310L);  // 示例PID
109.         pids.add(17976L); // 示例PID
110.         
111.         client.subscribeToPids(pids);
112.         
113.         // 保持连接
114.         Thread.sleep(60000); // 保持连接60秒
115.         
116.         client.close();
117.     }
118. }

复制代码

四、完整使用示例

1. package com.stocktv.india;
3. import java.io.IOException;
4. import java.text.SimpleDateFormat;
5. import java.util.Date;
7. public class IndiaStockAPIDemo {
8.     public static void main(String[] args) {
9.         try {
10.             // 1. 获取印度股票列表
11.             System.out.println("=== 印度股票列表 ===");
12.             MarketListResponse stockList = IndiaStockService.getIndiaStockList(1, 10);
13.             if (stockList.getCode() == 200) {
14.                 for (MarketListResponse.StockRecord stock : stockList.getData().getRecords()) {
15.                     System.out.printf("%s (%s): %.2f 涨跌: %.2f%%\n",
16.                             stock.getName(),
17.                             stock.getSymbol(),
18.                             stock.getLast(),
19.                             stock.getChgPct());
20.                 }
21.             }
22.             
23.             // 2. 获取印度市场指数
24.             System.out.println("\n=== 印度市场指数 ===");
25.             IndicesResponse indices = IndiaIndicesService.getIndiaIndices();
26.             if (indices.getCode() == 200) {
27.                 for (IndicesResponse.IndexData index : indices.getData()) {
28.                     System.out.printf("%s (%s): %.2f 涨跌: %.2f%%\n",
29.                             index.getName(),
30.                             index.getSymbol(),
31.                             index.getLast(),
32.                             index.getChgPct());
33.                 }
34.             }
35.             
36.             // 3. 获取印度IPO信息
37.             System.out.println("\n=== 印度IPO新股 ===");
38.             IpoResponse ipoList = IndiaIpoService.getIndiaIpo(1); // 未上市IPO
39.             if (ipoList.getCode() == 200 && ipoList.getData() != null) {
40.                 for (IpoResponse.IpoData ipo : ipoList.getData()) {
41.                     Date listingDate = new Date(ipo.getIpoListing() * 1000);
42.                     SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");
43.                     System.out.printf("公司: %s, 发行价: %s, 上市日期: %s\n",
44.                             ipo.getCompany(),
45.                             ipo.getIpoPrice(),
46.                             sdf.format(listingDate));
47.                 }
48.             }
49.             
50.             // 4. 获取涨跌排行榜
51.             System.out.println("\n=== 印度股票涨幅榜 ===");
52.             IndiaRankService.printTopGainers();
53.             
54.             // 5. 获取K线数据（假设有股票PID）
55.             System.out.println("\n=== 印度股票K线数据 ===");
56.             IndiaKlineService.printDailyKline(7310L); // 示例PID
57.             
58.         } catch (IOException e) {
59.             System.err.println("API调用失败: " + e.getMessage());
60.             e.printStackTrace();
61.         }
62.     }
63. }

复制代码

五、重要注意事项

• API Key：所有请求都需要在URL参数中添加key=您的API_KEY
  
• 国家ID：印度固定为countryId=14
  
• 实时数据：使用WebSocket接口获取实时行情
  
• 错误处理：始终检查响应中的code字段，200表示成功
  
• 并发限制：合理控制请求频率，避免过度调用
  

六、数据结构说明

从文档中的示例数据可以看到，印度股票数据包含以下关键字段：

• 基础信息：id(PID), name, symbol, countryId(14), flag("IN")
  
• 行情数据：last, chg, chgPct, high, low, volume
  
• 时间信息：time, open(是否开市)
  
• 技术指标：technicalDay, technicalHour等
  
• 基本面数据：fundamentalMarketCap, fundamentalRevenue等
  

七、最佳实践建议

• 连接池管理：使用HTTP连接池提高性能
  
• 异常处理：添加重试机制和熔断机制
  
• 数据缓存：对频繁访问的数据进行缓存
  
• 日志记录：记录API调用和错误信息
  
• 配置管理：将API Key等配置信息放在配置文件中
  

这个Java实现方案涵盖了印度股票数据的实时行情、K线、指数、IPO和排行榜等核心功能。您可以根据具体需求选择使用HTTP接口或WebSocket接口获取数据。

来源：程序园用户自行投稿发布，如果侵权，请联系站长删除
免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！