fix: 测试get请求进入客户端

林本磊
1 parent 4b2f3b41
Showing 3 changed files with 22 additions and 26 deletions Show diff stats
pom.xml
src/main/java/com/example/mina/client/box/aeroflex/AeroflexClient.java
src/main/java/com/example/mina/client/test/MinaClient.java
@@ -66,6 +66,10 @@
                 </exclusion>
             </exclusions>
         </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-web</artifactId>
+        </dependency>
  
     </dependencies>
  
@@ -27,7 +27,7 @@ public class AeroflexClient extends AbstractClient {
     public void setAttenuation(ClientDTO clientDTO) {
  
     }
-    
+
     /*@Override
     public boolean setAttenuation(int row, int col, int attenuation) {
         return false;
@@ -3,39 +3,31 @@ package com.example.mina.client.test;
 import com.example.mina.client.box.lte3000.Lte3000Client;
 import com.example.mina.client.entity.ClientDTO;
 import com.example.mina.server.entity.Entry;
+import org.springframework.stereotype.Controller;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.ResponseBody;
  
+@Controller
+@RequestMapping("/client")
+@ResponseBody
 public class MinaClient {
  
+    @RequestMapping("/isCrossPointOn")
+    public void index() {
+        ClientDTO clientDTO = ClientDTO.builder().row(2).col(3).maxAttn(5).build();
+        Lte3000Client lte3000Client = new Lte3000Client();
+        lte3000Client.start(clientDTO);
+
+        boolean a = lte3000Client.isCrossPointOn(clientDTO.getRow(),clientDTO.getCol());
+        System.out.println(a);
+    }
  
     public static void main(String[] args) {
-//        //Create TCP/IP connection
-//        NioSocketConnector connector = new NioSocketConnector();
-//
-//        //创建接受数据的过滤器
-//        DefaultIoFilterChainBuilder chain = connector.getFilterChain();
-//
-//        //设定这个过滤器将一行一行(/r/n)的读取数据
-//        chain.addLast("myChin", new ProtocolCodecFilter(new TextLineCodecFactory()));
-//
-//        //客户端的消息处理器：一个SamplMinaServerHander对象
-//        connector.setHandler(new ClientHandler());
-//
-//        //set connect timeout
-//        connector.setConnectTimeout(30);
-//
-//        //连接到服务器：
-//        ConnectFuture cf = connector.connect(new InetSocketAddress("localhost",9104));
-//
-//        //Wait for the connection attempt to be finished.
-//        cf.awaitUninterruptibly();
-//
-//        cf.getSession().getCloseFuture().awaitUninterruptibly();
-//
-//        connector.dispose();
+
         ClientDTO clientDTO = ClientDTO.builder().row(2).col(3).maxAttn(5).build();
         Lte3000Client lte3000Client = new Lte3000Client();
-
         lte3000Client.start(clientDTO);
+
         boolean a = lte3000Client.isCrossPointOn(clientDTO.getRow(),clientDTO.getCol());
         int c = lte3000Client.getAttenuation(clientDTO.getCol());
         byte[] bytes = lte3000Client.genCloseCommand();
...	...	@@ -66,6 +66,10 @@
66	66	</exclusion>
67	67	</exclusions>
68	68	</dependency>
	69	+ <dependency>
	70	+ <groupId>org.springframework.boot</groupId>
	71	+ <artifactId>spring-boot-starter-web</artifactId>
	72	+ </dependency>
69	73
70	74	</dependencies>
71	75
...	...
...	...	@@ -27,7 +27,7 @@ public class AeroflexClient extends AbstractClient {
27	27	public void setAttenuation(ClientDTO clientDTO) {
28	28
29	29	}
30		-
	30	+
31	31	/*@Override
32	32	public boolean setAttenuation(int row, int col, int attenuation) {
33	33	return false;
...	...
...	...	@@ -3,39 +3,31 @@ package com.example.mina.client.test;
3	3	import com.example.mina.client.box.lte3000.Lte3000Client;
4	4	import com.example.mina.client.entity.ClientDTO;
5	5	import com.example.mina.server.entity.Entry;
	6	+import org.springframework.stereotype.Controller;
	7	+import org.springframework.web.bind.annotation.RequestMapping;
	8	+import org.springframework.web.bind.annotation.ResponseBody;
6	9
	10	+@Controller
	11	+@RequestMapping("/client")
	12	+@ResponseBody
7	13	public class MinaClient {
8	14
	15	+ @RequestMapping("/isCrossPointOn")
	16	+ public void index() {
	17	+ ClientDTO clientDTO = ClientDTO.builder().row(2).col(3).maxAttn(5).build();
	18	+ Lte3000Client lte3000Client = new Lte3000Client();
	19	+ lte3000Client.start(clientDTO);
	20	+
	21	+ boolean a = lte3000Client.isCrossPointOn(clientDTO.getRow(),clientDTO.getCol());
	22	+ System.out.println(a);
	23	+ }
9	24
10	25	public static void main(String[] args) {
11		-// //Create TCP/IP connection
12		-// NioSocketConnector connector = new NioSocketConnector();
13		-//
14		-// //创建接受数据的过滤器
15		-// DefaultIoFilterChainBuilder chain = connector.getFilterChain();
16		-//
17		-// //设定这个过滤器将一行一行(/r/n)的读取数据
18		-// chain.addLast("myChin", new ProtocolCodecFilter(new TextLineCodecFactory()));
19		-//
20		-// //客户端的消息处理器：一个SamplMinaServerHander对象
21		-// connector.setHandler(new ClientHandler());
22		-//
23		-// //set connect timeout
24		-// connector.setConnectTimeout(30);
25		-//
26		-// //连接到服务器：
27		-// ConnectFuture cf = connector.connect(new InetSocketAddress("localhost",9104));
28		-//
29		-// //Wait for the connection attempt to be finished.
30		-// cf.awaitUninterruptibly();
31		-//
32		-// cf.getSession().getCloseFuture().awaitUninterruptibly();
33		-//
34		-// connector.dispose();
	26	+
35	27	ClientDTO clientDTO = ClientDTO.builder().row(2).col(3).maxAttn(5).build();
36	28	Lte3000Client lte3000Client = new Lte3000Client();
37		-
38	29	lte3000Client.start(clientDTO);
	30	+
39	31	boolean a = lte3000Client.isCrossPointOn(clientDTO.getRow(),clientDTO.getCol());
40	32	int c = lte3000Client.getAttenuation(clientDTO.getCol());
41	33	byte[] bytes = lte3000Client.genCloseCommand();
...	...