From da335bddc242b2872029003332ef7549cceb0ce8 Mon Sep 17 00:00:00 2001
From: zj <1772600164@qq.com>
Date: Wed, 29 May 2024 19:55:01 +0800
Subject: [PATCH] 1
---
src/main/java/com/nq/ws/WebsocketRunClient.java | 15 +++++++++------
1 files changed, 9 insertions(+), 6 deletions(-)
diff --git a/src/main/java/com/nq/ws/WebsocketRunClient.java b/src/main/java/com/nq/ws/WebsocketRunClient.java
index f6fe1c9..ab473fb 100644
--- a/src/main/java/com/nq/ws/WebsocketRunClient.java
+++ b/src/main/java/com/nq/ws/WebsocketRunClient.java
@@ -1,14 +1,16 @@
package com.nq.ws;
import com.google.gson.Gson;
-import com.nq.constant.StockConstant;
import com.nq.enums.EStockType;
import com.nq.pojo.StockRealTimeBean;
+import com.nq.service.IMandatoryLiquidationService;
+import com.nq.service.impl.MandatoryLiquidationService;
+import com.nq.utils.ApplicationContextRegisterUtil;
import com.nq.utils.redis.RedisKeyUtil;
-import com.nq.utils.redis.RedisShardedPoolUtils;
import lombok.extern.slf4j.Slf4j;
import org.java_websocket.client.WebSocketClient;
import org.java_websocket.handshake.ServerHandshake;
+import org.springframework.context.ApplicationContext;
import java.net.URI;
@@ -21,15 +23,16 @@
@Override
public void onOpen(ServerHandshake serverHandshake) {
- log.info("webSocket 客服端链接成功");
- send(("key:"+ StockConstant.KEY+":"+EStockType.IN.getContryId()).getBytes());
+ send(("key:"+ EStockType.IN.getStockKey()+":"+EStockType.IN.getContryId()).getBytes());
}
@Override
public void onMessage(String s) {
try {
+ ApplicationContext act = ApplicationContextRegisterUtil.getApplicationContext();
+ MandatoryLiquidationService liquidationService = (MandatoryLiquidationService) act.getBean(IMandatoryLiquidationService.class);
StockRealTimeBean stockDetailBean = new Gson().fromJson(s, StockRealTimeBean.class);
- RedisKeyUtil.setCacheRealTimeStock(EStockType.IN,stockDetailBean);
+ liquidationService.RealTimeDataProcess(EStockType.IN,stockDetailBean);
}catch (Exception e){
}
@@ -37,7 +40,7 @@
@Override
public void onClose(int i, String s, boolean b) {
- log.info("websocket 关闭"+1);
+ log.info("websocket 印股 关闭"+1);
}
@Override
--
Gitblit v1.9.3