huangping/starRiverProperty
1
0
Fork 0
mirror of https://github.com/hpd840321/starRiverProperty.git synced 2026-06-09 08:20:31 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix(v0.11): 第六轮走查——legacy 去除 System.out 演示入口与 Kafka 消费端日志

Browse Source 
- AESUtils / RSAUtils / SM4Utils / CustomXssUtil / SnowFlakeSerialCode：删除仅用于本地演示的 main，消除生产源码中的 System.out。
- KafkaConsumer：移除 printStackTrace；异常改为 logger.error(msg, e)；Class.newInstance 改为 getDeclaredConstructor().newInstance()。

对应 docs/reviews 05 工程卫生项；全量 maven-cloudwalk-legacy-public 已通过 compile。

Made-with: Cursor

Former-commit-id: 2d9fa1c9de
This commit is contained in:
反编译工作区
2026-04-25 00:16:42 +08:00
parent 9fa7e63396
commit f1e60cb06c
6 changed files with 9 additions and 65 deletions
Download Patch File Download Diff File Expand all files Collapse all files
maven-cloudwalk-legacy-public/cwos-sdk-event/src/main/java/cn/cloudwalk/cwos/client/event/consumer/KafkaConsumer.java
+9 -10
View File
@@ -150,7 +150,8 @@ if (this.eventListener == null) {
Reflections reflections = new Reflections(new Object[0]);
Set<Class<? extends EventListener>> subTypes = reflections.getSubTypesOf(EventListener.class);
if (subTypes.size() == 1) {
EventListener eventListener = ((Class<EventListener>)subTypes.iterator().next()).newInstance();
EventListener eventListener =
((Class<EventListener>)subTypes.iterator().next()).getDeclaredConstructor().newInstance();
this.eventListener = eventListener;
pullThread();
} else {
@@ -161,13 +162,12 @@ pullThread();
}
} else {
if (this.eventListener == null) {
this.eventListener = this.listenerClass.newInstance();
this.eventListener = this.listenerClass.getDeclaredConstructor().newInstance();
}
pullThread();
}
} catch (Exception e) {
e.printStackTrace();
this.logger.error(e.getMessage());
this.logger.error("KafkaConsumer.pull 初始化失败", e);
}
}
@@ -179,7 +179,8 @@ if (this.eventListener == null) {
Reflections reflections = new Reflections(new Object[0]);
Set<Class<? extends EventListener>> subTypes = reflections.getSubTypesOf(EventListener.class);
if (subTypes.size() == 1) {
EventListener eventListener = ((Class<EventListener>)subTypes.iterator().next()).newInstance();
EventListener eventListener =
((Class<EventListener>)subTypes.iterator().next()).getDeclaredConstructor().newInstance();
this.eventListener = eventListener;
} else {
throw new NoneClassImplementsException("none class or than one");
@@ -189,12 +190,11 @@ pullThread();
}
} else if (this.eventListener == null) {
this.eventListener = this.listenerClass.newInstance();
this.eventListener = this.listenerClass.getDeclaredConstructor().newInstance();
}
} catch (Exception e) {
e.printStackTrace();
this.logger.error(e.getMessage());
this.logger.error("KafkaConsumer.initListener 失败", e);
}
}
@@ -204,8 +204,7 @@ try {
this.eventListeners.put(eventType.getCode(), eventSingleSubEventListener);
pullThread();
} catch (Exception e) {
e.printStackTrace();
this.logger.error(e.getMessage());
this.logger.error("KafkaConsumer.pull(eventType) 失败", e);
}
}