1

zj

2024-09-24 ff812a4f923da2dea4c883f4e34e2ce928c76d99

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

@@ -45,9 +45,15 @@

    @Override
    public void onMessage(String s) {
        StockRealTimeBean stockDetailBean =  new Gson().fromJson(s, StockRealTimeBean.class);
        RedisKeyUtil.setCacheRealTimeStock(eStockType,stockDetailBean);
        send(s);
       try {
           if(!s.equals("pong") && !s.equals("身份验证成功")){
               StockRealTimeBean stockDetailBean =  new Gson().fromJson(s, StockRealTimeBean.class);
               RedisKeyUtil.setCacheRealTimeStock(eStockType,stockDetailBean);
               send(s);
           }
       }catch (Exception e){
           log.error("ws 消息接收错误："+s);
       }
    }

    public static Map<String, Object> jsonToMap(String json) {