feat: 修改抽象类中对initMatrix和handleMessage进行方法调用

杜云山
1 parent d7e6a910
Showing 3 changed files with 15 additions and 25 deletions Show diff stats
src/main/java/com/example/mina/base/AbstractVirtualBoxHandler.java
src/main/java/com/example/mina/box/aeroflex/AeroflexVirtualBoxHandler.java
src/main/java/com/example/mina/box/lte3000/Lte3000VirtualBoxHandler.java
 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);
+        }
+    }
+
     /**
      * 初始化矩阵以及该设备的一些参数
      */
@@ -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) {
 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&lt;Lte3000R
     private Lte3000DataBuffer dataBuffer;
-    public Lte3000VirtualBoxHandler() {
-        this.initMatrix();
-    }
-
     @Override
     protected void initMatrix() {
1	package com.example.mina.base;	1	package com.example.mina.base;
2		2
3	import org.apache.mina.core.service.IoHandlerAdapter;	3	import org.apache.mina.core.service.IoHandlerAdapter;
		4	+import org.apache.mina.core.session.IoSession;
4		5
5	/**	6	/**
6	* @author 杜云山	7	* @author 杜云山
	@@ -9,6 +10,19 @@ import org.apache.mina.core.service.IoHandlerAdapter;		@@ -9,6 +10,19 @@ import org.apache.mina.core.service.IoHandlerAdapter;
9	public abstract class AbstractVirtualBoxHandler<REQUEST extends BaseRequestMessage, RESPONSE extends BaseResponseMessage>	10	public abstract class AbstractVirtualBoxHandler<REQUEST extends BaseRequestMessage, RESPONSE extends BaseResponseMessage>
10	extends IoHandlerAdapter {	11	extends IoHandlerAdapter {
11		12
		13	+ public AbstractVirtualBoxHandler() {
		14	+ initMatrix();
		15	+ }
		16	+
		17	+ @Override
		18	+ public void messageReceived(IoSession session, Object message) throws Exception {
		19	+
		20	+ if (message instanceof BaseRequestMessage) {
		21	+ BaseResponseMessage responseMessage = handleMessage((REQUEST) message);
		22	+ session.write(responseMessage);
		23	+ }
		24	+ }
		25	+
12	/**	26	/**
13	* 初始化矩阵以及该设备的一些参数	27	* 初始化矩阵以及该设备的一些参数
14	*/	28	*/
	@@ -30,10 +30,6 @@ public class AeroflexVirtualBoxHandler		@@ -30,10 +30,6 @@ public class AeroflexVirtualBoxHandler
30		30
31	private AeroflexDataBuffer dataBuffer;	31	private AeroflexDataBuffer dataBuffer;
32		32
33	- public AeroflexVirtualBoxHandler() {
34	- this.initMatrix();
35	- }
36	-
37	@Override	33	@Override
38	protected void initMatrix() {	34	protected void initMatrix() {
39		35
	@@ -44,15 +40,6 @@ public class AeroflexVirtualBoxHandler		@@ -44,15 +40,6 @@ public class AeroflexVirtualBoxHandler
44	dataBuffer = new AeroflexDataBuffer(row, maxAttenuate);	40	dataBuffer = new AeroflexDataBuffer(row, maxAttenuate);
45	}	41	}
46		42
47	- @Override
48	- public void messageReceived(IoSession session, Object message) {
49	-
50	- if (message instanceof AeroflexRequestMessage) {
51	-
52	- AeroflexResponseMessage responseMessage = handleMessage((AeroflexRequestMessage) message);
53	- session.write(responseMessage);
54	- }
55	- }
56		43
57	@Override	44	@Override
58	protected AeroflexResponseMessage handleMessage(AeroflexRequestMessage message) {	45	protected AeroflexResponseMessage handleMessage(AeroflexRequestMessage message) {