注释

byit-plugin-core/myth-plugin-rpc-client/src/main/java/com/byit/client/handler/PluginConnectClient.java

@@ -71,8 +71,8 @@ public abstract class PluginConnectClient {
         if (connectClientMap == null) {
             synchronized (PluginConnectClient.class){
                 if (connectClientMap == null) {
-                    System.out.println("--------------------------");
                     connectClientMap = new ConcurrentHashMap<>(8);
+                    //这一步是在创建连接的时候对该方法进行停止回调设置
                     pluginClientInitialization.getPluginClientFactory().addStopCallback(() ->{
                         if (CollectionUtil.isNotEmpty(connectClientMap)) {
                             connectClientMap.forEach((key,value) ->{

byit-plugin-core/myth-plugin-rpc-client/src/main/java/com/byit/factory/PluginSpringClientFactory.java

@@ -88,8 +88,7 @@ public class PluginSpringClientFactory extends InstantiationAwareBeanPostProcess
                 LoadBalance loadBalance = taskClientAnn.loadBalance();
                 long timeout = taskClientAnn.timeout();
 
-                PluginClientInitialization pluginClientInitialization =
-                        new PluginClientInitialization(callbackUrl, timeout, loadBalance,
+                PluginClientInitialization pluginClientInitialization = new PluginClientInitialization(callbackUrl, timeout, loadBalance,
                                 pluginClientFactory, iFace,pluginClientClass);
                 Object proxyObject = pluginClientInitialization.getObject();
                 field.setAccessible(true);