rg演示站搭建

peter

2026-01-15 ebdd91f1eb56cadf7c71150668acd636204f4f29

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

@@ -49,6 +49,15 @@
//    @Override
//    public void onOpen(ServerHandshake serverHandshake) {
//        send(("key:"+ eStockType.getStockKey()+":"+eStockType.getContryId()).getBytes());
//        Timer heartbeatTimer;
//        // 启动心跳定时器
//        heartbeatTimer = new Timer();
//        heartbeatTimer.schedule(new TimerTask() {
//            @Override
//            public void run() {
//                send(("key:"+ eStockType.getStockKey()+":"+eStockType.getContryId()).getBytes());
//            }
//        }, 0, 3000); // 每3秒发送一次心跳消息
//    }
//
//    @Override
@@ -65,7 +74,7 @@
//            stockRealTimeBean.setPc(stringObjectMap.get("Chg").toString());
//            stockRealTimeBean.setPcp(stringObjectMap.get("ChgPct").toString()+"%");
//            stockRealTimeBean.setTime(stringObjectMap.get("Time").toString());
//            RedisKeyUtil.setCacheRealTimeStock(EStockType.IN,stockRealTimeBean);
//            RedisKeyUtil.setCacheRealTimeStock(EStockType.JP,stockRealTimeBean);
//            ObjectMapper objectMapper = new ObjectMapper();
//            try {
//                if(!stockRealTimeBean.getPcp().contains("-")){
@@ -74,11 +83,13 @@
//                String json = objectMapper.writeValueAsString(stockRealTimeBean);
//                sendLoca(json);
//                StockRealTimeBean stockDetailBean =  new Gson().fromJson(s, StockRealTimeBean.class);
//                RedisKeyUtil.setCacheRealTimeStock(EStockType.IN,stockDetailBean);
//                RedisKeyUtil.setCacheRealTimeStock(EStockType.JP,stockDetailBean);
//            } catch (JsonProcessingException e) {
//                throw new RuntimeException(e);
//            }
//
//        }else{
//            log.error("websocket  消息错误："+s);
//        }
//    }
//
@@ -90,7 +101,7 @@
//
//    @Override
//    public void onClose(int i, String s, boolean b) {
//        log.info("websocket  印度股票  关闭"+1);
//        log.info("websocket  日本股票  关闭"+1);
//    }
//
//    @Override