2-10演示站搭建

peter

2026-01-15 0ababc615d5b381f856ca84fb8dc715cdb2c4b5b

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

@@ -1,5 +1,7 @@
//package com.nq.ws;
//
//import com.fasterxml.jackson.core.JsonProcessingException;
//import com.fasterxml.jackson.databind.ObjectMapper;
//import com.google.gson.Gson;
//import com.google.gson.reflect.TypeToken;
//import com.nq.enums.EStockType;
@@ -61,14 +63,39 @@
//    @Override
//    public void onMessage(String s) {
//        if(!s.equals("pong") && !s.equals("身份验证成功")){
//            StockRealTimeBean stockDetailBean =  new Gson().fromJson(s, StockRealTimeBean.class);
//            RedisKeyUtil.setCacheRealTimeStock(eStockType,stockDetailBean);
//            Map<String, String> stringObjectMap = jsonToMap(s);
//            StockRealTimeBean stockRealTimeBean = new StockRealTimeBean();
//            stockRealTimeBean.setPid(stringObjectMap.get("Id").toString());
//            stockRealTimeBean.setLast(stringObjectMap.get("Last").toString());
//            stockRealTimeBean.setBid(stringObjectMap.get("Bid").toString());
//            stockRealTimeBean.setAsk(stringObjectMap.get("Ask").toString());
//            stockRealTimeBean.setHigh(stringObjectMap.get("High").toString());
//            stockRealTimeBean.setLow(stringObjectMap.get("Low").toString());
//            stockRealTimeBean.setPc(stringObjectMap.get("Chg").toString());
//            stockRealTimeBean.setPcp(stringObjectMap.get("ChgPct").toString()+"%");
//            stockRealTimeBean.setTime(stringObjectMap.get("Time").toString());
//            RedisKeyUtil.setCacheRealTimeStock(EStockType.IN,stockRealTimeBean);
//            ObjectMapper objectMapper = new ObjectMapper();
//            try {
//                if(!stockRealTimeBean.getPcp().contains("-")){
//                    stockRealTimeBean.setPcp("+"+stringObjectMap.get("ChgPct").toString()+"%");
//                }
//                String json = objectMapper.writeValueAsString(stockRealTimeBean);
//                sendLoca(json);
//                StockRealTimeBean stockDetailBean =  new Gson().fromJson(s, StockRealTimeBean.class);
//                RedisKeyUtil.setCacheRealTimeStock(EStockType.IN,stockDetailBean);
//            } catch (JsonProcessingException e) {
//                throw new RuntimeException(e);
//            }
//
//        }else{
//            log.error("websocket  消息错误："+s);
//        }
//    }
//
//    public static Map<String, Object> jsonToMap(String json) {
//    public static Map<String, String> jsonToMap(String json) {
//        Gson gson = new Gson();
//        Type type = new TypeToken<Map<String, Object>>(){}.getType();
//        Type type = new TypeToken<Map<String, String>>(){}.getType();
//        return gson.fromJson(json, type);
//    }
//