From c542fca86bae891bd091077b1b8658833b6b8599 Mon Sep 17 00:00:00 2001
From: 杜云山 <870666625@qq.com>
Date: Mon, 8 Mar 2021 13:38:57 +0800
Subject: [PATCH] feat: 修改抽象类中对initMatrix和handleMessage进行方法调用

---
 src/main/java/com/example/mina/base/AbstractVirtualBoxHandler.java         | 14 ++++++++++++++
 src/main/java/com/example/mina/box/aeroflex/AeroflexVirtualBoxHandler.java | 13 -------------
 src/main/java/com/example/mina/box/lte3000/Lte3000VirtualBoxHandler.java   | 13 +------------
 3 files changed, 15 insertions(+), 25 deletions(-)

diff --git a/src/main/java/com/example/mina/base/AbstractVirtualBoxHandler.java b/src/main/java/com/example/mina/base/AbstractVirtualBoxHandler.java
index 4457765..a6f2cd8 100644
--- a/src/main/java/com/example/mina/base/AbstractVirtualBoxHandler.java
+++ b/src/main/java/com/example/mina/base/AbstractVirtualBoxHandler.java
@@ -1,6 +1,7 @@
 package com.example.mina.base;
 
 import org.apache.mina.core.service.IoHandlerAdapter;
+import org.apache.mina.core.session.IoSession;
 
 /**
  * @author 杜云山
@@ -9,6 +10,19 @@ import org.apache.mina.core.service.IoHandlerAdapter;
 public abstract class AbstractVirtualBoxHandler<REQUEST extends BaseRequestMessage, RESPONSE extends BaseResponseMessage>
         extends IoHandlerAdapter {
 
+    public AbstractVirtualBoxHandler() {
+        initMatrix();
+    }
+
+    @Override
+    public void messageReceived(IoSession session, Object message) throws Exception {
+
+        if (message instanceof BaseRequestMessage) {
+            BaseResponseMessage responseMessage = handleMessage((REQUEST) message);
+            session.write(responseMessage);
+        }
+    }
+
     /**
      * 初始化矩阵以及该设备的一些参数
      */
diff --git a/src/main/java/com/example/mina/box/aeroflex/AeroflexVirtualBoxHandler.java b/src/main/java/com/example/mina/box/aeroflex/AeroflexVirtualBoxHandler.java
index f78a5a8..d4fb79c 100644
--- a/src/main/java/com/example/mina/box/aeroflex/AeroflexVirtualBoxHandler.java
+++ b/src/main/java/com/example/mina/box/aeroflex/AeroflexVirtualBoxHandler.java
@@ -30,10 +30,6 @@ public class AeroflexVirtualBoxHandler
 
     private AeroflexDataBuffer dataBuffer;
 
-    public AeroflexVirtualBoxHandler() {
-        this.initMatrix();
-    }
-
     @Override
     protected void initMatrix() {
 
@@ -44,15 +40,6 @@ public class AeroflexVirtualBoxHandler
         dataBuffer = new AeroflexDataBuffer(row, maxAttenuate);
     }
 
-    @Override
-    public void messageReceived(IoSession session, Object message) {
-
-        if (message instanceof AeroflexRequestMessage) {
-
-            AeroflexResponseMessage responseMessage = handleMessage((AeroflexRequestMessage) message);
-            session.write(responseMessage);
-        }
-    }
 
     @Override
     protected AeroflexResponseMessage handleMessage(AeroflexRequestMessage message) {
diff --git a/src/main/java/com/example/mina/box/lte3000/Lte3000VirtualBoxHandler.java b/src/main/java/com/example/mina/box/lte3000/Lte3000VirtualBoxHandler.java
index fdade46..09069c1 100644
--- a/src/main/java/com/example/mina/box/lte3000/Lte3000VirtualBoxHandler.java
+++ b/src/main/java/com/example/mina/box/lte3000/Lte3000VirtualBoxHandler.java
@@ -1,17 +1,10 @@
 package com.example.mina.box.lte3000;
 
 import com.example.mina.base.AbstractVirtualBoxHandler;
-
-import com.example.mina.base.BaseRequestMessage;
-import com.example.mina.base.BaseResponseMessage;
-import com.example.mina.box.aeroflex.AeroflexRequestMessage;
-import com.example.mina.box.aeroflex.AeroflexResponseMessage;
-import com.example.mina.util.CommandHelper;
-import com.example.mina.util.LogUtils;
 import com.example.mina.entity.Lte3000DataBuffer;
 import com.example.mina.helper.Lte3000CommandHelper;
+import com.example.mina.util.CommandHelper;
 import lombok.extern.slf4j.Slf4j;
-import org.apache.mina.core.buffer.IoBuffer;
 import org.apache.mina.core.session.IoSession;
 
 /**
@@ -39,10 +32,6 @@ public class Lte3000VirtualBoxHandler extends AbstractVirtualBoxHandler<Lte3000R
 
     private Lte3000DataBuffer dataBuffer;
 
-    public Lte3000VirtualBoxHandler() {
-        this.initMatrix();
-    }
-
     @Override
     protected void initMatrix() {
 
--
libgit2 0.21.2