| | |
| | | |
| | | @Override |
| | | public void onMessage(String message) { |
| | | if (message.contains("身份验证成功") || message.contains("pong") || message.contains("身份验证失败")) { |
| | | if (message.contains("身份验证成功") || message.contains("pong") || message.contains("身份验证失败") || message.contains("ws连接点只能有一个")) { |
| | | System.out.println("us" + message); |
| | | return; |
| | | } |
| | |
| | | RedisKeyUtil.setCacheRealTimeStock(EStockType.US,stockRealTimeBean); |
| | | ObjectMapper objectMapper = new ObjectMapper(); |
| | | try { |
| | | System.out.println("sdd"); |
| | | if(!stockRealTimeBean.getPcp().contains("-")){ |
| | | stockRealTimeBean.setPcp("+"+stringObjectMap.get("ChgPct").toString()+"%"); |
| | | } |