copy from src/main/java/com/nq/ws/TWWebsocketRunClient.java
copy to src/main/java/com/nq/ws/JPWebsocketRunClient.java
| File was copied from src/main/java/com/nq/ws/TWWebsocketRunClient.java |
| | |
| | | import java.util.*; |
| | | |
| | | @Slf4j |
| | | public class TWWebsocketRunClient extends WebSocketClient { |
| | | public class JPWebsocketRunClient extends WebSocketClient { |
| | | |
| | | private EStockType eStockType; |
| | | public TWWebsocketRunClient(URI serverUri, |
| | | public JPWebsocketRunClient(URI serverUri, |
| | | EStockType eStockType |
| | | ) { |
| | | super(serverUri); |
| | |
| | | //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("tw" + message); |
| | | System.out.println("JP:" + message); |
| | | return; |
| | | } |
| | | System.out.println("tw2" + message); |
| | | System.out.println("JP2" + 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.TW,stockRealTimeBean); |
| | | RedisKeyUtil.setCacheRealTimeStock(EStockType.JP,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); |
| | | RedisKeyUtil.setCacheRealTimeStock(EStockType.TW,stockDetailBean); |
| | | RedisKeyUtil.setCacheRealTimeStock(EStockType.JP,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 台湾股票 关闭 {} ", i); |
| | | 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) { |