update

.vscode/settings.json

@@ -0,0 +1,10 @@
+{
+    "files.associations": {
+        "malloc.h": "c",
+        "types.h": "c",
+        "stdlib.h": "c",
+        "sstream": "cpp",
+        "ostream": "cpp",
+        "iostream": "cpp"
+    }
+}

c/main.c

@@ -72,11 +72,15 @@ int main(int argc, char *argv[]) {
   char buffer[]     = {"hello my world!\r\n"};
   char recvbuf[100] = {};
 
-  ser_Data snd_data;
-  ser_Data rec_data;
-
-  snd_data.serfd = serport1fd;
-  rec_data.serfd = serport1fd;
+  ser_Data snd_data = {
+      .databuf = {0},
+      .serfd   = serport1fd,
+  };
+
+  ser_Data rec_data = {
+      .databuf = {0},
+      .serfd   = serport1fd,
+  };
 
   memcpy(snd_data.databuf, buffer, strlen(buffer));  // 拷贝发送数据
 

cpp/.vscode/settings.json

@@ -1,6 +0,0 @@
-{
-    "files.associations": {
-        "strings.h": "c",
-        "stat.h": "c"
-    }
-}

cpp/main.cpp

@@ -0,0 +1,136 @@
+#include <error.h>
+#include <fcntl.h>
+#include <malloc.h>
+#include <pthread.h>
+#include <stdio.h>
+#include <stdlib.h>
+#include <string.h>
+#include <strings.h>
+#include <sys/stat.h>
+#include <sys/types.h>
+#include <termios.h>
+#include <unistd.h>
+
+typedef struct serial_data {
+  char databuf[100];  // 发送/接受数据
+  int  serfd;         // 串口文件描述符
+
+} ser_Data;
+
+void *sersend(void *arg);
+void *serrecv(void *arg);
+
+int main(int argc, char *argv[]) {
+  pthread_t       pid1, pid2;
+  pthread_attr_t *pthread_arr1, *pthread_arr2;
+  pthread_arr1 = NULL;
+  pthread_arr2 = NULL;
+  int serport1fd;
+
+  /*   进行串口参数设置  */
+  termios *ter_s = (termios *)malloc(sizeof(*ter_s));
+
+  serport1fd = open(argv[1], O_RDWR | O_NOCTTY | O_NDELAY);  // 不成为控制终端程序，不受其他程序输出输出影响
+  if (serport1fd < 0) {
+    printf("%s open faild\r\n", argv[1]);
+    return -1;
+  }
+
+  bzero(ter_s, sizeof(*ter_s));
+
+  ter_s->c_cflag |= CLOCAL | CREAD;  // 激活本地连接与接受使能
+
+  ter_s->c_cflag &= ~CSIZE;  // 失能数据位屏蔽
+  ter_s->c_cflag |= CS8;     // 8位数据位
+
+  ter_s->c_cflag &= ~CSTOPB;  // 1位停止位
+
+  ter_s->c_cflag &= ~PARENB;  // 无校验位
+
+  ter_s->c_cc[VTIME] = 0;
+  ter_s->c_cc[VMIN]  = 0;
+
+  /*1 VMIN> 0 && VTIME> 0
+      VMIN为最少读取的字符数，当读取到一个字符后，会启动一个定时器，在定时器超时事前，如果已经读取到了VMIN个字符，则read返回VMIN个字符。如果在接收到VMIN个字符之前，定时器已经超时，则read返回已读取到的字符，注意这个定时器会在每次读取到一个字符后重新启用，即重新开始计时，而且是读取到第一个字节后才启用，也就是说超时的情况下，至少读取到一个字节数据。
+      2 VMIN > 0 && VTIME== 0
+      在只有读取到VMIN个字符时，read才返回，可能造成read被永久阻塞。
+      3 VMIN == 0 && VTIME> 0
+      和第一种情况稍有不同，在接收到一个字节时或者定时器超时时，read返回。如果是超时这种情况，read返回值是0。
+      4 VMIN == 0 && VTIME== 0
+      这种情况下read总是立即就返回，即不会被阻塞。----by 解释粘贴自博客园
+  */
+  cfsetispeed(ter_s, B115200);  // 设置输入波特率
+  cfsetospeed(ter_s, B115200);  // 设置输出波特率
+
+  tcflush(serport1fd, TCIFLUSH);  // 刷清未处理的输入和/或输出
+
+  if (tcsetattr(serport1fd, TCSANOW, ter_s) != 0) {
+    printf("com set error!\r\n");
+  }
+
+  char buffer[]     = {"hello my world!\r\n"};
+  char recvbuf[100] = {};
+
+  ser_Data snd_data = {
+      .databuf = {0},
+      .serfd   = serport1fd,
+  };
+  ser_Data rec_data = {
+      .databuf = {0},
+      .serfd   = serport1fd,
+  };
+
+  memcpy(snd_data.databuf, buffer, strlen(buffer));  // 拷贝发送数据
+
+  pthread_create(&pid1, pthread_arr1, sersend, (void *)&snd_data);
+  pthread_create(&pid2, pthread_arr2, serrecv, (void *)&rec_data);
+
+  while (1) {
+    usleep(100000);
+  }
+
+  pthread_join(pid1, NULL);
+  pthread_join(pid2, NULL);
+  free(ter_s);
+  return 0;
+}
+
+void *sersend(void *arg)  // 串口发送线程函数
+{
+  ser_Data *snd = (ser_Data *)arg;
+  int       ret;
+  while (1) {
+    ret = write(snd->serfd, snd->databuf, strlen(snd->databuf));
+    if (ret > 0) {
+      printf("send success, data is  %s\r\n", snd->databuf);
+    } else {
+      printf("send error!\r\n");
+    }
+    usleep(300000);
+    /*
+    if(发生中断)
+    break;//退出
+    */
+  }
+}
+
+void *serrecv(void *arg)  // 串口发送线程函数
+{
+  ser_Data *rec = (ser_Data *)arg;
+  int       ret;
+  while (1) {
+    ret = read(rec->serfd, rec->databuf, 1024);
+    if (ret > 0) {
+      printf("recv success,recv size is %d,data is  %s\r\n", ret, rec->databuf);
+    } else {
+      /*
+       什么也不做
+      */
+    }
+    usleep(1000);
+    /*
+    if(发生中断)
+    break;//退出
+    */
+  }
+}