devbox
知新_RL
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

socket编程之socket转串口_socket转232

作者：知新_RL | 2024-07-05 23:26:21

赞

踩

socket转232

---------------------------------------------------------------------------------

系统环境：Centos 6.5

    开发板：s3c2440

---------------------------------------------------------------------------------

1、程序功能

该程序是一个运行在开发板上的client程序，连接到windows下usr-tcp调试工具模拟的server，接受串口和socket数据并转发

usr-tcp通过tcp服务器向client发送数据，client接受到数据后通过串口发回usr-tcp

usr-tcp通过串口向client发送数据，client接收到数据后通过socket发回usr-tcp

 




2、源代码

串口相关设置 serial.c

  1. /*********************************************************************************
  2.  *      Copyright:  (C) 2016 Lu Zengmeng<1540999272@qq.com>
  3.  *                  All rights reserved.
  4.  *
  5.  *       Filename:  serial.c
  6.  *    Description:  This file 
  7.  *                 
  8.  *        Version:  1.0.0(08/01/2016)
  9.  *         Author:  Lu Zengmeng <1540999272@qq.com>
  10.  *      ChangeLog:  1, Release initial version on "08/01/2016 06:44:59 PM"
  11.  *                 
  12.  ********************************************************************************/
  13. #include <stdio.h>
  14. #include <termios.h>
  15. #include <fcntl.h>
  16. #include <string.h>
  17.  
  18. #define FAIL -1
  19. #define OK   0
  20.  
  21. int speed_arr[] = {B115200,B57600,B38400,B19200,B9600,B4800,B2400,B1200,B600,B300,B110};
  22. int name_arr[]  = { 115200, 57600, 38400, 19200, 9600, 4800, 2400, 1200, 600, 300, 110};
  23.  
  24. /* set baud rate */
  25. void set_speed(int fd, int speed)
  26. {
  27.     int i;
  28.     int status;
  29.     struct termios options;
  30.  
  31.     tcgetattr(fd, &options);
  32.     options.c_iflag &= ~ (INLCR | ICRNL | IGNCR);
  33.     options.c_oflag &= ~(ONLCR | OCRNL);
  34.     options.c_iflag &= ~(IXON);
  35.  
  36.     for( i= 0; i < sizeof(speed_arr) / sizeof(int); i++)
  37.     {
  38.         if(speed == name_arr[i])
  39.         {
  40.             tcflush(fd, TCIOFLUSH);/*empty input cache*/
  41.  
  42.             cfsetispeed(&options, speed_arr[i]);
  43.             cfsetospeed(&options, speed_arr[i]);
  44.  
  45.             status = tcsetattr(fd, TCSANOW, &options);
  46.             if(status != 0)
  47.                    perror("tcsetattr fd");
  48.  
  49.             return;
  50.         }
  51.         tcflush(fd,TCIOFLUSH);/*empty input cache*/
  52.     }
  53. }
  54.  
  55.  
  56. /**
  57.  * *@brief 设置串口数据位，停止位和效验位
  58.  * *@param fd 类型 int 打开的串口文件描述符
  59.  * *@param databits 类型 int 数据位 取值 为 7 或者8
  60.  * *@param stopbits 类型 int 停止位 取值为 1 或者2
  61.  * *@param parity 类型 int 效验类型 取值为N,E,O,S
  62.  * */
  63. int set_parity(int fd,int databits,int stopbits,int parity)
  64. {
  65.     struct termios options;
  66.     if ( tcgetattr( fd,&options) != 0)
  67.     {
  68.         perror("SetupSerial 1");
  69.         return(FAIL);
  70.     }
  71.     options.c_cflag &= ~CSIZE;
  72.     options.c_lflag  &= ~(ICANON | ECHO | ECHOE | ISIG);  /*Input*/
  73.     options.c_oflag  &= ~OPOST;   /*Output*/
  74.  
  75.     switch (databits) /*set datebits*/
  76.     {
  77.         case 7:
  78.             options.c_cflag |= CS7;
  79.             break;
  80.         case 8:
  81.             options.c_cflag |= CS8;
  82.             break;
  83.         default:
  84.             fprintf(stderr,"Unsupported data size\n");
  85.             return (FAIL);
  86.     }
  87.  
  88.     switch (parity)
  89.     {
  90.         case 'n':
  91.         case 'N':
  92.             options.c_cflag &= ~PARENB; /* Clear parity enable */
  93.             options.c_iflag &= ~INPCK; /* Enable parity checking */
  94.             break;
  95.         case 'o':
  96.         case 'O':
  97.             options.c_cflag |= (PARODD | PARENB); /* 设置为奇效验*/
  98.             options.c_iflag |= INPCK; /* Disnable parity checking */
  99.             break;
  100.         case 'e':
  101.         case 'E':
  102.             options.c_cflag |= PARENB; /* Enable parity */
  103.             options.c_cflag &= ~PARODD; /* 转换为偶效验*/
  104.             options.c_iflag |= INPCK; /* Disnable parity checking */
  105.             break;
  106.         case 'S':
  107.         case 's': /*as no parity*/
  108.             options.c_cflag &= ~PARENB;
  109.             options.c_cflag &= ~CSTOPB;
  110.             break;
  111.         default:
  112.             fprintf(stderr,"Unsupported parity\n");
  113.             return (FAIL);
  114.     }
  115.     /*set stopbits */
  116.     switch (stopbits)
  117.     {
  118.         case 1:
  119.             options.c_cflag &= ~CSTOPB;
  120.             break;
  121.         case 2:
  122.             options.c_cflag |= CSTOPB;
  123.             break;
  124.         default:
  125.             fprintf(stderr,"Unsupported stop bits\n");
  126.             return (FAIL);
  127.     }
  128.     /* Set input parity options */
  129.     if (parity != 'n')
  130.         options.c_iflag |= INPCK;
  131.  
  132.     options.c_cc[VTIME] = 0; // 15 seconds
  133.     options.c_cc[VMIN] = 0;
  134.  
  135.     tcflush(fd,TCIFLUSH); /* Update the optionsions and do it NOW */
  136.  
  137.     if (tcsetattr(fd,TCSANOW,&options) != 0)
  138.     {
  139.         perror("tcsetattr");
  140.         return FAIL;
  141.     }
  142.     return (OK);
  143. }
  144. /**
  145.  * *@breif open device
  146.  * */
  147. int open_dev(char *dev)
  148. {
  149.     int fd;
  150.  
  151.     fd = open( dev, O_RDWR|O_NOCTTY|O_NDELAY);
  152.     if (fd < 0)
  153.     {
  154.         perror("open");
  155.         return FAIL;
  156.     }
  157.     else
  158.         return fd;
  159. }

serial.h 

  1. /********************************************************************************
  2.  *      Copyright:  (C) 2016 Lu Zengmeng<1540999272@qq.com>
  3.  *                  All rights reserved.
  4.  *
  5.  *       Filename:  serial.h
  6.  *    Description:  This head file 
  7.  *
  8.  *        Version:  1.0.0(08/01/2016)
  9.  *         Author:  Lu Zengmeng <1540999272@qq.com>
  10.  *      ChangeLog:  1, Release initial version on "08/01/2016 06:44:25 PM"
  11.  *                 
  12.  ********************************************************************************/
  13. #include <stdio.h>
  14.  
  15. #ifndef __SERIAL_H__
  16. #define __SERIAL_H__
  17.  
  18. extern int speed_arr[];
  19. extern int name_arr[];
  20. extern void set_speed(int fd, int speed);
  21. extern int set_parity(int fd,int databits,int stopbits,int parity);
  22. extern int open_dev(char *dev);
  23.  
  24. #endif
socket初始化连接 tcp.c 

  1. /*********************************************************************************
  2.  *      Copyright:  (C) 2016 Lu Zengmeng<1540999272@qq.com>
  3.  *                  All rights reserved.
  4.  *
  5.  *       Filename:  tcp.c
  6.  *    Description:  This file 
  7.  *                 
  8.  *        Version:  1.0.0(08/02/2016)
  9.  *         Author:  Lu Zengmeng <1540999272@qq.com>
  10.  *      ChangeLog:  1, Release initial version on "08/02/2016 08:09:55 AM"
  11.  *                 
  12.  ********************************************************************************/
  13. #include <stdio.h>
  14. #include <sys/types.h>
  15. #include <sys/socket.h>
  16. #include <arpa/inet.h>
  17. #include <netinet/in.h>
  18. #include <strings.h>
  19. #include <stdlib.h>
  20. #include <unistd.h>
  21. #include <string.h>
  22. #include <fcntl.h>
  23. #include <sys/stat.h>
  24.  
  25. #include "tcp.h"
  26.  
  27. /**************************************************************************************
  28.  *  Description:
  29.  *   Input Args:
  30.  *  Output Args:
  31.  * Return Value:
  32.  *************************************************************************************/
  33. int socket_init(void)
  34. {
  35.  
  36.     int                    fd;
  37.     struct sockaddr_in     serv_addr;
  38.  
  39.  
  40.     bzero(&serv_addr,sizeof(serv_addr));
  41.     serv_addr.sin_family = AF_INET;
  42.     serv_addr.sin_port   = htons(PORT);
  43.  
  44.     if ((inet_pton(AF_INET,IPADDR,&serv_addr.sin_addr)) < 0)
  45.     {
  46.         perror("inet_pton");
  47.         exit(1);
  48.     }
  49.  
  50.     fd = socket(AF_INET, SOCK_STREAM, 0);
  51.     if (fd < 0)
  52.     {
  53.         perror("socket");
  54.         exit(1);
  55.     }
  56.  
  57.     if (-1 == connect(fd, (struct sockaddr *)&serv_addr, sizeof(serv_addr)))
  58.     {
  59.         perror("connect");
  60.         exit(1);
  61.     }
  62.     printf("connect sucesseful\n");
  63.  
  64.     return fd;
  65. }
  66.      /* ----- End of socket_init()  ----- */

tcp.h 

  1. /********************************************************************************
  2.  *      Copyright:  (C) 2016 Lu Zengmeng<1540999272@qq.com>
  3.  *                  All rights reserved.
  4.  *
  5.  *       Filename:  tcp.h
  6.  *    Description:  This head file 
  7.  *
  8.  *        Version:  1.0.0(08/02/2016)
  9.  *         Author:  Lu Zengmeng <1540999272@qq.com>
  10.  *      ChangeLog:  1, Release initial version on "08/02/2016 08:22:06 AM"
  11.  *                 
  12.  ********************************************************************************/
  13. #include <stdio.h>
  14.  
  15. #ifndef __TCP_H_
  16. #define __TCP_H_
  17.  
  18. #define PORT             8003
  19. #define IPADDR           "192.168.1.104"
  20. extern int socket_init(void);
  21.  
  22. #endif

main.c 

  1. /*********************************************************************************
  2.  *      Copyright:  (C) 2016 Lu Zengmeng<1540999272@qq.com>
  3.  *                  All rights reserved.
  4.  *
  5.  *       Filename:  main.c
  6.  *    Description:  This file 
  7.  *                 
  8.  *        Version:  1.0.0(08/01/2016)
  9.  *         Author:  Lu Zengmeng <1540999272@qq.com>
  10.  *      ChangeLog:  1, Release initial version on "08/01/2016 06:45:37 PM"
  11.  *                 
  12.  ********************************************************************************/
  13. #include <stdio.h>
  14. #include <stdlib.h>  
  15. #include <string.h>  
  16. #include <errno.h> 
  17. #include <unistd.h>  
  18.  
  19. #include <sys/types.h>  
  20. #include <sys/stat.h>  
  21.  
  22. #include <fcntl.h>   
  23. #include <termios.h> 
  24. #include <pthread.h> 
  25.  
  26. #include "serial.h" 
  27. #include "tcp.h" 
  28.  
  29. #define  DEVICE      "/dev/ttyS1"
  30. #define  BUF_SIZE    128
  31.  
  32. int    usrt_fd;
  33. int    sock_fd;
  34.  
  35. void usrt_to_socket (void);
  36. void socket_to_usrt (void);
  37.  
  38. /* start main */
  39. int main(int argc,char **argv)
  40. {
  41.     int    ret;
  42.     char   *dev = DEVICE;
  43.     pthread_t sock,usrt;
  44.  
  45.     sock_fd = socket_init();
  46.     usrt_fd = open_dev(dev);
  47.  
  48.     set_parity(usrt_fd,8,1,'N'); // 设置串口数据位、停止位、校验位
  49.     set_speed(usrt_fd,9600); // 设置串口波特率
  50.  
  51.     ret = pthread_create(&sock,NULL,(void *)socket_to_usrt,NULL); // 创建sock线程接收socket数据
  52.     if(ret < 0)
  53.     {
  54.         perror("phread_create");
  55.         exit(1);
  56.     }
  57.  
  58.     ret = pthread_create(&usrt,NULL,(void *)usrt_to_socket,NULL); // 创建usrt线程接收串口数据
  59.     if(ret < 0)
  60.     {
  61.         perror("phread_create");
  62.         exit(1);
  63.     }
  64.  
  65.     pthread_join(sock,NULL); // 等待线程退出
  66.     pthread_join(usrt,NULL);
  67.  
  68.     close(sock_fd);
  69.     close(usrt_fd);
  70.  
  71.     printf("main exit...\n");
  72.     return 0;
  73. }
  74.  
  75.  
  76. /**************************************************************************************
  77.  *  Description:接收socket数据并通过串口转发
  78.  *   Input Args:
  79.  *  Output Args:
  80.  * Return Value:
  81.  *************************************************************************************/
  82. void socket_to_usrt (void)
  83. {
  84.     printf("start socket_to_usrt...\n");
  85.     int     n = 0;
  86.     int     m = 0;
  87.     char    buf[BUF_SIZE];
  88.  
  89.     while(1)
  90.     {
  91.         memset(buf,0,BUF_SIZE);
  92.         n = read(sock_fd,buf,BUF_SIZE);
  93.         if(n>0)
  94.         {
  95.             if(0==strncmp(buf,"exit",4)) // 收到exit时，线程退出
  96.             {
  97.                 m = write(usrt_fd,buf,BUF_SIZE);
  98.                 if(m<0)
  99.                 {
  100.                     perror("write to usrt");
  101.                 }
  102.                 break;
  103.             }
  104.  
  105.             m = write(usrt_fd,buf,BUF_SIZE);
  106.             if(m<0)
  107.             {
  108.                 perror("write to usrt");
  109.             }
  110.         }
  111.         else if(n<0)
  112.         {
  113.             perror("read from socket");
  114.         }
  115.     }
  116.  
  117.     printf("socket_to_usrt exit...\n");
  118.     pthread_exit(0);
  119. } /* ----- End of sock_to_usrt()  ----- */
  120.  
  121.  
  122. /**************************************************************************************
  123.  *  Description:接收串口数据并通过socket转发
  124.  *   Input Args:
  125.  *  Output Args:
  126.  * Return Value:
  127.  *************************************************************************************/
  128. void usrt_to_socket (void)
  129. {
  130.     printf("start usrt_to_socket...\n");
  131.     int     n = 0;
  132.     int     m = 0;
  133.     char    buf[BUF_SIZE];
  134.  
  135.     while(1)
  136.     {
  137.         memset(buf,0,BUF_SIZE);
  138.         n = read(usrt_fd,buf,BUF_SIZE);
  139.         if(n>0)
  140.         {
  141.             if(0==strncmp(buf,"exit",4)) // 收到exit时，线程退出
  142.             {
  143.                 m = write(sock_fd,buf,BUF_SIZE);
  144.                 if(m<0)
  145.                 {
  146.                     perror("write to sock");
  147.                 }
  148.                 break;
  149.             }
  150.  
  151.             m = write(sock_fd,buf,BUF_SIZE);
  152.             if(m<0)
  153.             {
  154.                 perror("write to sock");
  155.             }
  156.         }
  157.  
  158.         else if(n<0)
  159.         {
  160.             perror("read from usrt");
  161.         }
  162.     }
  163.     
  164.     printf("usrt_to_socket exit...\n");
  165.     pthread_exit(0);
  166. } /* ----- End of usrt_to_sock()  ----- */
makefile 

  1. NAME=client
  2. CC=/opt/buildroot-2012.08/arm920t/usr/bin/arm-linux-gcc
  3. EXTRA_CFLAGS+= -Wall -Werror
  4. EXTRA_CFLAGS+= -lpthread
  5. all:
  6.         $(CC) $(EXTRA_CFLAGS) main.c serial.c tcp.c -o $(NAME)
  7.         cp $(NAME) /tftp


3、调试助手下载

USR-TCP232-Test




声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/知新_RL/article/detail/791264
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号