|
|
|
@ -119,6 +119,11 @@ public class ClientHandler extends SimpleChannelInboundHandler<CommMsg<Serializa
|
|
|
|
|
CollectorChannelCacheMap collectorChannelCacheMap = nettyClient.getCollectorChannelCacheMap();
|
|
|
|
|
String saveCollectorPackagePath = nettyClient.getSaveCollectorPackagePath();
|
|
|
|
|
|
|
|
|
|
if (Func.isBlank(packageValue)) {
|
|
|
|
|
System.out.println("packageValue 为空" + packageValue);
|
|
|
|
|
return;
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
List<LoadSchCollectorVO> redisLoadSchCollectors = JSON.fromJSONWithGeneric(packageValue, new TypeReference<List<LoadSchCollectorVO>>() {
|
|
|
|
|
});
|
|
|
|
|
|
|
|
|
|