From 50da1f165cc96d49d72694606920b77c74e1747c Mon Sep 17 00:00:00 2001
From: jiazx0107@163.com <jiazx0107@163.com>
Date: 星期四, 04 一月 2024 10:57:26 +0800
Subject: [PATCH] 调整KFKA数据推送测试2
---
src/main/java/com/fzzy/protocol/youxian0/client/ClientHandler.java | 8 +++++++-
1 files changed, 7 insertions(+), 1 deletions(-)
diff --git a/src/main/java/com/fzzy/protocol/youxian0/client/ClientHandler.java b/src/main/java/com/fzzy/protocol/youxian0/client/ClientHandler.java
index 0e99869..f29fd15 100644
--- a/src/main/java/com/fzzy/protocol/youxian0/client/ClientHandler.java
+++ b/src/main/java/com/fzzy/protocol/youxian0/client/ClientHandler.java
@@ -31,6 +31,8 @@
InetSocketAddress socketAddress = (InetSocketAddress) ctx.channel().remoteAddress();
log.info("杩炴帴缁堢鎺夌嚎锛孖P={},port={}", socketAddress.getAddress(), socketAddress.getPort());
+
+
}
@Override
@@ -47,7 +49,11 @@
analysisService = SpringUtil.getBean(AnalysisService.class);
}
- analysisService.analysis(socketAddress.getAddress(), socketAddress.getPort(), strMsg);
+ try{
+ analysisService.analysis(socketAddress.getAddress(), socketAddress.getPort(), strMsg);
+ }catch (Exception e){
+ log.error(e.getMessage(),e);
+ }
}
--
Gitblit v1.9.3