1

zyy

2026-05-19 83af5e3adc1e71c98617be0e1432860a13652df1

1

 src/main/java/com/nq/service/impl/SiteNewsServiceImpl.java

@@ -140,9 +140,9 @@
            executor.submit(() ->
                    addNews(1, PropertiesUtil.getProperty("US_HTTP_API") + "stock-markets?key=" + PropertiesUtil.getProperty("US_KEY") + "&type=1")
            );
            executor.submit(() ->
            /*executor.submit(() ->
                    addNews(1, PropertiesUtil.getProperty("JP_HTTP_API") + "stock-markets?key=" + PropertiesUtil.getProperty("JP_KEY") + "&type=1")
            );
            );*/
        } finally {
            // 关闭线程池
            executor.shutdown();

 src/main/java/com/nq/utils/task/stock/StockTask.java

@@ -91,8 +91,8 @@

                // 1. 定义需要处理的所有股票类型（集中管理，新增类型只需添加到列表）
                List<EStockType> stockTypes = Arrays.asList(
                        EStockType.US,
                        EStockType.JP
                        EStockType.US/*,
                        EStockType.JP*/
                );

                // 2. 批量创建所有异步任务

 src/main/java/com/nq/ws/WebSocketClientBeanConfig.java

@@ -20,7 +20,7 @@
    public Map<String, WebSocketClient> websocketRunClientMap() {

        Map<String, WebSocketClient> retMap = new HashMap<>(2);
        try {
        /*try {
            JPWebsocketRunClient jpWebsocketRunClient = new JPWebsocketRunClient(new URI(PropertiesUtil.getProperty("JP_WS_URL")), EStockType.JP);
            jpWebsocketRunClient.connect();
            jpWebsocketRunClient.setConnectionLostTimeout(0);
@@ -28,7 +28,7 @@
            retMap.put(EStockType.JP.getStockKey(), jpWebsocketRunClient);
        } catch (Exception e) {
            log.error("jpWebsocketRunClient 异常: {}", e.getMessage());
        }
        }*/
        try {
            USWebsocketRunClient usWebsocketRunClient = new USWebsocketRunClient(new URI(PropertiesUtil.getProperty("US_WS_URL")), EStockType.US);
            usWebsocketRunClient.connect();

 src/main/resources/application.properties

@@ -17,7 +17,7 @@
ftp.user=ftp_stock
ftp.pass=Fxw16SK6s7QA
ftp.address =/www/wwwroot/ftp_stock/
ftp.server.http.prefix=https://img.bitget-jp-us.shop/
ftp.server.http.prefix=https://img.bitget-jp-us.cyou/

redis1.ip=localhost
redis1.port=6379