From 1c6748cbef6bf2348106b27fb47a74efff8a8b2e Mon Sep 17 00:00:00 2001
From: zj <1772600164@qq.com>
Date: Tue, 10 Sep 2024 14:16:17 +0800
Subject: [PATCH] 1
---
src/main/java/com/nq/ws/WebsocketRunClient.java | 12 +++++++++---
1 files changed, 9 insertions(+), 3 deletions(-)
diff --git a/src/main/java/com/nq/ws/WebsocketRunClient.java b/src/main/java/com/nq/ws/WebsocketRunClient.java
index 8ddf719..18aa3fb 100644
--- a/src/main/java/com/nq/ws/WebsocketRunClient.java
+++ b/src/main/java/com/nq/ws/WebsocketRunClient.java
@@ -45,9 +45,15 @@
@Override
public void onMessage(String s) {
- StockRealTimeBean stockDetailBean = new Gson().fromJson(s, StockRealTimeBean.class);
- RedisKeyUtil.setCacheRealTimeStock(eStockType,stockDetailBean);
- send(s);
+ try {
+ if(!s.equals("pong") && !s.equals("身份验证成功")){
+ StockRealTimeBean stockDetailBean = new Gson().fromJson(s, StockRealTimeBean.class);
+ RedisKeyUtil.setCacheRealTimeStock(eStockType,stockDetailBean);
+ send(s);
+ }
+ }catch (Exception e){
+ log.error("ws 消息接收错误："+s);
+ }
}
public static Map<String, Object> jsonToMap(String json) {
--
Gitblit v1.9.3