第13章 RL-TCPnet之TCP服务器

STM32

转最新教程本章节为大家讲解RL-TCPnet的TCP服务器实现，学习本章节前，务必要优先学习第12章TCP传输控制协议基础知识。有了这些基础知识之后，再搞本章节会有事半功倍的效果。
      本章教程含STM32F407开发板和STM32F429开发板。
      13.1 初学者重要提示
      13.2 TCP服务器API函数
      13.3 TCP配置说明（Net_Config.c）
      13.4 TCP调试说明（Net_Debug.c）
      13.5 TCP服务器的实现方法
      13.6 网络调试助手和板子的调试操作步骤
      13.7 实验例程说明（裸机）
      13.8 实验例程说明（RTX）
      13.9    总结

lee_st · 2017-11-11 14:51:40

RTX任务创建：
/*
*********************************************************************************************************
*    函数名: AppTaskCreate
*    功能说明: 创建应用任务
*    形    参: 无
*    返回值: 无
*********************************************************************************************************
*/
static void AppTaskCreate (void)
{
     HandleTaskUserIF = os_tsk_create_user(AppTaskUserIF,             /* 任务函数 */
                                           1,                         /* 任务优先级 */
                                           &AppTaskUserIFStk,         /* 任务栈 */
                                           sizeof(AppTaskUserIFStk)); /* 任务栈大小，单位字节数 */

     HandleTaskLED = os_tsk_create_user(AppTaskLED,              /* 任务函数 */
                                        2,                       /* 任务优先级 */
                                        &AppTaskLEDStk,          /* 任务栈 */
                                        sizeof(AppTaskLEDStk));  /* 任务栈大小，单位字节数 */

     HandleTaskMsgPro = os_tsk_create_user(AppTaskMsgPro,             /* 任务函数 */
                                           3,                         /* 任务优先级 */
                                           &AppTaskMsgProStk,         /* 任务栈 */
                                           sizeof(AppTaskMsgProStk)); /* 任务栈大小，单位字节数 */

    HandleTaskTCPMain = os_tsk_create_user(AppTaskTCPMain,             /* 任务函数 */
                                           4,                         /* 任务优先级 */
                                           &AppTaskTCPMainStk,         /* 任务栈 */
                                           sizeof(AppTaskTCPMainStk)); /* 任务栈大小，单位字节数 */
}

82^#

提示: 该帖被管理员或版主屏蔽

lee_st · 2017-11-11 14:52:20

RL-TCPnet功能测试
这里专门创建了一个app_tcpnet_lib.c文件用于RL-TCPnet功能的测试，主要功能是创建了一个TCP Server。
#include "includes.h"

/*
*********************************************************************************************************
*                                      用于本文件的调试
*********************************************************************************************************
*/
#if 1
     #define printf_debug printf
#else
     #define printf_debug(...)
#endif

/*
*********************************************************************************************************
*                                      用于本文件的调试
*********************************************************************************************************
*/
#define PORT_NUM       1001    /* TCP服务器监听端口号 */

/*
*********************************************************************************************************
*                                         变量
*********************************************************************************************************
*/
uint8_t socket_tcp;

/*
*********************************************************************************************************
*    函数名: tcp_callback
*    功能说明: TCP Socket的回调函数
*    形    参: soc  TCP Socket类型
*             evt  事件类型
*             ptr  事件类型是TCP_EVT_DATA，ptr指向的缓冲区记录着接收到的TCP数据，其余事件记录IP地址
*             par  事件类型是TCP_EVT_DATA，记录接收到的数据个数，其余事件记录端口号
*    返回值:
*********************************************************************************************************
*/
U16 tcp_callback (U8 soc, U8 evt, U8 *ptr, U16 par)
{
     char buf[50];
     uint16_t i;

     /* 确保是socket_tcp的回调 */
     if (soc != socket_tcp)
     {
         return (0);
     }

     switch (evt)
     {
         /*
              远程客户端连接消息
             1、数组ptr存储远程设备的IP地址，par中存储端口号。
             2、返回数值1允许连接，返回数值0禁止连接。
         */
         case TCP_EVT_CONREQ:
              sprintf(buf, "远程客户端请求连接IP: %d.%d.%d.%d", ptr[0], ptr[1], ptr[2], ptr[3]);
              printf_debug("IP:%s  port:%drn", buf, par);
              return (1);

          /* 连接终止 */
         case TCP_EVT_ABORT:
              break;

         /* Socket远程连接已经建立 */
         case TCP_EVT_CONNECT:
              printf_debug("Socket is connected to remote peerrn");
              break;

         /* 连接断开 */
         case TCP_EVT_CLOSE:
              printf_debug("Connection has been closedrn");
              break;

         /* 发送的数据收到远程设备应答 */
         case TCP_EVT_ACK:
              break;

         /* 接收到TCP数据帧，ptr指向数据地址，par记录数据长度，单位字节 */
         case TCP_EVT_DATA:
              printf_debug("Data length = %drn", par);
              for(i = 0; i < par; i++)
              {
                   printf_debug("ptr[%d] = %drn", i, ptr[i]);
              }
              break;
     }

     return (0);
}

/*
*********************************************************************************************************
*    函数名: TCP_StatusCheck
*    功能说明: 检测TCP的连接状态，主要用于网线插拔的判断
*    形    参: 无
*    返回值: __TRUE  连接
*             __FALSE 断开
*********************************************************************************************************
*/
uint8_t TCP_StatusCheck(void)
{
     uint8_t res;

     switch (tcp_get_state(socket_tcp))
     {
         case TCP_STATE_FREE:
         case TCP_STATE_CLOSED:
              res = tcp_listen (socket_tcp, PORT_NUM);
              printf_debug("tcp listen res = %drn", res);
              break;

         case TCP_STATE_LISTEN:
              break;

         case TCP_STATE_CONNECT:
              return (__TRUE);

         default:
              break;
     }

     return (__FALSE);
}

/*
*********************************************************************************************************
*    函数名: TCPnetTest
*    功能说明: TCPnet应用
*    形    参: 无
*    返回值: 无
*********************************************************************************************************
*/
void TCPnetTest(void)
{
     int32_t iCount;
     uint8_t *sendbuf;
     uint8_t tcp_status;
     uint16_t maxlen;
     uint8_t res;
     OS_RESULT xResult;
     const uint16_t usMaxBlockTime = 2; /* 延迟周期 */

     /*
        创建TCP Socket并创建监听，客户端连接服务器后，10秒内无数据通信将断开连接。
        但是由于这里使能了TCP_TYPE_KEEP_ALIVE，会一直保持连接，不受10秒的时间限制。
     */
    socket_tcp = tcp_get_socket (TCP_TYPE_SERVER|TCP_TYPE_KEEP_ALIVE, 0, 10, tcp_callback);
     if(socket_tcp != 0)
     {
         res = tcp_listen (socket_tcp, PORT_NUM);
         printf_debug("tcp listen res = %drn", res);
     }

     while (1)
     {
         /* RL-TCPnet处理函数 */
         main_TcpNet();

         /* 用于网线插拔的处理 */
         tcp_status = TCP_StatusCheck();

         /* 按键消息的处理 */
         if((os_evt_wait_or(0xFFFF, usMaxBlockTime) == OS_R_EVT)&&(tcp_status == __TRUE))
         {
              xResult = os_evt_get ();
              switch (xResult)
              {
                   /* 接收到K1键按下，给远程TCP客户端发送8字节数据 */
                   case KEY1_BIT0:
                       printf_debug("tcp_get_state(socket_tcp) = %drn", tcp_get_state(socket_tcp));
                       iCount = 8;
                       do
                       {
                            main_TcpNet();
                            if (tcp_check_send (socket_tcp) == __TRUE)
                            {
                                 maxlen = tcp_max_dsize (socket_tcp);
                                 iCount -= maxlen;

                                 if(iCount < 0)
                                 {
                                      /* 这么计算没问题的 */
                                     maxlen = iCount + maxlen;
                                 }

                                 sendbuf = tcp_get_buf(maxlen);
                                 sendbuf[0] = '1';
                                 sendbuf[1] = '2';
                                 sendbuf[2] = '3';
                                 sendbuf[3] = '4';
                                 sendbuf[4] = '5';
                                 sendbuf[5] = '6';
                                 sendbuf[6] = '7';
                                 sendbuf[7] = '8';

                                 /* 测试发现只能使用获取的内存 */
                                 tcp_send (socket_tcp, sendbuf, maxlen);
                            }

                       }while(iCount > 0);
                       break;

                   /* 接收到K2键按下，给远程TCP客户端发送1024字节的数据 */
                   case KEY2_BIT1:
                       printf_debug("tcp_get_state(socket_tcp) = %drn", tcp_get_state(socket_tcp));
                       iCount = 1024;
                       do
                       {
                            main_TcpNet();
                            if (tcp_check_send (socket_tcp) == __TRUE)
                            {
                                 maxlen = tcp_max_dsize (socket_tcp);
                                 iCount -= maxlen;

                                 if(iCount < 0)
                                 {
                                      /* 这么计算没问题的 */
                                     maxlen = iCount + maxlen;
                                 }

                                 /* 这里仅初始化了每次所发送数据包的前8个字节 */
                                 sendbuf = tcp_get_buf(maxlen);
                                 sendbuf[0] = 'a';
                                 sendbuf[1] = 'b';
                                 sendbuf[2] = 'c';
                                 sendbuf[3] = 'd';
                                 sendbuf[4] = 'e';
                                 sendbuf[5] = 'f';
                                 sendbuf[6] = 'g';
                                 sendbuf[7] = 'h';

                                 /* 测试发现只能使用获取的内存 */
                                 tcp_send (socket_tcp, sendbuf, maxlen);
                            }

                       }while(iCount > 0);
                        break;

                   /* 接收到K3键按下，给远程TCP客户端发送5MB数据 */
                   case KEY3_BIT2:
                       printf_debug("tcp_get_state(socket_tcp) = %drn", tcp_get_state(socket_tcp));
                       iCount = 5*1024*1024;
                       do
                       {
                            main_TcpNet();
                            if (tcp_check_send (socket_tcp) == __TRUE)
                            {
                                 maxlen = tcp_max_dsize (socket_tcp);
                                 iCount -= maxlen;

                                 if(iCount < 0)
                                 {
                                     /* 这么计算没问题的 */
                                      maxlen = iCount + maxlen;
                                 }

                                 /* 这里仅初始化了每次所发送数据包的前8个字节 */
                                 sendbuf = tcp_get_buf(maxlen);
                                 sendbuf[0] = 'a';
                                 sendbuf[1] = 'b';
                                 sendbuf[2] = 'c';
                                 sendbuf[3] = 'd';
                                 sendbuf[4] = 'e';
                                 sendbuf[5] = 'f';
                                 sendbuf[6] = 'g';
                                 sendbuf[7] = 'h';

                                 /* 测试发现只能使用获取的内存 */
                                 tcp_send (socket_tcp, sendbuf, maxlen);
                            }

                       }while(iCount > 0);
                       break;

                    /* 其他的键值不处理 */
                   default:
                       break;
              }
         }
     }
}

lee_st · 2017-11-11 14:52:36

3.8.2 STM32F429开发板实验

配套例子：
V6-1009_RL-TCPnet实验_TCP服务器（RTX）
实验目的：
1.    学习RL-TCPnet的TCP服务器创建和数据收发。
实验内容：
1.    强烈推荐将网线接到路由器或者交换机上面测试，因为已经使能了DHCP，可以自动获取IP地址。
2.    创建了一个TCP Server，而且使能了局域网域名NetBIOS，用户只需在电脑端ping armfly就可以获得板子的IP地址，端口号1001。
3.    用户可以在电脑端用网络调试软件创建TCP Client连接此服务器端。
4.    按键K1按下，发送8字节的数据给TCPClient。
5.    按键K2按下，发送1024字节的数据给TCPClient。
6.    按键K3按下，发送5MB字节的数据给TCPClient。
实验操作：
详见本章节13.6小节。
配置向导文件设置（Net_Config.c）：
详见本章节13.3小节。
调试文件设置（Net_Debug.c）：
详见本章节13.4小节。

lee_st · 2017-11-11 14:55:11

RTX配置：
RTX配置向导详情如下：

lee_st · 2017-11-11 14:56:31

u  Task Configuration
（1）Number of concurrent running tasks
允许创建6个任务，实际创建了如下5个任务：
AppTaskUserIF任务：按键消息处理。
AppTaskLED任务    ：LED闪烁。
AppTaskMsgPro任务：按键检测。
AppTaskTCPMain任务：RL-TCPnet测试任务。
AppTaskStart任务  ：启动任务，也是最高优先级任务，这里实现RL-TCPnet的时间基准更新。
（2）Number of tasks with user-provided stack
创建的5个任务都是采用自定义堆栈方式。
（3）Run in privileged mode
设置任务运行在非特权级模式。

lee_st · 2017-11-11 14:58:00

RTX任务调试信息：

lee_st · 2017-11-11 14:58:43

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

lee_st · 2017-11-11 14:59:28

u 系统栈大小分配：

lee_st · 2017-11-11 15:00:01

u  RTX初始化：
/*
*********************************************************************************************************
*    函数名: main
*    功能说明: 标准c程序入口。
*    形    参: 无
*    返回值: 无
*********************************************************************************************************
*/
int main (void)
{
     /* 初始化外设 */
     bsp_Init();

     /* 创建启动任务 */
     os_sys_init_user (AppTaskStart,              /* 任务函数 */
                       5,                         /* 任务优先级 */
                       &AppTaskStartStk,          /* 任务栈 */
                       sizeof(AppTaskStartStk));  /* 任务栈大小，单位字节数 */
     while(1);
}

lee_st · 2017-11-11 15:00:32

u  硬件外设初始化
硬件外设的初始化是在 bsp.c 文件实现：
/*
*********************************************************************************************************
*    函数名: bsp_Init
*    功能说明: 初始化所有的硬件设备。该函数配置CPU寄存器和外设的寄存器并初始化一些全局变量。只需要调用一次
*    形    参：无
*    返回值: 无
*********************************************************************************************************
*/
void bsp_Init(void)
{
     /*
         由于ST固件库的启动文件已经执行了CPU系统时钟的初始化，所以不必再次重复配置系统时钟。
         启动文件配置了CPU主时钟频率、内部Flash访问速度和可选的外部SRAM FSMC初始化。

         系统时钟缺省配置为168MHz，如果需要更改，可以修改 system_stm32f4xx.c 文件
     */
     /* 优先级分组设置为4，可配置0-15级抢占式优先级，0级子优先级，即不存在子优先级。*/
     NVIC_PriorityGroupConfig(NVIC_PriorityGroup_4);

     SystemCoreClockUpdate();    /* 根据PLL配置更新系统时钟频率变量 SystemCoreClock */

     bsp_InitDWT();      /* 初始化DWT */
     bsp_InitUart();     /* 初始化串口 */
     bsp_InitKey();     /* 初始化按键变量（必须在 bsp_InitTimer() 之前调用） */

     bsp_InitExtIO();    /* FMC总线上扩展了32位输出IO, 操作LED等外设必须初始化 */
     bsp_InitLed();      /* 初始LED指示灯端口 */
}

lee_st · 2017-11-11 15:00:51

RTX任务创建：
/*
*********************************************************************************************************
*    函数名: AppTaskCreate
*    功能说明: 创建应用任务
*    形    参: 无
*    返回值: 无
*********************************************************************************************************
*/
static void AppTaskCreate (void)
{
     HandleTaskUserIF = os_tsk_create_user(AppTaskUserIF,             /* 任务函数 */
                                           1,                         /* 任务优先级 */
                                           &AppTaskUserIFStk,         /* 任务栈 */
                                           sizeof(AppTaskUserIFStk)); /* 任务栈大小，单位字节数 */

     HandleTaskLED = os_tsk_create_user(AppTaskLED,              /* 任务函数 */
                                        2,                       /* 任务优先级 */
                                        &AppTaskLEDStk,          /* 任务栈 */
                                        sizeof(AppTaskLEDStk));  /* 任务栈大小，单位字节数 */

     HandleTaskMsgPro = os_tsk_create_user(AppTaskMsgPro,             /* 任务函数 */
                                           3,                         /* 任务优先级 */
                                           &AppTaskMsgProStk,         /* 任务栈 */
                                           sizeof(AppTaskMsgProStk)); /* 任务栈大小，单位字节数 */

    HandleTaskTCPMain = os_tsk_create_user(AppTaskTCPMain,             /* 任务函数 */
                                           4,                         /* 任务优先级 */
                                           &AppTaskTCPMainStk,         /* 任务栈 */
                                           sizeof(AppTaskTCPMainStk)); /* 任务栈大小，单位字节数 */
}

93^#

提示: 该帖被管理员或版主屏蔽

lee_st · 2017-11-11 15:01:34

RL-TCPnet功能测试
这里专门创建了一个app_tcpnet_lib.c文件用于RL-TCPnet功能的测试，主要功能是创建了一个TCP Server。
#include "includes.h"

/*
*********************************************************************************************************
*                                      用于本文件的调试
*********************************************************************************************************
*/
#if 1
     #define printf_debug printf
#else
     #define printf_debug(...)
#endif

/*
*********************************************************************************************************
*                                      用于本文件的调试
*********************************************************************************************************
*/
#define PORT_NUM       1001    /* TCP服务器监听端口号 */

/*
*********************************************************************************************************
*                                         变量
*********************************************************************************************************
*/
uint8_t socket_tcp;

/*
*********************************************************************************************************
*    函数名: tcp_callback
*    功能说明: TCP Socket的回调函数
*    形    参: soc  TCP Socket类型
*             evt  事件类型
*             ptr  事件类型是TCP_EVT_DATA，ptr指向的缓冲区记录着接收到的TCP数据，其余事件记录IP地址
*             par  事件类型是TCP_EVT_DATA，记录接收到的数据个数，其余事件记录端口号
*    返回值:
*********************************************************************************************************
*/
U16 tcp_callback (U8 soc, U8 evt, U8 *ptr, U16 par)
{
     char buf[50];
     uint16_t i;

     /* 确保是socket_tcp的回调 */
     if (soc != socket_tcp)
     {
         return (0);
     }

     switch (evt)
     {
         /*
              远程客户端连接消息
             1、数组ptr存储远程设备的IP地址，par中存储端口号。
             2、返回数值1允许连接，返回数值0禁止连接。
         */
         case TCP_EVT_CONREQ:
              sprintf(buf, "远程客户端请求连接IP: %d.%d.%d.%d", ptr[0], ptr[1], ptr[2], ptr[3]);
              printf_debug("IP:%s  port:%drn", buf, par);
              return (1);

          /* 连接终止 */
         case TCP_EVT_ABORT:
              break;

         /* Socket远程连接已经建立 */
         case TCP_EVT_CONNECT:
              printf_debug("Socket is connected to remote peerrn");
              break;

         /* 连接断开 */
         case TCP_EVT_CLOSE:
              printf_debug("Connection has been closedrn");
              break;

         /* 发送的数据收到远程设备应答 */
         case TCP_EVT_ACK:
              break;

         /* 接收到TCP数据帧，ptr指向数据地址，par记录数据长度，单位字节 */
         case TCP_EVT_DATA:
              printf_debug("Data length = %drn", par);
              for(i = 0; i < par; i++)
              {
                   printf_debug("ptr[%d] = %drn", i, ptr[i]);
              }
              break;
     }

     return (0);
}

/*
*********************************************************************************************************
*    函数名: TCP_StatusCheck
*    功能说明: 检测TCP的连接状态，主要用于网线插拔的判断
*    形    参: 无
*    返回值: __TRUE  连接
*             __FALSE 断开
*********************************************************************************************************
*/
uint8_t TCP_StatusCheck(void)
{
     uint8_t res;

     switch (tcp_get_state(socket_tcp))
     {
         case TCP_STATE_FREE:
         case TCP_STATE_CLOSED:
              res = tcp_listen (socket_tcp, PORT_NUM);
              printf_debug("tcp listen res = %drn", res);
              break;

         case TCP_STATE_LISTEN:
              break;

         case TCP_STATE_CONNECT:
              return (__TRUE);

         default:
              break;
     }

     return (__FALSE);
}

/*
*********************************************************************************************************
*    函数名: TCPnetTest
*    功能说明: TCPnet应用
*    形    参: 无
*    返回值: 无
*********************************************************************************************************
*/
void TCPnetTest(void)
{
     int32_t iCount;
     uint8_t *sendbuf;
     uint8_t tcp_status;
     uint16_t maxlen;
     uint8_t res;
     OS_RESULT xResult;
     const uint16_t usMaxBlockTime = 2; /* 延迟周期 */

     /*
        创建TCP Socket并创建监听，客户端连接服务器后，10秒内无数据通信将断开连接。
        但是由于这里使能了TCP_TYPE_KEEP_ALIVE，会一直保持连接，不受10秒的时间限制。
     */
    socket_tcp = tcp_get_socket (TCP_TYPE_SERVER|TCP_TYPE_KEEP_ALIVE, 0, 10, tcp_callback);
     if(socket_tcp != 0)
     {
         res = tcp_listen (socket_tcp, PORT_NUM);
         printf_debug("tcp listen res = %drn", res);
     }

     while (1)
     {
         /* RL-TCPnet处理函数 */
         main_TcpNet();

         /* 用于网线插拔的处理 */
         tcp_status = TCP_StatusCheck();

         /* 按键消息的处理 */
         if((os_evt_wait_or(0xFFFF, usMaxBlockTime) == OS_R_EVT)&&(tcp_status == __TRUE))
         {
              xResult = os_evt_get ();
              switch (xResult)
              {
                   /* 接收到K1键按下，给远程TCP客户端发送8字节数据 */
                   case KEY1_BIT0:
                       printf_debug("tcp_get_state(socket_tcp) = %drn", tcp_get_state(socket_tcp));
                       iCount = 8;
                       do
                       {
                            main_TcpNet();
                            if (tcp_check_send (socket_tcp) == __TRUE)
                            {
                                 maxlen = tcp_max_dsize (socket_tcp);
                                 iCount -= maxlen;

                                 if(iCount < 0)
                                 {
                                      /* 这么计算没问题的 */
                                     maxlen = iCount + maxlen;
                                 }

                                 sendbuf = tcp_get_buf(maxlen);
                                 sendbuf[0] = '1';
                                 sendbuf[1] = '2';
                                 sendbuf[2] = '3';
                                 sendbuf[3] = '4';
                                 sendbuf[4] = '5';
                                 sendbuf[5] = '6';
                                 sendbuf[6] = '7';
                                 sendbuf[7] = '8';

                                 /* 测试发现只能使用获取的内存 */
                                 tcp_send (socket_tcp, sendbuf, maxlen);
                            }

                       }while(iCount > 0);
                       break;

                   /* 接收到K2键按下，给远程TCP客户端发送1024字节的数据 */
                   case KEY2_BIT1:
                       printf_debug("tcp_get_state(socket_tcp) = %drn", tcp_get_state(socket_tcp));
                       iCount = 1024;
                       do
                       {
                            main_TcpNet();
                            if (tcp_check_send (socket_tcp) == __TRUE)
                            {
                                 maxlen = tcp_max_dsize (socket_tcp);
                                 iCount -= maxlen;

                                 if(iCount < 0)
                                 {
                                      /* 这么计算没问题的 */
                                      maxlen = iCount + maxlen;
                                 }

                                 /* 这里仅初始化了每次所发送数据包的前8个字节 */
                                 sendbuf = tcp_get_buf(maxlen);
                                 sendbuf[0] = 'a';
                                 sendbuf[1] = 'b';
                                 sendbuf[2] = 'c';
                                 sendbuf[3] = 'd';
                                 sendbuf[4] = 'e';
                                 sendbuf[5] = 'f';
                                 sendbuf[6] = 'g';
                                 sendbuf[7] = 'h';

                                 /* 测试发现只能使用获取的内存 */
                                 tcp_send (socket_tcp, sendbuf, maxlen);
                            }

                       }while(iCount > 0);
                       break;

                   /* 接收到K3键按下，给远程TCP客户端发送5MB数据 */
                   case KEY3_BIT2:
                       printf_debug("tcp_get_state(socket_tcp) = %drn", tcp_get_state(socket_tcp));
                       iCount = 5*1024*1024;
                       do
                       {
                            main_TcpNet();
                            if (tcp_check_send (socket_tcp) == __TRUE)
                            {
                                 maxlen = tcp_max_dsize (socket_tcp);
                                 iCount -= maxlen;

                                 if(iCount < 0)
                                 {
                                     /* 这么计算没问题的 */
                                      maxlen = iCount + maxlen;
                                 }

                                 /* 这里仅初始化了每次所发送数据包的前8个字节 */
                                 sendbuf = tcp_get_buf(maxlen);
                                 sendbuf[0] = 'a';
                                 sendbuf[1] = 'b';
                                 sendbuf[2] = 'c';
                                 sendbuf[3] = 'd';
                                 sendbuf[4] = 'e';
                                 sendbuf[5] = 'f';
                                 sendbuf[6] = 'g';
                                 sendbuf[7] = 'h';

                                 /* 测试发现只能使用获取的内存 */
                                 tcp_send (socket_tcp, sendbuf, maxlen);
                            }

                       }while(iCount > 0);
                       break;

                    /* 其他的键值不处理 */
                   default:
                       break;
              }
         }
     }
}

lee_st · 2017-11-11 15:03:41

RL-TCPnet功能测试
这里专门创建了一个app_tcpnet_lib.c文件用于RL-TCPnet功能的测试，主要功能是创建了一个TCP Server。
#include "includes.h"

/*
*********************************************************************************************************
*                                      用于本文件的调试
*********************************************************************************************************
*/
#if 1
     #define printf_debug printf
#else
     #define printf_debug(...)
#endif

/*
*********************************************************************************************************
*                                      用于本文件的调试
*********************************************************************************************************
*/
#define PORT_NUM       1001    /* TCP服务器监听端口号 */

/*
*********************************************************************************************************
*                                         变量
*********************************************************************************************************
*/
uint8_t socket_tcp;

/*
*********************************************************************************************************
*    函数名: tcp_callback
*    功能说明: TCP Socket的回调函数
*    形    参: soc  TCP Socket类型
*             evt  事件类型
*             ptr  事件类型是TCP_EVT_DATA，ptr指向的缓冲区记录着接收到的TCP数据，其余事件记录IP地址
*             par  事件类型是TCP_EVT_DATA，记录接收到的数据个数，其余事件记录端口号
*    返回值:
*********************************************************************************************************
*/
U16 tcp_callback (U8 soc, U8 evt, U8 *ptr, U16 par)
{
     char buf[50];
     uint16_t i;

     /* 确保是socket_tcp的回调 */
     if (soc != socket_tcp)
     {
         return (0);
     }

     switch (evt)
     {
         /*
              远程客户端连接消息
             1、数组ptr存储远程设备的IP地址，par中存储端口号。
             2、返回数值1允许连接，返回数值0禁止连接。
         */
         case TCP_EVT_CONREQ:
              sprintf(buf, "远程客户端请求连接IP: %d.%d.%d.%d", ptr[0], ptr[1], ptr[2], ptr[3]);
              printf_debug("IP:%s  port:%drn", buf, par);
              return (1);

          /* 连接终止 */
         case TCP_EVT_ABORT:
              break;

         /* Socket远程连接已经建立 */
         case TCP_EVT_CONNECT:
              printf_debug("Socket is connected to remote peerrn");
              break;

         /* 连接断开 */
         case TCP_EVT_CLOSE:
              printf_debug("Connection has been closedrn");
              break;

         /* 发送的数据收到远程设备应答 */
         case TCP_EVT_ACK:
              break;

         /* 接收到TCP数据帧，ptr指向数据地址，par记录数据长度，单位字节 */
         case TCP_EVT_DATA:
              printf_debug("Data length = %drn", par);
              for(i = 0; i < par; i++)
              {
                   printf_debug("ptr[%d] = %drn", i, ptr[i]);
              }
              break;
     }

     return (0);
}

/*
*********************************************************************************************************
*    函数名: TCP_StatusCheck
*    功能说明: 检测TCP的连接状态，主要用于网线插拔的判断
*    形    参: 无
*    返回值: __TRUE  连接
*             __FALSE 断开
*********************************************************************************************************
*/
uint8_t TCP_StatusCheck(void)
{
     uint8_t res;

     switch (tcp_get_state(socket_tcp))
     {
         case TCP_STATE_FREE:
         case TCP_STATE_CLOSED:
              res = tcp_listen (socket_tcp, PORT_NUM);
              printf_debug("tcp listen res = %drn", res);
              break;

         case TCP_STATE_LISTEN:
              break;

         case TCP_STATE_CONNECT:
              return (__TRUE);

         default:
              break;
     }

     return (__FALSE);
}

/*
*********************************************************************************************************
*    函数名: TCPnetTest
*    功能说明: TCPnet应用
*    形    参: 无
*    返回值: 无
*********************************************************************************************************
*/
void TCPnetTest(void)
{
     int32_t iCount;
     uint8_t *sendbuf;
     uint8_t tcp_status;
     uint16_t maxlen;
     uint8_t res;
     OS_RESULT xResult;
     const uint16_t usMaxBlockTime = 2; /* 延迟周期 */

     /*
        创建TCP Socket并创建监听，客户端连接服务器后，10秒内无数据通信将断开连接。
        但是由于这里使能了TCP_TYPE_KEEP_ALIVE，会一直保持连接，不受10秒的时间限制。
     */
    socket_tcp = tcp_get_socket (TCP_TYPE_SERVER|TCP_TYPE_KEEP_ALIVE, 0, 10, tcp_callback);
     if(socket_tcp != 0)
     {
         res = tcp_listen (socket_tcp, PORT_NUM);
         printf_debug("tcp listen res = %drn", res);
     }

     while (1)
     {
         /* RL-TCPnet处理函数 */
         main_TcpNet();

         /* 用于网线插拔的处理 */
         tcp_status = TCP_StatusCheck();

         /* 按键消息的处理 */
         if((os_evt_wait_or(0xFFFF, usMaxBlockTime) == OS_R_EVT)&&(tcp_status == __TRUE))
         {
              xResult = os_evt_get ();
              switch (xResult)
              {
                   /* 接收到K1键按下，给远程TCP客户端发送8字节数据 */
                   case KEY1_BIT0:
                       printf_debug("tcp_get_state(socket_tcp) = %drn", tcp_get_state(socket_tcp));
                       iCount = 8;
                       do
                       {
                            main_TcpNet();
                            if (tcp_check_send (socket_tcp) == __TRUE)
                            {
                                 maxlen = tcp_max_dsize (socket_tcp);
                                 iCount -= maxlen;

                                 if(iCount < 0)
                                 {
                                      /* 这么计算没问题的 */
                                     maxlen = iCount + maxlen;
                                 }

                                 sendbuf = tcp_get_buf(maxlen);
                                 sendbuf[0] = '1';
                                 sendbuf[1] = '2';
                                 sendbuf[2] = '3';
                                 sendbuf[3] = '4';
                                 sendbuf[4] = '5';
                                 sendbuf[5] = '6';
                                 sendbuf[6] = '7';
                                 sendbuf[7] = '8';

                                 /* 测试发现只能使用获取的内存 */
                                 tcp_send (socket_tcp, sendbuf, maxlen);
                            }

                       }while(iCount > 0);
                       break;

                   /* 接收到K2键按下，给远程TCP客户端发送1024字节的数据 */
                   case KEY2_BIT1:
                       printf_debug("tcp_get_state(socket_tcp) = %drn", tcp_get_state(socket_tcp));
                       iCount = 1024;
                       do
                       {
                            main_TcpNet();
                            if (tcp_check_send (socket_tcp) == __TRUE)
                            {
                                 maxlen = tcp_max_dsize (socket_tcp);
                                 iCount -= maxlen;

                                 if(iCount < 0)
                                 {
                                      /* 这么计算没问题的 */
                                      maxlen = iCount + maxlen;
                                 }

                                 /* 这里仅初始化了每次所发送数据包的前8个字节 */
                                 sendbuf = tcp_get_buf(maxlen);
                                 sendbuf[0] = 'a';
                                 sendbuf[1] = 'b';
                                 sendbuf[2] = 'c';
                                 sendbuf[3] = 'd';
                                 sendbuf[4] = 'e';
                                 sendbuf[5] = 'f';
                                 sendbuf[6] = 'g';
                                 sendbuf[7] = 'h';

                                 /* 测试发现只能使用获取的内存 */
                                 tcp_send (socket_tcp, sendbuf, maxlen);
                            }

                       }while(iCount > 0);
                       break;

                   /* 接收到K3键按下，给远程TCP客户端发送5MB数据 */
                   case KEY3_BIT2:
                       printf_debug("tcp_get_state(socket_tcp) = %drn", tcp_get_state(socket_tcp));
                       iCount = 5*1024*1024;
                       do
                       {
                            main_TcpNet();
                            if (tcp_check_send (socket_tcp) == __TRUE)
                            {
                                 maxlen = tcp_max_dsize (socket_tcp);
                                 iCount -= maxlen;

                                 if(iCount < 0)
                                 {
                                     /* 这么计算没问题的 */
                                      maxlen = iCount + maxlen;
                                 }

                                 /* 这里仅初始化了每次所发送数据包的前8个字节 */
                                 sendbuf = tcp_get_buf(maxlen);
                                 sendbuf[0] = 'a';
                                 sendbuf[1] = 'b';
                                 sendbuf[2] = 'c';
                                 sendbuf[3] = 'd';
                                 sendbuf[4] = 'e';
                                 sendbuf[5] = 'f';
                                 sendbuf[6] = 'g';
                                 sendbuf[7] = 'h';

                                 /* 测试发现只能使用获取的内存 */
                                 tcp_send (socket_tcp, sendbuf, maxlen);
                            }

                       }while(iCount > 0);
                       break;

                    /* 其他的键值不处理 */
                   default:
                       break;
              }
         }
     }
}