init

pom.xml

@@ -9,6 +9,11 @@
     <version>1.0</version>
 
     <dependencies>
+        <dependency>
+            <groupId>com.squareup.okhttp3</groupId>
+            <artifactId>okhttp</artifactId>
+            <version>4.9.3</version>
+        </dependency>
         <dependency>
             <groupId>com.fazecast</groupId>
             <artifactId>jSerialComm</artifactId>

src/main/java/server/TcpServer.java

@@ -29,7 +29,7 @@ public class TcpServer {
 
     // 服务器地址端口
 //    private static final String IP = "192.168.0.112";
-//    private static final String IP = "192.168.0.107";
+    private static final String IP = "192.168.0.107";
     private static final int PORT = 9200;
 
     /** 用于分配处理业务线程的线程组个数 */
@@ -86,7 +86,7 @@ public class TcpServer {
         }
         logger.info("mac: "+sb.toString());
         logger.info("Local host name: "+hostname);
-        b.bind(addr.getHostAddress(), PORT).sync();
+        b.bind(IP, PORT).sync();
         logger.info("TCP Server Started");
 
     }

src/main/java/server/TcpServerHandler.java

@@ -3,9 +3,12 @@ package server;
 import com.fazecast.jSerialComm.SerialPort;
 import io.netty.channel.ChannelHandlerContext;
 import io.netty.channel.SimpleChannelInboundHandler;
+import okhttp3.*;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
+import java.io.IOException;
+
 /**
  * @author yuli
  * @ClassName TcpServerHandler
@@ -14,6 +17,7 @@ public class TcpServerHandler extends SimpleChannelInboundHandler<Object> {
 
     private static Logger logger = LoggerFactory.getLogger(TcpServerHandler.class);
 
+    private static final String serverUrl  = "http://localhost:8001/gps";
     /**
         * 打印接收到的内容，并回传
          //        * @param [ctx, msg]
@@ -34,6 +38,34 @@ public class TcpServerHandler extends SimpleChannelInboundHandler<Object> {
             openComm();
         }
         logger.info("**COM口读出数据<<start:" + result  +">>end");
+        sendGnss(result);
+    }
+
+    private void sendGnss(String msg) {
+
+        try {
+           String result =  post(serverUrl,msg);
+           logger.info(result);
+        } catch (IOException e) {
+            e.printStackTrace();
+        }
+    }
+
+
+    public static final MediaType JSON
+            = MediaType.get("application/json; charset=utf-8");
+
+    OkHttpClient client = new OkHttpClient();
+
+    String post(String url, String json) throws IOException {
+        RequestBody body = RequestBody.create(json, JSON);
+        Request request = new Request.Builder()
+                .url(url)
+                .post(body)
+                .build();
+        try (Response response = client.newCall(request).execute()) {
+            return response.body().string();
+        }
     }
 
     private static  SerialPort serialPort;