硬汉嵌入式论坛

 找回密码
 立即注册
查看: 1970|回复: 5
收起左侧

[RL-TCPnet教程] 【RL-TCPnet网络教程】第26章 RL-TCPnet之DHCP应用

[复制链接]

740

主题

1326

回帖

3546

积分

管理员

春暖花开

Rank: 9Rank: 9Rank: 9

积分
3546
QQ
发表于 2017-11-22 14:48:02 | 显示全部楼层 |阅读模式
第26章      RL-TCPnet之DHCP应用



        本章节为大家讲解RL-TCPnet的DHCP应用,学习本章节前,务必要优先学习第25章的DHCP基础知识。有了这些基础知识之后,再搞本章节会有事半功倍的效果。
        本章教程含STM32F407开发板和STM32F429开发板。
26.1 初学者重要提示
26.2 DHCP函数
26.3 DHCP配置说明(Net_Config.c)
26.4 DHCP调试说明(Net_Debug.c)
26.5 DHCP检测过程
26.6 网络调试助手和板子的操作步骤
26.7 实验例程说明(RTX)
26.8      总结



26.1  初学者重要提示

1、学习本章节前,务必保证已经学习了第25章的基础知识。
2、本章相对比较简单,配套的例子中实现了一种8秒内无法通过DHCP Client获取动态IP的情况下,使用配置向导文件Net_Config.c中设置的静态IP地址。

26.2 DHCP函数


        涉及到DHCP的,仅有如下两个函数:
(1)dhcp_disable
        此函数比较简单,用于禁止DHCP。
(2)dhcp_cbfunc
        此函数是DHCP的回调函数,实际测试发现,这个函数没有任何效果,也就是此函数没有被调用到。
关于这2个函数的讲解及其使用方法可以看教程第 3 章 3.4 小节里面说的参考资料 rlarm.chm 文件:
26.1.png


注意,这两个函数都不支持重入,也就是不支持多任务调用。
努力打造安富莱高质量微信公众号:点击扫描图片关注
回复

使用道具 举报

740

主题

1326

回帖

3546

积分

管理员

春暖花开

Rank: 9Rank: 9Rank: 9

积分
3546
QQ
 楼主| 发表于 2017-11-22 15:00:56 | 显示全部楼层
26.3 DHCP配置说明(Net_Config.c)


        (本章节配套例子的配置与本小节的说明相同)
        RL-TCPnet的配置工作是通过配置文件Net_Config.c实现。在MDK工程中打开文件Net_Config.c,可以看到下图所示的工程配置向导:
26.2.png

RL-TCPnet要配置的选项非常多,我们这里把几个主要的配置选项简单介绍下。
26.3.png

System Definitions
(1)Local Host Name
        局域网域名。
        这里起名为armfly,使用局域网域名限制为15个字符。
(2)Memory Pool size
        参数范围1536-262144字节。
        内存池大小配置,单位字节。另外注意一点,配置向导这里显示的单位是字节,如果看原始定义,MDK会做一个自动的4字节倍数转换,比如我们这里配置的是8192字节,那么原始定义是#define MEM_SIZE  2048,也就是8192/4 = 2048。
(3)Tick Timer interval
        可取10,20,25,40,50,100,200,单位ms。
        系统滴答时钟间隔,也就是网络协议栈的系统时间基准,默认情况下,取值100ms。
26.4.png

Ethernet Network Interface
       以太网接口配置,勾选了此选项就可以配置了,如果没有使能DHCP的话,将使用这里配置的固定IP
(1)MAC Address
       局域网内可以随意配置,只要不跟局域网内其它设备的MAC地址冲突即可。
(2)IP Address
        IP地址。
(3)Subnet mask
        子网掩码。
(4)Default Gateway
        默认网关。
26.5.png

Ethernet Network Interface
       以太网接口配置,这个配置里面还有如下两项比较重要的配置需要说明。
(1)NetBIOS Name Service
       NetBIOS局域网域名服务,这里打上对勾就使能了。这样我们就可以通过前面配置的Local Host Name局域网域名进行访问,而不需要通过IP地址访问了。
(2)Dynaminc Host Configuration
       即DHCP,这里打上对勾就使能了。使能了DHCP后,RL-TCPnet就可以从外接的路由器上获得动态IP地址。
① Vendor Class Identifier
       厂商ID,如果设置了的话,会将其加到DHCP的请求消息中,用于识别网络设备的不同厂商。
② Bootfile Name
        从DHCP 服务器获取的引导文件名。
③ NTP Servers
         从DCHP服务器获得NTP服务器列表。
26.6.png

UDP Sockets
        UDP Sockets配置,打上对勾就使能了此项功能
(1)Number of UDP Sockets
        用于配置可创建的UDP Sockets数量,这里配置了5个。
        范围1 – 20。
26.7.png

TCP Sockets
        TCP Sockets配置,打上对勾就使能了此项功能
(1)Number of TCP Sockets
        用于配置可创建的TCP Sockets数量。
(2)Number of Retries
       范围0-20。
        用于配置重试次数,TCP数据传输时,如果在设置的重试时间内得不到应答,算一次重试失败,这里就是配置的最大重试次数。
(3)Retry Timeout in seconds
        范围1-10,单位秒。
        重试时间。如果发送的数据在重试时间内得不到应答,将重新发送数据。
(4)Default Connect Timeout in seconds
        范围1-600,单位秒。
        用于配置默认的保持连接时间,即我们常说的Keep Alive时间,如果时间到了将断开连接。常用于HTTP Server,Telnet Server等。
(5)Maximum Segment Size
        范围536-1460,单位字节。
        MSS定义了TCP数据包能够传输的最大数据分段。
(6)Receive Window Size
        范围536-65535,单位字节。
        TCP接收窗口大小。
26.8.png

BSD Socket Interface
        BSD Socket配置,打上对勾就使能了此项功能
(1)BSD_NUMSOCKS
        用于配置可创建的BSD Socket数量。
        范围1-20。
(2)BSD_SRVSOCKS
        定义的BSD Socket中可以采用TCP通信协议的服务器个数。
(3)BSD_RCVTOUT
        socket接收函数recv工作在阻塞状态时的溢出时间设置,单位秒。
        范围0-600秒,配置为0的话,表示无限等待。
(4)BSD_GETHOSTEN
        启用或禁用Berkeley风格的主机名解。

26.4 DHCP调试说明(Net_Debug.c)


         (重要说明,RL-TCPnet的调试是通过串口打印出来的)
        RL-TCPnet的调试功能是通过配置文件Net_Debug.c实现。在MDK工程中打开文件Net_Debug.c,可以看到下图所示的工程配置向导:
26.9.png

Print Time Stamp
        勾选了此选项的话,打印消息时,前面会附带时间信息。
其它所有的选项
        默认情况下,所有的调试选项都关闭了,每个选项有三个调试级别可选择,这里我们以DHCP Debug为例,点击下拉列表,可以看到里面有Off,Errors only和Full debug三个调试级别可供选择,每个调试选项里面都是这三个级别。
26.10.png

Off:表示关闭此选项的调试功能。
Errorsonly:表示仅在此选项出错时,将其错误打印出来。
Fulldebug:表示此选项的全功能调试。
        下面是对DHCP Debug配置为Full debug时,打印出来的消息:
26.11.png
努力打造安富莱高质量微信公众号:点击扫描图片关注
回复

使用道具 举报

740

主题

1326

回帖

3546

积分

管理员

春暖花开

Rank: 9Rank: 9Rank: 9

积分
3546
QQ
 楼主| 发表于 2017-11-22 15:01:58 | 显示全部楼层
26.5 DHCP检测过程


        本章节配套的程序中对DHCP检测过程做了一个简单的判断,8秒内不能获得动态IP地址的话,将使用配置向导文件Net_Config.c里面设置的固定IP地址:192.168.1.100。
        检测代码如下:
  1. /*
  2. **********************************************************************************************************
  3.                                                    外部调用
  4. **********************************************************************************************************
  5. */
  6. #define DHCP_TOUT   80                 /* DHCP动态IP获取的溢出时间设置为8秒 */
  7. #define MY_IP localm[NETIF_ETH].IpAdr
  8. extern LOCALM localm[];            
  9. /*
  10. **********************************************************************************************************
  11.                                                    变量
  12. **********************************************************************************************************
  13. */
  14. uint32_t dhcp_tout;
  15. uint8_t DHCP_Status[2][40] = {"IP: 192.168.X.X",              
  16.                               "Waiting for DHCP"};
  17. /*
  18. *********************************************************************************************************
  19. *    函 数 名: main
  20. *    功能说明: 标准c程序入口。
  21. *    形    参: 无
  22. *    返 回 值: 无
  23. *********************************************************************************************************
  24. */
  25. static void dhcp_check(void)
  26. {
  27.      /* 检测是否通过DHCP自动获得IP */
  28.      if (mem_test (&MY_IP, 0, IP_ADRLEN) == __FALSE && !(dhcp_tout & 0x80000000))
  29.      {
  30.          /* 已经获得IP */
  31.          dhcp_tout = 0;
  32.          sprintf((char *)DHCP_Status[0],"%d.%d.%d.%d", MY_IP[0], MY_IP[1],
  33.                                     MY_IP[2], MY_IP[3]);
  34.          sprintf((char *)DHCP_Status[1],"DHCP Success");
  35.          printf_tcpdbg("%s\\r\\n", DHCP_Status[0]);
  36.          printf_tcpdbg("%s\\r\\n", DHCP_Status[1]);
  37.          return;
  38.      }
  39.    
  40.      /* 每100ms进行一次减减操作 */
  41.      if (--dhcp_tout == 0)
  42.      {
  43.          /* 设置的8秒自动获取IP时间已经到了,禁止DHCP,准备使用固定IP */
  44.          dhcp_disable ();
  45.          sprintf((char *)DHCP_Status[1],"DHCP Failed" );
  46.          /* 更新溢出时间,将固定IP的分配时间也设置为8秒 */
  47.          dhcp_tout = 80 | 0x80000000;
  48.          return;
  49.      }
  50.    
  51.      /* 设置固定IP的8秒时间到 */
  52.      if (dhcp_tout == 0x80000000)
  53.      {
  54.          dhcp_tout = 0;
  55.          sprintf((char *)DHCP_Status[0],"%d.%d.%d.%d", MY_IP[0], MY_IP[1],
  56.                                     MY_IP[2], MY_IP[3]);
  57.          sprintf((char *)DHCP_Status[1],"DHCP Failed Use static IP");
  58.          printf_tcpdbg("%s\\r\\n", DHCP_Status[0]);
  59.          printf_tcpdbg("%s\\r\\n", DHCP_Status[1]);
  60.      }
  61. }
  62. /*
  63. *********************************************************************************************************
  64. *    函 数 名: TCPnetTest
  65. *    功能说明: 主要实现动态IP获取和网络协议栈主函数main_TcpNet的调用。
  66. *    形    参: 无
  67. *    返 回 值: 无
  68. *********************************************************************************************************
  69. */
  70. void TCPnetTest(void)
  71. {
  72.      uint32_t tstart, tend;
  73.    
  74.      /* 初始化变量 */
  75.      dhcp_tout = DHCP_TOUT;
  76.      tstart = os_time_get();
  77.    
  78.      while (1)
  79.      {
  80.          /* 每100ms做一次DHCP检测 */
  81.          if(dhcp_tout != 0)
  82.          {
  83.               tend = os_time_get() - tstart;
  84.               //printf_tcpdbg("%x %d\\r\\n", dhcp_tout, tend);
  85.               if(tend >= 100)
  86.               {
  87.                    tstart = os_time_get();
  88.                    dhcp_check();
  89.               }
  90.          }
  91.         
  92.          os_evt_wait_and(0x0001, 0xFFFF);
  93.          while (main_TcpNet() == __TRUE);
  94.      }
  95. }
复制代码
努力打造安富莱高质量微信公众号:点击扫描图片关注
回复

使用道具 举报

740

主题

1326

回帖

3546

积分

管理员

春暖花开

Rank: 9Rank: 9Rank: 9

积分
3546
QQ
 楼主| 发表于 2017-11-22 15:02:29 | 显示全部楼层
26.6 网络调试助手和板子的操作步骤


因为这个例子是基于前面第19章BSD Socket服务器的例子简单修改而来,所以操作步骤直接看第19章的19.9小节即可。
努力打造安富莱高质量微信公众号:点击扫描图片关注
回复

使用道具 举报

740

主题

1326

回帖

3546

积分

管理员

春暖花开

Rank: 9Rank: 9Rank: 9

积分
3546
QQ
 楼主| 发表于 2017-11-22 15:11:04 | 显示全部楼层
26.7 实验例程说明(RTX)



26.7.1 STM32F407开发板实验


配套例子:
    V5-1033_RL-TCPnet实验_DHCP应用(RTX)
实验目的:
    1.     学习RL-TCPnet的DHCP应用。
实验内容:
    1.      DHCP已经使能,如果插上网线8秒内无法从路由器/交换机获得IP地址,将使用固定IP:192.168.1.100。此固定IP是在配置向导文件Net_Config.c里面设置的。
    2.      本例程创建了一个socket服务器,采用TCP通信协议,而且使能了局域网域名NetBIOS,用户只需在电脑端ping armfly就可以获得板子的IP地址,本地端口被设置为1024。
    3.      用户可以在电脑端用网络调试软件创建TCP Client连接此服务器。
    4.      网络调试助手发送命令字符1,板子回复字符1到8以及回车和换行两个字符,共10个。
    5.      网络调试助手发送命令字符2,板子回复1024个字符,前4个字符是abcd,最后4个字符是efgh,中间的1016个全部是字符0。
实验操作:
    详见本章节26.6小节。
配置向导文件设置(Net_Config.c):
    详见本章节26.3小节。
调试文件设置(Net_Debug.c):
    详见本章节26.4小节。
RTX配置:
    RTX配置向导详情如下:
26.12.png

Task Configuration
(1)Number of concurrent running tasks
         允许创建7个任务,实际创建了如下6个任务:
        AppTaskUserIF任务   :按键消息处理。
        AppTaskLED任务     :LED闪烁。
        AppTaskMsgPro任务 :按键检测。
        AppTaskSocket任务  :socket服务器任务。
        AppTaskTCPMain任务:RL-TCPnet网络主任务。
        AppTaskStart任务  :启动任务,也是最高优先级任务,这里实现RL-TCPnet的时间基准更新。
(2)Number of tasks with user-provided stack
        创建的6个任务都是采用自定义堆栈方式。
(3)Run in privileged mode
        设置任务运行在非特权级模式。
RTX任务调试信息:
26.13.png

程序设计:
任务栈大小分配:
    staticuint64_t AppTaskUserIFStk[1024/8];   /* 任务栈 */
    staticuint64_t AppTaskLEDStk[1024/8];      /* 任务栈 */
    staticuint64_t AppTaskMsgProStk[1024/8];  /* 任务栈 */
    staticuint64_t AppTaskSocketStk[2048/8];   /* 任务栈 */
    staticuint64_t AppTaskTCPMainStk[2048/8]; /* 任务栈 */
    staticuint64_t AppTaskStartStk[1024/8];     /* 任务栈 */
    将任务栈定义成uint64_t类型可以保证任务栈是8字节对齐的,8字节对齐的含义就是数组的首地址对8求余等于0。如果不做8字节对齐的话,部分C语言库函数、浮点运算和uint64_t类型数据运算会出问题。
系统栈大小分配:
26.14.png

RTX初始化:
  1. /*
  2. *********************************************************************************************************
  3. *    函 数 名: main
  4. *    功能说明: 标准c程序入口。
  5. *    形    参: 无
  6. *    返 回 值: 无
  7. *********************************************************************************************************
  8. */
  9. int main (void)
  10. {   
  11.      /* 初始化外设 */
  12.      bsp_Init();
  13.    
  14.      /* 创建启动任务 */
  15.      os_sys_init_user (AppTaskStart,              /* 任务函数 */
  16.                        6,                         /* 任务优先级 */
  17.                        &AppTaskStartStk,          /* 任务栈 */
  18.                        sizeof(AppTaskStartStk));  /* 任务栈大小,单位字节数 */
  19.      while(1);
  20. }
复制代码
硬件外设初始化
    硬件外设的初始化是在 bsp.c 文件实现:
  1. /*
  2. *********************************************************************************************************
  3. *    函 数 名: bsp_Init
  4. *    功能说明: 初始化所有的硬件设备。该函数配置CPU寄存器和外设的寄存器并初始化一些全局变量。只需要调用一次
  5. *    形    参:无
  6. *    返 回 值: 无
  7. *********************************************************************************************************
  8. */
  9. void bsp_Init(void)
  10. {
  11.      /*
  12.          由于ST固件库的启动文件已经执行了CPU系统时钟的初始化,所以不必再次重复配置系统时钟。
  13.          启动文件配置了CPU主时钟频率、内部Flash访问速度和可选的外部SRAM FSMC初始化。
  14.          系统时钟缺省配置为168MHz,如果需要更改,可以修改 system_stm32f4xx.c 文件
  15.      */
  16.      /* 优先级分组设置为4,可配置0-15级抢占式优先级,0级子优先级,即不存在子优先级。*/
  17.      NVIC_PriorityGroupConfig(NVIC_PriorityGroup_4);
  18.      bsp_InitDWT();     /* 初始化DWT */
  19.      bsp_InitUart();    /* 初始化串口 */
  20.      bsp_InitKey();    /* 初始化按键变量(必须在 bsp_InitTimer() 之前调用) */
  21.      bsp_InitLed();    /* 初始LED指示灯端口 */
  22. }
复制代码
RTX任务创建:
  1. /*
  2. *********************************************************************************************************
  3. *    函 数 名: AppTaskCreate
  4. *    功能说明: 创建应用任务
  5. *    形    参: 无
  6. *    返 回 值: 无
  7. *********************************************************************************************************
  8. */
  9. static void AppTaskCreate (void)
  10. {
  11.      HandleTaskUserIF = os_tsk_create_user(AppTaskUserIF,             /* 任务函数 */
  12.                                            1,                         /* 任务优先级 */
  13.                                            &AppTaskUserIFStk,         /* 任务栈 */
  14.                                            sizeof(AppTaskUserIFStk)); /* 任务栈大小,单位字节数 */
  15.    
  16.      HandleTaskLED = os_tsk_create_user(AppTaskLED,              /* 任务函数 */
  17.                                         2,                       /* 任务优先级 */
  18.                                         &AppTaskLEDStk,          /* 任务栈 */
  19.                                         sizeof(AppTaskLEDStk));  /* 任务栈大小,单位字节数 */
  20.    
  21.      HandleTaskMsgPro = os_tsk_create_user(AppTaskMsgPro,             /* 任务函数 */
  22.                                            3,                         /* 任务优先级 */
  23.                                            &AppTaskMsgProStk,         /* 任务栈 */
  24.                                            sizeof(AppTaskMsgProStk)); /* 任务栈大小,单位字节数 */
  25.    
  26.      HandleTaskSocket = os_tsk_create_user(AppTaskSocket,             /* 任务函数 */
  27.                                            4,                         /* 任务优先级 */
  28.                                            &AppTaskSocketStk,         /* 任务栈 */
  29.                                            sizeof(AppTaskSocketStk)); /* 任务栈大小,单位字节数 */
  30.    
  31.     HandleTaskTCPMain = os_tsk_create_user(AppTaskTCPMain,             /* 任务函数 */
  32.                                            5,                         /* 任务优先级 */
  33.                                            &AppTaskTCPMainStk,         /* 任务栈 */
  34.                                            sizeof(AppTaskTCPMainStk)); /* 任务栈大小,单位字节数 */
  35. }
复制代码
六个RTX任务的实现:
  1. /*
  2. *********************************************************************************************************
  3. *    函 数 名: AppTaskUserIF
  4. *    功能说明: 按键消息处理     
  5. *    形    参: 无
  6. *    返 回 值: 无
  7. *   优 先 级: 1  (数值越小优先级越低,这个跟uCOS相反)
  8. *********************************************************************************************************
  9. */
  10. __task void AppTaskUserIF(void)
  11. {
  12.      uint8_t ucKeyCode;
  13.     while(1)
  14.     {
  15.          ucKeyCode = bsp_GetKey();
  16.         
  17.          if (ucKeyCode != KEY_NONE)
  18.          {
  19.               switch (ucKeyCode)
  20.               {
  21.                    /* K1键按下 */
  22.                    case KEY_DOWN_K1:
  23.                        printf("K1键按下\\r\\n");        
  24.                        break;  
  25.                    /* K2键按下 */
  26.                    case KEY_DOWN_K2:
  27.                        printf("K2键按下\\r\\n");
  28.                        break;
  29.                   
  30.                    /* K3键按下 */
  31.                    case KEY_DOWN_K3:
  32.                        printf("K3键按下\\r\\n");
  33.                        break;
  34.                    /* 其他的键值不处理 */
  35.                    default:                    
  36.                        break;
  37.               }
  38.          }
  39.         
  40.          os_dly_wait(20);
  41.      }
  42. }
  43. /*
  44. *********************************************************************************************************
  45. *    函 数 名: AppTaskLED
  46. *    功能说明: LED闪烁。
  47. *    形    参: 无
  48. *    返 回 值: 无
  49. *   优 先 级: 2
  50. *********************************************************************************************************
  51. */
  52. __task void AppTaskLED(void)
  53. {
  54.      const uint16_t usFrequency = 500; /* 延迟周期 */
  55.    
  56.      /* 设置延迟周期 */
  57.      os_itv_set(usFrequency);
  58.    
  59.     while(1)
  60.     {
  61.          bsp_LedToggle(2);
  62.          /* os_itv_wait是绝对延迟,os_dly_wait是相对延迟。*/
  63.          os_itv_wait();
  64.     }
  65. }
  66. /*
  67. *********************************************************************************************************
  68. *    函 数 名: AppTaskMsgPro
  69. *    功能说明: 按键检测
  70. *    形    参: 无
  71. *    返 回 值: 无
  72. *   优 先 级: 3
  73. *********************************************************************************************************
  74. */
  75. __task void AppTaskMsgPro(void)
  76. {
  77.     while(1)
  78.     {
  79.          bsp_KeyScan();
  80.          os_dly_wait(10);
  81.     }
  82. }
  83. /*
  84. *********************************************************************************************************
  85. *    函 数 名: AppTaskSocket
  86. *    功能说明: RL-TCPnet测试任务
  87. *    形    参: 无
  88. *    返 回 值: 无
  89. *   优 先 级: 4
  90. *********************************************************************************************************
  91. */
  92. __task void AppTaskSocket(void)
  93. {
  94.      while (1)
  95.      {
  96.          SocketTest();
  97.      }
  98. }
  99. /*
  100. *********************************************************************************************************
  101. *    函 数 名: AppTaskTCPMain
  102. *    功能说明: RL-TCPnet网络主任务
  103. *    形    参: 无
  104. *    返 回 值: 无
  105. *   优 先 级: 5
  106. *********************************************************************************************************
  107. */
  108. __task void AppTaskTCPMain(void)
  109. {
  110.      while (1)
  111.      {
  112.          TCPnetTest();
  113.      }
  114. }
  115. /*
  116. *********************************************************************************************************
  117. *    函 数 名: AppTaskStart
  118. *    功能说明: 启动任务,也是最高优先级任务,这里实现RL-TCPnet的时间基准更新。
  119. *    形    参: 无
  120. *    返 回 值: 无
  121. *   优 先 级: 6
  122. *********************************************************************************************************
  123. */
  124. __task void AppTaskStart(void)
  125. {
  126.      /* 初始化RL-TCPnet */
  127.      init_TcpNet ();
  128.    
  129.      /* 创建任务 */
  130.      AppTaskCreate();
  131.    
  132.      os_itv_set (100);
  133.    
  134.     while(1)
  135.     {
  136.          os_itv_wait ();
  137.         
  138.          /* RL-TCPnet时间基准更新函数 */
  139.          timer_tick ();
  140.     }
  141. }
复制代码
RL-TCPnet网络主任务
    这里专门创建了一个app_tcpnet_lib.c文件用于RL-TCPnet的网络主任务,实现动态IP获取和网络协议栈主函数main_TcpNet的调用。
  1. #include "includes.h"
  2. /*
  3. *********************************************************************************************************
  4. *                                      用于本文件的调试
  5. *********************************************************************************************************
  6. */
  7. #if 1
  8.      #define printf_tcpdbg printf
  9. #else
  10.      #define printf_tcpdbg(...)
  11. #endif
  12. /*
  13. **********************************************************************************************************
  14.                                                    外部调用
  15. **********************************************************************************************************
  16. */
  17. #define DHCP_TOUT   80                 /* DHCP动态IP获取的溢出时间设置为8秒 */
  18. #define MY_IP localm[NETIF_ETH].IpAdr
  19. extern LOCALM localm[];            
  20. /*
  21. **********************************************************************************************************
  22.                                                    变量
  23. **********************************************************************************************************
  24. */
  25. uint32_t dhcp_tout;
  26. uint8_t DHCP_Status[2][40] = {"IP: 192.168.X.X",              
  27.                               "Waiting for DHCP"};
  28. /*
  29. *********************************************************************************************************
  30. *    函 数 名: main
  31. *    功能说明: 标准c程序入口。
  32. *    形    参: 无
  33. *    返 回 值: 无
  34. *********************************************************************************************************
  35. */
  36. static void dhcp_check(void)
  37. {
  38.      /* 检测是否通过DHCP自动获得IP */
  39.      if (mem_test (&MY_IP, 0, IP_ADRLEN) == __FALSE && !(dhcp_tout & 0x80000000))
  40.      {
  41.           /* 已经获得IP */
  42.          dhcp_tout = 0;
  43.          sprintf((char *)DHCP_Status[0],"%d.%d.%d.%d", MY_IP[0], MY_IP[1],
  44.                                     MY_IP[2], MY_IP[3]);
  45.          sprintf((char *)DHCP_Status[1],"DHCP Success");
  46.          printf_tcpdbg("%s\\r\\n", DHCP_Status[0]);
  47.          printf_tcpdbg("%s\\r\\n", DHCP_Status[1]);
  48.          return;
  49.      }
  50.    
  51.      /* 每100ms进行一次减减操作 */
  52.      if (--dhcp_tout == 0)
  53.      {
  54.           /* 设置的8秒自动获取IP时间已经到了,禁止DHCP,准备使用固定IP */
  55.          dhcp_disable ();
  56.          sprintf((char *)DHCP_Status[1],"DHCP Failed" );
  57.           /* 更新溢出时间,将固定IP的分配时间也设置为8秒 */
  58.          dhcp_tout = 80 | 0x80000000;
  59.          return;
  60.      }
  61.    
  62.      /* 设置固定IP的8秒时间到 */
  63.      if (dhcp_tout == 0x80000000)
  64.      {
  65.          dhcp_tout = 0;
  66.           sprintf((char *)DHCP_Status[0],"%d.%d.%d.%d", MY_IP[0], MY_IP[1],
  67.                                     MY_IP[2], MY_IP[3]);
  68.          sprintf((char *)DHCP_Status[1],"DHCP Failed Use static IP");
  69.          printf_tcpdbg("%s\\r\\n", DHCP_Status[0]);
  70.          printf_tcpdbg("%s\\r\\n", DHCP_Status[1]);
  71.      }
  72. }
  73. /*
  74. *********************************************************************************************************
  75. *    函 数 名: TCPnetTest
  76. *    功能说明: 主要实现动态IP获取和网络协议栈主函数main_TcpNet的调用。
  77. *    形    参: 无
  78. *    返 回 值: 无
  79. *********************************************************************************************************
  80. */
  81. void TCPnetTest(void)
  82. {
  83.      uint32_t tstart, tend;
  84.    
  85.      /* 初始化变量 */
  86.      dhcp_tout = DHCP_TOUT;
  87.      tstart = os_time_get();
  88.    
  89.      while (1)
  90.      {
  91.           /* 每100ms做一次DHCP检测 */
  92.          if(dhcp_tout != 0)
  93.          {
  94.               tend = os_time_get() - tstart;
  95.               //printf_tcpdbg("%x %d\\r\\n", dhcp_tout, tend);
  96.               if(tend >= 100)
  97.               {
  98.                    tstart = os_time_get();
  99.                    dhcp_check();
  100.               }
  101.          }
  102.         
  103.          os_evt_wait_and(0x0001, 0xFFFF);
  104.          while (main_TcpNet() == __TRUE);
  105.      }
  106. }
复制代码
Socket 服务器任务
    这里专门创建了一个app_socket_lib.c文件用于socket服务器任务。
  1. #include "includes.h"
  2. /*
  3. *********************************************************************************************************
  4. *                                      用于本文件的调试
  5. *********************************************************************************************************
  6. */
  7. #if 1
  8.      #define printf_debug printf
  9. #else
  10.      #define printf_debug(...)
  11. #endif
  12. /*
  13. *********************************************************************************************************
  14. *                              宏定义,本地端口
  15. *********************************************************************************************************
  16. */
  17. /* 这个是本地端口 */
  18. #define LocalPort_NUM    1001
  19. /*
  20. *********************************************************************************************************
  21. *                                         变量
  22. *********************************************************************************************************
  23. */
  24. /* RL-TCPnet API的返回值 */
  25. const char * ReVal_Table[]=
  26. {
  27.      " 0: SCK_SUCCESS       Success                             ",
  28.      "-1: SCK_ERROR         General Error                       ",
  29.      "-2: SCK_EINVALID      Invalid socket descriptor           ",
  30.      "-3: SCK_EINVALIDPARA  Invalid parameter                   ",
  31.      "-4: SCK_EWOULDBLOCK   It would have blocked.              ",
  32.      "-5: SCK_EMEMNOTAVAIL  Not enough memory in memory pool    ",
  33.      "-6: SCK_ECLOSED       Connection is closed or aborted     ",
  34.      "-7: SCK_ELOCKED       Socket is locked in RTX environment ",
  35.      "-8: SCK_ETIMEOUT      Socket, Host Resolver timeout       ",
  36.      "-9: SCK_EINPROGRESS   Host Name resolving in progress     ",
  37.      "-10: SCK_ENONAME      Host Name not existing              ",
  38. };
  39. uint8_t sendbuf[1024];
  40. /*
  41. *********************************************************************************************************
  42. *    函 数 名: SocketTest
  43. *    功能说明: Socket应用
  44. *    形    参: 无
  45. *    返 回 值: 无
  46. *********************************************************************************************************
  47. */
  48. void SocketTest(void)
  49. {
  50.      char dbuf[10];
  51.      int len;
  52.      int sock, sd, res;
  53.      SOCKADDR_IN addr;
  54.      SOCKADDR_IN ReAddr;
  55.    
  56.      while (1)
  57.      {
  58.          /* 创建一个socket
  59.             第1个参数AF_INET:当前仅支持这个类型的地址族。
  60.             第2个参数SOCK_STREAM:表示数据流通信类型,即使用的TCP。
  61.             第3个参数0 :配置为0的话,自动跟第2个参数进行协议匹配,这里就是TCP协议。
  62.          */
  63.          sock = socket (AF_INET, SOCK_STREAM, 0);
  64.          /* 端口号设置为1001 */
  65.          addr.sin_port        = htons(LocalPort_NUM);
  66.         
  67.          /* 与函数socket中的AF_INET作用一样 */
  68.          addr.sin_family      = PF_INET;
  69.           /*
  70.             INADDR_ANY就是指定地址为0.0.0.0的地址,这个地址事实上表示不确定地址,或所有地址,
  71.             任意地址。用在这里的话就表示监控端口号为ddr.sin_port的所有IP地址消息。一般主要用
  72.             于有多个网卡或者IP地址的情况。开发板只用了DM9161的网口,就是监听这个网口的IP地址。
  73.          */
  74.          addr.sin_addr.s_addr = INADDR_ANY;
  75.         
  76.          /* 给socket绑定IP和端口号 */
  77.          bind (sock, (SOCKADDR *)&addr, sizeof(addr));
  78.          /* 设置监听,最大监听1个连接 */
  79.          listen (sock, 1);
  80.         
  81.           /*
  82.             等待soket连接请求,有的话,自动创建1个新的socket进行连接通信,没有的话,等待连接。
  83.             注意,能够accept的个数受到listen函数的限制,而listen函数又受到Net_Config.c中宏定义
  84.             BSD_NUMSOCKS 的限制。
  85.          */
  86.          len = sizeof(ReAddr);
  87.          sd = accept (sock, (SOCKADDR *)&ReAddr, &len);
  88.          printf_debug ("远程客户端请求连接IP: %d.%d.%d.%d\\n", ReAddr.sin_addr.s_b1,
  89.                                                              ReAddr.sin_addr.s_b2,
  90.                                                                        ReAddr.sin_addr.s_b3,
  91.                                                              ReAddr.sin_addr.s_b4);
  92.          printf_debug ("远程客户端端口号: %d\\n", ntohs(ReAddr.sin_port));
  93.         
  94.          /* 关闭监听socket,这个监听socket是调用函数socket后自动创建的 */
  95.          closesocket (sock);
  96.          sock = sd;
  97.         
  98.          while (1)
  99.          {
  100.               /*
  101.                 socket数据接收函数,如果recv工作在阻塞模式,使用这个函数注意以下事项:
  102.                 1. 此函数的溢出时间受到Net_Config.c中宏定义 BSD_RCVTOUT 的限制。溢出时间到会自动退出。
  103.                 2. 这个函数接收到一次数据包就会返回,大于或者小于设置的缓冲区大小都没有关系,如果数据量
  104.                    大于接收缓冲区大小,用户只需多次调用函数recv进行接收即可。
  105.                 3. 实际接收到数据大小通过判断此函数的返回值即可。
  106.               */
  107.               res = recv (sock, dbuf, sizeof(dbuf), 0);
  108.               if (res <= 0)
  109.               {
  110.                    printf_debug("退出接收函数,重新开始监听%s\\r\\n", ReVal_Table[abs(res)]);
  111.                    break;
  112.               }
  113.               else
  114.               {
  115.                    printf_debug("Receive Data Length = %d\\r\\n", res);
  116.                    switch(dbuf[0])
  117.                    {
  118.                         /* 字符命令 1 */
  119.                        case '1':
  120.                             sendbuf[0] = '1';
  121.                             sendbuf[1] = '2';
  122.                             sendbuf[2] = '3';
  123.                             sendbuf[3] = '4';
  124.                             sendbuf[4] = '5';
  125.                             sendbuf[5] = '6';
  126.                             sendbuf[6] = '7';
  127.                             sendbuf[7] = '8';
  128.                             sendbuf[8] = '\\r';
  129.                             sendbuf[9] = '\\n';                       
  130.                             res = send (sock, (char *)sendbuf, 10, 0);
  131.                             if (res < 0)
  132.                             {
  133.                                  printf_debug("函数send发送数据失败\\r\\n");
  134.                             }
  135.                             else
  136.                             {
  137.                                  printf_debug("函数send发送数据成功\\r\\n");                                
  138.                             }
  139.                             break;
  140.                      
  141.                         /* 字符命令 2 */
  142.                        case '2':
  143.                             /* 将数据缓冲区清成字符0,方便网络调试助手查看数据 */
  144.                             len = sizeof(sendbuf);
  145.                             memset(sendbuf, 48, len);
  146.                      
  147.                             /* 这里仅初始化了数据包的前4个字节和最后4个字节 */
  148.                             sendbuf[0] = 'a';
  149.                             sendbuf[1] = 'b';
  150.                             sendbuf[2] = 'c';
  151.                             sendbuf[3] = 'd';
  152.                             sendbuf[len - 4] = 'e';
  153.                             sendbuf[len - 3] = 'f';
  154.                             sendbuf[len - 2] = 'g';
  155.                             sendbuf[len - 1] = 'h';                  
  156.                             res = send (sock, (char *)sendbuf, len, 0);
  157.                             if (res < 0)
  158.                             {
  159.                                  printf_debug("函数send发送数据失败%s\\r\\n", ReVal_Table[abs(res)]);
  160.                             }
  161.                             else
  162.                             {
  163.                                  printf_debug("函数send成功发送数据 = %d字节\\r\\n", res);                                
  164.                             }
  165.                             break;
  166.                   
  167.                        /* 其它数值不做处理 */
  168.                        default:                    
  169.                             break;
  170.                    }
  171.               }
  172.          }
  173.         
  174.           /*
  175.             溢出时间到,远程设备断开连接等,程序都会执行到这里,我们在这里关闭socket,
  176.             程序返回到第一个大while循环的开头重新创建socket并监听。
  177.          */
  178.          closesocket (sock);
  179.      }
  180. }
复制代码


努力打造安富莱高质量微信公众号:点击扫描图片关注
回复

使用道具 举报

740

主题

1326

回帖

3546

积分

管理员

春暖花开

Rank: 9Rank: 9Rank: 9

积分
3546
QQ
 楼主| 发表于 2017-11-22 15:11:42 | 显示全部楼层
26.7.2 STM32F429开发板实验


配套例子:
    V6-1033_RL-TCPnet实验_DHCP应用(RTX)
实验目的:
    1.     学习RL-TCPnet的DHCP应用。
实验内容:
    1.      DHCP已经使能,如果插上网线8秒内无法从路由器/交换机获得IP地址,将使用固定IP:192.168.1.100。此固定IP是在配置向导文件Net_Config.c里面设置的。
    2.      本例程创建了一个socket服务器,采用TCP通信协议,而且使能了局域网域名NetBIOS,用户只需在电脑端ping armfly就可以获得板子的IP地址,本地端口被设置为1024。
    3.      用户可以在电脑端用网络调试软件创建TCP Client连接此服务器。
    4.      网络调试助手发送命令字符1,板子回复字符1到8以及回车和换行两个字符,共10个。
    5.      网络调试助手发送命令字符2,板子回复1024个字符,前4个字符是abcd,最后4个字符是efgh,中间的1016个全部是字符0。
实验操作:
    详见本章节26.6小节。
配置向导文件设置(Net_Config.c):
    详见本章节26.3小节。
调试文件设置(Net_Debug.c):
    详见本章节26.4小节。
RTX配置:
        RTX配置向导详情如下:
26.15.png

Task Configuration
(1)Number of concurrent running tasks
        允许创建7个任务,实际创建了如下6个任务:
        AppTaskUserIF任务   :按键消息处理。
        AppTaskLED任务     :LED闪烁。
        AppTaskMsgPro任务 :按键检测。
        AppTaskSocket任务  :socket服务器任务
        AppTaskTCPMain任务:RL-TCPnet网络主任务。
        AppTaskStart任务  :启动任务,也是最高优先级任务,这里实现RL-TCPnet的时间基准更新。
(2)Number of tasks with user-provided stack
        创建的6个任务都是采用自定义堆栈方式。
(3)Run in privileged mode
         设置任务运行在非特权级模式。
RTX任务调试信息:
26.16.png

程序设计:
任务栈大小分配:
    static uint64_t AppTaskUserIFStk[1024/8];   /* 任务栈 */
    static uint64_t AppTaskLEDStk[1024/8];      /* 任务栈 */
    static uint64_t AppTaskMsgProStk[1024/8];  /* 任务栈 */
    static uint64_t AppTaskSocketStk[2048/8];   /* 任务栈 */
    static uint64_t AppTaskTCPMainStk[2048/8]; /* 任务栈 */
    static uint64_t AppTaskStartStk[1024/8];     /* 任务栈 */
    将任务栈定义成uint64_t类型可以保证任务栈是8字节对齐的,8字节对齐的含义就是数组的首地址对8求余等于0。如果不做8字节对齐的话,部分C语言库函数、浮点运算和uint64_t类型数据运算会出问题。
系统栈大小分配:
26.17.png

RTX初始化:
  1. [size=3][b]/*[/b][/size]
  2. [size=3][b]*********************************************************************************************************[/b][/size]
  3. [size=3][b]* 函 数 名: main[/b][/size]
  4. [size=3][b]* 功能说明: 标准c程序入口。[/b][/size]
  5. [size=3][b]* 形 参: 无[/b][/size]
  6. [size=3][b]* 返 回 值: 无[/b][/size]
  7. [size=3][b]*********************************************************************************************************[/b][/size]
  8. [size=3][b]*/[/b][/size]
  9. [size=3][b]int main (void)[/b][/size]
  10. [size=3][b]{[/b][/size]
  11. [size=3][b]/* 初始化外设 */[/b][/size]
  12. [size=3][b]bsp_Init();[/b][/size]
  13. [size=3][b]/* 创建启动任务 */[/b][/size]
  14. [size=3][b]os_sys_init_user (AppTaskStart, /* 任务函数 */[/b][/size]
  15. [size=3][b]6, /* 任务优先级 */[/b][/size]
  16. [size=3][b]&AppTaskStartStk, /* 任务栈 */[/b][/size]
  17. [size=3][b]sizeof(AppTaskStartStk)); /* 任务栈大小,单位字节数 */[/b][/size]
  18. [size=3][b]while(1);[/b][/size]
  19. [size=3][b]}[/b][/size]
复制代码

硬件外设初始化
    硬件外设的初始化是在 bsp.c 文件实现:
  1. [size=3]/*[/size]
  2. [size=3]*********************************************************************************************************[/size]
  3. [size=3]* 函 数 名: bsp_Init[/size]
  4. [size=3]* 功能说明: 初始化所有的硬件设备。该函数配置CPU寄存器和外设的寄存器并初始化一些全局变量。只需要调用一次[/size]
  5. [size=3]* 形 参:无[/size]
  6. [size=3]* 返 回 值: 无[/size]
  7. [size=3]*********************************************************************************************************[/size]
  8. [size=3]*/[/size]
  9. [size=3]void bsp_Init(void)[/size]
  10. [size=3]{[/size]
  11. [size=3]/*[/size]
  12. [size=3]由于ST固件库的启动文件已经执行了CPU系统时钟的初始化,所以不必再次重复配置系统时钟。[/size]
  13. [size=3]启动文件配置了CPU主时钟频率、内部Flash访问速度和可选的外部SRAM FSMC初始化。[/size]
  14. [size=3]系统时钟缺省配置为168MHz,如果需要更改,可以修改 system_stm32f4xx.c 文件[/size]
  15. [size=3]*/[/size]
  16. [size=3]/* 优先级分组设置为4,可配置0-15级抢占式优先级,0级子优先级,即不存在子优先级。*/[/size]
  17. [size=3]NVIC_PriorityGroupConfig(NVIC_PriorityGroup_4);[/size]
  18. [size=3]SystemCoreClockUpdate(); /* 根据PLL配置更新系统时钟频率变量 SystemCoreClock */[/size]
  19. [size=3]bsp_InitDWT(); /* 初始化DWT */[/size]
  20. [size=3]bsp_InitUart(); /* 初始化串口 */[/size]
  21. [size=3]bsp_InitKey(); /* 初始化按键变量(必须在 bsp_InitTimer() 之前调用) */[/size]
  22. [size=3]bsp_InitExtIO(); /* FMC总线上扩展了32位输出IO, 操作LED等外设必须初始化 */[/size]
  23. [size=3]bsp_InitLed(); /* 初始LED指示灯端口 */[/size]
  24. [size=3]}[/size]
复制代码

RTX任务创建:
  1. [size=3][b]/*[/b][/size]
  2. [size=3][b]*********************************************************************************************************[/b][/size]
  3. [size=3][b]* 函 数 名: AppTaskCreate[/b][/size]
  4. [size=3][b]* 功能说明: 创建应用任务[/b][/size]
  5. [size=3][b]* 形 参: 无[/b][/size]
  6. [size=3][b]* 返 回 值: 无[/b][/size]
  7. [size=3][b]*********************************************************************************************************[/b][/size]
  8. [size=3][b]*/[/b][/size]
  9. [size=3][b]static void AppTaskCreate (void)[/b][/size]
  10. [size=3][b]{[/b][/size]
  11. [size=3][b]HandleTaskUserIF = os_tsk_create_user(AppTaskUserIF, /* 任务函数 */[/b][/size]
  12. [size=3][b]1, /* 任务优先级 */[/b][/size]
  13. [size=3][b]&AppTaskUserIFStk, /* 任务栈 */[/b][/size]
  14. [size=3][b]sizeof(AppTaskUserIFStk)); /* 任务栈大小,单位字节数 */[/b][/size]
  15. [size=3][b]HandleTaskLED = os_tsk_create_user(AppTaskLED, /* 任务函数 */[/b][/size]
  16. [size=3][b]2, /* 任务优先级 */[/b][/size]
  17. [size=3][b]&AppTaskLEDStk, /* 任务栈 */[/b][/size]
  18. [size=3][b]sizeof(AppTaskLEDStk)); /* 任务栈大小,单位字节数 */[/b][/size]
  19. [size=3][b]HandleTaskMsgPro = os_tsk_create_user(AppTaskMsgPro, /* 任务函数 */[/b][/size]
  20. [size=3][b]3, /* 任务优先级 */[/b][/size]
  21. [size=3][b]&AppTaskMsgProStk, /* 任务栈 */[/b][/size]
  22. [size=3][b]sizeof(AppTaskMsgProStk)); /* 任务栈大小,单位字节数 */[/b][/size]
  23. [size=3][b]HandleTaskSocket = os_tsk_create_user(AppTaskSocket, /* 任务函数 */[/b][/size]
  24. [size=3][b]4, /* 任务优先级 */[/b][/size]
  25. [size=3][b]&AppTaskSocketStk, /* 任务栈 */[/b][/size]
  26. [size=3][b]sizeof(AppTaskSocketStk)); /* 任务栈大小,单位字节数 */[/b][/size]
  27. [size=3][b]HandleTaskTCPMain = os_tsk_create_user(AppTaskTCPMain, /* 任务函数 */[/b][/size]
  28. [size=3][b]5, /* 任务优先级 */[/b][/size]
  29. [size=3][b]&AppTaskTCPMainStk, /* 任务栈 */[/b][/size]
  30. [size=3][b]sizeof(AppTaskTCPMainStk)); /* 任务栈大小,单位字节数 */[/b][/size]
  31. [size=3][b]}[/b][/size]
复制代码

六个RTX任务的实现:
  1. [size=3][b]/*[/b][/size]
  2. [size=3][b]*********************************************************************************************************[/b][/size]
  3. [size=3][b]* 函 数 名: AppTaskUserIF[/b][/size]
  4. [size=3][b]* 功能说明: 按键消息处理[/b][/size]
  5. [size=3][b]* 形 参: 无[/b][/size]
  6. [size=3][b]* 返 回 值: 无[/b][/size]
  7. [size=3][b]* 优 先 级: 1 (数值越小优先级越低,这个跟uCOS相反)[/b][/size]
  8. [size=3][b]*********************************************************************************************************[/b][/size]
  9. [size=3][b]*/[/b][/size]
  10. [size=3][b]__task void AppTaskUserIF(void)[/b][/size]
  11. [size=3][b]{[/b][/size]
  12. [size=3][b]uint8_t ucKeyCode;[/b][/size]
  13. [size=3][b]while(1)[/b][/size]
  14. [size=3][b]{[/b][/size]
  15. [size=3][b]ucKeyCode = bsp_GetKey();[/b][/size]
  16. [size=3][b]if (ucKeyCode != KEY_NONE)[/b][/size]
  17. [size=3][b]{[/b][/size]
  18. [size=3][b]switch (ucKeyCode)[/b][/size]
  19. [size=3][b]{[/b][/size]
  20. [size=3][b]/* K1键按下 */[/b][/size]
  21. [size=3][b]case KEY_DOWN_K1:[/b][/size]
  22. [size=3][b]printf("K1键按下\\r\\n");[/b][/size]
  23. [size=3][b]break;[/b][/size]
  24. [size=3][b]/* K2键按下 */[/b][/size]
  25. [size=3][b]case KEY_DOWN_K2:[/b][/size]
  26. [size=3][b]printf("K2键按下\\r\\n");[/b][/size]
  27. [size=3][b]break;[/b][/size]
  28. [size=3][b]/* K3键按下 */[/b][/size]
  29. [size=3][b]case KEY_DOWN_K3:[/b][/size]
  30. [size=3][b]printf("K3键按下\\r\\n");[/b][/size]
  31. [size=3][b]break;[/b][/size]
  32. [size=3][b]/* 其他的键值不处理 */[/b][/size]
  33. [size=3][b]default:[/b][/size]
  34. [size=3][b]break;[/b][/size]
  35. [size=3][b]}[/b][/size]
  36. [size=3][b]}[/b][/size]
  37. [size=3][b]os_dly_wait(20);[/b][/size]
  38. [size=3][b]}[/b][/size]
  39. [size=3][b]}[/b][/size]
  40. [size=3][b]/*[/b][/size]
  41. [size=3][b]*********************************************************************************************************[/b][/size]
  42. [size=3][b]* 函 数 名: AppTaskLED[/b][/size]
  43. [size=3][b]* 功能说明: LED闪烁。[/b][/size]
  44. [size=3][b]* 形 参: 无[/b][/size]
  45. [size=3][b]* 返 回 值: 无[/b][/size]
  46. [size=3][b]* 优 先 级: 2[/b][/size]
  47. [size=3][b]*********************************************************************************************************[/b][/size]
  48. [size=3][b]*/[/b][/size]
  49. [size=3][b]__task void AppTaskLED(void)[/b][/size]
  50. [size=3][b]{[/b][/size]
  51. [size=3][b]const uint16_t usFrequency = 500; /* 延迟周期 */[/b][/size]
  52. [size=3][b]/* 设置延迟周期 */[/b][/size]
  53. [size=3][b]os_itv_set(usFrequency);[/b][/size]
  54. [size=3][b]while(1)[/b][/size]
  55. [size=3][b]{[/b][/size]
  56. [size=3][b]bsp_LedToggle(2);[/b][/size]
  57. [size=3][b]/* os_itv_wait是绝对延迟,os_dly_wait是相对延迟。*/[/b][/size]
  58. [size=3][b]os_itv_wait();[/b][/size]
  59. [size=3][b]}[/b][/size]
  60. [size=3][b]}[/b][/size]
  61. [size=3][b]/*[/b][/size]
  62. [size=3][b]*********************************************************************************************************[/b][/size]
  63. [size=3][b]* 函 数 名: AppTaskMsgPro[/b][/size]
  64. [size=3][b]* 功能说明: 按键检测[/b][/size]
  65. [size=3][b]* 形 参: 无[/b][/size]
  66. [size=3][b]* 返 回 值: 无[/b][/size]
  67. [size=3][b]* 优 先 级: 3[/b][/size]
  68. [size=3][b]*********************************************************************************************************[/b][/size]
  69. [size=3][b]*/[/b][/size]
  70. [size=3][b]__task void AppTaskMsgPro(void)[/b][/size]
  71. [size=3][b]{[/b][/size]
  72. [size=3][b]while(1)[/b][/size]
  73. [size=3][b]{[/b][/size]
  74. [size=3][b]bsp_KeyScan();[/b][/size]
  75. [size=3][b]os_dly_wait(10);[/b][/size]
  76. [size=3][b]}[/b][/size]
  77. [size=3][b]}[/b][/size]
  78. [size=3][b]/*[/b][/size]
  79. [size=3][b]*********************************************************************************************************[/b][/size]
  80. [size=3][b]* 函 数 名: AppTaskSocket[/b][/size]
  81. [size=3][b]* 功能说明: RL-TCPnet测试任务[/b][/size]
  82. [size=3][b]* 形 参: 无[/b][/size]
  83. [size=3][b]* 返 回 值: 无[/b][/size]
  84. [size=3][b]* 优 先 级: 4[/b][/size]
  85. [size=3][b]*********************************************************************************************************[/b][/size]
  86. [size=3][b]*/[/b][/size]
  87. [size=3][b]__task void AppTaskSocket(void)[/b][/size]
  88. [size=3][b]{[/b][/size]
  89. [size=3][b]while (1)[/b][/size]
  90. [size=3][b]{[/b][/size]
  91. [size=3][b]SocketTest();[/b][/size]
  92. [size=3][b]}[/b][/size]
  93. [size=3][b]}[/b][/size]
  94. [size=3][b]/*[/b][/size]
  95. [size=3][b]*********************************************************************************************************[/b][/size]
  96. [size=3][b]* 函 数 名: AppTaskTCPMain[/b][/size]
  97. [size=3][b]* 功能说明: RL-TCPnet网络主任务[/b][/size]
  98. [size=3][b]* 形 参: 无[/b][/size]
  99. [size=3][b]* 返 回 值: 无[/b][/size]
  100. [size=3][b]* 优 先 级: 5[/b][/size]
  101. [size=3][b]*********************************************************************************************************[/b][/size]
  102. [size=3][b]*/[/b][/size]
  103. [size=3][b]__task void AppTaskTCPMain(void)[/b][/size]
  104. [size=3][b]{[/b][/size]
  105. [size=3][b]while (1)[/b][/size]
  106. [size=3][b]{[/b][/size]
  107. [size=3][b]TCPnetTest();[/b][/size]
  108. [size=3][b]}[/b][/size]
  109. [size=3][b]}[/b][/size]
  110. [size=3][b]/*[/b][/size]
  111. [size=3][b]*********************************************************************************************************[/b][/size]
  112. [size=3][b]* 函 数 名: AppTaskStart[/b][/size]
  113. [size=3][b]* 功能说明: 启动任务,也是最高优先级任务,这里实现RL-TCPnet的时间基准更新。[/b][/size]
  114. [size=3][b]* 形 参: 无[/b][/size]
  115. [size=3][b]* 返 回 值: 无[/b][/size]
  116. [size=3][b]* 优 先 级: 6[/b][/size]
  117. [size=3][b]*********************************************************************************************************[/b][/size]
  118. [size=3][b]*/[/b][/size]
  119. [size=3][b]__task void AppTaskStart(void)[/b][/size]
  120. [size=3][b]{[/b][/size]
  121. [size=3][b]/* 初始化RL-TCPnet */[/b][/size]
  122. [size=3][b]init_TcpNet ();[/b][/size]
  123. [size=3][b]/* 创建任务 */[/b][/size]
  124. [size=3][b]AppTaskCreate();[/b][/size]
  125. [size=3][b]os_itv_set (100);[/b][/size]
  126. [size=3][b]while(1)[/b][/size]
  127. [size=3][b]{[/b][/size]
  128. [size=3][b]os_itv_wait ();[/b][/size]
  129. [size=3][b]/* RL-TCPnet时间基准更新函数 */[/b][/size]
  130. [size=3][b]timer_tick ();[/b][/size]
  131. [size=3][b]}[/b][/size]
  132. [size=3][b]}[/b][/size]
复制代码

RL-TCPnet网络主任务
    这里专门创建了一个app_tcpnet_lib.c文件用于RL-TCPnet的网络主任务,实现动态IP获取和网络协议栈主函数main_TcpNet的调用。
  1. [size=3]#include "includes.h"[/size]
  2. [size=3]/*[/size]
  3. [size=3]*********************************************************************************************************[/size]
  4. [size=3]* 用于本文件的调试[/size]
  5. [size=3]*********************************************************************************************************[/size]
  6. [size=3]*/[/size]
  7. [size=3]#if 1[/size]
  8. [size=3]#define printf_tcpdbg printf[/size]
  9. [size=3]#else[/size]
  10. [size=3]#define printf_tcpdbg(...)[/size]
  11. [size=3]#endif[/size]
  12. [size=3]/*[/size]
  13. [size=3]**********************************************************************************************************[/size]
  14. [size=3]外部调用[/size]
  15. [size=3]**********************************************************************************************************[/size]
  16. [size=3]*/[/size]
  17. [size=3]#define DHCP_TOUT 80 /* DHCP动态IP获取的溢出时间设置为8秒 */[/size]
  18. [size=3]#define MY_IP localm[NETIF_ETH].IpAdr[/size]
  19. [size=3]extern LOCALM localm[];[/size]
  20. [size=3]/*[/size]
  21. [size=3]**********************************************************************************************************[/size]
  22. [size=3]变量[/size]
  23. [size=3]**********************************************************************************************************[/size]
  24. [size=3]*/[/size]
  25. [size=3]uint32_t dhcp_tout;[/size]
  26. [size=3]uint8_t DHCP_Status[2][40] = {"IP: 192.168.X.X",[/size]
  27. [size=3]"Waiting for DHCP"};[/size]
  28. [size=3]/*[/size]
  29. [size=3]*********************************************************************************************************[/size]
  30. [size=3]* 函 数 名: main[/size]
  31. [size=3]* 功能说明: 标准c程序入口。[/size]
  32. [size=3]* 形 参: 无[/size]
  33. [size=3]* 返 回 值: 无[/size]
  34. [size=3]*********************************************************************************************************[/size]
  35. [size=3]*/[/size]
  36. [size=3]static void dhcp_check(void)[/size]
  37. [size=3]{[/size]
  38. [size=3]/* 检测是否通过DHCP自动获得IP */[/size]
  39. [size=3]if (mem_test (&MY_IP, 0, IP_ADRLEN) == __FALSE && !(dhcp_tout & 0x80000000))[/size]
  40. [size=3]{[/size]
  41. [size=3]/* 已经获得IP */[/size]
  42. [size=3]dhcp_tout = 0;[/size]
  43. [size=3]sprintf((char *)DHCP_Status[0],"%d.%d.%d.%d", MY_IP[0], MY_IP[1],[/size]
  44. [size=3]MY_IP[2], MY_IP[3]);[/size]
  45. [size=3]sprintf((char *)DHCP_Status[1],"DHCP Success");[/size]
  46. [size=3]printf_tcpdbg("%s\\r\\n", DHCP_Status[0]);[/size]
  47. [size=3]printf_tcpdbg("%s\\r\\n", DHCP_Status[1]);[/size]
  48. [size=3]return;[/size]
  49. [size=3]}[/size]
  50. [size=3]/* 每100ms进行一次减减操作 */[/size]
  51. [size=3]if (--dhcp_tout == 0)[/size]
  52. [size=3]{[/size]
  53. [size=3]/* 设置的8秒自动获取IP时间已经到了,禁止DHCP,准备使用固定IP */[/size]
  54. [size=3]dhcp_disable ();[/size]
  55. [size=3]sprintf((char *)DHCP_Status[1],"DHCP Failed" );[/size]
  56. [size=3]/* 更新溢出时间,将固定IP的分配时间也设置为8秒 */[/size]
  57. [size=3]dhcp_tout = 80 | 0x80000000;[/size]
  58. [size=3]return;[/size]
  59. [size=3]}[/size]
  60. [size=3]/* 设置固定IP的8秒时间到 */[/size]
  61. [size=3]if (dhcp_tout == 0x80000000)[/size]
  62. [size=3]{[/size]
  63. [size=3]dhcp_tout = 0;[/size]
  64. [size=3]sprintf((char *)DHCP_Status[0],"%d.%d.%d.%d", MY_IP[0], MY_IP[1],[/size]
  65. [size=3]MY_IP[2], MY_IP[3]);[/size]
  66. [size=3]sprintf((char *)DHCP_Status[1],"DHCP Failed Use static IP");[/size]
  67. [size=3]printf_tcpdbg("%s\\r\\n", DHCP_Status[0]);[/size]
  68. [size=3]printf_tcpdbg("%s\\r\\n", DHCP_Status[1]);[/size]
  69. [size=3]}[/size]
  70. [size=3]}[/size]
  71. [size=3]/*[/size]
  72. [size=3]*********************************************************************************************************[/size]
  73. [size=3]* 函 数 名: TCPnetTest[/size]
  74. [size=3]* 功能说明: 主要实现动态IP获取和网络协议栈主函数main_TcpNet的调用。[/size]
  75. [size=3]* 形 参: 无[/size]
  76. [size=3]* 返 回 值: 无[/size]
  77. [size=3]*********************************************************************************************************[/size]
  78. [size=3]*/[/size]
  79. [size=3]void TCPnetTest(void)[/size]
  80. [size=3]{[/size]
  81. [size=3]uint32_t tstart, tend;[/size]
  82. [size=3]/* 初始化变量 */[/size]
  83. [size=3]dhcp_tout = DHCP_TOUT;[/size]
  84. [size=3]tstart = os_time_get();[/size]
  85. [size=3]while (1)[/size]
  86. [size=3]{[/size]
  87. [size=3]/* 每100ms做一次DHCP检测 */[/size]
  88. [size=3]if(dhcp_tout != 0)[/size]
  89. [size=3]{[/size]
  90. [size=3]tend = os_time_get() - tstart;[/size]
  91. [size=3]//printf_tcpdbg("%x %d\\r\\n", dhcp_tout, tend);[/size]
  92. [size=3]if(tend >= 100)[/size]
  93. [size=3]{[/size]
  94. [size=3]tstart = os_time_get();[/size]
  95. [size=3]dhcp_check();[/size]
  96. [size=3]}[/size]
  97. [size=3]}[/size]
  98. [size=3]os_evt_wait_and(0x0001, 0xFFFF);[/size]
  99. [size=3]while (main_TcpNet() == __TRUE);[/size]
  100. [size=3]}[/size]
  101. [size=3]}[/size]
复制代码

Socket 服务器任务
    这里专门创建了一个app_socket_lib.c文件用于socket服务器任务。
  1. [size=3]#include "includes.h"[/size]
  2. [size=3]/*[/size]
  3. [size=3]*********************************************************************************************************[/size]
  4. [size=3]* 用于本文件的调试[/size]
  5. [size=3]*********************************************************************************************************[/size]
  6. [size=3]*/[/size]
  7. [size=3]#if 1[/size]
  8. [size=3]#define printf_debug printf[/size]
  9. [size=3]#else[/size]
  10. [size=3]#define printf_debug(...)[/size]
  11. [size=3]#endif[/size]
  12. [size=3]/*[/size]
  13. [size=3]*********************************************************************************************************[/size]
  14. [size=3]* 宏定义,本地端口[/size]
  15. [size=3]*********************************************************************************************************[/size]
  16. [size=3]*/[/size]
  17. [size=3]/* 这个是本地端口 */[/size]
  18. [size=3]#define LocalPort_NUM 1001[/size]
  19. [size=3]/*[/size]
  20. [size=3]*********************************************************************************************************[/size]
  21. [size=3]* 变量[/size]
  22. [size=3]*********************************************************************************************************[/size]
  23. [size=3]*/[/size]
  24. [size=3]/* RL-TCPnet API的返回值 */[/size]
  25. [size=3]const char * ReVal_Table[]=[/size]
  26. [size=3]{[/size]
  27. [size=3]" 0: SCK_SUCCESS Success ",[/size]
  28. [size=3]"-1: SCK_ERROR General Error ",[/size]
  29. [size=3]"-2: SCK_EINVALID Invalid socket descriptor ",[/size]
  30. [size=3]"-3: SCK_EINVALIDPARA Invalid parameter ",[/size]
  31. [size=3]"-4: SCK_EWOULDBLOCK It would have blocked. ",[/size]
  32. [size=3]"-5: SCK_EMEMNOTAVAIL Not enough memory in memory pool ",[/size]
  33. [size=3]"-6: SCK_ECLOSED Connection is closed or aborted ",[/size]
  34. [size=3]"-7: SCK_ELOCKED Socket is locked in RTX environment ",[/size]
  35. [size=3]"-8: SCK_ETIMEOUT Socket, Host Resolver timeout ",[/size]
  36. [size=3]"-9: SCK_EINPROGRESS Host Name resolving in progress ",[/size]
  37. [size=3]"-10: SCK_ENONAME Host Name not existing ",[/size]
  38. [size=3]};[/size]
  39. [size=3]uint8_t sendbuf[1024];[/size]
  40. [size=3]/*[/size]
  41. [size=3]*********************************************************************************************************[/size]
  42. [size=3]* 函 数 名: SocketTest[/size]
  43. [size=3]* 功能说明: Socket应用[/size]
  44. [size=3]* 形 参: 无[/size]
  45. [size=3]* 返 回 值: 无[/size]
  46. [size=3]*********************************************************************************************************[/size]
  47. [size=3]*/[/size]
  48. [size=3]void SocketTest(void)[/size]
  49. [size=3]{[/size]
  50. [size=3]char dbuf[10];[/size]
  51. [size=3]int len;[/size]
  52. [size=3]int sock, sd, res;[/size]
  53. [size=3]SOCKADDR_IN addr;[/size]
  54. [size=3]SOCKADDR_IN ReAddr;[/size]
  55. [size=3]while (1)[/size]
  56. [size=3]{[/size]
  57. [size=3]/* 创建一个socket[/size]
  58. [size=3]第1个参数AF_INET:当前仅支持这个类型的地址族。[/size]
  59. [size=3]第2个参数SOCK_STREAM:表示数据流通信类型,即使用的TCP。[/size]
  60. [size=3]第3个参数0 :配置为0的话,自动跟第2个参数进行协议匹配,这里就是TCP协议。[/size]
  61. [size=3]*/[/size]
  62. [size=3]sock = socket (AF_INET, SOCK_STREAM, 0);[/size]
  63. [size=3]/* 端口号设置为1001 */[/size]
  64. [size=3]addr.sin_port = htons(LocalPort_NUM);[/size]
  65. [size=3]/* 与函数socket中的AF_INET作用一样 */[/size]
  66. [size=3]addr.sin_family = PF_INET;[/size]
  67. [size=3]/*[/size]
  68. [size=3]INADDR_ANY就是指定地址为0.0.0.0的地址,这个地址事实上表示不确定地址,或所有地址,[/size]
  69. [size=3]任意地址。用在这里的话就表示监控端口号为ddr.sin_port的所有IP地址消息。一般主要用[/size]
  70. [size=3]于有多个网卡或者IP地址的情况。开发板只用了DM9161的网口,就是监听这个网口的IP地址。[/size]
  71. [size=3]*/[/size]
  72. [size=3]addr.sin_addr.s_addr = INADDR_ANY;[/size]
  73. [size=3]/* 给socket绑定IP和端口号 */[/size]
  74. [size=3]bind (sock, (SOCKADDR *)&addr, sizeof(addr));[/size]
  75. [size=3]/* 设置监听,最大监听1个连接 */[/size]
  76. [size=3]listen (sock, 1);[/size]
  77. [size=3]/*[/size]
  78. [size=3]等待soket连接请求,有的话,自动创建1个新的socket进行连接通信,没有的话,等待连接。[/size]
  79. [size=3]注意,能够accept的个数受到listen函数的限制,而listen函数又受到Net_Config.c中宏定义[/size]
  80. [size=3]BSD_NUMSOCKS 的限制。[/size]
  81. [size=3]*/[/size]
  82. [size=3]len = sizeof(ReAddr);[/size]
  83. [size=3]sd = accept (sock, (SOCKADDR *)&ReAddr, &len);[/size]
  84. [size=3]printf_debug ("远程客户端请求连接IP: %d.%d.%d.%d\\n", ReAddr.sin_addr.s_b1,[/size]
  85. [size=3]ReAddr.sin_addr.s_b2,[/size]
  86. [size=3]ReAddr.sin_addr.s_b3,[/size]
  87. [size=3]ReAddr.sin_addr.s_b4);[/size]
  88. [size=3]printf_debug ("远程客户端端口号: %d\\n", ntohs(ReAddr.sin_port));[/size]
  89. [size=3]/* 关闭监听socket,这个监听socket是调用函数socket后自动创建的 */[/size]
  90. [size=3]closesocket (sock);[/size]
  91. [size=3]sock = sd;[/size]
  92. [size=3]while (1)[/size]
  93. [size=3]{[/size]
  94. [size=3]/*[/size]
  95. [size=3]socket数据接收函数,如果recv工作在阻塞模式,使用这个函数注意以下事项:[/size]
  96. [size=3]1. 此函数的溢出时间受到Net_Config.c中宏定义 BSD_RCVTOUT 的限制。溢出时间到会自动退出。[/size]
  97. [size=3]2. 这个函数接收到一次数据包就会返回,大于或者小于设置的缓冲区大小都没有关系,如果数据量[/size]
  98. [size=3]大于接收缓冲区大小,用户只需多次调用函数recv进行接收即可。[/size]
  99. [size=3]3. 实际接收到数据大小通过判断此函数的返回值即可。[/size]
  100. [size=3]*/[/size]
  101. [size=3]res = recv (sock, dbuf, sizeof(dbuf), 0);[/size]
  102. [size=3]if (res <= 0)[/size]
  103. [size=3]{[/size]
  104. [size=3]printf_debug("退出接收函数,重新开始监听%s\\r\\n", ReVal_Table[abs(res)]);[/size]
  105. [size=3]break;[/size]
  106. [size=3]}[/size]
  107. [size=3]else[/size]
  108. [size=3]{[/size]
  109. [size=3]printf_debug("Receive Data Length = %d\\r\\n", res);[/size]
  110. [size=3]switch(dbuf[0])[/size]
  111. [size=3]{[/size]
  112. [size=3]/* 字符命令 1 */[/size]
  113. [size=3]case '1':[/size]
  114. [size=3]sendbuf[0] = '1';[/size]
  115. [size=3]sendbuf[1] = '2';[/size]
  116. [size=3]sendbuf[2] = '3';[/size]
  117. [size=3]sendbuf[3] = '4';[/size]
  118. [size=3]sendbuf[4] = '5';[/size]
  119. [size=3]sendbuf[5] = '6';[/size]
  120. [size=3]sendbuf[6] = '7';[/size]
  121. [size=3]sendbuf[7] = '8';[/size]
  122. [size=3]sendbuf[8] = '\\r';[/size]
  123. [size=3]sendbuf[9] = '\\n';[/size]
  124. [size=3]res = send (sock, (char *)sendbuf, 10, 0);[/size]
  125. [size=3]if (res < 0)[/size]
  126. [size=3]{[/size]
  127. [size=3]printf_debug("函数send发送数据失败\\r\\n");[/size]
  128. [size=3]}[/size]
  129. [size=3]else[/size]
  130. [size=3]{[/size]
  131. [size=3]printf_debug("函数send发送数据成功\\r\\n");[/size]
  132. [size=3]}[/size]
  133. [size=3]break;[/size]
  134. [size=3]/* 字符命令 2 */[/size]
  135. [size=3]case '2':[/size]
  136. [size=3]/* 将数据缓冲区清成字符0,方便网络调试助手查看数据 */[/size]
  137. [size=3]len = sizeof(sendbuf);[/size]
  138. [size=3]memset(sendbuf, 48, len);[/size]
  139. [size=3]/* 这里仅初始化了数据包的前4个字节和最后4个字节 */[/size]
  140. [size=3]sendbuf[0] = 'a';[/size]
  141. [size=3]sendbuf[1] = 'b';[/size]
  142. [size=3]sendbuf[2] = 'c';[/size]
  143. [size=3]sendbuf[3] = 'd';[/size]
  144. [size=3]sendbuf[len - 4] = 'e';[/size]
  145. [size=3]sendbuf[len - 3] = 'f';[/size]
  146. [size=3]sendbuf[len - 2] = 'g';[/size]
  147. [size=3]sendbuf[len - 1] = 'h';[/size]
  148. [size=3]res = send (sock, (char *)sendbuf, len, 0);[/size]
  149. [size=3]if (res < 0)[/size]
  150. [size=3]{[/size]
  151. [size=3]printf_debug("函数send发送数据失败%s\\r\\n", ReVal_Table[abs(res)]);[/size]
  152. [size=3]}[/size]
  153. [size=3]else[/size]
  154. [size=3]{[/size]
  155. [size=3]printf_debug("函数send成功发送数据 = %d字节\\r\\n", res);[/size]
  156. [size=3]}[/size]
  157. [size=3]break;[/size]
  158. [size=3]/* 其它数值不做处理 */[/size]
  159. [size=3]default:[/size]
  160. [size=3]break;[/size]
  161. [size=3]}[/size]
  162. [size=3]}[/size]
  163. [size=3]}[/size]
  164. [size=3]/*[/size]
  165. [size=3]溢出时间到,远程设备断开连接等,程序都会执行到这里,我们在这里关闭socket,[/size]
  166. [size=3]程序返回到第一个大while循环的开头重新创建socket并监听。[/size]
  167. [size=3]*/[/size]
  168. [size=3]closesocket (sock);[/size]
  169. [size=3]}[/size]
  170. [size=3]}[/size]
复制代码
努力打造安富莱高质量微信公众号:点击扫描图片关注
回复

使用道具 举报

您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

QQ|小黑屋|Archiver|手机版|硬汉嵌入式论坛

GMT+8, 2024-5-17 03:00 , Processed in 0.270133 second(s), 37 queries .

Powered by Discuz! X3.4 Licensed

Copyright © 2001-2023, Tencent Cloud.

快速回复 返回顶部 返回列表