Java 对接印度股票数据源实现 http+ws实时数据

以下是使用 Java 对接 StockTV 印度股票数据源的完整实现，包括实时行情、K线数据、公司信息等功能。
1. 项目依赖

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

1. <dependencies>
2.    
3.     <dependency>
4.         <groupId>org.apache.httpcomponents</groupId>
5.         httpclient</artifactId>
6.         <version>4.5.14</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.    
23.    
24.     <dependency>
25.         <groupId>org.slf4j</groupId>
26.         slf4j-api</artifactId>
27.         <version>2.0.7</version>
28.     </dependency>
29.     <dependency>
30.         <groupId>org.slf4j</groupId>
31.         slf4j-simple</artifactId>
32.         <version>2.0.7</version>
33.     </dependency>
34. </dependencies>

复制代码

2. 配置类

1. package com.stocktv.india.config;
3. import com.fasterxml.jackson.databind.ObjectMapper;
4. import org.apache.http.impl.client.CloseableHttpClient;
5. import org.apache.http.impl.client.HttpClients;
7. public class StockTVConfig {
8.    
9.     // API 基础配置
10.     public static final String BASE_URL = "https://api.stocktv.top";
11.     public static final String WS_URL = "wss://ws-api.stocktv.top/connect";
12.    
13.     // 印度市场特定配置
14.     public static final int INDIA_COUNTRY_ID = 14;
15.     public static final int NSE_EXCHANGE_ID = 46;
16.     public static final int BSE_EXCHANGE_ID = 74;
17.    
18.     // API Key - 请替换为实际的 API Key
19.     private String apiKey;
20.    
21.     // HTTP 客户端
22.     private final CloseableHttpClient httpClient;
23.     private final ObjectMapper objectMapper;
24.    
25.     public StockTVConfig(String apiKey) {
26.         this.apiKey = apiKey;
27.         this.httpClient = HttpClients.createDefault();
28.         this.objectMapper = new ObjectMapper();
29.     }
30.    
31.     // Getters
32.     public String getApiKey() { return apiKey; }
33.     public CloseableHttpClient getHttpClient() { return httpClient; }
34.     public ObjectMapper getObjectMapper() { return objectMapper; }
35. }

复制代码

3. 数据模型类

股票基本信息

1. package com.stocktv.india.model;
3. import com.fasterxml.jackson.annotation.JsonProperty;
4. import lombok.Data;
6. import java.math.BigDecimal;
8. @Data
9. public class Stock {
10.     @JsonProperty("id")
11.     private Long id;
12.    
13.     @JsonProperty("symbol")
14.     private String symbol;
15.    
16.     @JsonProperty("name")
17.     private String name;
18.    
19.     @JsonProperty("last")
20.     private BigDecimal lastPrice;
21.    
22.     @JsonProperty("chg")
23.     private BigDecimal change;
24.    
25.     @JsonProperty("chgPct")
26.     private BigDecimal changePercent;
27.    
28.     @JsonProperty("high")
29.     private BigDecimal high;
30.    
31.     @JsonProperty("low")
32.     private BigDecimal low;
33.    
34.     @JsonProperty("volume")
35.     private Long volume;
36.    
37.     @JsonProperty("open")
38.     private Boolean isOpen;
39.    
40.     @JsonProperty("exchangeId")
41.     private Integer exchangeId;
42.    
43.     @JsonProperty("countryId")
44.     private Integer countryId;
45.    
46.     @JsonProperty("time")
47.     private Long timestamp;
48.    
49.     @JsonProperty("fundamentalMarketCap")
50.     private BigDecimal marketCap;
51.    
52.     @JsonProperty("fundamentalRevenue")
53.     private String revenue;
54.    
55.     // 技术指标
56.     @JsonProperty("technicalDay")
57.     private String technicalDay;
58.    
59.     @JsonProperty("technicalHour")
60.     private String technicalHour;
61.    
62.     @JsonProperty("technicalWeek")
63.     private String technicalWeek;
64.    
65.     @JsonProperty("technicalMonth")
66.     private String technicalMonth;
67. }

复制代码

K线数据

1. package com.stocktv.india.model;
3. import com.fasterxml.jackson.annotation.JsonProperty;
4. import lombok.Data;
6. import java.math.BigDecimal;
8. @Data
9. public class KLine {
10.     @JsonProperty("time")
11.     private Long timestamp;
12.    
13.     @JsonProperty("open")
14.     private BigDecimal open;
15.    
16.     @JsonProperty("high")
17.     private BigDecimal high;
18.    
19.     @JsonProperty("low")
20.     private BigDecimal low;
21.    
22.     @JsonProperty("close")
23.     private BigDecimal close;
24.    
25.     @JsonProperty("volume")
26.     private Long volume;
27.    
28.     @JsonProperty("vo")
29.     private BigDecimal turnover;
30. }

复制代码

指数数据

1. package com.stocktv.india.model;
3. import com.fasterxml.jackson.annotation.JsonProperty;
4. import lombok.Data;
6. import java.math.BigDecimal;
8. @Data
9. public class Index {
10.     @JsonProperty("id")
11.     private Long id;
12.    
13.     @JsonProperty("name")
14.     private String name;
15.    
16.     @JsonProperty("symbol")
17.     private String symbol;
18.    
19.     @JsonProperty("last")
20.     private BigDecimal lastPrice;
21.    
22.     @JsonProperty("chg")
23.     private BigDecimal change;
24.    
25.     @JsonProperty("chgPct")
26.     private BigDecimal changePercent;
27.    
28.     @JsonProperty("high")
29.     private BigDecimal high;
30.    
31.     @JsonProperty("low")
32.     private BigDecimal low;
33.    
34.     @JsonProperty("isOpen")
35.     private Boolean isOpen;
36.    
37.     @JsonProperty("time")
38.     private Long timestamp;
39. }

复制代码

API 响应包装类

1. package com.stocktv.india.model;
3. import com.fasterxml.jackson.annotation.JsonProperty;
4. import lombok.Data;
6. import java.util.List;
8. @Data
9. public class ApiResponse<T> {
10.     @JsonProperty("code")
11.     private Integer code;
12.    
13.     @JsonProperty("message")
14.     private String message;
15.    
16.     @JsonProperty("data")
17.     private T data;
18. }
20. @Data
21. class StockListResponse {
22.     @JsonProperty("records")
23.     private List<Stock> records;
24.    
25.     @JsonProperty("total")
26.     private Integer total;
27.    
28.     @JsonProperty("current")
29.     private Integer current;
30.    
31.     @JsonProperty("pages")
32.     private Integer pages;
33. }

复制代码

4. HTTP API 客户端

1. package com.stocktv.india.client;
3. import com.fasterxml.jackson.core.type.TypeReference;
4. import com.stocktv.india.config.StockTVConfig;
5. import com.stocktv.india.model.*;
6. import org.apache.http.client.methods.CloseableHttpResponse;
7. import org.apache.http.client.methods.HttpGet;
8. import org.apache.http.client.utils.URIBuilder;
9. import org.apache.http.impl.client.CloseableHttpClient;
10. import org.apache.http.util.EntityUtils;
11. import org.slf4j.Logger;
12. import org.slf4j.LoggerFactory;
14. import java.io.IOException;
15. import java.net.URI;
16. import java.net.URISyntaxException;
17. import java.util.List;
19. public class StockTVHttpClient {
20.    
21.     private static final Logger logger = LoggerFactory.getLogger(StockTVHttpClient.class);
22.    
23.     private final StockTVConfig config;
24.     private final CloseableHttpClient httpClient;
25.    
26.     public StockTVHttpClient(StockTVConfig config) {
27.         this.config = config;
28.         this.httpClient = config.getHttpClient();
29.     }
30.    
31.     /**
32.      * 获取印度股票列表
33.      */
34.     public List<Stock> getIndiaStocks(Integer pageSize, Integer page) throws IOException, URISyntaxException {
35.         URI uri = new URIBuilder(config.BASE_URL + "/stock/stocks")
36.                 .addParameter("countryId", String.valueOf(config.INDIA_COUNTRY_ID))
37.                 .addParameter("pageSize", String.valueOf(pageSize))
38.                 .addParameter("page", String.valueOf(page))
39.                 .addParameter("key", config.getApiKey())
40.                 .build();
41.         
42.         ApiResponse<StockListResponse> response = executeGetRequest(uri,
43.             new TypeReference>() {});
44.         
45.         if (response.getCode() == 200) {
46.             return response.getData().getRecords();
47.         } else {
48.             throw new RuntimeException("API Error: " + response.getMessage());
49.         }
50.     }
51.    
52.     /**
53.      * 查询单个股票
54.      */
55.     public List<Stock> queryStock(Long pid, String symbol, String name) throws IOException, URISyntaxException {
56.         URIBuilder uriBuilder = new URIBuilder(config.BASE_URL + "/stock/queryStocks")
57.                 .addParameter("key", config.getApiKey());
58.         
59.         if (pid != null) {
60.             uriBuilder.addParameter("id", String.valueOf(pid));
61.         }
62.         if (symbol != null) {
63.             uriBuilder.addParameter("symbol", symbol);
64.         }
65.         if (name != null) {
66.             uriBuilder.addParameter("name", name);
67.         }
68.         
69.         URI uri = uriBuilder.build();
70.         
71.         ApiResponse<List<Stock>> response = executeGetRequest(uri,
72.             new TypeReference>>() {});
73.         
74.         return response.getData();
75.     }
76.    
77.     /**
78.      * 批量查询多个股票
79.      */
80.     public List<Stock> getStocksByPids(List<Long> pids) throws IOException, URISyntaxException {
81.         String pidsStr = String.join(",", pids.stream().map(String::valueOf).toArray(String[]::new));
82.         
83.         URI uri = new URIBuilder(config.BASE_URL + "/stock/stocksByPids")
84.                 .addParameter("key", config.getApiKey())
85.                 .addParameter("pids", pidsStr)
86.                 .build();
87.         
88.         ApiResponse<List<Stock>> response = executeGetRequest(uri,
89.             new TypeReference>>() {});
90.         
91.         return response.getData();
92.     }
93.    
94.     /**
95.      * 获取印度主要指数
96.      */
97.     public List<Index> getIndiaIndices() throws IOException, URISyntaxException {
98.         URI uri = new URIBuilder(config.BASE_URL + "/stock/indices")
99.                 .addParameter("countryId", String.valueOf(config.INDIA_COUNTRY_ID))
100.                 .addParameter("key", config.getApiKey())
101.                 .build();
102.         
103.         ApiResponse<List<Index>> response = executeGetRequest(uri,
104.             new TypeReference>>() {});
105.         
106.         return response.getData();
107.     }
108.    
109.     /**
110.      * 获取K线数据
111.      */
112.     public List<KLine> getKLineData(Long pid, String interval) throws IOException, URISyntaxException {
113.         URI uri = new URIBuilder(config.BASE_URL + "/stock/kline")
114.                 .addParameter("pid", String.valueOf(pid))
115.                 .addParameter("interval", interval)
116.                 .addParameter("key", config.getApiKey())
117.                 .build();
118.         
119.         ApiResponse<List<KLine>> response = executeGetRequest(uri,
120.             new TypeReference>>() {});
121.         
122.         return response.getData();
123.     }
124.    
125.     /**
126.      * 获取涨跌排行榜
127.      */
128.     public List<Stock> getUpDownList(Integer type) throws IOException, URISyntaxException {
129.         URI uri = new URIBuilder(config.BASE_URL + "/stock/updownList")
130.                 .addParameter("countryId", String.valueOf(config.INDIA_COUNTRY_ID))
131.                 .addParameter("type", String.valueOf(type))
132.                 .addParameter("key", config.getApiKey())
133.                 .build();
134.         
135.         ApiResponse<List<Stock>> response = executeGetRequest(uri,
136.             new TypeReference>>() {});
137.         
138.         return response.getData();
139.     }
140.    
141.     /**
142.      * 通用GET请求执行方法
143.      */
144.     private <T> T executeGetRequest(URI uri, TypeReference<T> typeReference) throws IOException {
145.         HttpGet request = new HttpGet(uri);
146.         
147.         try (CloseableHttpResponse response = httpClient.execute(request)) {
148.             String responseBody = EntityUtils.toString(response.getEntity());
149.             logger.debug("API Response: {}", responseBody);
150.             
151.             return config.getObjectMapper().readValue(responseBody, typeReference);
152.         }
153.     }
154. }

复制代码

5. WebSocket 实时数据客户端

1. package com.stocktv.india.client;
3. import com.fasterxml.jackson.databind.JsonNode;
4. import com.fasterxml.jackson.databind.ObjectMapper;
5. import com.stocktv.india.config.StockTVConfig;
6. import org.java_websocket.client.WebSocketClient;
7. import org.java_websocket.handshake.ServerHandshake;
8. import org.slf4j.Logger;
9. import org.slf4j.LoggerFactory;
11. import java.net.URI;
12. import java.util.concurrent.CountDownLatch;
13. import java.util.concurrent.TimeUnit;
15. public class StockTVWebSocketClient {
16.    
17.     private static final Logger logger = LoggerFactory.getLogger(StockTVWebSocketClient.class);
18.    
19.     private final StockTVConfig config;
20.     private final ObjectMapper objectMapper;
21.     private WebSocketClient webSocketClient;
22.     private CountDownLatch connectionLatch;
23.    
24.     public StockTVWebSocketClient(StockTVConfig config) {
25.         this.config = config;
26.         this.objectMapper = config.getObjectMapper();
27.     }
28.    
29.     /**
30.      * 连接WebSocket服务器
31.      */
32.     public void connect() throws Exception {
33.         String wsUrl = config.WS_URL + "?key=" + config.getApiKey();
34.         URI serverUri = URI.create(wsUrl);
35.         
36.         connectionLatch = new CountDownLatch(1);
37.         
38.         webSocketClient = new WebSocketClient(serverUri) {
39.             @Override
40.             public void onOpen(ServerHandshake handshake) {
41.                 logger.info("WebSocket连接已建立");
42.                 connectionLatch.countDown();
43.             }
44.             
45.             @Override
46.             public void onMessage(String message) {
47.                 try {
48.                     handleMessage(message);
49.                 } catch (Exception e) {
50.                     logger.error("处理WebSocket消息时出错", e);
51.                 }
52.             }
53.             
54.             @Override
55.             public void onClose(int code, String reason, boolean remote) {
56.                 logger.info("WebSocket连接已关闭: code={}, reason={}, remote={}", code, reason, remote);
57.             }
58.             
59.             @Override
60.             public void onError(Exception ex) {
61.                 logger.error("WebSocket连接错误", ex);
62.             }
63.         };
64.         
65.         webSocketClient.connect();
66.         
67.         // 等待连接建立
68.         if (!connectionLatch.await(10, TimeUnit.SECONDS)) {
69.             throw new RuntimeException("WebSocket连接超时");
70.         }
71.     }
72.    
73.     /**
74.      * 处理收到的消息
75.      */
76.     private void handleMessage(String message) throws Exception {
77.         JsonNode jsonNode = objectMapper.readTree(message);
78.         
79.         // 解析实时行情数据
80.         if (jsonNode.has("pid")) {
81.             RealTimeData realTimeData = objectMapper.treeToValue(jsonNode, RealTimeData.class);
82.             onRealTimeData(realTimeData);
83.         } else {
84.             logger.info("收到消息: {}", message);
85.         }
86.     }
87.    
88.     /**
89.      * 处理实时行情数据 - 需要子类重写
90.      */
91.     protected void onRealTimeData(RealTimeData data) {
92.         logger.info("实时行情: {} - 最新价: {}, 涨跌幅: {}%",
93.             data.getPid(), data.getLastNumeric(), data.getPcp());
94.     }
95.    
96.     /**
97.      * 发送消息
98.      */
99.     public void sendMessage(String message) {
100.         if (webSocketClient != null && webSocketClient.isOpen()) {
101.             webSocketClient.send(message);
102.         }
103.     }
104.    
105.     /**
106.      * 关闭连接
107.      */
108.     public void close() {
109.         if (webSocketClient != null) {
110.             webSocketClient.close();
111.         }
112.     }
113.    
114.     /**
115.      * 实时数据模型
116.      */
117.     public static class RealTimeData {
118.         private String pid;
119.         private String lastNumeric;
120.         private String bid;
121.         private String ask;
122.         private String high;
123.         private String low;
124.         private String lastClose;
125.         private String pc;
126.         private String pcp;
127.         private String turnoverNumeric;
128.         private String time;
129.         private String timestamp;
130.         private Integer type;
131.         
132.         // Getters and Setters
133.         public String getPid() { return pid; }
134.         public void setPid(String pid) { this.pid = pid; }
135.         public String getLastNumeric() { return lastNumeric; }
136.         public void setLastNumeric(String lastNumeric) { this.lastNumeric = lastNumeric; }
137.         public String getBid() { return bid; }
138.         public void setBid(String bid) { this.bid = bid; }
139.         public String getAsk() { return ask; }
140.         public void setAsk(String ask) { this.ask = ask; }
141.         public String getHigh() { return high; }
142.         public void setHigh(String high) { this.high = high; }
143.         public String getLow() { return low; }
144.         public void setLow(String low) { this.low = low; }
145.         public String getLastClose() { return lastClose; }
146.         public void setLastClose(String lastClose) { this.lastClose = lastClose; }
147.         public String getPc() { return pc; }
148.         public void setPc(String pc) { this.pc = pc; }
149.         public String getPcp() { return pcp; }
150.         public void setPcp(String pcp) { this.pcp = pcp; }
151.         public String getTurnoverNumeric() { return turnoverNumeric; }
152.         public void setTurnoverNumeric(String turnoverNumeric) { this.turnoverNumeric = turnoverNumeric; }
153.         public String getTime() { return time; }
154.         public void setTime(String time) { this.time = time; }
155.         public String getTimestamp() { return timestamp; }
156.         public void setTimestamp(String timestamp) { this.timestamp = timestamp; }
157.         public Integer getType() { return type; }
158.         public void setType(Integer type) { this.type = type; }
159.     }
160. }

复制代码

6. 服务类

1. package com.stocktv.india.service;
3. import com.stocktv.india.client.StockTVHttpClient;
4. import com.stocktv.india.client.StockTVWebSocketClient;
5. import com.stocktv.india.config.StockTVConfig;
6. import com.stocktv.india.model.Index;
7. import com.stocktv.india.model.KLine;
8. import com.stocktv.india.model.Stock;
9. import org.slf4j.Logger;
10. import org.slf4j.LoggerFactory;
12. import java.util.List;
14. public class IndiaStockService {
15.    
16.     private static final Logger logger = LoggerFactory.getLogger(IndiaStockService.class);
17.    
18.     private final StockTVHttpClient httpClient;
19.     private final StockTVWebSocketClient webSocketClient;
20.    
21.     public IndiaStockService(String apiKey) {
22.         StockTVConfig config = new StockTVConfig(apiKey);
23.         this.httpClient = new StockTVHttpClient(config);
24.         this.webSocketClient = new StockTVWebSocketClient(config);
25.     }
26.    
27.     /**
28.      * 获取Nifty 50成分股
29.      */
30.     public List<Stock> getNifty50Stocks() {
31.         try {
32.             // 获取前50只股票（实际应该根据Nifty 50成分股列表查询）
33.             return httpClient.getIndiaStocks(50, 1);
34.         } catch (Exception e) {
35.             logger.error("获取Nifty 50成分股失败", e);
36.             throw new RuntimeException(e);
37.         }
38.     }
39.    
40.     /**
41.      * 获取印度主要指数
42.      */
43.     public List<Index> getMajorIndices() {
44.         try {
45.             return httpClient.getIndiaIndices();
46.         } catch (Exception e) {
47.             logger.error("获取印度指数失败", e);
48.             throw new RuntimeException(e);
49.         }
50.     }
51.    
52.     /**
53.      * 查询特定股票
54.      */
55.     public List<Stock> getStockBySymbol(String symbol) {
56.         try {
57.             return httpClient.queryStock(null, symbol, null);
58.         } catch (Exception e) {
59.             logger.error("查询股票失败: " + symbol, e);
60.             throw new RuntimeException(e);
61.         }
62.     }
63.    
64.     /**
65.      * 获取股票K线数据
66.      */
67.     public List<KLine> getStockKLine(Long pid, String interval) {
68.         try {
69.             return httpClient.getKLineData(pid, interval);
70.         } catch (Exception e) {
71.             logger.error("获取K线数据失败: pid=" + pid, e);
72.             throw new RuntimeException(e);
73.         }
74.     }
75.    
76.     /**
77.      * 获取涨幅榜
78.      */
79.     public List<Stock> getGainers() {
80.         try {
81.             return httpClient.getUpDownList(1); // 1表示涨幅榜
82.         } catch (Exception e) {
83.             logger.error("获取涨幅榜失败", e);
84.             throw new RuntimeException(e);
85.         }
86.     }
87.    
88.     /**
89.      * 启动实时数据监听
90.      */
91.     public void startRealTimeMonitoring() {
92.         try {
93.             webSocketClient.connect();
94.             logger.info("实时数据监听已启动");
95.         } catch (Exception e) {
96.             logger.error("启动实时数据监听失败", e);
97.             throw new RuntimeException(e);
98.         }
99.     }
100.    
101.     /**
102.      * 停止实时数据监听
103.      */
104.     public void stopRealTimeMonitoring() {
105.         webSocketClient.close();
106.         logger.info("实时数据监听已停止");
107.     }
108. }

复制代码

7. 使用示例

1. package com.stocktv.india.demo;
3. import com.stocktv.india.service.IndiaStockService;
4. import com.stocktv.india.client.StockTVWebSocketClient;
5. import com.stocktv.india.model.Index;
6. import com.stocktv.india.model.KLine;
7. import com.stocktv.india.model.Stock;
8. import org.slf4j.Logger;
9. import org.slf4j.LoggerFactory;
11. import java.util.List;
13. public class IndiaStockDemo {
14.    
15.     private static final Logger logger = LoggerFactory.getLogger(IndiaStockDemo.class);
16.    
17.     public static void main(String[] args) {
18.         // 替换为实际的 API Key
19.         String apiKey = "您的API_KEY";
20.         
21.         IndiaStockService stockService = new IndiaStockService(apiKey);
22.         
23.         try {
24.             // 1. 获取印度主要指数
25.             logger.info("=== 印度主要指数 ===");
26.             List<Index> indices = stockService.getMajorIndices();
27.             indices.forEach(index ->
28.                 logger.info("{}: {} ({}{}%)",
29.                     index.getName(), index.getLastPrice(),
30.                     index.getChange().doubleValue() > 0 ? "+" : "",
31.                     index.getChangePercent())
32.             );
33.             
34.             // 2. 获取Nifty 50成分股
35.             logger.info("\n=== Nifty 50成分股（示例）===");
36.             List<Stock> niftyStocks = stockService.getNifty50Stocks();
37.             niftyStocks.stream().limit(10).forEach(stock ->
38.                 logger.info("{} ({}) : {} INR, 涨跌幅: {}%",
39.                     stock.getSymbol(), stock.getName(),
40.                     stock.getLastPrice(), stock.getChangePercent())
41.             );
42.             
43.             // 3. 查询特定股票
44.             logger.info("\n=== 查询RELIANCE股票 ===");
45.             List<Stock> relianceStock = stockService.getStockBySymbol("RELIANCE");
46.             if (!relianceStock.isEmpty()) {
47.                 Stock stock = relianceStock.get(0);
48.                 logger.info("Reliance Industries: {} INR, 成交量: {}",
49.                     stock.getLastPrice(), stock.getVolume());
50.             }
51.             
52.             // 4. 获取K线数据
53.             logger.info("\n=== RELIANCE日K线数据 ===");
54.             if (!relianceStock.isEmpty()) {
55.                 Long pid = relianceStock.get(0).getId();
56.                 List<KLine> kLines = stockService.getStockKLine(pid, "P1D");
57.                 kLines.stream().limit(5).forEach(kLine ->
58.                     logger.info("时间: {}, 开: {}, 高: {}, 低: {}, 收: {}",
59.                         kLine.getTimestamp(), kLine.getOpen(),
60.                         kLine.getHigh(), kLine.getLow(), kLine.getClose())
61.                 );
62.             }
63.             
64.             // 5. 获取涨幅榜
65.             logger.info("\n=== 今日涨幅榜 ===");
66.             List<Stock> gainers = stockService.getGainers();
67.             gainers.stream().limit(5).forEach(stock ->
68.                 logger.info("{}: {} INR, 涨幅: {}%",
69.                     stock.getSymbol(), stock.getLastPrice(), stock.getChangePercent())
70.             );
71.             
72.             // 6. 启动实时数据监听（可选）
73.             logger.info("\n=== 启动实时数据监听 ===");
74.             // stockService.startRealTimeMonitoring();
75.             
76.             // 保持程序运行一段时间
77.             Thread.sleep(30000);
78.             
79.             // 停止实时数据监听
80.             // stockService.stopRealTimeMonitoring();
81.             
82.         } catch (Exception e) {
83.             logger.error("演示程序执行失败", e);
84.         }
85.     }
86. }

复制代码

8. 自定义实时数据处理

如果需要自定义实时数据处理逻辑，可以继承 StockTVWebSocketClient：

1. package com.stocktv.india.custom;
3. import com.stocktv.india.client.StockTVWebSocketClient;
4. import com.stocktv.india.config.StockTVConfig;
5. import org.slf4j.Logger;
6. import org.slf4j.LoggerFactory;
8. public class CustomWebSocketClient extends StockTVWebSocketClient {
9.    
10.     private static final Logger logger = LoggerFactory.getLogger(CustomWebSocketClient.class);
11.    
12.     public CustomWebSocketClient(StockTVConfig config) {
13.         super(config);
14.     }
15.    
16.     @Override
17.     protected void onRealTimeData(RealTimeData data) {
18.         // 自定义实时数据处理逻辑
19.         if ("7310".equals(data.getPid())) { // RELIANCE的PID
20.             logger.info("RELIANCE实时行情 - 价格: {}, 涨跌幅: {}%, 成交量: {}",
21.                 data.getLastNumeric(), data.getPcp(), data.getTurnoverNumeric());
22.         }
23.         
24.         // 可以在这里添加交易逻辑、报警逻辑等
25.         if (Double.parseDouble(data.getPcp()) > 5.0) {
26.             logger.warn("股票 {} 涨幅超过5%: {}%", data.getPid(), data.getPcp());
27.         }
28.     }
29. }

复制代码

9. 配置说明

时间间隔参数

• PT5M - 5分钟K线
  
• PT15M - 15分钟K线
  
• PT1H - 1小时K线
  
• P1D - 日K线
  
• P1W - 周K线
  
• P1M - 月K线
  

排行榜类型

• 1 - 涨幅榜
  
• 2 - 跌幅榜
  
• 3 - 涨停榜
  
• 4 - 跌停榜
  

10. 注意事项

• API Key管理: 建议从配置文件或环境变量读取API Key
  
• 错误处理: 所有API调用都需要适当的异常处理
  
• 频率限制: 注意API的调用频率限制
  
• 连接管理: WebSocket连接需要处理重连逻辑
  
• 数据缓存: 对于不经常变化的数据可以实施缓存
  

这个完整的Java实现提供了对接印度股票数据源的所有核心功能，可以根据具体需求进行扩展和优化。

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

这个好，看起来很实用