演示站

zj

2025-11-05 9c6296d07a668b15b9794709172e28ce3d9603e2

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

@@ -43,7 +43,7 @@

    private static HttpPost httpPost;
    static {
        httpPost = new HttpPost("http://127.0.0.1:8001/api/sendNotification"); // 初始化 HttpPost
        httpPost = new HttpPost("http://127.0.0.1:8008/api/sendNotification"); // 初始化 HttpPost
    }

    @Override
@@ -74,6 +74,10 @@
            stockRealTimeBean.setPc(stringObjectMap.get("Chg").toString());
            stockRealTimeBean.setPcp(stringObjectMap.get("ChgPct").toString()+"%");
            stockRealTimeBean.setTime(stringObjectMap.get("Time").toString());
            stockRealTimeBean.setOpen(stringObjectMap.get("Open"));
            stockRealTimeBean.setPrevClose(stringObjectMap.get("PrevClose"));
            stockRealTimeBean.setSymbol(stringObjectMap.get("Symbol"));

            RedisKeyUtil.setCacheRealTimeStock(EStockType.US,stockRealTimeBean);
            ObjectMapper objectMapper = new ObjectMapper();
            try {
@@ -128,4 +132,4 @@
            log.error("Http 请求错误", e);
        }
    }
}
}