完成 AeroflexVirtualBox

杜云山
1 parent 75092d17
Showing 33 changed files with 512 additions and 877 deletions Show diff stats
pom.xml
src/main/java/com/example/mina/Application.java
src/main/java/com/example/mina/base/AbstractHardwareDataBuffer.java
src/main/java/com/example/mina/base/AbstractVirtualBoxHandler.java
src/main/java/com/example/mina/box1/AeroflexVirtualBoxHandler.java
src/main/java/com/example/mina/config/AeroflexVirtualBoxConfiguration.java
src/main/java/com/example/mina/config/ConfigMina.java
src/main/java/com/example/mina/config/SecurityConfig.java
src/main/java/com/example/mina/controller/RouterController.java
src/main/java/com/example/mina/entity/AeroflexDataBuffer.java
src/main/java/com/example/mina/entity/Entry.java
src/main/java/com/example/mina/http/HttpSimulator.java
src/main/java/com/example/mina/mina/client/MinaClient.java
src/main/java/com/example/mina/mina/client/MinaClientHandler.java
src/main/java/com/example/mina/mina/code/ByteDecoder.java
src/main/java/com/example/mina/mina/code/ByteEnCoder.java
src/main/java/com/example/mina/mina/code/ByteFactory.java
src/main/java/com/example/mina/mina/server/MinaServer.java
src/main/java/com/example/mina/mina/server/MinaServerHandler.java
src/main/java/com/example/mina/property/AeroflexVirtualProperties.java
@@ -5,21 +5,34 @@
     <parent>
         <groupId>org.springframework.boot</groupId>
         <artifactId>spring-boot-starter-parent</artifactId>
-        <version>2.2.11.RELEASE</version>
+        <version>2.4.3</version>
         <relativePath/> <!-- lookup parent from repository -->
     </parent>
-    <groupId>com.example</groupId>
-    <artifactId>demo</artifactId>
+    <groupId>com.peony</groupId>
+    <artifactId>virtual-box</artifactId>
     <version>0.0.1-SNAPSHOT</version>
     <name>mina</name>
-    <description>Demo project for Spring Boot</description>
+
     <properties>
         <java.version>1.8</java.version>
     </properties>
+
     <dependencies>
+
         <dependency>
             <groupId>org.springframework.boot</groupId>
-            <artifactId>spring-boot-starter-web</artifactId>
+            <artifactId>spring-boot-starter</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-configuration-processor</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>org.apache.mina</groupId>
+            <artifactId>mina-core</artifactId>
+            <version>2.1.4</version>
         </dependency>
         <dependency>
@@ -28,11 +41,14 @@
             <scope>runtime</scope>
             <optional>true</optional>
         </dependency>
+
         <dependency>
             <groupId>org.projectlombok</groupId>
             <artifactId>lombok</artifactId>
+            <scope>provided</scope>
             <optional>true</optional>
         </dependency>
+
         <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-test</artifactId>
@@ -44,42 +60,6 @@
                 </exclusion>
             </exclusions>
         </dependency>
-        <!--导入模板引擎才能实现页面跳转-->
-        <dependency>
-            <groupId>org.springframework.boot</groupId>
-            <artifactId>spring-boot-starter-thymeleaf</artifactId>
-        </dependency>
-        <!--springbootSecurity-->
-        <dependency>
-            <groupId>org.springframework.boot</groupId>
-            <artifactId>spring-boot-starter-security</artifactId>
-        </dependency>
-
-        <!--rabbitmq-->
-        <dependency>
-            <groupId>org.springframework.boot</groupId>
-            <artifactId>spring-boot-starter-amqp</artifactId>
-        </dependency>
-
-        <!--spring-statemachine-->
-        <dependency>
-            <groupId>org.springframework.statemachine</groupId>
-            <artifactId>spring-statemachine-core</artifactId>
-            <version>1.2.0.RELEASE</version>
-        </dependency>
-
-        <!--mina-->
-        <dependency>
-            <groupId>org.apache.mina</groupId>
-            <artifactId>mina-core</artifactId>
-            <version>2.1.3</version>
-        </dependency>
-        <dependency>
-            <groupId>org.apache.mina</groupId>
-            <artifactId>mina-integration-spring</artifactId>
-            <version>1.1.7</version>
-        </dependency>
-
     </dependencies>
@@ -3,6 +3,10 @@ package com.example.mina;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+/**
+ * @author 杜云山
+ * @date 2021/03/05
+ */
 @SpringBootApplication
 public class Application {
@@ -0,0 +1,92 @@
+package com.example.mina.base;
+
+import com.example.mina.entity.Entry;
+
+/**
+ * @author 杜云山
+ * @date 2021/03/05
+ */
+public abstract class AbstractHardwareDataBuffer {
+
+    protected int maxRow;
+
+    protected int maxCol;
+
+    protected int maxOffset;
+
+    protected int maxAttenuate;
+
+    protected Entry[][] matrixData;
+
+    protected Entry[] offsetData;
+
+    public AbstractHardwareDataBuffer() {
+    }
+
+    public AbstractHardwareDataBuffer(int row, int col, int offset, int maxAttenuate) {
+        this.maxRow = row;
+        this.maxCol = col;
+        this.maxOffset = offset;
+        this.maxAttenuate = maxAttenuate;
+    }
+
+    /**
+     * Set cross point attenuation value. Actually that is not correct.
+     * In case of LTE device, this is a ON/OFF status (0,1)
+     *
+     * @param row the row index. *** starts from 1 ***
+     * @param col the col index. *** starts from 1 ***
+     * @param val the attenuation value
+     */
+    public synchronized void setAttenuation(int row, int col, int val) {
+
+        if (val != -1 && (row < 1 || row > maxRow || col < 1 || col > maxCol)) {
+            return;
+        }
+        if (val == -1) {
+            val = maxAttenuate;
+        }
+        matrixData[row - 1][col - 1] = new Entry(row - 1, col - 1, "rr", val, false);
+        ;
+    }
+
+    public int getAttenuation(int row, int col) {
+        return matrixData[row - 1][col - 1].getValue();
+    }
+
+    public synchronized void setOffset(int row, int val) {
+        if (row < 1 || row > maxOffset) {
+            return;
+        }
+        offsetData[row - 1] = new Entry(row - 1, 0, "rr", val, false);
+    }
+
+    public int getOffset(int row) {
+        return offsetData[row - 1].getValue();
+    }
+
+    public Entry[] getOffsetData() {
+        return offsetData;
+    }
+
+    public Entry[][] getMatrixData() {
+        return matrixData;
+    }
+
+    public int getMaxRow() {
+        return maxRow;
+    }
+
+    public int getMaxCol() {
+        return maxCol;
+    }
+
+    public int getMaxOffset() {
+        return maxOffset;
+    }
+
+    public int getMaxAttenuate() {
+        return maxAttenuate;
+    }
+
+}
@@ -0,0 +1,25 @@
+package com.example.mina.base;
+
+import org.apache.mina.core.service.IoHandlerAdapter;
+
+/**
+ * @author 杜云山
+ * @date 21/03/05
+ */
+public abstract class AbstractVirtualBoxHandler extends IoHandlerAdapter {
+
+    /**
+     * 初始化矩阵以及该设备的一些参数
+     */
+    protected abstract void initMatrix();
+
+    /**
+     * 处理消息
+     *
+     * @param cmd 指令数据
+     * @param len 数据长度
+     * @return 返回消息
+     */
+    protected abstract byte[] handleMessage(byte[] cmd, int len);
+
+}
@@ -0,0 +1,139 @@
+package com.example.mina.box1;
+
+import com.example.mina.base.AbstractVirtualBoxHandler;
+import com.example.mina.entity.AeroflexDataBuffer;
+import com.example.mina.util.StrUtil;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.mina.core.buffer.IoBuffer;
+import org.apache.mina.core.session.IoSession;
+
+/**
+ * @author 杜云山
+ * @date 21/03/05
+ */
+@Slf4j
+public class AeroflexVirtualBoxHandler extends AbstractVirtualBoxHandler {
+
+    private static final byte[] ERROR = "ERROR".getBytes();
+
+    private static final byte[] NONE = "OK".getBytes();
+
+    private static final String SET_ALL = "ATTN ALL MAX";
+
+    private static final String SET_ONE = "ATTN";
+
+    private static final String GET_ONE = "ATTN?";
+
+    private static final String SPACE_SPLIT = " ";
+
+    private static final String SEMICOLON_SPLIT = ";";
+
+    private AeroflexDataBuffer dataBuffer;
+
+    public AeroflexVirtualBoxHandler() {
+        this.initMatrix();
+    }
+
+    @Override
+    protected void initMatrix() {
+
+        int row = 10;
+        int col = 1;
+        int maxAttenuate = 888;
+
+        dataBuffer = new AeroflexDataBuffer(row, maxAttenuate);
+    }
+
+    @Override
+    public void messageReceived(IoSession session, Object message) {
+
+        IoBuffer ioBuffer = (IoBuffer) message;
+        byte[] bytes = ioBuffer.array();
+
+        byte[] result = handleMessage(bytes, bytes.length);
+
+        session.write(IoBuffer.wrap(result));
+    }
+
+    @Override
+    protected byte[] handleMessage(byte[] cmd, int len) {
+        String command = new String(cmd).trim();
+
+        log.info("aeroflexVirtualBoxHandler receive: {}", command);
+
+        if (command.startsWith(SET_ALL)) {
+            //set all to max
+            for (int i = 1; i < dataBuffer.getMaxRow(); i++) {
+                dataBuffer.setOffset(i, dataBuffer.getMaxAttenuate());
+            }
+
+            return NONE;
+        } else if (command.startsWith(GET_ONE)) {
+            //get
+            String[] sss = command.split(SPACE_SPLIT);
+            if (sss.length >= 2) {
+
+                int row = StrUtil.toInt(sss[1]);
+                if (row >= 0 && row <= dataBuffer.getMaxRow()) {
+                    String str = String.valueOf(dataBuffer.getOffset(row));
+                    log.info("aeroflexVirtualBoxHandler return: {}", str);
+                    return str.getBytes();
+                }
+            }
+            return ERROR;
+
+        } else if (command.startsWith(SET_ONE)) {
+            //Set, Follow by ATTN?
+            String[] aa = command.split(SEMICOLON_SPLIT);
+
+            String[] sss = aa[0].split(SPACE_SPLIT);
+
+            if (sss.length >= 3) {
+
+                int row = StrUtil.toInt(sss[1]);
+                int val = StrUtil.toInt(sss[2]);
+
+                if (row >= 0 && row <= dataBuffer.getMaxRow()) {
+                    if (val >= 0 && val <= dataBuffer.getMaxAttenuate()) {
+                        dataBuffer.setOffset(row, val);
+
+                        String str = String.valueOf(dataBuffer.getOffset(row));
+                        log.info("aeroflexVirtualBoxHandler return =====>  {}", str);
+                        return str.getBytes();
+                    }
+                }
+            }
+
+            return ERROR;
+
+        } else {
+            return ERROR;
+        }
+
+    }
+
+    @Override
+    public void sessionCreated(IoSession session) {
+
+        log.info("--- abstractVirtual server session created");
+    }
+
+    @Override
+    public void sessionOpened(IoSession session) {
+
+        log.info("--- abstractVirtual server session Opened");
+    }
+
+    @Override
+    public void sessionClosed(IoSession session) {
+
+        log.info("--- abstractVirtual server session Closed");
+    }
+
+    @Override
+    public void messageSent(IoSession session, Object message) {
+
+        log.info("--- abstractVirtual 发送数据成功!{}", message);
+    }
+
+}
@@ -0,0 +1,50 @@
+package com.example.mina.config;
+
+import com.example.mina.box1.AeroflexVirtualBoxHandler;
+import com.example.mina.property.AeroflexVirtualProperties;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.mina.transport.socket.nio.NioSocketAcceptor;
+import org.springframework.context.annotation.Configuration;
+
+import javax.annotation.PostConstruct;
+import java.net.InetSocketAddress;
+
+/**
+ * @author 杜云山
+ * @date 21/03/05
+ */
+@Slf4j
+@Configuration(proxyBeanMethods = false)
+public class AeroflexVirtualBoxConfiguration {
+
+    private final AeroflexVirtualProperties aeroflexVirtualProperties;
+
+    public AeroflexVirtualBoxConfiguration(AeroflexVirtualProperties aeroflexVirtualProperties) {
+        this.aeroflexVirtualProperties = aeroflexVirtualProperties;
+    }
+
+    @PostConstruct
+    public void init() {
+
+        if (!aeroflexVirtualProperties.getEnable()) {
+            log.info("AeroflexVirtual服务端 配置未开启");
+            return;
+        }
+
+        if (aeroflexVirtualProperties.getPort() == null) {
+            log.info("AeroflexVirtual服务端 端口未配置");
+            return;
+        }
+
+        try {
+            NioSocketAcceptor acceptor = new NioSocketAcceptor();
+            acceptor.setHandler(new AeroflexVirtualBoxHandler());
+            acceptor.setReuseAddress(true);
+            acceptor.bind(new InetSocketAddress(aeroflexVirtualProperties.getPort()));
+            log.info("AeroflexVirtual服务端已经启动,监听端口: {}", aeroflexVirtualProperties.getPort());
+        } catch (Exception e) {
+            log.error("无法启动AeroflexVirtual服务端, {}", e.getMessage(), e);
+        }
+    }
+
+}
@@ -1,97 +0,0 @@
-package com.example.mina.config;
-
-import com.example.mina.mina.code.ByteFactory;
-import com.example.mina.mina.server.MinaServerHandler;
-import org.apache.mina.core.filterchain.DefaultIoFilterChainBuilder;
-import org.apache.mina.core.service.IoAcceptor;
-import org.apache.mina.core.session.IdleStatus;
-import org.apache.mina.filter.codec.ProtocolCodecFilter;
-import org.apache.mina.filter.executor.ExecutorFilter;
-import org.apache.mina.filter.logging.LoggingFilter;
-import org.apache.mina.transport.socket.nio.NioSocketAcceptor;
-import org.springframework.context.annotation.Bean;
-import org.springframework.context.annotation.Configuration;
-
-import java.io.IOException;
-import java.net.InetSocketAddress;
-
-/**
- * @author dy
- * @date 2021/3/3
- */
-@Configuration
-public class ConfigMina {
-
-    /**
-     * 配置mina的多线程过滤器
-     *
-     * @return
-     */
-    @Bean
-    public ExecutorFilter executorFilter() {
-        //设置初始化线程数，最大线程数
-        ExecutorFilter executorFilter = new ExecutorFilter(10, 20);
-        return executorFilter;
-    }
-
-    /**
-     * 配置mina的转码过滤器
-     *
-     * @return
-     */
-    @Bean
-    public ProtocolCodecFilter protocolCodecFilter() {
-//        TextLineCodecFactory factory = new TextLineCodecFactory(Charset.forName("UTF-8"),
-//                LineDelimiter.WINDOWS.getValue(), LineDelimiter.WINDOWS.getValue());
-
-
-        //TextLineCodecFactory factory = new TextLineCodecFactory(Charset.forName("UTF-8"), LineDelimiter.WINDOWS.getValue(), LineDelimiter.WINDOWS.getValue());
-        ProtocolCodecFilter pcf = new ProtocolCodecFilter(new ByteFactory());
-        //ProtocolCodecFilter pcf = new ProtocolCodecFilter(factory);
-        return pcf;
-    }
-
-    /**
-     * 配置mina的日志过滤器
-     *
-     * @return
-     */
-    @Bean
-    public LoggingFilter loggingFilter() {
-        return new LoggingFilter();
-    }
-
-    /**
-     * 将过滤器注入到mina的链式管理器中
-     *
-     * @return
-     */
-    @Bean
-    public DefaultIoFilterChainBuilder defaultIoFilterChainBuilder() {
-        DefaultIoFilterChainBuilder def = new DefaultIoFilterChainBuilder();
-        def.addLast("executor", executorFilter());
-        def.addLast("logger", loggingFilter());
-        def.addLast("protocol", protocolCodecFilter());
-        return def;
-    }
-
-    /**
-     * 开启mina的server服务，并设置对应的参数
-     *
-     * @return
-     * @throws IOException
-     */
-    @Bean
-    public IoAcceptor ioAcceptor() throws IOException {
-        IoAcceptor nio = new NioSocketAcceptor();
-        //设置缓冲区大小
-        nio.getSessionConfig().setReadBufferSize(2048);
-        //设置空闲状态时间，10秒没操作就进入空闲状态
-        nio.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE, 10);
-        nio.setFilterChainBuilder(defaultIoFilterChainBuilder());
-        nio.setHandler(new MinaServerHandler());
-        nio.bind(new InetSocketAddress(9098));
-        return nio;
-    }
-
-}
@@ -1,27 +0,0 @@
-package com.example.mina.config;
-
-import org.springframework.context.annotation.Configuration;
-import org.springframework.security.config.annotation.web.builders.HttpSecurity;
-import org.springframework.security.config.annotation.web.configuration.WebSecurityConfigurerAdapter;
-
-/**
- * @author dy
- * @date 2021/2/25
- */
-@Configuration
-public class SecurityConfig extends WebSecurityConfigurerAdapter {
-
-    @Override
-    protected void configure(HttpSecurity http) throws Exception {
-        // 首页所有人都可以访问，功能也只有对应有权限的人才能访问到
-        // 请求授权的规则
-
-//        http.authorizeRequests()
-//                .antMatchers("/").permitAll()
-//                .antMatchers("/level1/**").hasRole("vip1")
-//                .antMatchers("/level2/**").hasRole("vip2")
-//                .antMatchers("/level3/**").hasRole("vip3");
-        // 开启自动配置的登录功能
-        http.formLogin();
-    }
-}
@@ -1,41 +0,0 @@
-package com.example.mina.controller;
-
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.stereotype.Controller;
-import org.springframework.web.bind.annotation.GetMapping;
-import org.springframework.web.bind.annotation.PathVariable;
-
-/**
- * @author dy
- * @date 2021/2/22
- */
-@Controller
-@Slf4j
-public class RouterController {
-
-    @GetMapping({"/", "/index"})
-    public String index() {
-        log.info("是否进入程序");
-        return "/index";
-    }
-
-    @GetMapping("/toLogin")
-    public String toLogin() {
-        return "views/login";
-    }
-
-    @GetMapping("/level1/{id}")
-    public String level1(@PathVariable("id") int id) {
-        return "views/level1/" + id;
-    }
-
-    @GetMapping("/level2/{id}")
-    public String level2(@PathVariable("id") int id) {
-        return "views/level2/" + id;
-    }
-
-    @GetMapping("/level3/{id}")
-    public String level3(@PathVariable("id") int id) {
-        return "views/level3/" + id;
-    }
-}
@@ -0,0 +1,29 @@
+package com.example.mina.entity;
+
+import com.example.mina.base.AbstractHardwareDataBuffer;
+
+/**
+ * @author 杜云山
+ * @date 2021/03/05
+ */
+public class AeroflexDataBuffer extends AbstractHardwareDataBuffer {
+
+    public AeroflexDataBuffer(int row, int maxAtten) {
+        super(row, row, row, maxAtten);
+
+        matrixData = new Entry[row][row];
+        offsetData = new Entry[row];
+
+        for (int i = 0; i < row; i++) {
+            for (int k = 0; k < row; k++) {
+                matrixData[i][k] = new Entry(i, k, "kk", maxAtten, false);
+            }
+        }
+
+        for (int i = 0; i < row; i++) {
+            offsetData[i] = new Entry(i, 0, "rr", maxAtten, false);
+        }
+
+    }
+
+}
@@ -0,0 +1,60 @@
+package com.example.mina.entity;
+
+/**
+ * @author 杜云山
+ * @date 2021/03/05
+ */
+public class Entry {
+
+    private final int row;
+
+    private final int col;
+
+    private final String name;
+
+    private int value;
+
+    private final boolean booked;
+
+    private final long timestamp;
+
+    public static final Entry EMPTY = new Entry(0, 0, null, 0, false);
+
+    public Entry(int row, int col, String name, int value, boolean booked) {
+        this.row = row;
+        this.col = col;
+        this.name = name;
+        this.value = value;
+        this.booked = booked;
+        this.timestamp = System.nanoTime();
+    }
+
+    public int getRow() {
+        return row;
+    }
+
+    public int getCol() {
+        return col;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    public int getValue() {
+        return value;
+    }
+
+    public boolean isBooked() {
+        return booked;
+    }
+
+    public void setValue(int v) {
+        this.value = v;
+    }
+
+    public long getTimestamp() {
+        return this.timestamp;
+    }
+
+}
@@ -1,136 +0,0 @@
-package com.example.mina.http;
-
-import java.io.*;
-import java.net.InetSocketAddress;
-import java.net.Socket;
-
-/**
- * @author dy
- * @date 2021/3/4
- */
-public class HttpSimulator {
-
-    private Socket socket;
-
-    private int port = 80;
-
-    private String host = "localhost";
-
-    private String request = ""; // HTTP请求消息
-
-    private boolean isPost, isHead;
-
-
-    public void run() throws Exception {
-        BufferedReader reader = new BufferedReader(new InputStreamReader(
-                System.in));
-        while (true)  // 开始大循环
-        {
-            try {
-                if (!readHostAndPort(reader)) {
-                    break;
-                }
-                readHttpRequest(reader);
-                sendHttpRequest();
-                readHttpResponse(reader);
-
-            } catch (Exception e) {
-                System.out.println("err:" + e.getMessage());
-
-            }
-
-        }
-
-    }
-
-
-    public static void main(String[] args) throws Exception {
-        new HttpSimulator().run();
-
-    }
-
-    private boolean readHostAndPort(BufferedReader consoleReader)
-            throws Exception {
-        System.out.print("host:port>");
-        String[] ss = null;
-        String s = consoleReader.readLine();
-        if (s.equals("q")) {
-            return false;
-        } else {
-            ss = s.split("[:]");
-            if (!ss[0].equals("")) {
-                host = ss[0];
-            }
-            if (ss.length > 1) {
-                port = Integer.parseInt(ss[1]);
-            }
-            System.out.println(host + ":" + String.valueOf(port));
-            return true;
-        }
-    }
-
-    private void readHttpRequest(BufferedReader consoleReader)
-            throws Exception {
-        System.out.println("请输入HTTP请求:");
-        String s = consoleReader.readLine();
-        request = s + "\r\n";
-        boolean isPost = s.substring(0, 4).equals("POST");
-        boolean isHead = s.substring(0, 4).equals("HEAD");
-        while (!(s = consoleReader.readLine()).equals("")) {
-            request = request + s + "\r\n";
-        }
-        request = request + "\r\n";
-        if (isPost) {
-            System.out.println("请输入POST方法的内容:");
-            s = consoleReader.readLine();
-            request = request + s;
-        }
-    }
-
-    private void sendHttpRequest() throws Exception {
-        socket = new Socket();
-        socket.setSoTimeout(10 * 1000);
-        System.out.println("正在连接服务器");
-        socket.connect(new InetSocketAddress(host, port), 10 * 1000);
-        System.out.println("服务器连接成功！");
-        OutputStream out = socket.getOutputStream();
-        OutputStreamWriter writer = new OutputStreamWriter(out);
-        writer.write(request);
-        writer.flush();
-    }
-
-    private void readHttpResponse(BufferedReader consoleReader) {
-        String s = "";
-        try {
-            InputStream in = socket.getInputStream();
-            InputStreamReader inReader = new InputStreamReader(in);
-            BufferedReader socketReader = new BufferedReader(inReader);
-            System.out.println("---------HTTP头---------");
-            boolean b = true; // true: 未读取消息头 false: 已经读取消息头
-            while ((s = socketReader.readLine()) != null) {
-                if (s.equals("") && b == true && !isHead) {
-                    System.out.println("------------------------");
-                    b = false;
-                    System.out.print("是否显示HTTP的内容(Y/N):");
-                    String choice = consoleReader.readLine();
-                    if (choice.equals("Y") || choice.equals("y")) {
-                        System.out.println("---------HTTP内容---------");
-                        continue;
-                    } else {
-                        break;
-                    }
-                } else {
-                    System.out.println(s);
-                }
-            }
-        } catch (Exception e) {
-            System.out.println("err:" + e.getMessage());
-        } finally {
-            try {
-                socket.close();
-            } catch (Exception e) {
-            }
-        }
-        System.out.println("------------------------");
-    }
-}
@@ -1,40 +0,0 @@
-package com.example.mina.mina.client;
-
-import org.apache.mina.core.service.IoConnector;
-import org.apache.mina.filter.codec.ProtocolCodecFilter;
-import org.apache.mina.filter.codec.textline.LineDelimiter;
-import org.apache.mina.filter.codec.textline.TextLineCodecFactory;
-import org.apache.mina.transport.socket.nio.NioSocketConnector;
-
-import java.net.InetSocketAddress;
-import java.nio.charset.Charset;
-
-/**
- * @author dy
- * @date 2021/3/3
- */
-public class MinaClient {
-
-    public static void main(String[] args) {
-        //1、创建客户端IoService
-        IoConnector connector = new NioSocketConnector();
-        //客户端链接超时时间
-        connector.setConnectTimeoutMillis(30000);
-        //2、客户端过滤器
-        connector.getFilterChain().addLast("test",
-                new ProtocolCodecFilter(
-                        new TextLineCodecFactory(
-                                Charset.forName("UTF-8"),
-                                LineDelimiter.WINDOWS.getValue(),
-                                LineDelimiter.WINDOWS.getValue()
-                        )
-                )
-        );
-        //3、客户端IoHandler，发生消息
-        connector.setHandler(new MinaClientHandler("2"));
-        //连接服务端
-        connector.connect(new InetSocketAddress("localhost", 9098));
-
-    }
-
-}
@@ -1,39 +0,0 @@
-package com.example.mina.mina.client;
-
-import org.apache.mina.core.service.IoHandlerAdapter;
-import org.apache.mina.core.session.IoSession;
-
-/**
- * @author dy
- * @date 2021/3/3
- */
-public class MinaClientHandler extends IoHandlerAdapter {
-
-    private final String values;
-
-    public MinaClientHandler(String values) {
-        this.values = values;
-    }
-
-    @Override
-    public void sessionOpened(IoSession session) {
-        session.write(values);
-//        //调用IoService的dispose方法关闭线程,这样每次调用client方法发送数据之后就会关闭client
-//        IoService service = session.getService();
-//        service.dispose();
-
-    }
-
-    /**
-     * 接收服务器端反馈消息
-     *
-     * @param session
-     * @param message
-     * @throws Exception
-     */
-    @Override
-    public void messageReceived(IoSession session, Object message) throws Exception {
-        System.out.println("收到服务器响应消息：" + message);
-    }
-
-}
@@ -1,29 +0,0 @@
-package com.example.mina.mina.code;
-
-import org.apache.mina.core.buffer.IoBuffer;
-import org.apache.mina.core.session.IoSession;
-import org.apache.mina.filter.codec.ProtocolDecoder;
-import org.apache.mina.filter.codec.ProtocolDecoderAdapter;
-import org.apache.mina.filter.codec.ProtocolDecoderOutput;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-/**
- * @author dy
- * @date 2021/3/3
- */
-public class ByteDecoder extends ProtocolDecoderAdapter {
-    //打印日志信息
-    private final static Logger log = LoggerFactory
-            .getLogger(ProtocolDecoder.class);
-
-    @Override
-    public void decode(IoSession session, IoBuffer in, ProtocolDecoderOutput out) throws Exception {
-        int limit = in.limit();
-        byte[] bytes = new byte[limit];
-
-        in.get(bytes);
-
-        out.write(bytes);
-    }
-}
@@ -1,37 +0,0 @@
-package com.example.mina.mina.code;
-
-import org.apache.mina.core.buffer.IoBuffer;
-import org.apache.mina.core.session.IoSession;
-import org.apache.mina.filter.codec.ProtocolEncoder;
-import org.apache.mina.filter.codec.ProtocolEncoderAdapter;
-import org.apache.mina.filter.codec.ProtocolEncoderOutput;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-/**
- * @author dy
- * @date 2021/3/3
- */
-public class ByteEnCoder extends ProtocolEncoderAdapter {
-    //用于打印日志信息
-    private final static Logger log = LoggerFactory
-            .getLogger(ProtocolEncoder.class);
-
-    //编码 将数据包转成字节数组
-    @Override
-    public void encode(IoSession session, Object message, ProtocolEncoderOutput out) throws Exception {
-        byte[] bytes = (byte[]) message;
-
-        IoBuffer buffer = IoBuffer.allocate(256);
-        buffer.setAutoExpand(true);
-
-        buffer.put(bytes);
-        buffer.flip();
-
-        out.write(buffer);
-        out.flush();
-
-        buffer.free();
-    }
-
-}
@@ -1,34 +0,0 @@
-package com.example.mina.mina.code;
-
-import org.apache.mina.core.session.IoSession;
-import org.apache.mina.filter.codec.ProtocolCodecFactory;
-import org.apache.mina.filter.codec.ProtocolDecoder;
-import org.apache.mina.filter.codec.ProtocolEncoder;
-
-/**
- * @author dy
- * @date 2021/3/3
- */
-public class ByteFactory implements ProtocolCodecFactory {
-    private final ByteDecoder decoder;
-    private final ByteEnCoder encoder;
-
-    //构造
-    public ByteFactory() {
-        encoder = new ByteEnCoder();
-        decoder = new ByteDecoder();
-    }
-
-    @Override
-    public ProtocolDecoder getDecoder(IoSession arg0) throws Exception {
-        // TODO Auto-generated method stub
-        return decoder;
-    }
-
-    @Override
-    public ProtocolEncoder getEncoder(IoSession arg0) throws Exception {
-        // TODO Auto-generated method stub
-        return encoder;
-    }
-
-}
@@ -1,92 +0,0 @@
-package com.example.mina.mina.server;
-
-import com.example.mina.mina.code.ByteFactory;
-import org.apache.mina.core.service.IoAcceptor;
-import org.apache.mina.core.session.IdleStatus;
-import org.apache.mina.filter.codec.ProtocolCodecFilter;
-import org.apache.mina.filter.codec.textline.LineDelimiter;
-import org.apache.mina.filter.codec.textline.TextLineCodecFactory;
-import org.apache.mina.filter.executor.ExecutorFilter;
-import org.apache.mina.filter.logging.LogLevel;
-import org.apache.mina.filter.logging.LoggingFilter;
-import org.apache.mina.transport.socket.nio.NioSocketAcceptor;
-
-import java.io.IOException;
-import java.net.InetSocketAddress;
-import java.nio.charset.Charset;
-
-/**
- * @author dy
- * @date 2021/3/3
- */
-public class MinaServer {
-
-    public static ExecutorFilter executorFilter() {
-        //设置初始化线程数，最大线程数
-        ExecutorFilter executorFilter = new ExecutorFilter(10, 20);
-        return executorFilter;
-    }
-
-    public static LoggingFilter loggingFilter() {
-        return new LoggingFilter();
-    }
-
-    public static ProtocolCodecFilter protocolCodecFilter() {
-//        TextLineCodecFactory factory = new TextLineCodecFactory(Charset.forName("UTF-8"),
-//                LineDelimiter.WINDOWS.getValue(), LineDelimiter.WINDOWS.getValue());
-
-
-        //TextLineCodecFactory factory = new TextLineCodecFactory(Charset.forName("UTF-8"), LineDelimiter.WINDOWS.getValue(), LineDelimiter.WINDOWS.getValue());
-        ProtocolCodecFilter pcf = new ProtocolCodecFilter(new ByteFactory());
-        //ProtocolCodecFilter pcf = new ProtocolCodecFilter(factory);
-        return pcf;
-    }
-
-    public static void main(String[] args) throws IOException {
-        /*IoAcceptor nio = new NioSocketAcceptor();
-        //设置缓冲区大小
-        nio.getSessionConfig().setReadBufferSize(2048);
-        //设置空闲状态时间，10秒没操作就进入空闲状态
-        nio.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE, 10);
-
-        DefaultIoFilterChainBuilder def = new DefaultIoFilterChainBuilder();
-        def.addLast("executor", executorFilter());
-        def.addLast("logger", loggingFilter());
-        def.addLast("protocol", protocolCodecFilter());
-
-        nio.setFilterChainBuilder(def);
-        nio.setHandler(new MinaServerHandler());
-        nio.bind(new InetSocketAddress(9098));*/
-
-
-
-
-
-        //1、创建IoService，拥有监听是否有客户端链接
-        IoAcceptor acceptor = new NioSocketAcceptor();
-        //设置缓冲区大小
-        acceptor.getSessionConfig().setReadBufferSize(2048);
-        //设置空闲状态时间，10秒没操作就进入空闲状态
-        acceptor.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE, 10);
-
-        //创建日志过滤器,mina内部使用的是slf4j日志，加入日志之后可以查看mina的运行细节信息
-        LoggingFilter log = new LoggingFilter();
-        log.setSessionOpenedLogLevel(LogLevel.INFO);
-        acceptor.getFilterChain().addLast("logger", log);
-
-        //2、实现过滤器
-        //acceptor.getFilterChain().addLast("protocol", protocolCodecFilter());
-        acceptor.getFilterChain().addLast("protocol",
-                new ProtocolCodecFilter(
-                        new TextLineCodecFactory(Charset.forName("UTF-8"), LineDelimiter.WINDOWS.getValue(), LineDelimiter.WINDOWS.getValue())
-                )
-        );
-        //3、实现IoHandler，并注册到IoService
-        acceptor.setHandler(new MinaServerHandler());
-        //绑定端口，绑定之前必须设置handler实现类
-        acceptor.bind(new InetSocketAddress(9098));
-
-
-    }
-
-}
@@ -1,141 +0,0 @@
-package com.example.mina.mina.server;
-
-import org.apache.mina.core.service.IoHandlerAdapter;
-import org.apache.mina.core.session.IoSession;
-
-import java.io.ByteArrayOutputStream;
-import java.io.ObjectOutputStream;
-import java.net.SocketAddress;
-import java.nio.charset.Charset;
-import java.nio.charset.StandardCharsets;
-
-/**
- * @author dy
- * @date 2021/3/3
- */
-public class MinaServerHandler extends IoHandlerAdapter {
-
-    @Override
-    public void messageReceived(IoSession session, Object message) throws Exception {
-//        String command = new String(ObjectToByte(message)).trim();
-//
-//        if (command.startsWith("ATTN ALL MAX")) {//set all to max
-//            for (int i = 1; i < dataBuffer.getMaxRow(); i++) {
-//                dataBuffer.setOffset(i, dataBuffer.getMaxAtten());
-//            }
-//
-//            return NONE;
-//        } else if (command.startsWith("ATTN?")) {//get
-//            String[] sss = command.split(" ");
-//            if (sss.length >= 2) {
-//                LogUtils.println(sss[0], sss[1]);
-//
-//                int row = StrUtil.toInt(sss[1]);
-//                if (row >= 0 && row <= dataBuffer.getMaxRow()) {
-//                    String str = String.valueOf(dataBuffer.getOffset(row));
-//                    LogUtils.println("AeroflexVirtualBoxService::handleCommand  return : ", str);
-//                    return str.getBytes();
-//                }
-//            }
-//
-//            return ERROR;
-//        } else if (command.startsWith("ATTN")) {//Set, Follow by ATTN?
-//            LogUtils.println("command.startsWith(\"ATTN\")");
-//            String[] aa = command.split(";");
-//
-//            LogUtils.println(aa[0], aa[1]);
-//
-//            String[] sss = aa[0].split(" ");
-//            StrUtil.printArray(sss);
-//
-//            if (sss.length >= 3) {
-//                int row = StrUtil.toInt(sss[1]);
-//                int val = StrUtil.toInt(sss[2]);
-//
-//                System.out.println(row + "/" + val);
-//
-//
-//                if (row >= 0 && row <= dataBuffer.getMaxRow()) {
-//                    if (val >= 0 && val <= dataBuffer.getMaxAtten()) {
-//                        dataBuffer.setOffset(row, val);
-//
-//                        String str = String.valueOf(dataBuffer.getOffset(row));
-//                        LogUtils.println("handleCommand  return =====>  ", str);
-//                        return str.getBytes();
-//                    }
-//                }
-//            }
-
-        //业务代码在这里编写处理
-        String str = new String((byte[])message);
-        System.out.println("The message received is [" + str + "]");
-        //获取客户端的连接地址
-        SocketAddress socketAddress = session.getRemoteAddress();
-        System.out.println(socketAddress);
-        String send = "消息已处理，你可以去玩了。。。";
-        //响应给对应客户端信息
-        session.write(send.getBytes());
-        session.closeNow();
-//        // 此处关闭session后客户端无法接收到服务器反馈的消息
-//        if (str.endsWith("quit")) {
-//            //注意：在这里调用close方法之后，只是关闭当前的tcp连接，server端还正常运行，
-//            //需要调用IoService的dispose方法才能关闭server端，client端同理
-//
-//            return;
-//        }
-    }
-
-    @Override
-    public void sessionCreated(IoSession session) throws Exception {
-        System.out.println("server session created");
-        super.sessionCreated(session);
-    }
-
-    @Override
-    public void sessionOpened(IoSession session) throws Exception {
-        System.out.println("server session Opened");
-        super.sessionOpened(session);
-    }
-
-    @Override
-    public void sessionClosed(IoSession session) throws Exception {
-        System.out.println("server session Closed");
-        super.sessionClosed(session);
-    }
-
-    /**
-     * 在IoHandlerAdapter中有一个messageSent的方法，但是重写这个方法之后，不会发送数据，该方法只有数据发送成功之后才会调用，
-     * 所以在 messageReceived 方法中使用 session.write("消息已处理，你可以去玩了。。。"); 给客户端响应数据
-     *
-     * @param session
-     * @param message
-     * @throws Exception
-     */
-    @Override
-    public void messageSent(IoSession session, Object message) throws Exception {
-        // TODO Auto-generated method stub
-        System.out.println("发送数据成功了。。。" + message);
-        //    	session.write("testSent");
-        super.messageSent(session, message);
-    }
-
-    private byte[] ObjectToByte(Object obj) {
-        byte[] bytes = null;
-        try {
-            // object to bytearray
-            ByteArrayOutputStream bo = new ByteArrayOutputStream();
-            ObjectOutputStream oo = new ObjectOutputStream(bo);
-            oo.writeObject(obj);
-
-            bytes = bo.toByteArray();
-
-            bo.close();
-            oo.close();
-        } catch (Exception e) {
-            System.out.println("translation" + e.getMessage());
-            e.printStackTrace();
-        }
-        return bytes;
-    }
-
-}
@@ -0,0 +1,26 @@
+package com.example.mina.property;
+
+import lombok.Getter;
+import lombok.Setter;
+import lombok.ToString;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.boot.context.properties.EnableConfigurationProperties;
+import org.springframework.context.annotation.Configuration;
+
+/**
+ * @author 杜云山
+ * @date 2021/03/05
+ */
+@Getter
+@Setter
+@ToString
+@ConfigurationProperties(prefix = "aeroflex-virtual")
+@Configuration
+@EnableConfigurationProperties(AeroflexVirtualProperties.class)
+public class AeroflexVirtualProperties {
+
+    private Boolean enable = false;
+
+    private Integer port = null;
+
+}
 \ No newline at end of file
@@ -0,0 +1,63 @@
+package com.example.mina.util;
+
+import lombok.extern.slf4j.Slf4j;
+
+/**
+ * @author 杜云山
+ * @date 2021/03/05
+ */
+@Slf4j
+public class StrUtil {
+
+    public static int[] parseCommaInts(String str) {
+        if (str == null) {
+            return new int[0];
+        }
+
+        String[] ss = str.split(",");
+        int[] ids = new int[ss.length];
+
+        int count = 0;
+        for (int i = 0; i < ss.length; i++) {
+            int p = toInt(ss[i]);
+            ids[i] = p;
+            if (p >= 0) {
+                count++;
+            }
+        }
+
+        if (count < ss.length) {
+            int[] ids2 = new int[count];
+            count = 0;
+            for (int i = 0; i < ss.length; i++) {
+                if (ids[i] >= 0) {
+                    ids2[count++] = ids[i];
+                }
+            }
+
+            ids = ids2;
+        }
+
+        return ids;
+    }
+
+    public static int toInt(String str) {
+        if (isEmpty(str)) {
+            return -1;
+        }
+
+        try {
+            float f = Float.parseFloat(str.trim());
+            return (int) f;
+        } catch (Exception e) {
+            log.error("{}, 无法转换为数字", str, e);
+            return -1;
+        }
+
+    }
+
+    public static boolean isEmpty(String str) {
+        return str == null || str.trim().isEmpty();
+    }
+
+}
-server:
-  port: 8080
-  servlet:
-    context-path: /test
-
-# rabbitmq配置
-  #spring:
-    # rabbitmq:
-    # host: localhost
-    # port: 5672
-    #  username: guest
-    #  password: guest
-  #  virtual-host: /
 \ No newline at end of file
+aeroflex-virtual:
+  enable: true
+  port: 9100
 \ No newline at end of file
@@ -1,10 +0,0 @@
-<!DOCTYPE html>
-<html lang="en">
-<head>
-    <meta charset="UTF-8">
-    <title>Title</title>
-</head>
-<body>
-<div>我是首页</div>
-</body>
-</html>
 \ No newline at end of file
@@ -1,10 +0,0 @@
-<!DOCTYPE html>
-<html lang="en">
-<head>
-    <meta charset="UTF-8">
-    <title>Title</title>
-</head>
-<body>
-<div>我是level1-1</div>
-</body>
-</html>
 \ No newline at end of file
@@ -1,10 +0,0 @@
-<!DOCTYPE html>
-<html lang="en">
-<head>
-    <meta charset="UTF-8">
-    <title>Title</title>
-</head>
-<body>
-<div>我是level1-2</div>
-</body>
-</html>
 \ No newline at end of file
@@ -1,10 +0,0 @@
-<!DOCTYPE html>
-<html lang="en">
-<head>
-    <meta charset="UTF-8">
-    <title>Title</title>
-</head>
-<body>
-<div>我是level1-3</div>
-</body>
-</html>
 \ No newline at end of file
@@ -1,10 +0,0 @@
-<!DOCTYPE html>
-<html lang="en">
-<head>
-    <meta charset="UTF-8">
-    <title>Title</title>
-</head>
-<body>
-<div>我是level2-1</div>
-</body>
-</html>
 \ No newline at end of file
@@ -1,10 +0,0 @@
-<!DOCTYPE html>
-<html lang="en">
-<head>
-    <meta charset="UTF-8">
-    <title>Title</title>
-</head>
-<body>
-<div>我是level2-2</div>
-</body>
-</html>
 \ No newline at end of file
@@ -1,10 +0,0 @@
-<!DOCTYPE html>
-<html lang="en">
-<head>
-    <meta charset="UTF-8">
-    <title>Title</title>
-</head>
-<body>
-<div>我是level2-3</div>
-</body>
-</html>
 \ No newline at end of file
@@ -1,10 +0,0 @@
-<!DOCTYPE html>
-<html lang="en">
-<head>
-    <meta charset="UTF-8">
-    <title>Title</title>
-</head>
-<body>
-<div>我是level3-1</div>
-</body>
-</html>
 \ No newline at end of file
@@ -1,10 +0,0 @@
-<!DOCTYPE html>
-<html lang="en">
-<head>
-    <meta charset="UTF-8">
-    <title>Title</title>
-</head>
-<body>
-<div>我是level3-2</div>
-</body>
-</html>
 \ No newline at end of file
@@ -1,10 +0,0 @@
-<!DOCTYPE html>
-<html lang="en">
-<head>
-    <meta charset="UTF-8">
-    <title>Title</title>
-</head>
-<body>
-<div>我是level3-3</div>
-</body>
-</html>
 \ No newline at end of file
@@ -1,10 +0,0 @@
-<!DOCTYPE html>
-<html lang="en">
-<head>
-    <meta charset="UTF-8">
-    <title>Title</title>
-</head>
-<body>
-<div>我是登录页</div>
-</body>
-</html>
 \ No newline at end of file
@@ -0,0 +1,92 @@		@@ -0,0 +1,92 @@
	1	+package com.example.mina.base;
	2	+
	3	+import com.example.mina.entity.Entry;
	4	+
	5	+/**
	6	+ * @author 杜云山
	7	+ * @date 2021/03/05
	8	+ */
	9	+public abstract class AbstractHardwareDataBuffer {
	10	+
	11	+ protected int maxRow;
	12	+
	13	+ protected int maxCol;
	14	+
	15	+ protected int maxOffset;
	16	+
	17	+ protected int maxAttenuate;
	18	+
	19	+ protected Entry[][] matrixData;
	20	+
	21	+ protected Entry[] offsetData;
	22	+
	23	+ public AbstractHardwareDataBuffer() {
	24	+ }
	25	+
	26	+ public AbstractHardwareDataBuffer(int row, int col, int offset, int maxAttenuate) {
	27	+ this.maxRow = row;
	28	+ this.maxCol = col;
	29	+ this.maxOffset = offset;
	30	+ this.maxAttenuate = maxAttenuate;
	31	+ }
	32	+
	33	+ /**
	34	+ * Set cross point attenuation value. Actually that is not correct.
	35	+ * In case of LTE device, this is a ON/OFF status (0,1)
	36	+ *
	37	+ * @param row the row index. * starts from 1 *
	38	+ * @param col the col index. * starts from 1 *
	39	+ * @param val the attenuation value
	40	+ */
	41	+ public synchronized void setAttenuation(int row, int col, int val) {
	42	+
	43	+ if (val != -1 && (row < 1 \|\| row > maxRow \|\| col < 1 \|\| col > maxCol)) {
	44	+ return;
	45	+ }
	46	+ if (val == -1) {
	47	+ val = maxAttenuate;
	48	+ }
	49	+ matrixData[row - 1][col - 1] = new Entry(row - 1, col - 1, "rr", val, false);
	50	+ ;
	51	+ }
	52	+
	53	+ public int getAttenuation(int row, int col) {
	54	+ return matrixData[row - 1][col - 1].getValue();
	55	+ }
	56	+
	57	+ public synchronized void setOffset(int row, int val) {
	58	+ if (row < 1 \|\| row > maxOffset) {
	59	+ return;
	60	+ }
	61	+ offsetData[row - 1] = new Entry(row - 1, 0, "rr", val, false);
	62	+ }
	63	+
	64	+ public int getOffset(int row) {
	65	+ return offsetData[row - 1].getValue();
	66	+ }
	67	+
	68	+ public Entry[] getOffsetData() {
	69	+ return offsetData;
	70	+ }
	71	+
	72	+ public Entry[][] getMatrixData() {
	73	+ return matrixData;
	74	+ }
	75	+
	76	+ public int getMaxRow() {
	77	+ return maxRow;
	78	+ }
	79	+
	80	+ public int getMaxCol() {
	81	+ return maxCol;
	82	+ }
	83	+
	84	+ public int getMaxOffset() {
	85	+ return maxOffset;
	86	+ }
	87	+
	88	+ public int getMaxAttenuate() {
	89	+ return maxAttenuate;
	90	+ }
	91	+
	92	+}
@@ -0,0 +1,25 @@		@@ -0,0 +1,25 @@
	1	+package com.example.mina.base;
	2	+
	3	+import org.apache.mina.core.service.IoHandlerAdapter;
	4	+
	5	+/**
	6	+ * @author 杜云山
	7	+ * @date 21/03/05
	8	+ */
	9	+public abstract class AbstractVirtualBoxHandler extends IoHandlerAdapter {
	10	+
	11	+ /**
	12	+ * 初始化矩阵以及该设备的一些参数
	13	+ */
	14	+ protected abstract void initMatrix();
	15	+
	16	+ /**
	17	+ * 处理消息
	18	+ *
	19	+ * @param cmd 指令数据
	20	+ * @param len 数据长度
	21	+ * @return 返回消息
	22	+ */
	23	+ protected abstract byte[] handleMessage(byte[] cmd, int len);
	24	+
	25	+}
@@ -0,0 +1,139 @@		@@ -0,0 +1,139 @@
	1	+package com.example.mina.box1;
	2	+
	3	+import com.example.mina.base.AbstractVirtualBoxHandler;
	4	+import com.example.mina.entity.AeroflexDataBuffer;
	5	+import com.example.mina.util.StrUtil;
	6	+import lombok.extern.slf4j.Slf4j;
	7	+import org.apache.mina.core.buffer.IoBuffer;
	8	+import org.apache.mina.core.session.IoSession;
	9	+
	10	+/**
	11	+ * @author 杜云山
	12	+ * @date 21/03/05
	13	+ */
	14	+@Slf4j
	15	+public class AeroflexVirtualBoxHandler extends AbstractVirtualBoxHandler {
	16	+
	17	+ private static final byte[] ERROR = "ERROR".getBytes();
	18	+
	19	+ private static final byte[] NONE = "OK".getBytes();
	20	+
	21	+ private static final String SET_ALL = "ATTN ALL MAX";
	22	+
	23	+ private static final String SET_ONE = "ATTN";
	24	+
	25	+ private static final String GET_ONE = "ATTN?";
	26	+
	27	+ private static final String SPACE_SPLIT = " ";
	28	+
	29	+ private static final String SEMICOLON_SPLIT = ";";
	30	+
	31	+ private AeroflexDataBuffer dataBuffer;
	32	+
	33	+ public AeroflexVirtualBoxHandler() {
	34	+ this.initMatrix();
	35	+ }
	36	+
	37	+ @Override
	38	+ protected void initMatrix() {
	39	+
	40	+ int row = 10;
	41	+ int col = 1;
	42	+ int maxAttenuate = 888;
	43	+
	44	+ dataBuffer = new AeroflexDataBuffer(row, maxAttenuate);
	45	+ }
	46	+
	47	+ @Override
	48	+ public void messageReceived(IoSession session, Object message) {
	49	+
	50	+ IoBuffer ioBuffer = (IoBuffer) message;
	51	+ byte[] bytes = ioBuffer.array();
	52	+
	53	+ byte[] result = handleMessage(bytes, bytes.length);
	54	+
	55	+ session.write(IoBuffer.wrap(result));
	56	+ }
	57	+
	58	+ @Override
	59	+ protected byte[] handleMessage(byte[] cmd, int len) {
	60	+ String command = new String(cmd).trim();
	61	+
	62	+ log.info("aeroflexVirtualBoxHandler receive: {}", command);
	63	+
	64	+ if (command.startsWith(SET_ALL)) {
	65	+ //set all to max
	66	+ for (int i = 1; i < dataBuffer.getMaxRow(); i++) {
	67	+ dataBuffer.setOffset(i, dataBuffer.getMaxAttenuate());
	68	+ }
	69	+
	70	+ return NONE;
	71	+ } else if (command.startsWith(GET_ONE)) {
	72	+ //get
	73	+ String[] sss = command.split(SPACE_SPLIT);
	74	+ if (sss.length >= 2) {
	75	+
	76	+ int row = StrUtil.toInt(sss[1]);
	77	+ if (row >= 0 && row <= dataBuffer.getMaxRow()) {
	78	+ String str = String.valueOf(dataBuffer.getOffset(row));
	79	+ log.info("aeroflexVirtualBoxHandler return: {}", str);
	80	+ return str.getBytes();
	81	+ }
	82	+ }
	83	+ return ERROR;
	84	+
	85	+ } else if (command.startsWith(SET_ONE)) {
	86	+ //Set, Follow by ATTN?
	87	+ String[] aa = command.split(SEMICOLON_SPLIT);
	88	+
	89	+ String[] sss = aa[0].split(SPACE_SPLIT);
	90	+
	91	+ if (sss.length >= 3) {
	92	+
	93	+ int row = StrUtil.toInt(sss[1]);
	94	+ int val = StrUtil.toInt(sss[2]);
	95	+
	96	+ if (row >= 0 && row <= dataBuffer.getMaxRow()) {
	97	+ if (val >= 0 && val <= dataBuffer.getMaxAttenuate()) {
	98	+ dataBuffer.setOffset(row, val);
	99	+
	100	+ String str = String.valueOf(dataBuffer.getOffset(row));
	101	+ log.info("aeroflexVirtualBoxHandler return =====> {}", str);
	102	+ return str.getBytes();
	103	+ }
	104	+ }
	105	+ }
	106	+
	107	+ return ERROR;
	108	+
	109	+ } else {
	110	+ return ERROR;
	111	+ }
	112	+
	113	+ }
	114	+
	115	+ @Override
	116	+ public void sessionCreated(IoSession session) {
	117	+
	118	+ log.info("--- abstractVirtual server session created");
	119	+ }
	120	+
	121	+ @Override
	122	+ public void sessionOpened(IoSession session) {
	123	+
	124	+ log.info("--- abstractVirtual server session Opened");
	125	+ }
	126	+
	127	+ @Override
	128	+ public void sessionClosed(IoSession session) {
	129	+
	130	+ log.info("--- abstractVirtual server session Closed");
	131	+ }
	132	+
	133	+ @Override
	134	+ public void messageSent(IoSession session, Object message) {
	135	+
	136	+ log.info("--- abstractVirtual 发送数据成功!{}", message);
	137	+ }
	138	+
	139	+}
@@ -0,0 +1,50 @@		@@ -0,0 +1,50 @@
	1	+package com.example.mina.config;
	2	+
	3	+import com.example.mina.box1.AeroflexVirtualBoxHandler;
	4	+import com.example.mina.property.AeroflexVirtualProperties;
	5	+import lombok.extern.slf4j.Slf4j;
	6	+import org.apache.mina.transport.socket.nio.NioSocketAcceptor;
	7	+import org.springframework.context.annotation.Configuration;
	8	+
	9	+import javax.annotation.PostConstruct;
	10	+import java.net.InetSocketAddress;
	11	+
	12	+/**
	13	+ * @author 杜云山
	14	+ * @date 21/03/05
	15	+ */
	16	+@Slf4j
	17	+@Configuration(proxyBeanMethods = false)
	18	+public class AeroflexVirtualBoxConfiguration {
	19	+
	20	+ private final AeroflexVirtualProperties aeroflexVirtualProperties;
	21	+
	22	+ public AeroflexVirtualBoxConfiguration(AeroflexVirtualProperties aeroflexVirtualProperties) {
	23	+ this.aeroflexVirtualProperties = aeroflexVirtualProperties;
	24	+ }
	25	+
	26	+ @PostConstruct
	27	+ public void init() {
	28	+
	29	+ if (!aeroflexVirtualProperties.getEnable()) {
	30	+ log.info("AeroflexVirtual服务端配置未开启");
	31	+ return;
	32	+ }
	33	+
	34	+ if (aeroflexVirtualProperties.getPort() == null) {
	35	+ log.info("AeroflexVirtual服务端端口未配置");
	36	+ return;
	37	+ }
	38	+
	39	+ try {
	40	+ NioSocketAcceptor acceptor = new NioSocketAcceptor();
	41	+ acceptor.setHandler(new AeroflexVirtualBoxHandler());
	42	+ acceptor.setReuseAddress(true);
	43	+ acceptor.bind(new InetSocketAddress(aeroflexVirtualProperties.getPort()));
	44	+ log.info("AeroflexVirtual服务端已经启动,监听端口: {}", aeroflexVirtualProperties.getPort());
	45	+ } catch (Exception e) {
	46	+ log.error("无法启动AeroflexVirtual服务端, {}", e.getMessage(), e);
	47	+ }
	48	+ }
	49	+
	50	+}
	@@ -1,97 +0,0 @@	@@ -1,97 +0,0 @@
1	-package com.example.mina.config;
2	-
3	-import com.example.mina.mina.code.ByteFactory;
4	-import com.example.mina.mina.server.MinaServerHandler;
5	-import org.apache.mina.core.filterchain.DefaultIoFilterChainBuilder;
6	-import org.apache.mina.core.service.IoAcceptor;
7	-import org.apache.mina.core.session.IdleStatus;
8	-import org.apache.mina.filter.codec.ProtocolCodecFilter;
9	-import org.apache.mina.filter.executor.ExecutorFilter;
10	-import org.apache.mina.filter.logging.LoggingFilter;
11	-import org.apache.mina.transport.socket.nio.NioSocketAcceptor;
12	-import org.springframework.context.annotation.Bean;
13	-import org.springframework.context.annotation.Configuration;
14	-
15	-import java.io.IOException;
16	-import java.net.InetSocketAddress;
17	-
18	-/**
19	- * @author dy
20	- * @date 2021/3/3
21	- */
22	-@Configuration
23	-public class ConfigMina {
24	-
25	- /**
26	- * 配置mina的多线程过滤器
27	- *
28	- * @return
29	- */
30	- @Bean
31	- public ExecutorFilter executorFilter() {
32	- //设置初始化线程数，最大线程数
33	- ExecutorFilter executorFilter = new ExecutorFilter(10, 20);
34	- return executorFilter;
35	- }
36	-
37	- /**
38	- * 配置mina的转码过滤器
39	- *
40	- * @return
41	- */
42	- @Bean
43	- public ProtocolCodecFilter protocolCodecFilter() {
44	-// TextLineCodecFactory factory = new TextLineCodecFactory(Charset.forName("UTF-8"),
45	-// LineDelimiter.WINDOWS.getValue(), LineDelimiter.WINDOWS.getValue());
46	-
47	-
48	- //TextLineCodecFactory factory = new TextLineCodecFactory(Charset.forName("UTF-8"), LineDelimiter.WINDOWS.getValue(), LineDelimiter.WINDOWS.getValue());
49	- ProtocolCodecFilter pcf = new ProtocolCodecFilter(new ByteFactory());
50	- //ProtocolCodecFilter pcf = new ProtocolCodecFilter(factory);
51	- return pcf;
52	- }
53	-
54	- /**
55	- * 配置mina的日志过滤器
56	- *
57	- * @return
58	- */
59	- @Bean
60	- public LoggingFilter loggingFilter() {
61	- return new LoggingFilter();
62	- }
63	-
64	- /**
65	- * 将过滤器注入到mina的链式管理器中
66	- *
67	- * @return
68	- */
69	- @Bean
70	- public DefaultIoFilterChainBuilder defaultIoFilterChainBuilder() {
71	- DefaultIoFilterChainBuilder def = new DefaultIoFilterChainBuilder();
72	- def.addLast("executor", executorFilter());
73	- def.addLast("logger", loggingFilter());
74	- def.addLast("protocol", protocolCodecFilter());
75	- return def;
76	- }
77	-
78	- /**
79	- * 开启mina的server服务，并设置对应的参数
80	- *
81	- * @return
82	- * @throws IOException
83	- */
84	- @Bean
85	- public IoAcceptor ioAcceptor() throws IOException {
86	- IoAcceptor nio = new NioSocketAcceptor();
87	- //设置缓冲区大小
88	- nio.getSessionConfig().setReadBufferSize(2048);
89	- //设置空闲状态时间，10秒没操作就进入空闲状态
90	- nio.getSessionConfig().setIdleTime(IdleStatus.BOTH_IDLE, 10);
91	- nio.setFilterChainBuilder(defaultIoFilterChainBuilder());
92	- nio.setHandler(new MinaServerHandler());
93	- nio.bind(new InetSocketAddress(9098));
94	- return nio;
95	- }
96	-
97	-}
	@@ -1,27 +0,0 @@	@@ -1,27 +0,0 @@
1	-package com.example.mina.config;
2	-
3	-import org.springframework.context.annotation.Configuration;
4	-import org.springframework.security.config.annotation.web.builders.HttpSecurity;
5	-import org.springframework.security.config.annotation.web.configuration.WebSecurityConfigurerAdapter;
6	-
7	-/**
8	- * @author dy
9	- * @date 2021/2/25
10	- */
11	-@Configuration
12	-public class SecurityConfig extends WebSecurityConfigurerAdapter {
13	-
14	- @Override
15	- protected void configure(HttpSecurity http) throws Exception {
16	- // 首页所有人都可以访问，功能也只有对应有权限的人才能访问到
17	- // 请求授权的规则
18	-
19	-// http.authorizeRequests()
20	-// .antMatchers("/").permitAll()
21	-// .antMatchers("/level1/**").hasRole("vip1")
22	-// .antMatchers("/level2/**").hasRole("vip2")
23	-// .antMatchers("/level3/**").hasRole("vip3");
24	- // 开启自动配置的登录功能
25	- http.formLogin();
26	- }
27	-}
	@@ -1,41 +0,0 @@	@@ -1,41 +0,0 @@
1	-package com.example.mina.controller;
2	-
3	-import lombok.extern.slf4j.Slf4j;
4	-import org.springframework.stereotype.Controller;
5	-import org.springframework.web.bind.annotation.GetMapping;
6	-import org.springframework.web.bind.annotation.PathVariable;
7	-
8	-/**
9	- * @author dy
10	- * @date 2021/2/22
11	- */
12	-@Controller
13	-@Slf4j
14	-public class RouterController {
15	-
16	- @GetMapping({"/", "/index"})
17	- public String index() {
18	- log.info("是否进入程序");
19	- return "/index";
20	- }
21	-
22	- @GetMapping("/toLogin")
23	- public String toLogin() {
24	- return "views/login";
25	- }
26	-
27	- @GetMapping("/level1/{id}")
28	- public String level1(@PathVariable("id") int id) {
29	- return "views/level1/" + id;
30	- }
31	-
32	- @GetMapping("/level2/{id}")
33	- public String level2(@PathVariable("id") int id) {
34	- return "views/level2/" + id;
35	- }
36	-
37	- @GetMapping("/level3/{id}")
38	- public String level3(@PathVariable("id") int id) {
39	- return "views/level3/" + id;
40	- }
41	-}
@@ -0,0 +1,29 @@		@@ -0,0 +1,29 @@
	1	+package com.example.mina.entity;
	2	+
	3	+import com.example.mina.base.AbstractHardwareDataBuffer;
	4	+
	5	+/**
	6	+ * @author 杜云山
	7	+ * @date 2021/03/05
	8	+ */
	9	+public class AeroflexDataBuffer extends AbstractHardwareDataBuffer {
	10	+
	11	+ public AeroflexDataBuffer(int row, int maxAtten) {
	12	+ super(row, row, row, maxAtten);
	13	+
	14	+ matrixData = new Entry[row][row];
	15	+ offsetData = new Entry[row];
	16	+
	17	+ for (int i = 0; i < row; i++) {
	18	+ for (int k = 0; k < row; k++) {
	19	+ matrixData[i][k] = new Entry(i, k, "kk", maxAtten, false);
	20	+ }
	21	+ }
	22	+
	23	+ for (int i = 0; i < row; i++) {
	24	+ offsetData[i] = new Entry(i, 0, "rr", maxAtten, false);
	25	+ }
	26	+
	27	+ }
	28	+
	29	+}
@@ -0,0 +1,60 @@		@@ -0,0 +1,60 @@
	1	+package com.example.mina.entity;
	2	+
	3	+/**
	4	+ * @author 杜云山
	5	+ * @date 2021/03/05
	6	+ */
	7	+public class Entry {
	8	+
	9	+ private final int row;
	10	+
	11	+ private final int col;
	12	+
	13	+ private final String name;
	14	+
	15	+ private int value;
	16	+
	17	+ private final boolean booked;
	18	+
	19	+ private final long timestamp;
	20	+
	21	+ public static final Entry EMPTY = new Entry(0, 0, null, 0, false);
	22	+
	23	+ public Entry(int row, int col, String name, int value, boolean booked) {
	24	+ this.row = row;
	25	+ this.col = col;
	26	+ this.name = name;
	27	+ this.value = value;
	28	+ this.booked = booked;
	29	+ this.timestamp = System.nanoTime();
	30	+ }
	31	+
	32	+ public int getRow() {
	33	+ return row;
	34	+ }
	35	+
	36	+ public int getCol() {
	37	+ return col;
	38	+ }
	39	+
	40	+ public String getName() {
	41	+ return name;
	42	+ }
	43	+
	44	+ public int getValue() {
	45	+ return value;
	46	+ }
	47	+
	48	+ public boolean isBooked() {
	49	+ return booked;
	50	+ }
	51	+
	52	+ public void setValue(int v) {
	53	+ this.value = v;
	54	+ }
	55	+
	56	+ public long getTimestamp() {
	57	+ return this.timestamp;
	58	+ }
	59	+
	60	+}
	@@ -1,136 +0,0 @@	@@ -1,136 +0,0 @@
1	-package com.example.mina.http;
2	-
3	-import java.io.*;
4	-import java.net.InetSocketAddress;
5	-import java.net.Socket;
6	-
7	-/**
8	- * @author dy
9	- * @date 2021/3/4
10	- */
11	-public class HttpSimulator {
12	-
13	- private Socket socket;
14	-
15	- private int port = 80;
16	-
17	- private String host = "localhost";
18	-
19	- private String request = ""; // HTTP请求消息
20	-
21	- private boolean isPost, isHead;
22	-
23	-
24	- public void run() throws Exception {
25	- BufferedReader reader = new BufferedReader(new InputStreamReader(
26	- System.in));
27	- while (true) // 开始大循环
28	- {
29	- try {
30	- if (!readHostAndPort(reader)) {
31	- break;
32	- }
33	- readHttpRequest(reader);
34	- sendHttpRequest();
35	- readHttpResponse(reader);
36	-
37	- } catch (Exception e) {
38	- System.out.println("err:" + e.getMessage());
39	-
40	- }
41	-
42	- }
43	-
44	- }
45	-
46	-
47	- public static void main(String[] args) throws Exception {
48	- new HttpSimulator().run();
49	-
50	- }
51	-
52	- private boolean readHostAndPort(BufferedReader consoleReader)
53	- throws Exception {
54	- System.out.print("host:port>");
55	- String[] ss = null;
56	- String s = consoleReader.readLine();
57	- if (s.equals("q")) {
58	- return false;
59	- } else {
60	- ss = s.split("[:]");
61	- if (!ss[0].equals("")) {
62	- host = ss[0];
63	- }
64	- if (ss.length > 1) {
65	- port = Integer.parseInt(ss[1]);
66	- }
67	- System.out.println(host + ":" + String.valueOf(port));
68	- return true;
69	- }
70	- }
71	-
72	- private void readHttpRequest(BufferedReader consoleReader)
73	- throws Exception {
74	- System.out.println("请输入HTTP请求:");
75	- String s = consoleReader.readLine();
76	- request = s + "\r\n";
77	- boolean isPost = s.substring(0, 4).equals("POST");
78	- boolean isHead = s.substring(0, 4).equals("HEAD");
79	- while (!(s = consoleReader.readLine()).equals("")) {
80	- request = request + s + "\r\n";
81	- }
82	- request = request + "\r\n";
83	- if (isPost) {
84	- System.out.println("请输入POST方法的内容:");
85	- s = consoleReader.readLine();
86	- request = request + s;
87	- }
88	- }
89	-
90	- private void sendHttpRequest() throws Exception {
91	- socket = new Socket();
92	- socket.setSoTimeout(10 * 1000);
93	- System.out.println("正在连接服务器");
94	- socket.connect(new InetSocketAddress(host, port), 10 * 1000);
95	- System.out.println("服务器连接成功！");
96	- OutputStream out = socket.getOutputStream();
97	- OutputStreamWriter writer = new OutputStreamWriter(out);
98	- writer.write(request);
99	- writer.flush();
100	- }
101	-
102	- private void readHttpResponse(BufferedReader consoleReader) {
103	- String s = "";
104	- try {
105	- InputStream in = socket.getInputStream();
106	- InputStreamReader inReader = new InputStreamReader(in);
107	- BufferedReader socketReader = new BufferedReader(inReader);
108	- System.out.println("---------HTTP头---------");
109	- boolean b = true; // true: 未读取消息头 false: 已经读取消息头
110	- while ((s = socketReader.readLine()) != null) {
111	- if (s.equals("") && b == true && !isHead) {
112	- System.out.println("------------------------");
113	- b = false;
114	- System.out.print("是否显示HTTP的内容(Y/N):");
115	- String choice = consoleReader.readLine();
116	- if (choice.equals("Y") \|\| choice.equals("y")) {
117	- System.out.println("---------HTTP内容---------");
118	- continue;
119	- } else {
120	- break;
121	- }
122	- } else {
123	- System.out.println(s);
124	- }
125	- }
126	- } catch (Exception e) {
127	- System.out.println("err:" + e.getMessage());
128	- } finally {
129	- try {
130	- socket.close();
131	- } catch (Exception e) {
132	- }
133	- }
134	- System.out.println("------------------------");
135	- }
136	-}