Skip to content

D
Distributed Computing and Network Fusion System
Commit 6a7798ab authored by Hu Jintao's avatar Hu Jintao
Browse files
Options

完成铱星网络部署

parent ec05c963
Expand all Hide whitespace changes
Inline Side-by-side
Showing with 1425 additions and 160 deletions
apps/cnf-path-computing/business-api/src/main/java/com/pitong/business/item/DataPackage.java
View file @ 6a7798ab
package com.pitong.business.item;
import java.io.Serializable;
import java.util.LinkedList;
import java.util.List;
import java.util.Stack;
public class DataPackage implements Serializable {
private int number;
......@@ -12,6 +14,46 @@ public class DataPackage implements Serializable {
private Long currentime;
private Long fun1time;
private List<Double> compCapacity;
private LinkedList<Double> tranDelay;
//当前卫星节点
private int currentHop;
//路由新添解析步骤
private int routeNumber;
public Stack[] route;
public void setTranDelay(LinkedList<Double> tranDelay) {
this.tranDelay = tranDelay;
}
public LinkedList<Double> getTranDelay() {
return tranDelay;
}
public int getCurrentHop() {
return currentHop;
}
public void setCurrentHop(int currentHop) {
this.currentHop = currentHop;
}
public void setRouteNumber(int routeNumber) {
this.routeNumber = routeNumber;
}
public void setRoute(Stack[] route) {
this.route = route;
}
public int getRouteNumber() {
return routeNumber;
}
public Stack[] getRoute() {
return route;
}
public List<Double> getCompCapacity() {
return compCapacity;
......
apps/cnf-path-computing/businessInCloud/src/main/java/top/ninwoo/test/BisheTestMain.java
View file @ 6a7798ab
......@@ -16,9 +16,7 @@ import top.ninwoo.test.doMap.path;
import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Arrays;
import java.util.List;
import java.util.Random;
import java.util.*;
@SpringBootApplication
@path
......@@ -52,14 +50,38 @@ public class BisheTestMain implements ApplicationRunner {
System.out.println("========================================");
System.out.println("exec start timestamp: " + System.currentTimeMillis());
System.out.println();
System.out.println("launch timestamp: " + System.currentTimeMillis());
System.out.println();
// DoMap doMap = new DoMap();
List<Integer> sequence = Arrays.asList(1, 3, 7, 8, 12, 17, 20);
System.out.println("optimal mapping scheme"+sequence);
DoMap doMap = new DoMap();
doMap.doMapApp();
//将节点映射结果保存为List
int[] result = doMap.result;
while (result[0] == 0){
System.out.println("failure mapping ："+Arrays.toString(result));
doMap.doMapApp();
result = doMap.result;
}
List<Integer> sequence = new ArrayList<>();
for (int a:result
) {
sequence.add(a);
}
//将路由结果保存
Stack[] route = doMap.route;
int routeNumber = 0;
int nextHop = 1;
long waitT = doMap.startT-System.currentTimeMillis();
if (waitT > 0){
Thread.sleep(waitT);
}
System.out.println("exec start timestamp: " + System.currentTimeMillis());
System.out.println("========================================");
System.out.println();
//List<Integer> sequence = Arrays.asList(result);
// System.out.println("optimal mapping scheme"+sequence);
String loc = null;
String file_path = "passport.jpg";
......@@ -70,10 +92,15 @@ public class BisheTestMain implements ApplicationRunner {
List<Double> compCapacity = Arrays.asList(1.112341341313, 0.5196272109574349, 0.675827555541419, 0.7637869915859579, 0.7998320296858645,
0.638652700648973, 0.6396760676518485, 0.5615337810185533, 0.6356797503522186, 0.8266103444996542, 0.6924037701405794,
0.9371892689614395, 0.6949256728585527, 0.6212614126622614, 0.6318393608430264, 0.7494680794385384, 0.9983949989039682,
0.5610722256465777, 0.6415780028672076, 0.9371892689);//取值范围0.2到1，首尾固定为1M/s
DataPackage dataPackage = combine(number, sequence, loc, file_path, eta, currentime, fun1time, compCapacity);
0.5610722256465777, 0.6415780028672076, 0.9371892689, 0.5269659075274151, 0.8219152161388867, 0.5815463889106197, 0.8431429542046349,
0.31386253514456774, 0.6045132365410817, 0.8102279249524735, 0.47057296148341216, 0.8529743685059654, 0.8177711194660409);//取值范围0.2到1，首尾固定为1M/s
LinkedList<Double> tranDelay = doMap.list;
for (int i = 0;i<tranDelay.size();i++){
tranDelay.set(i,tranDelay.get(i)/(i+2)+(Math.random()*10+1));
}
DataPackage dataPackage = combine(number, routeNumber, sequence, loc, file_path, eta, currentime, fun1time, compCapacity,route,nextHop,tranDelay);
send(dataPackage, targetIp, 2020);
//接收卫星回传信息
for(int i = 0;i<sequence.size();i++){
ServerSocket serverSocket = new ServerSocket(8900);
//获取数据流
......@@ -134,15 +161,20 @@ public class BisheTestMain implements ApplicationRunner {
}
}
private static DataPackage combine(int number, List<Integer> sequence, String loc, String file_path, double eta, Long Currentime, Long fun1time, List<Double> compCapacity) {
private static DataPackage combine(int number, int routeNumber, List<Integer> sequence, String loc, String file_path,
double eta, Long Currentime, Long fun1time, List<Double> compCapacity, Stack[] route, int nextHop, LinkedList<Double> tranDelay) {
DataPackage dataPackage = new DataPackage();
dataPackage.setNumber(number);
dataPackage.setRouteNumber(routeNumber);
dataPackage.setPicture(loadPicture(file_path));
dataPackage.setSequence(sequence);
dataPackage.setEta(eta);
dataPackage.setCurrentime(Currentime);
dataPackage.setFun1time(fun1time);
dataPackage.setCompCapacity(compCapacity);
dataPackage.setRoute(route);
dataPackage.setCurrentHop(nextHop);
dataPackage.setTranDelay(tranDelay);
return dataPackage;
}
......
apps/cnf-path-computing/businessInCloud/src/main/java/top/ninwoo/test/doMap/CycleTopo.java 0 → 100644
View file @ 6a7798ab
package top.ninwoo.test.doMap;
import top.ninwoo.test.sateTopo.entity.SimData;
import top.ninwoo.test.sateTopo.entity.WeiXingData;
import top.ninwoo.test.sateTopo.service.impl.ToponetImpl;
import top.ninwoo.test.sateTopo.service.impl.WeixingImpl;
import java.io.File;
import java.util.*;
public class CycleTopo {
public static void main(String[] args) { cycleTp(); }
public static HashMap<Integer, double[][]> cycleTp(){
//从文本中获取卫星的数据
WeixingImpl wx = new WeixingImpl();
ToponetImpl tp = new ToponetImpl();
SimData sd = new SimData();
//tp.delHistory();
File file = new File("topusim_1.txt");
//D:\LabratoryJavaPro\codingDownload\latestCoding\
List<WeiXingData> wxData = null;
{
try {
wxData = wx.iniTopo(file,sd.getZhouqi());
} catch (IllegalAccessException e) {
e.printStackTrace();
}
}
//初始topo
double[][] toponet = tp.getWeightedTopology(wxData,sd);
//去掉ovs
double[][] topoNet = new double[30][30];
for (int i = 0;i<topoNet.length;i++){
for (int j = 0;j<topoNet.length;j++){
topoNet[i][j] = toponet[i][j];
}
}
HashMap<Integer, double[][]> TopoStore = new HashMap<>();
TopoStore.put(0,topoNet);
for (int i = 1;i<sd.getZhouqi()/sd.getJiange(); i++) {
int time = i * sd.getJiange();
List<WeiXingData> changetp = wx.changeTopo(wxData,time);
double[][] changeTopo = tp.getWeightedTopology(changetp,sd);
//去掉ovs
for (int k = 0;k<topoNet.length;k++){
for (int j = 0;j<topoNet.length;j++){
topoNet[k][j] = changeTopo[k][j];
}
}
for (int k = 0;k<topoNet.length;k++){
for (int j = k+1;j<topoNet.length;j++){
topoNet[k][j] = topoNet[j][k];
}
}
TopoStore.put(i,topoNet);
}
int count = 0;
int count2 = -1;
Iterator<Map.Entry<Integer, double[][]>> iterator = TopoStore.entrySet().iterator();
while(iterator.hasNext()){
double[][] value = iterator.next().getValue();
for (int i = 0;i<value.length;i++){
if (i>0){
boolean equals = Arrays.equals(value[i], topoNet[i]);
count += (equals?1:0);
}
for (int j = 0;j<topoNet.length;j++){
topoNet[i][j] = value[i][j];
}
}
for (int k = 0;k<topoNet.length;k++){
for (int j = k+1;j<topoNet.length;j++){
topoNet[k][j] = topoNet[j][k];
}
}
if (count != 30){
count2++;
}
/* System.out.println(Arrays.deepToString(topoNet));
System.out.println("=========================================");
System.out.println(count2);*/
}
return TopoStore;
}
}
apps/cnf-path-computing/businessInCloud/src/main/java/top/ninwoo/test/doMap/InterSlotDijstraV2.java
View file @ 6a7798ab
......@@ -54,14 +54,18 @@ public class InterSlotDijstraV2 {
for(int i = 0; i < edgeWeight.length; i++) {
singlePointDijstra(edgeWeight, i, testLatency, pathRecord.lastHop[i], pathRecord.pathWeight[i]);
/* for(int j = 0; j < edgeWeight.length; j++) {
pathWeight[i][j] = singleRowWeight[j];
// System.out.print(pathWeight[i][j]+""+'\t');
}*/
// System.out.println('\n');
}
System.out.println(Arrays.deepToString(pathRecord.pathWeight));
System.out.println(Arrays.deepToString(pathRecord.lastHop));
// System.out.println(Arrays.deepToString(pathRecord.pathWeight));
//上一跳路由矩阵
/*System.out.println("上一跳路由矩阵");
System.out.println(Arrays.deepToString(pathRecord.lastHop));*/
// System.out.println(Arrays.deepToString(pathWeight));
return pathRecord;
}
......
apps/cnf-path-computing/businessInCloud/src/main/java/top/ninwoo/test/doMap/path.java
View file @ 6a7798ab
......@@ -11,17 +11,19 @@ import java.lang.annotation.Target;
@Retention(RetentionPolicy.RUNTIME)
public @interface path {
String savePath() default "/home/ninwoo/dynamic_sate/picResult";
String savePath() default "/home/ninwoo/jthudocker/picResult";
String rmCmd() default "rm /home/ninwoo/dynamic_sate/picResult/*.jpg";
String rmCmd() default "rm /home/ninwoo/jthudocker/picResult/*.jpg";
String saveCmd1() default "docker cp sate1_0:/pic/in.jpg /home/ninwoo/dynamic_sate/picResult/source.jpg";
String saveCmd1() default "docker cp sate1_0:/pic/in.jpg /home/ninwoo/jthudocker/picResult/source.jpg";
String saveCmd2() default "docker cp sate1_0:/pic/out1.jpg /home/ninwoo/dynamic_sate/picResult/task_1.1.jpg";
String saveCmd2() default "docker cp sate1_0:/pic/out1.jpg /home/ninwoo/jthudocker/picResult/task_1.1.jpg";
String saveCmd3() default "docker cp sate1_0:/pic/out2.jpg /home/ninwoo/dynamic_sate/picResult/task_1.2.jpg";
String saveCmd3() default "docker cp sate1_0:/pic/out2.jpg /home/ninwoo/jthudocker/picResult/task_1.2.jpg";
String saveCmd4() default "_0:/pic/out.jpg /home/ninwoo/dynamic_sate/picResult/task_";
String saveCmd4() default "_0:/pic/out.jpg /home/ninwoo/jthudocker/picResult/task_";
String saveCmd5() default "save pictrues to dynamic_sate/picResult directory finish";
String saveCmd5() default "save pictrues to jthudocker/picResult directory finish";
// /home/ninwoo/jthudocker/picResult /home/ninwoo/dynamic_sate/picResult
}
apps/cnf-path-computing/businessInCloud/src/main/java/top/ninwoo/test/doMap/verification/array2Print.java 0 → 100644
View file @ 6a7798ab
package top.ninwoo.test.doMap.verification;
import java.util.Arrays;
import java.util.Stack;
public class array2Print {
static Stack[] route = new Stack[8];
static int a;
public static void main(String[] args) {
double[] arr =new double[10];
for (int i = 0;i<10;i++){
arr[i] = Math.random()*0.8+0.2;
}
System.out.println(Arrays.toString(arr));
/*
Stack stack = new Stack();
System.out.println(route[0]);
*/
/* System.out.println(a+1);
for (int i = 0;i<route.length;i++){
route[i] = new Stack();
}*/
/* for (int i = 0;i<8;i++){
stack.push(2);
//route[i].push(2*i);
}*/
//System.out.println(route);
/* int x = 0;
int[][] a = { { 8, 2, 6, 5 }, { 6, 3, 1, 0 }, { 8, 7, 9, 6 } };
System.out.print("\t\t");
for (int i = 0; i <= a.length; i++) {
System.out.print(i + "\t");
}
System.out.print("\n\t" + "-------------------------");
System.out.println();
for (int i = 0; i < a.length; i++) {
System.out.print(i + " |\t");
for (int j = 0; j < a[i].length; j++) {
System.out.print(a[i][j] + "\t"); // "\t"是制表符
}
System.out.println();
}*/
}
}
apps/cnf-path-computing/businessInCloud/src/main/java/top/ninwoo/test/doMap/verification/tst.java 0 → 100644
View file @ 6a7798ab
package top.ninwoo.test.doMap.verification;
import java.util.LinkedList;
public class tst {
public static void main(String[] args) {
LinkedList<Double> objects = new LinkedList<>();
objects.add((double) 5);
objects.set(0,objects.get(0)/2);
System.out.println(objects);
}
}
apps/cnf-path-computing/businessInCloud/src/main/java/top/ninwoo/test/sateTopo/entity/SimData.java 0 → 100644
View file @ 6a7798ab
package top.ninwoo.test.sateTopo.entity;
import lombok.Data;
/**
* @description 储存有关星间链路的数据
*/
@Data
public class SimData {
//时间间隔，默认值为10
private int jiange = 20;
//周期值，默认值为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 = 4*10e7;
public double ptGtGr(){
return pt*gt*gr;
}
public double n0B(){
return n0*bandwidth;
}
}
apps/cnf-path-computing/businessInCloud/src/main/java/top/ninwoo/test/sateTopo/entity/WeiXingData.java 0 → 100644
View file @ 6a7798ab
package top.ninwoo.test.sateTopo.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 Integer lastime = 0;
@Override
public String toString(){
return "卫星名是："+name+";高度是："+high+"\n"+"x轴坐标："+xaxis+"\n"+"y轴坐标："+yaxis+"\n"+"z轴坐标："+zaxis;
}
}
apps/cnf-path-computing/businessInCloud/src/main/java/top/ninwoo/test/sateTopo/service/Toponet.java 0 → 100644
View file @ 6a7798ab
package top.ninwoo.test.sateTopo.service;
import top.ninwoo.test.sateTopo.entity.SimData;
import top.ninwoo.test.sateTopo.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-path-computing/businessInCloud/src/main/java/top/ninwoo/test/sateTopo/service/Weixing.java 0 → 100644
View file @ 6a7798ab
package top.ninwoo.test.sateTopo.service;
import top.ninwoo.test.sateTopo.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-path-computing/businessInCloud/src/main/java/top/ninwoo/test/sateTopo/service/impl/ToponetImpl.java 0 → 100644
View file @ 6a7798ab
package top.ninwoo.test.sateTopo.service.impl;
import top.ninwoo.test.sateTopo.entity.SimData;
import top.ninwoo.test.sateTopo.entity.WeiXingData;
import top.ninwoo.test.sateTopo.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.getJiange()/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-path-computing/businessInCloud/src/main/java/top/ninwoo/test/sateTopo/service/impl/WeixingImpl.java 0 → 100644
View file @ 6a7798ab
package top.ninwoo.test.sateTopo.service.impl;
import top.ninwoo.test.sateTopo.entity.SimData;
import top.ninwoo.test.sateTopo.entity.WeiXingData;
import top.ninwoo.test.sateTopo.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 {
SimData simData = new SimData();
@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)){
wx.get(i).setSpeed(2*Math.PI*(1/zhouqi));}
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 = Math.toRadians(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-path-computing/businessInCloud/src/main/resources/application.properties
View file @ 6a7798ab
bishe.app.app-name=joliu
bishe.app.cloud-url=192.168.47.130:9091
bishe.app.cloud-url=192.168.31.198:9091
# bishe.app.cloud-url=192.168.31.198:9090
eta=0.7
targetIp=172.17.0.2
......
apps/cnf-path-computing/businessInDocker/src/main/java/com/pitong/business/Application.java
View file @ 6a7798ab
......@@ -3,27 +3,33 @@ package com.pitong.business;
import com.pitong.business.item.DataPackage;
import com.pitong.business.item.Picture;
import com.pitong.business.service.IPService;
import com.pitong.business.service.ServerService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.*;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.builder.SpringApplicationBuilder;
import org.springframework.stereotype.Service;
import java.io.BufferedInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.ObjectInputStream;
import java.io.*;
import java.lang.reflect.Method;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.LinkedList;
import java.util.List;
import java.util.Stack;
@Service
@SpringBootApplication
public class Application implements ApplicationRunner {
@Autowired
private ServerService serverService;
@Autowired
private IPService ipService;
@Value("${slot}")
private Long slot; //时隙值
public static void main(String[] args) {
new SpringApplicationBuilder(Application.class)
......@@ -46,6 +52,33 @@ public class Application implements ApplicationRunner {
objectInputStream = new ObjectInputStream(new BufferedInputStream(inputStream));
Object object = objectInputStream.readObject();
DataPackage dataPackage = (DataPackage) object;
Stack[] route = dataPackage.getRoute();
int routeNumber = dataPackage.getRouteNumber();
int[] mapping = {0,1,2,3,4,5,5,6};
List<Integer> sequencet = dataPackage.getSequence();
int currentHop = dataPackage.getCurrentHop();
if (!route[routeNumber].empty()){
//发送到其他卫星计算，本卫星只转发
//get下一转发节点
Integer nextHop = (Integer) route[routeNumber].pop();
System.out.println("cover transfer next sate:"+nextHop);
//重新组合数据包
dataPackage.setRoute(route);
dataPackage.setCurrentHop(nextHop);
transferPackage(dataPackage, nextHop, startime);
continue;
}else if(sequencet.get(mapping[routeNumber])!=currentHop){
int nextHop = sequencet.get(mapping[routeNumber]);
System.out.println("routeNumber"+routeNumber);
System.out.println("currentHop:"+currentHop+" task exec sate"+nextHop);
dataPackage.setCurrentHop(nextHop);
transferPackage(dataPackage, nextHop, startime);
continue;
}
int number = dataPackage.getNumber();
List<Integer> sequence = dataPackage.getSequence();
Picture picture = dataPackage.getPicture();
......@@ -55,12 +88,15 @@ public class Application implements ApplicationRunner {
Long Currentime = dataPackage.getCurrentime();
Long fun1time = dataPackage.getFun1time();
List<Double> compCapacity = dataPackage.getCompCapacity();
LinkedList<Double> tranDelay =dataPackage.getTranDelay();
System.out.println("route array"+tranDelay);
System.out.println("=====================");
System.out.println("running");
String methodName = "func" + number;
Method method = serverService.getClass().getMethod(methodName, Class.forName("java.util.List"), Picture.class, Class.forName("java.lang.String"), Class.forName("java.lang.Double"),
Class.forName("java.lang.Long"),Class.forName("java.lang.Long"), Class.forName("java.lang.Long"), Class.forName("java.util.List"));
method.invoke(serverService, sequence, picture, loc, eta, Currentime, startime, fun1time, compCapacity);
Class.forName("java.lang.Long"),Class.forName("java.lang.Long"), Class.forName("java.lang.Long"), Class.forName("java.util.List"), route.getClass(), Class.forName("java.util.LinkedList"));
method.invoke(serverService, sequence, picture, loc, eta, Currentime, startime, fun1time, compCapacity, route, tranDelay);
}
} catch (IOException | ClassNotFoundException e) {
e.printStackTrace();
......@@ -80,4 +116,39 @@ public class Application implements ApplicationRunner {
}
}
}
private void transferPackage(DataPackage dataPackage, int nextHop, long startime) {
//获取目标节点ip
String app_name = "sate" + nextHop;
String IP = ipService.getIpByAppName(app_name);
//发送至目标
send(dataPackage, IP, 2020, startime);
}
private void send(DataPackage dataPackage, String ip, int port, Long startime) {
Socket socket = null;
try {
socket = new Socket(ip, port);
ObjectOutputStream objectOutputStream = new ObjectOutputStream(socket.getOutputStream());
objectOutputStream.writeObject(dataPackage);
} catch (IOException e) {
Long waitime = slot-(System.currentTimeMillis()-startime)%slot;
try {
Thread.sleep(waitime+10);
} catch (InterruptedException ex) {
ex.printStackTrace();
}
System.out.println(">>>>>>>>>>>>>>>>>>>");
System.out.println("blocked current slot: " + ((System.currentTimeMillis()-startime)/slot + 1));
System.out.println("try again ...");
send(dataPackage, ip, port, startime);
} finally {
try {
if (socket != null) {
socket.close();
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
apps/cnf-path-computing/businessInDocker/src/main/java/com/pitong/business/service/parameters.java
View file @ 6a7798ab
......@@ -13,7 +13,8 @@ public @interface parameters {
long slot() default 1000L*20;
String cldUrl() default "192.168.47.130";
String cldUrl() default "192.168.31.198";
// 192.168.47.130
int cldPort() default 8900;
}
apps/cnf-path-computing/businessInDocker/src/main/resources/application.yaml
View file @ 6a7798ab
......@@ -2,10 +2,10 @@
bishe:
app:
app-name: joliu
cloud-url: 192.168.47.130:9091
cloud-url: 192.168.31.198:9091
# cloud-url: 192.168.31.198:9090
slot: 20000 # 1000L*20
coe: 0.7
cldUrl: 192.168.47.130
cldUrl: 192.168.31.198
cldPort: 8900
apps/cnf-weixingsim/src/main/java/top/ninwoo/weixingsim/WxMain.java
View file @ 6a7798ab
......@@ -7,5 +7,6 @@ import org.springframework.boot.autoconfigure.SpringBootApplication;
public class WxMain {
public static void main(String[] args) {
SpringApplication.run(WxMain.class, args);
//init
}
}
apps/cnf-weixingsim/src/main/java/top/ninwoo/weixingsim/entity/SimData.java
View file @ 6a7798ab
......@@ -8,7 +8,7 @@ import lombok.Data;
@Data
public class SimData {
//时间间隔，默认值为10
private int jiange = 10;
private int jiange = 20;
//周期值，默认值为100分钟，即为6000秒
private int zhouqi = 6000;
......@@ -27,7 +27,7 @@ public class SimData {
private double lamda = 0.05;
//星间信道容量最低容限
private double c0 = 10e9;
private double c0 = 4*10e7;
public double ptGtGr(){
return pt*gt*gr;
......
apps/cnf-weixingsim/src/main/java/top/ninwoo/weixingsim/service/Toponet.java
View file @ 6a7798ab
......@@ -26,6 +26,13 @@ public interface Toponet {
*/
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
......
apps/cnf-weixingsim/src/main/java/top/ninwoo/weixingsim/service/impl/ToponetImpl.java
View file @ 6a7798ab
......@@ -48,6 +48,27 @@ public class ToponetImpl implements Toponet {
}
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) {
......
apps/cnf-weixingsim/src/main/resources/application.properties
View file @ 6a7798ab
bishe.app.app-name=joliu
bishe.app.cloud-url=127.0.0.1:9091
\ No newline at end of file
bishe.app.cloud-url=192.168.31.198:9091
\ No newline at end of file
apps/cnf-weixingsim/src/test/java/top/ninwoo/WxTests.java
View file @ 6a7798ab
......@@ -265,7 +265,7 @@ public class WxTests {
SeparatedClusterConfig separatedClusterConfig = new SeparatedClusterConfig();
List<ContainerDescription> cds = new ArrayList<>();
// TODO: 这个ID应该是从借口获取的
separatedClusterConfig.setEdgeNodeId("192.168.47.130:18088");
separatedClusterConfig.setEdgeNodeId("192.168.31.198:18088");
ClusterConfig clusterConfig = new ClusterConfig();
clusterConfig.setId(11111l);
clusterConfig.setOwner("joliu");
......@@ -289,7 +289,7 @@ public class WxTests {
DockerContainer container = new DockerContainer();
container.setName(wxData.get(k).getName());
container.setCommand("sh");
container.setImage("joliu/networktest");
container.setImage("joliu/networktest:path");
containerDescription.setDockerContainer(container);
cds.add(containerDescription);
......@@ -307,7 +307,7 @@ public class WxTests {
clusterService.sendClusterConfigToEdgeNode(clusterConfigs);
//下发逻辑拓扑
/* //下发逻辑拓扑
clusterService.sendLogicTopoToEdgeNode(clusterConfigs);
for (int i = 1;i<sd.getZhouqi()/sd.getJiange(); i++) {
......@@ -321,7 +321,7 @@ public class WxTests {
clusterService.adjustLogicTopoToEdgeNode(clusterConfigs);
//Boolean tag = false;
/* for(int k=1;k<toponet[0].length;k++){
*//* 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;
......@@ -330,8 +330,8 @@ public class WxTests {
}
if(tag){
break out;
}*/
}
}*//*
}*/
System.out.println("所有topo完成");
}
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment