handOver具体逻辑完成

尹本进
1 parent 2a8e3c51
Showing 6 changed files with 138 additions and 25 deletions Show diff stats
src/main/java/com/example/mina/client/base/ExperimentOptions.java
src/main/java/com/example/mina/client/base/ExperimentOptionsPair.java
src/main/java/com/example/mina/client/base/MatrixClient.java
src/main/java/com/example/mina/client/base/StationPair.java
src/main/java/com/example/mina/client/experiment/HandOverExperimentOptions.java
src/main/java/com/example/mina/client/experiment/HandoverExperiment.java
@@ -31,7 +31,7 @@ public abstract class ExperimentOptions {
     protected ZonedDateTime finishAt;
-    protected List<ExperimentOptionsPair> pairs;
+    protected List<StationPair> pairs;
     protected abstract boolean checkOptions();
 }
@@ -1,21 +0,0 @@
-package com.example.mina.client.base;
-
-import java.util.List;
-import lombok.Data;
-
-/**
- * 输入输出端口
- * @author BenJin Yin
- * @date 2021/4/2
- */
-@Data
-public class ExperimentOptionsPair {
-    /**
-     * 输入端口
-     */
-    private Integer out;
-    /**
-     * 输出端口
-     */
-    private List<Integer> inList;
-}
@@ -179,7 +179,7 @@ public class MatrixClient {
         public void run() {
             while (true) {
                 try {
-                    MatrixCommand command = commands.poll(5, TimeUnit.SECONDS);
+                    MatrixCommand command = commands.poll();
                     if(command != null){
                         log.info("======================");
@@ -0,0 +1,21 @@
+package com.example.mina.client.base;
+
+import java.util.List;
+import lombok.Data;
+
+/**
+ * 输入输出端口
+ * @author BenJin Yin
+ * @date 2021/4/2
+ */
+@Data
+public class StationPair {
+    /**
+     * 输出端口
+     */
+    private Integer out;
+    /**
+     * 输入端口
+     */
+    private List<Integer> inList;
+}
@@ -2,8 +2,12 @@ package com.example.mina.client.experiment;
 import com.example.mina.client.base.ExperimentOptions;
 import lombok.Data;
+import lombok.EqualsAndHashCode;
+import lombok.ToString;
 @Data
+@EqualsAndHashCode(callSuper = true)
+@ToString(callSuper = true)
 public class HandOverExperimentOptions extends ExperimentOptions {
 package com.example.mina.client.experiment;
-import com.example.mina.client.base.MatrixClient;
-import com.example.mina.client.base.MatrixConstants;
 import com.example.mina.client.base.Experiment;
 import com.example.mina.client.base.ExperimentOptions;
+import com.example.mina.client.base.MatrixClient;
+import com.example.mina.client.base.MatrixCommand;
+import com.example.mina.client.base.MatrixConstants;
+import com.example.mina.client.base.StationPair;
+import java.util.ArrayList;
+import java.util.List;
+import org.springframework.util.CollectionUtils;
 public class HandoverExperiment extends Experiment {
@@ -18,6 +23,110 @@ public class HandoverExperiment extends Experiment {
     @Override
     public void schedule() {
+        List<StationPair> pairs = options.getPairs();
+        if (CollectionUtils.isEmpty(pairs)) {
+            return;
+        }
+        StationPair one = pairs.get(0);
+        if (one == null || one.getInList() == null) {
+            return;
+        }
+        // 输入端口的个数
+        int inSize = one.getInList().size();
+        if (inSize < 2) {
+            return;
+        }
+        // 循环次数
+        Integer count = options.getMaxIterCount();
+        if (count == null || count < 1) {
+            return;
+        }
+        Integer step = options.getStep();
+        Integer endAttenuation = options.getEndAttenuation();
+        int dynamicCont = endAttenuation / step;
+        if (step == null || step <= 0) {
+            return;
+        }
+        for (int i = 0; i < count; i++) {
+            // 输入端口只有 2 个
+            if (inSize == 2) {
+                for (int k = 0; k <= dynamicCont; k++) {
+                    int dynamic = step * k;
+                    List<MatrixCommand> commandList = new ArrayList<>();
+                    for (StationPair pair : pairs) {
+                        Integer out = pair.getOut();
+                        Integer inOne = pair.getInList().get(0);
+                        Integer inTwo = pair.getInList().get(1);
+                        MatrixCommand commandOne = MatrixCommand.builder().command(MatrixConstants.COMMAND_SET_ATTN)
+                                .col(inOne).row(out).attn(dynamic).build();
+                        MatrixCommand commandTwo = MatrixCommand.builder().command(MatrixConstants.COMMAND_SET_ATTN)
+                                .col(inTwo).row(out).attn(endAttenuation - dynamic).build();
+                        commandList.add(commandOne);
+                        commandList.add(commandTwo);
+                    }
+                    commandList.forEach(this::sendCommand);
+                    commandList.clear();
+                    try {
+                        Thread.sleep(options.getPeriod() * 1000);
+                    } catch (InterruptedException e) {
+                        e.printStackTrace();
+                    }
+                }
+            } else {
+                // 输入端口大于 2
+                // 行数
+                int rowCount = 1 + inSize * dynamicCont;
+                // 动态衰减值 矩阵
+                int[][] attenuation = new int[rowCount][inSize];
+                // 当前动态输入端口指针
+                int current = 0;
+                for (int k = 0; k < rowCount; k++) {
+                    // 动态衰减值
+                    int dynamic = step * (k != 0 && k % dynamicCont == 0 ? dynamicCont : k % dynamicCont);
+                    for (int j = 0; j < inSize; j++) {
+                        if (j == current && j != inSize - 1) {
+                            attenuation[k][j++] = dynamic;
+                            attenuation[k][j] = endAttenuation - dynamic;
+                        } else if (j == current && j == inSize - 1) {
+                            attenuation[k][j] = dynamic;
+                            attenuation[k][0] = endAttenuation - dynamic;
+                        } else {
+                            attenuation[k][j] = endAttenuation;
+                        }
+                    }
+                    // 一轮衰减完成后，当前动态输入端口指针 加 1
+                    if (k != 0 && k % dynamicCont == 0) {
+                        current++;
+                    }
+                }
+                for (int x = 0; x < rowCount; x++) {
+                    // 当前行 --> 时间点，需要发送的 命令
+                    List<MatrixCommand> commandList = new ArrayList<>();
+                    for (int y = 0; y < inSize; y++) {
+                        int att = attenuation[x][y];
+                        for (StationPair pair : pairs) {
+                            Integer out = pair.getOut();
+                            Integer in = pair.getInList().get(y);
+                            commandList.add(MatrixCommand.builder().command(MatrixConstants.COMMAND_SET_ATTN)
+                                    .col(in).row(out).attn(att).build());
+                        }
+                    }
+                    commandList.forEach(this::sendCommand);
+                    // 发送完成后，清空集合。
+                    commandList.clear();
+                    try {
+                        Thread.sleep(options.getPeriod() * 1000);
+                    } catch (InterruptedException e) {
+                        e.printStackTrace();
+                    }
+                }
+            }
+            try {
+                Thread.sleep(options.getPause() * 1000);
+            } catch (InterruptedException e) {
+                e.printStackTrace();
+            }
+        }
     }
 }
	@@ -31,7 +31,7 @@ public abstract class ExperimentOptions {		@@ -31,7 +31,7 @@ public abstract class ExperimentOptions {
31		31
32	protected ZonedDateTime finishAt;	32	protected ZonedDateTime finishAt;
33		33
34	- protected List<ExperimentOptionsPair> pairs;	34	+ protected List<StationPair> pairs;
35		35
36	protected abstract boolean checkOptions();	36	protected abstract boolean checkOptions();
37	}	37	}
	@@ -1,21 +0,0 @@	@@ -1,21 +0,0 @@
1	-package com.example.mina.client.base;
2	-
3	-import java.util.List;
4	-import lombok.Data;
5	-
6	-/**
7	- * 输入输出端口
8	- * @author BenJin Yin
9	- * @date 2021/4/2
10	- */
11	-@Data
12	-public class ExperimentOptionsPair {
13	- /**
14	- * 输入端口
15	- */
16	- private Integer out;
17	- /**
18	- * 输出端口
19	- */
20	- private List<Integer> inList;
21	-}
	@@ -179,7 +179,7 @@ public class MatrixClient {		@@ -179,7 +179,7 @@ public class MatrixClient {
179	public void run() {	179	public void run() {
180	while (true) {	180	while (true) {
181	try {	181	try {
182	- MatrixCommand command = commands.poll(5, TimeUnit.SECONDS);	182	+ MatrixCommand command = commands.poll();
183		183
184	if(command != null){	184	if(command != null){
185	log.info("======================");	185	log.info("======================");
@@ -0,0 +1,21 @@		@@ -0,0 +1,21 @@
	1	+package com.example.mina.client.base;
	2	+
	3	+import java.util.List;
	4	+import lombok.Data;
	5	+
	6	+/**
	7	+ * 输入输出端口
	8	+ * @author BenJin Yin
	9	+ * @date 2021/4/2
	10	+ */
	11	+@Data
	12	+public class StationPair {
	13	+ /**
	14	+ * 输出端口
	15	+ */
	16	+ private Integer out;
	17	+ /**
	18	+ * 输入端口
	19	+ */
	20	+ private List<Integer> inList;
	21	+}
1	package com.example.mina.client.experiment;	1	package com.example.mina.client.experiment;
2		2
3	-import com.example.mina.client.base.MatrixClient;
4	-import com.example.mina.client.base.MatrixConstants;
5	import com.example.mina.client.base.Experiment;	3	import com.example.mina.client.base.Experiment;
6	import com.example.mina.client.base.ExperimentOptions;	4	import com.example.mina.client.base.ExperimentOptions;
		5	+import com.example.mina.client.base.MatrixClient;
		6	+import com.example.mina.client.base.MatrixCommand;
		7	+import com.example.mina.client.base.MatrixConstants;
		8	+import com.example.mina.client.base.StationPair;
		9	+import java.util.ArrayList;
		10	+import java.util.List;
		11	+import org.springframework.util.CollectionUtils;
7		12
8	public class HandoverExperiment extends Experiment {	13	public class HandoverExperiment extends Experiment {
9		14
	@@ -18,6 +23,110 @@ public class HandoverExperiment extends Experiment {		@@ -18,6 +23,110 @@ public class HandoverExperiment extends Experiment {
18		23
19	@Override	24	@Override
20	public void schedule() {	25	public void schedule() {
		26	+ List<StationPair> pairs = options.getPairs();
		27	+ if (CollectionUtils.isEmpty(pairs)) {
		28	+ return;
		29	+ }
		30	+ StationPair one = pairs.get(0);
		31	+ if (one == null \|\| one.getInList() == null) {
		32	+ return;
		33	+ }
		34	+ // 输入端口的个数
		35	+ int inSize = one.getInList().size();
		36	+ if (inSize < 2) {
		37	+ return;
		38	+ }
		39	+ // 循环次数
		40	+ Integer count = options.getMaxIterCount();
		41	+ if (count == null \|\| count < 1) {
		42	+ return;
		43	+ }
		44	+ Integer step = options.getStep();
		45	+ Integer endAttenuation = options.getEndAttenuation();
		46	+ int dynamicCont = endAttenuation / step;
		47	+ if (step == null \|\| step <= 0) {
		48	+ return;
		49	+ }
		50	+ for (int i = 0; i < count; i++) {
		51	+ // 输入端口只有 2 个
		52	+ if (inSize == 2) {
		53	+ for (int k = 0; k <= dynamicCont; k++) {
		54	+ int dynamic = step * k;
		55	+ List<MatrixCommand> commandList = new ArrayList<>();
		56	+ for (StationPair pair : pairs) {
		57	+ Integer out = pair.getOut();
		58	+ Integer inOne = pair.getInList().get(0);
		59	+ Integer inTwo = pair.getInList().get(1);
		60	+ MatrixCommand commandOne = MatrixCommand.builder().command(MatrixConstants.COMMAND_SET_ATTN)
		61	+ .col(inOne).row(out).attn(dynamic).build();
		62	+ MatrixCommand commandTwo = MatrixCommand.builder().command(MatrixConstants.COMMAND_SET_ATTN)
		63	+ .col(inTwo).row(out).attn(endAttenuation - dynamic).build();
		64	+ commandList.add(commandOne);
		65	+ commandList.add(commandTwo);
		66	+ }
		67	+ commandList.forEach(this::sendCommand);
		68	+ commandList.clear();
		69	+ try {
		70	+ Thread.sleep(options.getPeriod() * 1000);
		71	+ } catch (InterruptedException e) {
		72	+ e.printStackTrace();
		73	+ }
		74	+ }
		75	+ } else {
		76	+ // 输入端口大于 2
		77	+ // 行数
		78	+ int rowCount = 1 + inSize * dynamicCont;
		79	+ // 动态衰减值矩阵
		80	+ int[][] attenuation = new int[rowCount][inSize];
		81	+ // 当前动态输入端口指针
		82	+ int current = 0;
		83	+ for (int k = 0; k < rowCount; k++) {
		84	+ // 动态衰减值
		85	+ int dynamic = step * (k != 0 && k % dynamicCont == 0 ? dynamicCont : k % dynamicCont);
		86	+ for (int j = 0; j < inSize; j++) {
		87	+ if (j == current && j != inSize - 1) {
		88	+ attenuation[k][j++] = dynamic;
		89	+ attenuation[k][j] = endAttenuation - dynamic;
		90	+ } else if (j == current && j == inSize - 1) {
		91	+ attenuation[k][j] = dynamic;
		92	+ attenuation[k][0] = endAttenuation - dynamic;
		93	+ } else {
		94	+ attenuation[k][j] = endAttenuation;
		95	+ }
		96	+ }
		97	+ // 一轮衰减完成后，当前动态输入端口指针加 1
		98	+ if (k != 0 && k % dynamicCont == 0) {
		99	+ current++;
		100	+ }
		101	+ }
		102	+ for (int x = 0; x < rowCount; x++) {
		103	+ // 当前行 --> 时间点，需要发送的命令
		104	+ List<MatrixCommand> commandList = new ArrayList<>();
		105	+ for (int y = 0; y < inSize; y++) {
		106	+ int att = attenuation[x][y];
		107	+ for (StationPair pair : pairs) {
		108	+ Integer out = pair.getOut();
		109	+ Integer in = pair.getInList().get(y);
		110	+ commandList.add(MatrixCommand.builder().command(MatrixConstants.COMMAND_SET_ATTN)
		111	+ .col(in).row(out).attn(att).build());
		112	+ }
		113	+ }
		114	+ commandList.forEach(this::sendCommand);
		115	+ // 发送完成后，清空集合。
		116	+ commandList.clear();
		117	+ try {
		118	+ Thread.sleep(options.getPeriod() * 1000);
		119	+ } catch (InterruptedException e) {
		120	+ e.printStackTrace();
		121	+ }
		122	+ }
		123	+ }
		124	+ try {
		125	+ Thread.sleep(options.getPause() * 1000);
		126	+ } catch (InterruptedException e) {
		127	+ e.printStackTrace();
		128	+ }
		129	+ }
21	}	130	}
22		131
23	}	132	}