From 83e518b3f7adef29f7812a30e6eb16a159ed43f7 Mon Sep 17 00:00:00 2001 From: zhangjian Date: Sun, 28 Apr 2024 19:52:18 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96refinitiv=E8=AF=B7=E6=B1=82?= =?UTF-8?q?=E6=95=B0=E6=8D=AE=E9=87=8A=E6=94=BE=E8=B5=84=E6=BA=90?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../cn/stock/market/listener/AppClient.java | 2 +- .../market/web/MessageRetifiveController.java | 24 +++++++++++++++++++ .../market/web/RefinitivApiController.java | 15 ++++++++++++ 3 files changed, 40 insertions(+), 1 deletion(-) diff --git a/src/main/java/cn/stock/market/listener/AppClient.java b/src/main/java/cn/stock/market/listener/AppClient.java index 2f8f6aa..5babe1f 100644 --- a/src/main/java/cn/stock/market/listener/AppClient.java +++ b/src/main/java/cn/stock/market/listener/AppClient.java @@ -68,7 +68,7 @@ public class AppClient implements OmmConsumerClient { return messageFuture; } - private void resetMessageFuture() { + public void resetMessageFuture() { this.messageFuture = new CompletableFuture<>(); } diff --git a/src/main/java/cn/stock/market/web/MessageRetifiveController.java b/src/main/java/cn/stock/market/web/MessageRetifiveController.java index 845c0f9..9df59dc 100644 --- a/src/main/java/cn/stock/market/web/MessageRetifiveController.java +++ b/src/main/java/cn/stock/market/web/MessageRetifiveController.java @@ -59,6 +59,9 @@ public class MessageRetifiveController { return ServerResponse.createBySuccess("操作成功",refreshMsg.toString()); } catch (Exception e) { return ServerResponse.createByError(); + } finally { + // 可能需要重置或清理资源 + appClient.resetMessageFuture(); } } @@ -85,6 +88,9 @@ public class MessageRetifiveController { } catch (Exception e) { log.error("获取列表异常link:"+nextLink,e); return ServerResponse.createByError(); + } finally { + // 可能需要重置或清理资源 + appClient.resetMessageFuture(); } } return ServerResponse.createBySuccess("操作成功"); @@ -158,6 +164,9 @@ public class MessageRetifiveController { } } catch (Exception e) { log.error("获取列表异常link:"+itemName,e); + } finally { + // 可能需要重置或清理资源 + appClient.resetMessageFuture(); } } @@ -183,6 +192,9 @@ public class MessageRetifiveController { } } catch (Exception e) { log.error("获取股票详情link:"+itemName,e); + } finally { + // 可能需要重置或清理资源 + appClient.resetMessageFuture(); } return ServerResponse.createBySuccess("操作成功"); @@ -206,6 +218,9 @@ public class MessageRetifiveController { } } catch (Exception e) { log.error("获取股票详情link:"+name,e); + } finally { + // 可能需要重置或清理资源 + appClient.resetMessageFuture(); } } return ServerResponse.createBySuccess("操作成功",list); @@ -236,6 +251,9 @@ public class MessageRetifiveController { } } catch (Exception e) { log.error("获取股票详情link:"+name,e); + } finally { + // 可能需要重置或清理资源 + appClient.resetMessageFuture(); } return ServerResponse.createBySuccess("操作成功",list); } @@ -261,6 +279,9 @@ public class MessageRetifiveController { } } catch (Exception e) { log.error("获取股票详情link:"+name,e); + } finally { + // 可能需要重置或清理资源 + appClient.resetMessageFuture(); } return ServerResponse.createBySuccess("操作成功",list); } @@ -288,6 +309,9 @@ public class MessageRetifiveController { } } catch (Exception e) { log.error("获取股票详情link:"+name,e); + } finally { + // 可能需要重置或清理资源 + appClient.resetMessageFuture(); } return ServerResponse.createBySuccess("操作成功",list); } diff --git a/src/main/java/cn/stock/market/web/RefinitivApiController.java b/src/main/java/cn/stock/market/web/RefinitivApiController.java index 14c19f1..39bd191 100644 --- a/src/main/java/cn/stock/market/web/RefinitivApiController.java +++ b/src/main/java/cn/stock/market/web/RefinitivApiController.java @@ -62,6 +62,9 @@ public class RefinitivApiController { } } catch (Exception e) { log.error("获取股票详情link:" + symbol, e); + } finally { + // 可能需要重置或清理资源 + appClient.resetMessageFuture(); } return ServerResponse.createBySuccess("操作成功"); @@ -86,6 +89,9 @@ public class RefinitivApiController { } } catch (Exception e) { log.error("获取股票详情link:" + name, e); + } finally { + // 可能需要重置或清理资源 + appClient.resetMessageFuture(); } } return ServerResponse.createBySuccess("操作成功", list); @@ -121,6 +127,9 @@ public class RefinitivApiController { } } catch (Exception e) { log.error("获取股票详情link:" + name, e); + } finally { + // 可能需要重置或清理资源 + appClient.resetMessageFuture(); } return ServerResponse.createBySuccess("操作成功", list); @@ -154,6 +163,9 @@ public class RefinitivApiController { } } catch (Exception e) { log.error("获取股票详情link:" + name, e); + } finally { + // 可能需要重置或清理资源 + appClient.resetMessageFuture(); } return ServerResponse.createBySuccess("操作成功", list); @@ -188,6 +200,9 @@ public class RefinitivApiController { } } catch (Exception e) { log.error("获取股票详情link:"+name,e); + } finally { + // 可能需要重置或清理资源 + appClient.resetMessageFuture(); } return ServerResponse.createBySuccess("操作成功",list); }