移除循环

mycert.pem

@@ -0,0 +1,16 @@
+-----BEGIN CERTIFICATE-----
+MIICijCCAjCgAwIBAgIEZ8ANhTAKBggqhkjOPQQDAjCBpDELMAkGA1UEBhMCQ04x
+EjAQBgNVBAgMCeaxn+iLj+ecgTESMBAGA1UEBwwJ6IuP5bee5biCMTAwLgYDVQQK
+DCfluLjnhp/luILlpaXnibnova/ku7bmioDmnK/mnInpmZDlhazlj7gxCTAHBgNV
+BAsTADEwMC4GA1UEAwwn5bi454af5biC5aWl54m56L2v5Lu25oqA5pyv5pyJ6ZmQ
+5YWs5Y+4MB4XDTI1MDIyNzA3MDAxOFoXDTM1MDIyNzA3MDAxOFowgYsxCzAJBgNV
+BAYTAkNOMRIwEAYDVQQIDAnmsZ/oi4/nnIExEjAQBgNVBAcMCeiLj+W3nuW4gjEw
+MC4GA1UECgwn5bi454af5biC5aWl54m56L2v5Lu25oqA5pyv5pyJ6ZmQ5YWs5Y+4
+MQkwBwYDVQQLEwAxFzAVBgNVBAMTDjExMi4zMy4xMTEuMTYwMFkwEwYHKoZIzj0C
+AQYIKoZIzj0DAQcDQgAEYuXgPu1MRA2EO/tN+85G96Oaai2hH18/6g4eKPJYwJkf
+QVRE/Gf/8ocvgecizwOe7U2uPFo8O221KOToY2TJBaNnMGUwDgYDVR0PAQH/BAQD
+AgWgMBMGA1UdJQQMMAoGCCsGAQUFBwMBMAwGA1UdEwEB/wQCMAAwHwYDVR0jBBgw
+FoAUU+BcoCFoLBjiwugufIVlT6GcGyUwDwYDVR0RBAgwBocEcCFvoDAKBggqhkjO
+PQQDAgNIADBFAiEA5I2i9Us1jgRCXozHbM2cwhG1nzzZmhc5pQhSMfPXmEMCIEYz
+vkMh3j00s2V54lzORkDsCfRCR8hgedtvltv3IXNw
+-----END CERTIFICATE-----

src/main.rs

@@ -193,7 +193,7 @@ async fn run_mqtt_and_serial() -> Result<()> {
     println!("正在读取数据... (按 Ctrl+C 退出)");
 
     // Read data continuously
-    let mut serial_buf: Vec<u8> = vec![0; 1000];
+    let mut serial_buf: Vec<u8> = vec![0; 1000000];
     loop {
         match port.read(serial_buf.as_mut_slice()) {
             Ok(t) => {
@@ -212,7 +212,7 @@ async fn run_mqtt_and_serial() -> Result<()> {
                     };
 
                     // 开始循环发送数据
-                    loop {
+                    // loop {
                         // 序列化数据
                         let json_data = serde_json::to_string(&weight_data)?;
                         println!("当前JSON数据: {}", json_data);
@@ -228,8 +228,8 @@ async fn run_mqtt_and_serial() -> Result<()> {
                         }
 
                         // 等待3秒
-                        thread::sleep(Duration::from_secs(3));
-                    }
+                        // thread::sleep(Duration::from_secs(1));
+                    // }
                 }
             }
             Err(ref e) if e.kind() == io::ErrorKind::TimedOut => {