From 72aa034dbe931cc2406434f63b282fe6b8f52a23 Mon Sep 17 00:00:00 2001 From: linbenlei <572833793@qq.com> Date: Fri, 12 Mar 2021 17:11:26 +0800 Subject: [PATCH] fix: 测试get请求进入客户端 --- pom.xml | 4 ++++ src/main/java/com/example/mina/client/box/aeroflex/AeroflexClient.java | 2 +- src/main/java/com/example/mina/client/test/MinaClient.java | 42 +++++++++++++++++------------------------- 3 files changed, 22 insertions(+), 26 deletions(-) diff --git a/pom.xml b/pom.xml index 9112935..622b282 100644 --- a/pom.xml +++ b/pom.xml @@ -66,6 +66,10 @@ + + org.springframework.boot + spring-boot-starter-web + diff --git a/src/main/java/com/example/mina/client/box/aeroflex/AeroflexClient.java b/src/main/java/com/example/mina/client/box/aeroflex/AeroflexClient.java index cd903d2..0b86e5b 100644 --- a/src/main/java/com/example/mina/client/box/aeroflex/AeroflexClient.java +++ b/src/main/java/com/example/mina/client/box/aeroflex/AeroflexClient.java @@ -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; diff --git a/src/main/java/com/example/mina/client/test/MinaClient.java b/src/main/java/com/example/mina/client/test/MinaClient.java index 6d67e50..b04bc10 100644 --- a/src/main/java/com/example/mina/client/test/MinaClient.java +++ b/src/main/java/com/example/mina/client/test/MinaClient.java @@ -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(); -- libgit2 0.21.2