| | |
|---|
| | | // |
|---|
| | | // @Override |
|---|
| | | // public void onMessage(String s) { |
|---|
| | | // Map<String, Object> map = jsonToMap(s); |
|---|
| | | // if(map.get("pid").equals("00000001")){ |
|---|
| | | // System.out.println(s); |
|---|
| | | // } |
|---|
| | | // try { |
|---|
| | | // ApplicationContext act = ApplicationContextRegisterUtil.getApplicationContext(); |
|---|
| | | // MandatoryLiquidationService liquidationService = (MandatoryLiquidationService) act.getBean(IMandatoryLiquidationService.class); |
|---|
| | | // StockRealTimeBean stockDetailBean = new Gson().fromJson(s, StockRealTimeBean.class); |
|---|
| | | // liquidationService.RealTimeDataProcess(eStockType,stockDetailBean); |
|---|
| | | // RedisKeyUtil.setCacheRealTimeStock(EStockType.IN,stockDetailBean); |
|---|
| | | // }catch (Exception e){ |
|---|
| | | // |
|---|
| | | // } |
|---|
| | |
|---|
| | | // |
|---|
| | | // @Override |
|---|
| | | // public void onClose(int i, String s, boolean b) { |
|---|
| | | // log.info("websocket 马来西亚 关闭"+1); |
|---|
| | | // log.info("websocket 印度股票 关闭"+1); |
|---|
| | | // } |
|---|
| | | // |
|---|
| | | // @Override |
|---|
