添加云计算模块

apps/cnf-distributed-business-computing/cnf-distributed-business-topu/pom.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>cnf-distributed-business-computing</artifactId>
+        <groupId>top.ninwoo</groupId>
+        <version>1.0-SNAPSHOT</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>cnf-distributed-business-topu</artifactId>
+
+    <dependencies>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-web</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>top.ninwoo</groupId>
+            <artifactId>cnf-client-starter</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-test</artifactId>
+            <scope>test</scope>
+        </dependency>
+
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+        </dependency>
+
+    </dependencies>
+
+
+</project>
\ No newline at end of file

apps/cnf-distributed-business-computing/pom.xml

@@ -20,6 +20,7 @@
         <module>dbc-business-utils</module>
         <module>dbc-commom-api</module>
         <module>cnf-distri-test</module>
+        <module>cnf-distributed-business-topu</module>
     </modules>
 
     <artifactId>cnf-distributed-business-computing</artifactId>

apps/cnf-distributed-file-transfer/dfs-transfer-topology/pom.xml

+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>cnf-distributed-file-transfer</artifactId>
+        <groupId>top.ninwoo</groupId>
+        <version>1.0-SNAPSHOT</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>dfs-transfer-topology</artifactId>
+
+    <dependencies>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-web</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>top.ninwoo</groupId>
+            <artifactId>cnf-client-starter</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-test</artifactId>
+            <scope>test</scope>
+        </dependency>
+
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+        </dependency>
+
+    </dependencies>
+
+
+</project>
\ No newline at end of file

apps/cnf-distributed-file-transfer/dfs-transfer-topology/src/main/java/top/ninwoo/weixingsim/WxMain.java

+package top.ninwoo.weixingsim;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+@SpringBootApplication
+public class WxMain {
+
+    public static void main(String[] args) {
+        SpringApplication.run(WxMain.class, args);
+    }
+}

apps/cnf-distributed-file-transfer/dfs-transfer-topology/src/main/java/top/ninwoo/weixingsim/sateTopology/entity/SimData.java

+package top.ninwoo.weixingsim.sateTopology.entity;
+
+import lombok.Data;
+
+/**
+ * @description 储存有关星间链路的数据
+ */
+@Data
+public class SimData {
+    //设置时间，默认为 2020-01-01 00-00-00
+    //24小时制
+    private String defaultDate = "2020-01-01 00-00-00";
+    //时间间隔，默认值为10
+    private int jiange = 10;
+    //周期值，默认值为100分钟，即为6000秒
+    private int zhouqi = 6000;
+    //todo：这里因该预设默认值
+    //星间链路带宽
+    private double bandwidth = 10e9;
+    //加性高斯白噪声(AWGN)
+    private double n0 = 5*10e-15;
+    //信号发射功率
+    private double pt = 5*10e3;
+    //信号发射增益系数
+    private double gt = 52.5;
+    //信号接收增益系数
+    private double gr = 37.5;
+    //载波波长
+    private double lamda = 0.05;
+
+    //星间信道容量最低容限
+    private double c0 = 10e9;
+
+    public double ptGtGr(){
+        return pt*gt*gr;
+    }
+    public double n0B(){
+        return n0*bandwidth;
+    }
+}

apps/cnf-distributed-file-transfer/dfs-transfer-topology/src/main/java/top/ninwoo/weixingsim/sateTopology/entity/WeiXingData.java

+package top.ninwoo.weixingsim.sateTopology.entity;
+
+import lombok.Data;
+
+@Data
+public class WeiXingData {
+    //卫星的名字，之后可能作为增删改查的唯一标识
+    private String name;
+    //地心距离
+    private Float high = (float)780;
+    //根据高度计算得出，规定(默认)逆时针为正方向
+    private Double speed;
+    private Boolean tag=true;
+    //测试用一个角度作为初始相位，后期需要三个角度来算出xyz坐标轴
+    private Float alpha;
+    private Float beta;
+    private Float gamma;
+    //xyz坐标轴数据
+    private Double  xaxis;
+    private Double  yaxis;
+    private Double  zaxis;
+    //卫星的序列号
+    private Integer index;
+    //运行时间
+    private int lastime = 0;
+
+    @Override
+    public String toString(){
+        return "卫星名是："+name+";高度是："+high+"\n"+"x轴坐标："+xaxis+"\n"+"y轴坐标："+yaxis+"\n"+"z轴坐标："+zaxis;
+    }
+}

apps/cnf-distributed-file-transfer/dfs-transfer-topology/src/main/java/top/ninwoo/weixingsim/sateTopology/init/Initapp.java

+package top.ninwoo.weixingsim.sateTopology.init;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.CommandLineRunner;
+import top.ninwoo.bishe.starter.service.ClusterService;
+import top.ninwoo.common.entity.*;
+import top.ninwoo.weixingsim.sateTopology.entity.SimData;
+import top.ninwoo.weixingsim.sateTopology.entity.WeiXingData;
+import top.ninwoo.weixingsim.sateTopology.service.impl.ToponetImpl;
+import top.ninwoo.weixingsim.sateTopology.service.impl.WeixingImpl;
+
+import java.io.File;
+import java.text.SimpleDateFormat;
+import java.util.ArrayList;
+import java.util.List;
+
+
+public class Initapp implements CommandLineRunner {
+
+    @Autowired
+    private ClusterService clusterService;
+
+    @Override
+    public void run(String... args) throws Exception {
+        ArrayList<SeparatedClusterConfig> clusterConfigs = new ArrayList<>();
+        SeparatedClusterConfig separatedClusterConfig = new SeparatedClusterConfig();
+        List<ContainerDescription> cds = new ArrayList<>();
+        // TODO: 这个ID应该是从借口获取的
+        separatedClusterConfig.setEdgeNodeId("192.168.190.135:18088");
+        ClusterConfig clusterConfig = new ClusterConfig();
+        clusterConfig.setId(11111l);
+        clusterConfig.setOwner("joliu");
+
+        //从文本中获取卫星的数据
+        WeixingImpl wx = new WeixingImpl();
+        ToponetImpl tp = new ToponetImpl();
+        SimData sd = new SimData();
+        //tp.delHistory();
+        File file = new File("C:\\WorkSpace\\test\\topusim_1.txt");
+        List<WeiXingData> wxData = wx.iniTopo(file,sd.getZhouqi());
+        int[][] toponet = tp.getTopology(wxData,sd);
+
+
+        //创建容器
+        for (int k = 0; k < wxData.size(); k++) {
+            ContainerDescription containerDescription = new ContainerDescription();
+            containerDescription.setMode("normal");
+            containerDescription.setReplicas(1);
+
+            DockerContainer container = new DockerContainer();
+            container.setName(wxData.get(k).getName());
+            container.setCommand("sh");
+            container.setImage("joliu/networktest");
+
+            containerDescription.setDockerContainer(container);
+            cds.add(containerDescription);
+        }
+
+        //设置创建时间
+        //自己设计的时间
+        //sd.setDefaultDate("2020-07-16 20-38-56");
+        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH-mm-ss");//24小时制
+        clusterConfig.setCreateTime(sdf.parse(sd.getDefaultDate()));
+////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
+        clusterConfig.setDockers(cds);
+        NetworkTopology topo = new NetworkTopology();
+        topo.setAppNames(tp.getAppNames(wxData));
+        // 这个参数好像没啥用
+        topo.setTopologyId(11);
+        topo.setTopology(toponet);
+        clusterConfig.setTopology(topo);
+        separatedClusterConfig.setClusterConfig(clusterConfig);
+        clusterConfigs.add(separatedClusterConfig);
+
+        clusterService.sendClusterConfigToEdgeNode(clusterConfigs);
+
+        //下发逻辑拓扑
+        clusterService.sendLogicTopoToEdgeNode(clusterConfigs);
+
+        out:for (int i = 1; i<600; i++) {
+            Thread.sleep(2000);
+            int time = i * sd.getJiange();
+            List<WeiXingData> changetp = wx.changeTopo(wxData,time);
+
+            topo.setTopology(tp.getTopology(changetp,sd));
+
+            //下发修改后逻辑拓扑
+            clusterService.adjustLogicTopoToEdgeNode(clusterConfigs);
+            Boolean tag = false;
+
+            for(int k=1;k<toponet[0].length;k++){
+                for (int j=0;j<k;j++){
+                    if(toponet[k][j] == tp.getTopology(changetp, sd)[k][j]){
+                        tag = true;
+                    }
+                }
+            }
+            if(tag){
+                break out;
+            }
+        }
+
+        System.out.println("所有topo完成");
+    }
+
+}

apps/cnf-distributed-file-transfer/dfs-transfer-topology/src/main/java/top/ninwoo/weixingsim/sateTopology/service/Toponet.java

+package top.ninwoo.weixingsim.sateTopology.service;
+
+import top.ninwoo.weixingsim.sateTopology.entity.SimData;
+import top.ninwoo.weixingsim.sateTopology.entity.WeiXingData;
+
+import java.util.List;
+
+/**
+ * 拓扑网络的服务
+ * 根据Weixing的服务所得到的List转化为二维数组
+ */
+
+public interface Toponet {
+
+    /**
+     * @param weiXingDataList WeiXingData对象
+     * @return 拓扑图的元素
+     * @description 得到生成拓扑网络中的所有元素名字，需要自动生成所需的ovs，和docker容器一一对应
+     */
+    String[] getAppNames(List<WeiXingData> weiXingDataList);
+
+    /**
+     * @param weiXingDataList WeiXingData对象
+     * @return 二维数组，也就是拓扑图
+     * @description 得到网络拓扑形式类似为 app1 app2 app3 ovs1 ovs2 ovs3
+     */
+    int[][] getTopology(List<WeiXingData> weiXingDataList, SimData simData);
+
+    /**
+     * @param weiXingDataList WeiXingData对象
+     * @return 二维数组，也就是拓扑图
+     * @description 得到网络拓扑形式类似为 app1 app2 app3 ovs1 ovs2 ovs3
+     */
+    double[][] getWeightedTopology(List<WeiXingData> weiXingDataList, SimData simData);
+
+    /**
+     * @param a 具体的卫星a
+     * @param b 具体的卫星b
+     * @return a，b之间的距离
+     * @description 计算距离，在getTopology中调用
+     */
+    Double distance(WeiXingData a, WeiXingData b);
+
+    Double channelCapacity(WeiXingData a, WeiXingData b, SimData simData);
+
+    /**
+     @description 记录卫星拓扑的变化历史
+     */
+    /**
+     * @description 写入一个文本文件中，作为拓扑的历史记录
+     * @param appNames 传入的卫星名字，取前1/2
+     * @param topo 卫星拓扑图
+     */
+    void history(String[] appNames, int[][] topo);
+
+    /**
+     * @description 删除历史记lu
+     */
+    void delHistory();
+}

apps/cnf-distributed-file-transfer/dfs-transfer-topology/src/main/java/top/ninwoo/weixingsim/sateTopology/service/Weixing.java

+package top.ninwoo.weixingsim.sateTopology.service;
+
+import top.ninwoo.weixingsim.sateTopology.entity.WeiXingData;
+
+import java.io.File;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 有关卫星的服务
+ * 1.解析初始文本，得到初始的卫星状态
+ * 2.将卫星的状态写入一个List中
+ * 3.增删改查四种基本功能
+ */
+
+public interface Weixing {
+
+    /**
+     * @description 从文本中获取卫星的初始状态，但是其中的数据均为string型
+     * @param file  传入的文本路径
+     * @return      返回一个List
+     */
+    List<Map> parseTxt(File file);
+
+    /**
+     * @description 将parseTxt中得到的Map转化为初始的卫星数据
+     * @param wx    WeiXingData类
+     * @param map   parseTxt得到的Map
+     * @return      单个卫星数据
+     * @throws IllegalAccessException
+     */
+    WeiXingData initWX(Class wx, Map map)throws IllegalAccessException;
+
+    List<WeiXingData> initNet(List<Map> maps) throws IllegalAccessException;
+
+    /**
+     * @description 根据卫星高度计算出卫星的速度，取逆时针为正方向。
+     * @description 和addAxis不同，只需计算一次即可
+     * @param wx    WeiXingData对象
+     * @return
+     */
+    List<WeiXingData> addWSpeed(List<WeiXingData> wx, int zhouqi);
+
+    /**
+     * @description 根据角度，高度，速度和间隔时间t获取卫星的坐标数据
+     * @param wx    WeiXingData对象
+     * @return
+     */
+    List<WeiXingData> addAxis(List<WeiXingData> wx);
+
+    /**
+     * @description 为每个卫星添加序号值
+     * @param wx 卫星List
+     * @return bool类型
+     */
+    boolean addIndex(List<WeiXingData> wx);
+
+    /**
+     * @description 确认index和卫星List的对应关系
+     * @param wx 卫星List
+     * @return boolean
+     */
+    boolean checkIndex(List<WeiXingData> wx);
+
+    /**
+     * @description 确保卫星列表中中没有名字重复的卫星
+     * @param wx 卫星List
+     */
+    void checkWX(List<WeiXingData> wx);
+    /**
+     增删改查的功能
+     */
+    /**
+     * @description 根据提供的appName查找对应的序列号
+     * @param weiXingDataList 卫星List
+     * @param appName 卫星名字
+     * @return index 序列号
+     */
+    Integer findindex(List<WeiXingData> weiXingDataList, String appName);
+
+    /**
+     * @description 查找功能
+     * @param weiXingDataList 传入的卫星列表
+     * @param appName 查找的卫星名字
+     * @return 卫星数据
+     */
+    WeiXingData findWX(List<WeiXingData> weiXingDataList, String appName);
+
+    /**
+     * @description 增加一个卫星，这里无需考虑顺序问题，卫星主要靠名字搜索
+     * @param weiXingDataList 旧的卫星List数据
+     * @param newWX  新的卫星数据
+     * @return 新的卫星List数据
+     */
+    List<WeiXingData> addWX(List<WeiXingData> weiXingDataList, WeiXingData newWX);
+
+    /**
+     * @description 删除指定的卫星
+     * @param weiXingDataList 旧的卫星List数据
+     * @param appName 指定卫星的名字
+     * @return 新的卫星List
+     */
+    List<WeiXingData> delWX(List<WeiXingData> weiXingDataList, String appName);
+
+    /**
+     * @description 修改给定卫星的给定值,只能修改高度
+     * @param weiXingDataList 旧的卫星List
+     * @param appName 要修改的卫星名字
+     * @param field 要修改的属性
+     * @param val 要改成的值，传入为String类型，可在代码中转化为Double类型的值
+     * @return 新的卫星List
+     */
+    List<WeiXingData> changeWX(List<WeiXingData> weiXingDataList, String appName, String field, String val);
+
+    /**
+     * @description 初始化拓扑
+     * @param file  传入文件路径
+     * @return      返回为卫星List
+     */
+    List<WeiXingData> iniTopo(File file, int zhouqi) throws IllegalAccessException;
+
+    /**
+     * @description 改变拓扑
+     * @param wxData 旧的网络
+     * @param time   抽样时间
+     * @return       改变后的网络
+     */
+    List<WeiXingData> changeTopo(List<WeiXingData> wxData, int time);
+
+    /**
+     * @description 增减卫星时需要调用
+     * @param wxData
+     * @return
+     */
+    List<WeiXingData> initChangeTopo(List<WeiXingData> wxData, int zhouqi);
+}
+
+

apps/cnf-distributed-file-transfer/dfs-transfer-topology/src/main/java/top/ninwoo/weixingsim/sateTopology/service/impl/ToponetImpl.java

+package top.ninwoo.weixingsim.sateTopology.service.impl;
+
+import top.ninwoo.weixingsim.sateTopology.entity.SimData;
+import top.ninwoo.weixingsim.sateTopology.entity.WeiXingData;
+import top.ninwoo.weixingsim.sateTopology.service.Toponet;
+
+import java.io.BufferedWriter;
+import java.io.File;
+import java.io.FileWriter;
+import java.io.IOException;
+import java.text.SimpleDateFormat;
+import java.util.Date;
+import java.util.List;
+
+public class ToponetImpl implements Toponet {
+
+    @Override
+    public String[] getAppNames(List<WeiXingData> weiXingDataList) {
+        //先判断有多少个docker容器，并生成相对应的ovs
+        int n = weiXingDataList.size();
+        //创建docker容器和一个ovs的数组
+        String[] appNames = new String[n+1];
+        for(int j=0;j<n;j++){
+            appNames[j] = weiXingDataList.get(j).getName();
+        }
+        appNames[n] = "br:"+ "ovs";
+
+        return appNames;
+    }
+
+    @Override
+    public int[][] getTopology(List<WeiXingData> weiXingDataList, SimData simData) {
+        int n = weiXingDataList.size();
+        int[][] topu = new int[n+1][n+1];
+        //先将docker容器和ovs相连如：app1连br:ovs,app2连br:ovs
+        for (int i = 0; i < n; i++) {
+            topu[n][i] = 1;
+        }
+        //判断docker之间是否相通
+        for(int a=0;a<n;a++){
+            for(int b=a+1;b<n;b++){
+                //通过距离来判断
+                double channelCapacity = this.channelCapacity(weiXingDataList.get(a),weiXingDataList.get(b),simData);
+                if(channelCapacity>=simData.getC0()){
+                    topu[b][a] = 1;
+                }
+            }
+        }
+        return topu;
+    }
+
+    @Override
+    public double[][] getWeightedTopology(List<WeiXingData> weiXingDataList, SimData simData) {
+        int n = weiXingDataList.size();
+        double[][] topu = new double[n+1][n+1];
+        //先将docker容器和ovs相连如：app1连br:ovs,app2连br:ovs
+        for (int i = 0; i < n; i++) {
+            topu[n][i] = 1;
+        }
+        //判断docker之间是否相通
+        for(int a=0;a<n;a++){
+            for(int b=a+1;b<n;b++){
+                //通过距离来判断
+                double channelCapacity = this.channelCapacity(weiXingDataList.get(a),weiXingDataList.get(b),simData);
+                if(channelCapacity>=simData.getC0()){
+                    topu[b][a] = channelCapacity/1024/1024;
+                }
+            }
+        }
+        return topu;
+    }
+    ////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
+    @Override
+    public Double distance(WeiXingData a, WeiXingData b) {
+        Double r;
+        r = Math.sqrt(Math.pow(a.getXaxis()-b.getXaxis(),2)+Math.pow(a.getYaxis()-b.getYaxis(),2)+Math.pow(a.getZaxis()-b.getZaxis(),2));
+        return r;
+    }
+
+    @Override
+    public Double channelCapacity(WeiXingData a, WeiXingData b, SimData sd) {
+        double r = this.distance(a, b);
+        double channelCapacity;
+
+        channelCapacity = sd.getBandwidth()*Math.log(1+(sd.ptGtGr()/(Math.pow(4*Math.PI*r/sd.getLamda(),2)*sd.n0B())))/Math.log(2);
+
+        return channelCapacity;
+    }
+    ////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
+    @Override
+    public void history(String[] appNames, int[][] topo) {
+        File file1 = new File("C:\\WorkSpace\\test\\history.txt");
+        try {
+            FileWriter fw = new FileWriter(file1,true);
+            BufferedWriter bw = new BufferedWriter(fw);
+
+            //先写上日期标记
+            SimpleDateFormat sdf =new SimpleDateFormat("yyyy-MM-dd HH:mm:ss SSS" );
+            Date d= new Date();
+            String str = sdf.format(d);
+            bw.write(str + "开始的拓扑结构"+ "\n");
+
+            //todo 需要设计排版
+            int num = appNames.length;
+            int[][] logic = new int[num][num];
+            for(int i = 0; i<num;i++){
+                for(int m =0;m<num;m++){
+                    logic[i][m] = topo[i+num][m+num];
+                    bw.write(logic[i][m] + " ");
+                    bw.flush();
+                }
+                bw.write("\n" );
+                bw.flush();
+            }
+            bw.close();
+            fw.close();
+
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+    }
+
+    @Override
+    public void delHistory() {
+        File file = new File("C:\\WorkSpace\\test\\history.txt");
+        if (file.exists()) {
+            file.delete();
+        }
+    }
+}
+

apps/cnf-distributed-file-transfer/dfs-transfer-topology/src/main/java/top/ninwoo/weixingsim/sateTopology/service/impl/WeixingImpl.java

+package top.ninwoo.weixingsim.sateTopology.service.impl;
+
+
+import top.ninwoo.weixingsim.sateTopology.entity.WeiXingData;
+import top.ninwoo.weixingsim.sateTopology.service.Weixing;
+
+import java.io.BufferedReader;
+import java.io.File;
+import java.io.FileReader;
+import java.lang.reflect.Field;
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+public class WeixingImpl implements Weixing {
+
+    @Override
+    public List<Map> parseTxt(File file) {
+        String str;
+        List<Map> maps = new ArrayList<Map>();
+        try {
+            BufferedReader br = new BufferedReader(new FileReader(file));
+            while((str = br.readLine()) != null){
+                if(str.equals("-------------")){
+                    //WeiXing initwx = new WeiXing();
+                    Map<String,String> map = new HashMap();
+                    str = br.readLine();
+                    while(str.equals("-------------")==false){
+                        String[] split = str.split("=");
+                        //if(split(0)==initwx.)
+                        map.put(split[0], split[1]);
+                        str = br.readLine();
+                    }
+                    maps.add(map);
+                }
+            }
+        }catch (Exception e){
+            e.printStackTrace();
+        }
+        return maps;
+    }
+
+    @Override
+    public  WeiXingData initWX(Class wx, Map map) throws IllegalAccessException {
+        WeiXingData initwx = new WeiXingData();
+        Field[] fields = wx.getDeclaredFields();
+
+        for (Field field : fields) {
+            field.setAccessible(true);
+            if (field.getType() == Float.class) {
+                field.set(initwx, Float.parseFloat((String) map.get(field.getName())));
+            } else if (field.getType() == String.class) {
+                field.set(initwx, map.get(field.getName()));
+            }else if (field.getType() == Boolean.class) {
+                if(map.get(field.getName()).equals("true")){
+                    field.set(initwx, true);
+                }else{field.set(initwx, false);}
+            }
+        }
+        return initwx;
+    }
+
+    @Override
+    public List<WeiXingData> initNet(List<Map> maps) throws IllegalAccessException {
+        List<WeiXingData> initnet = new ArrayList<>();
+
+        for(int i=0;i<maps.size();i++){
+            WeiXingData wx = new WeiXingData();
+            wx = this.initWX(WeiXingData.class,maps.get(i));
+            initnet.add(wx);
+        }
+        return initnet;
+    }
+
+    @Override
+    public List<WeiXingData> addWSpeed(List<WeiXingData> wx,int zhouqi) {
+        for(int i=0;i<wx.size();i++){
+            if(wx.get(i).getTag().equals(true)){
+                Double speed = 2*Math.PI/zhouqi;
+                wx.get(i).setSpeed(speed);}
+            else{wx.get(i).setSpeed((-1)*2*Math.PI*(1/zhouqi));}
+        }
+        return wx;
+    }
+
+    @Override
+    public List<WeiXingData> addAxis(List<WeiXingData> wx) {
+        for (int i = 0; i < wx.size(); i++) {
+            Float High = wx.get(i).getHigh();
+            Double hudu = wx.get(i).getSpeed() * wx.get(i).getLastime();
+            Double Alpha = Math.toRadians(wx.get(i).getAlpha());
+            Double Beta = Math.toRadians(wx.get(i).getBeta());
+            Double Gamma = Math.toRadians(wx.get(i).getGamma());
+            wx.get(i).setXaxis(High * Math.cos(hudu + Gamma) * Math.sin(Beta) + High * Math.sin(hudu + Gamma) * Math.cos(Alpha) * Math.cos(Beta));
+            wx.get(i).setYaxis(High * Math.cos(hudu + Gamma) * Math.cos(Beta) - High * Math.sin(hudu + Gamma) * Math.cos(Alpha) * Math.sin(Beta));
+            wx.get(i).setZaxis(High * Math.sin(hudu + Gamma) * Math.sin(Alpha));
+        }
+        return wx;
+    }
+
+    @Override
+    public boolean addIndex(List<WeiXingData> wx) {
+        for(int i=0;i<wx.size();i++){
+            wx.get(i).setIndex(i+1);
+        }
+        return true;
+    }
+
+    @Override
+    public boolean checkIndex(List<WeiXingData> wx) {
+        boolean k=false;
+        int tag = 0;
+        for(int m=0;m<wx.size();m++){
+            if(wx.get(m).getIndex() == m+1){
+                tag++;
+            }else{
+                wx.get(m).setIndex(m+1);
+                m=m-1;
+            }
+        }
+
+        if(tag == wx.size()){
+            k = true;
+        }
+        return k;
+    }
+
+    @Override
+    public void checkWX(List<WeiXingData> wx) {
+        for(int i=0;i<wx.size();i++){
+            for(int j=i+1;j<wx.size();j++){
+                if(wx.get(i).getName().equals(wx.get(j).getName())){
+                    String str = wx.get(i).getName() + i + j;
+                    wx.get(j).setName(str);
+                }
+            }
+        }
+    }
+
+    ////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
+    @Override
+    public Integer findindex(List<WeiXingData> weiXingDataList, String appName) {
+        Integer index = 0;
+        for(int i=0;i<weiXingDataList.size();i++){
+            if(weiXingDataList.get(i).getName().equals(appName)){
+                index = weiXingDataList.get(i).getIndex();
+                break;
+            }
+        }
+        return index;
+    }
+
+    @Override
+    public WeiXingData findWX(List<WeiXingData> weiXingDataList, String appName) {
+        WeiXingData wxData = null;
+        int k = findindex(weiXingDataList,appName);
+        if(k != 0){
+            wxData = weiXingDataList.get(k-1);
+        }
+        return wxData;
+    }
+
+    //增加和删除卫星需要反求（球坐标）
+    @Override
+    public List<WeiXingData> addWX(List<WeiXingData> weiXingDataList, WeiXingData newWX) {
+        //先判断是否已存在相同名字的卫星
+        WeiXingData wxdata = findWX(weiXingDataList,newWX.getName());
+        if(wxdata != null){
+            //加上时间这一唯一标识
+            newWX.setName(newWX.getName()+System.currentTimeMillis());
+        }
+        weiXingDataList.add(newWX);
+
+        //修改坐标系
+        for(int i=0;i<weiXingDataList.size()-1;i++){
+            float gamma = (float) (weiXingDataList.get(i).getGamma()+weiXingDataList.get(i).getLastime()*weiXingDataList.get(i).getSpeed());
+            weiXingDataList.get(i).setGamma(gamma);
+            weiXingDataList.get(i).setLastime(0);
+        }
+        this.addIndex(weiXingDataList);
+        this.checkIndex(weiXingDataList);
+        return weiXingDataList;
+    }
+
+    @Override
+    public List<WeiXingData> delWX(List<WeiXingData> weiXingDataList, String appName) {
+        //找到该卫星
+        WeiXingData wxdata = findWX(weiXingDataList,appName);
+        if(wxdata != null){
+            weiXingDataList.remove(wxdata.getIndex()-1);
+        }
+
+        //修改坐标系
+        for(int i=0;i<weiXingDataList.size();i++){
+            float gamma = (float) (weiXingDataList.get(i).getGamma()+weiXingDataList.get(i).getLastime()*weiXingDataList.get(i).getSpeed());
+            weiXingDataList.get(i).setGamma(gamma);
+            weiXingDataList.get(i).setLastime(0);
+        }
+
+        this.addIndex(weiXingDataList);
+        this.checkIndex(weiXingDataList);
+        return weiXingDataList;
+    }
+
+    //todo 只考虑增加高度一个选项
+    @Override
+    public List<WeiXingData> changeWX(List<WeiXingData> weiXingDataList, String appName, String field, String val) {
+        return null;
+    }
+    ////////////////////////////////////////////////////////////////////////////////////////////////////////////////////////
+    @Override
+    public List<WeiXingData> iniTopo(File file,int zhouqi) throws IllegalAccessException {
+        List<Map> maps = this.parseTxt(file);
+        List<WeiXingData> wxData = this.initNet(maps);
+        wxData = this.initChangeTopo(wxData,zhouqi);
+
+        return wxData;
+    }
+
+    @Override
+    public List<WeiXingData> changeTopo(List<WeiXingData> wxData, int time) {
+        for(int i=0;i<wxData.size();i++){
+            wxData.get(i).setLastime(time);
+        }
+        wxData = this.addAxis(wxData);
+        this.addIndex(wxData);
+        this.checkIndex(wxData);
+
+        return wxData;
+    }
+
+    @Override
+    public List<WeiXingData> initChangeTopo(List<WeiXingData> wxData,int zhouqi) {
+        wxData = this.addWSpeed(wxData,zhouqi);
+        wxData = this.addAxis(wxData);
+        this.checkWX(wxData);
+        this.addIndex(wxData);
+        this.checkIndex(wxData);
+
+        return wxData;
+    }
+}
+

apps/cnf-distributed-file-transfer/dfs-transfer-topology/src/main/resources/application.properties

+bishe.app.app-name=joliu
+#bishe.app.cloud-url=192.168.31.156:9090
+bishe.app.cloud-url=192.168.81.1:9091
+
+spring.influx.url=http://192.168.0.108:8086
+spring.influx.user=admin
+spring.influx.password=admin
\ No newline at end of file

apps/cnf-distributed-file-transfer/pom.xml

@@ -18,6 +18,7 @@
         <module>dfs-file-utils</module>
         <module>dfs-transfer-client</module>
         <module>dfs-transfer-server</module>
+        <module>dfs-transfer-topology</module>
     </modules>
 
     <dependencyManagement>

cnf-cloud-center/src/main/resources/application.yml

@@ -5,6 +5,7 @@ zookeeper:
   #url: zk.cnf.org:2181
   url: 192.168.81.1:2181
 
+
 bs:
   cloudcenter:
     name: my-bs-cloud-center

cnf-test/src/test/java/top/ninwoo/YmwangDfsTests.java

@@ -55,7 +55,7 @@ public class YmwangDfsTests {
         /*通过镜像"ymwang/dfs_transfer_server"启动一个名为server1的容器，用于存储图片切片*/
         ContainerDescription containerDescriptionServer1 = new ContainerDescription();
         containerDescriptionServer1.setMode("normal");
-        containerDescriptionServer1.setReplicas(20);
+        containerDescriptionServer1.setReplicas(30);
         DockerContainer containerServer1 = new DockerContainer();
         containerServer1.setName("dfs_server");//创建一个server1容器
         containerServer1.setCommand("sh");