| | |
| | | heartbeatTimer.schedule(new TimerTask() { |
| | | @Override |
| | | public void run() { |
| | | send(("key:"+ eStockType.getStockKey()+":"+eStockType.getContryId()).getBytes()); |
| | | if (isOpen()) { |
| | | //send(("key:"+ eStockType.getStockKey()+":"+eStockType.getContryId()).getBytes()); |
| | | send("heartbeat"); |
| | | } |
| | | |
| | | } |
| | | }, 0, 3000); // 每3秒发送一次心跳消息 |
| | | } |
| | |
| | | @Override |
| | | public void onMessage(String message) { |
| | | if (message.contains("身份验证成功") || message.contains("pong") || message.contains("身份验证失败") || message.contains("ws连接点只能有一个")) { |
| | | System.out.println("us" + message); |
| | | System.out.println("hk" + message); |
| | | return; |
| | | } |
| | | System.out.println("us2" + message); |
| | | System.out.println("hk2" + message); |
| | | Map<String, String> stringObjectMap = jsonToMap(message); |
| | | StockRealTimeBean stockRealTimeBean = new StockRealTimeBean(); |
| | | stockRealTimeBean.setPid(stringObjectMap.get("Id").toString()); |
| | |
| | | stockRealTimeBean.setPc(stringObjectMap.get("Chg").toString()); |
| | | stockRealTimeBean.setPcp(stringObjectMap.get("ChgPct").toString()+"%"); |
| | | stockRealTimeBean.setTime(stringObjectMap.get("Time").toString()); |
| | | RedisKeyUtil.setCacheRealTimeStock(EStockType.US,stockRealTimeBean); |
| | | RedisKeyUtil.setCacheRealTimeStock(EStockType.HK,stockRealTimeBean); |
| | | ObjectMapper objectMapper = new ObjectMapper(); |
| | | try { |
| | | if(!stockRealTimeBean.getPcp().contains("-")){ |
| | |
| | | String json = objectMapper.writeValueAsString(stockRealTimeBean); |
| | | sendLoca(json); |
| | | StockRealTimeBean stockDetailBean = new Gson().fromJson(message, StockRealTimeBean.class); |
| | | System.out.println(stockDetailBean); |
| | | RedisKeyUtil.setCacheRealTimeStock(EStockType.US,stockDetailBean); |
| | | RedisKeyUtil.setCacheRealTimeStock(EStockType.HK,stockDetailBean); |
| | | } catch (JsonProcessingException e) { |
| | | log.error("websocket 美国股票 消息错误:{}", e.getMessage()); |
| | | log.error("websocket 香港股票 消息错误:{}", e.getMessage()); |
| | | } |
| | | } |
| | | |
| | |
| | | |
| | | @Override |
| | | public void onClose(int i, String s, boolean b) { |
| | | log.info("websocket 美国股票 关闭"+1); |
| | | log.info("websocket 香港股票 关闭 {} ", i); |
| | | } |
| | | |
| | | @Override |
| | | public void onError(Exception e) { |
| | | log.info("websocket 美国股票 错误" + e.getMessage()); |
| | | log.info("websocket 香港股票 错误{}", e.getMessage()); |
| | | } |
| | | |
| | | public void sendLoca(String message) { |