修改测试用例

discovery-springcloud-example-a/src/main/java/com/nepxion/discovery/plugin/example/impl/DiscoveryPluginConfigSimulator.java

@@ -38,21 +38,19 @@ public class DiscoveryPluginConfigSimulator {
             public void run() {
                 // 本地文件模拟代替远程文件，随机读取
                 int index = threadLocalRandom.nextInt(4) + 1;
-                InputStream inputStream = createInputStream("src/main/resources/discovery" + index + ".xml");
+                InputStream inputStream = getInputStream("src/main/resources/discovery" + index + ".xml");
                 discoveryPluginConfigPublisher.publish(inputStream);
             }
         }, 0L, 15000L);
     }
 
-    private InputStream createInputStream(String fileName) {
-        File file = new File(fileName);
-        InputStream inputStream = null;
+    private InputStream getInputStream(String fileName) {
         try {
-            inputStream = new FileInputStream(file);
+            return new FileInputStream(new File(fileName));
         } catch (FileNotFoundException e) {
             e.printStackTrace();
         }
 
-        return inputStream;
+        return null;
     }
 }
\ No newline at end of file

discovery-springcloud-example-a/src/main/java/com/nepxion/discovery/plugin/example/impl/DiscoveryPluginFileLoader.java

@@ -22,7 +22,7 @@ public class DiscoveryPluginFileLoader extends AbstractFileLoader {
     @Override
     public InputStream getRemoteInputStream() throws IOException {
         // 本地文件模拟代替远程文件
-        return createInputStream("src/main/resources/discovery1.xml");
+        return getInputStream("src/main/resources/discovery1.xml");
     }
 
     @Override
@@ -31,18 +31,16 @@ public class DiscoveryPluginFileLoader extends AbstractFileLoader {
         return "classpath:discovery1.xml";
 
         // 配置文件放在工程根目录下
-        // return "file:discovery.xml";
+        // return "file:discovery1.xml";
     }
 
-    private InputStream createInputStream(String fileName) {
-        File file = new File(fileName);
-        InputStream inputStream = null;
+    private InputStream getInputStream(String fileName) {
         try {
-            inputStream = new FileInputStream(file);
+            return new FileInputStream(new File(fileName));
         } catch (FileNotFoundException e) {
             e.printStackTrace();
         }
 
-        return inputStream;
+        return null;
     }
 }
\ No newline at end of file