安装

java安装说明.docx

@@ -0,0 +1,14 @@
+1.目录不要有中文 、空格，打开项目目录，在该目录打开cmd，查看是否安装java环境，有环境的可以直接跳到第4步
+
+2.要是查看不到java版本号，就需要安装java环境，要是有java版本号，直接看第4步
+
+3.配置环境变量
+https://www.runoob.com/java/java-environment-setup.html
+ 4.修改成自己需要的tcp端口，打开application.yml，记事本就可以打开
+ 
+
+
+5.项目目录打开cmd
+
+输入java -jar pelma_analyse-0.0.1-SNAPSHOT.jar
+已经正常启动

src/main/java/com/ccsens/pelma_analyse/service/impl/PelmaDataAcceptImpl.java

@@ -27,7 +27,12 @@ public class PelmaDataAcceptImpl implements PelmaDataAccept {
         String pelma_url = GetServiceUrlAnalyseUtil.getUrl();
 
         String url = pelma_url + "/storePelma";
+        try {
             String res = restTemplate.postForObject(url, map, String.class);
             System.out.println(res);
+        } catch (Exception exception){
+            System.out.println(exception.getMessage());
+        }
+
     }
 }

src/main/java/com/ccsens/pelma_analyse/service/impl/SerialServiceImpl.java

@@ -8,7 +8,9 @@ import org.springframework.stereotype.Service;
 import org.springframework.web.client.RestTemplate;
 import purejavacomm.SerialPort;
 
+import java.io.BufferedReader;
 import java.io.IOException;
+import java.io.InputStreamReader;
 import java.text.DecimalFormat;
 import java.util.ArrayList;
 import java.util.Arrays;
@@ -34,40 +36,107 @@ public class SerialServiceImpl implements SerialService {
      */
     @Override
     public void connect() {
+        String inputCom = "";
+        InputStreamReader in = new InputStreamReader(System.in);
+        BufferedReader bufferedReader = new BufferedReader(in);
+        while (true){
+            System.out.print("请输入串口（例：10）：");
+            try {
+                inputCom = bufferedReader.readLine();//获得数据
+
                 SerialPort openSerial = null;
                 try {
                     String serial_com = "";
-            for (int i = com_num; i <= com_num_limit; i++) {
-                serial_com = "com" + i;
+                    serial_com = "com" + inputCom;
                     try {
                         openSerial = SerialTool.openPort(serial_com, 115200, 8, 1, 0);
                     } catch (Exception e){
+                        System.out.println("打开串口失败");
                         continue;
                     }
 
-                if (openSerial instanceof SerialPort){
-                    break;
-                }
-                System.out.println('a');
+                    if (!(openSerial instanceof SerialPort)){
+                        System.out.println("打开串口失败");
+                        continue;
                     }
                     if (openSerial == null){
                         System.out.println("打开串口失败");
-                return;
+                        continue;
                     }
 
                     System.out.println("打开串口" + serial_com);
 
                     //lora初始化话
-//            initLora(openSerial);
+                    initLora(openSerial);
                     //上报数据
-//            sendData(openSerial);
+                    sendData(openSerial);
                     //测试足底
 //            sendPelmaData(openSerial);
                 } catch (Exception e) {
                     System.out.println(e.getMessage());
                 }
+            } catch (IOException e) {
+
+                e.printStackTrace();
+                continue;
+                //System.out.println(e.toString());
             }
 
+
+        }
+
+    }
+
+//    /**
+//     * 连接串口
+//     */
+//    @Override
+//    public void connect() {
+//        String inputCom = "";
+//        InputStreamReader in = new InputStreamReader(System.in);
+//        BufferedReader bufferedReader = new BufferedReader(in);
+//        System.out.print("请输入串口（例：10）：");
+//        try {
+//            inputCom = bufferedReader.readLine();//获得数据
+//        } catch (IOException e) {
+//            e.printStackTrace();
+//            //System.out.println(e.toString());
+//        }
+//
+//        SerialPort openSerial = null;
+//        try {
+//            String serial_com = "";
+//            for (int i = com_num; i <= com_num_limit; i++) {
+//                serial_com = "com" + i;
+//                try {
+//                    openSerial = SerialTool.openPort(serial_com, 115200, 8, 1, 0);
+//                } catch (Exception e){
+//                    continue;
+//                }
+//
+//                if (openSerial instanceof SerialPort){
+//                    break;
+//                }
+//                System.out.println('a');
+//            }
+//            if (openSerial == null){
+//                System.out.println("打开串口失败");
+//                return;
+//            }
+//
+//            System.out.println("打开串口" + serial_com);
+//
+//            //lora初始化话
+//            initLora(openSerial);
+//            //上报数据
+//            sendData(openSerial);
+//            //测试足底
+////            sendPelmaData(openSerial);
+//        } catch (Exception e) {
+//            System.out.println(e.getMessage());
+//        }
+//    }
+
     /**
      * lora初始化话
      * @param openSerial

src/main/java/com/ccsens/pelma_analyse/util/netty/SocketServer.java

@@ -39,7 +39,7 @@ public class SocketServer {
     public void start() {
         this.init();
         this.serverBootstrap.bind(this.port);
-        log.info("Netty started on port: {} (TCP) with boss thread {}", this.port, this.bossThread);
+        log.info("网线端口: {} (TCP) with boss thread {}", this.port, this.bossThread);
     }
 
     /**

src/main/resources/application.yml

@@ -4,7 +4,10 @@ spring:
 server:
   port: 8080
 
+#网页地址
 service_url_analyse: "http://127.0.0.1:8000"
+
+#足底 网线端口
 netty:
   port: 8081
   bossThread: 1