第15章 RL-TCPnet之创建多个TCP连接

STM32

转最新网络教程，简介如下
本章节为大家讲解RL-TCPnet的TCP多客户端实现，因为多客户端在实际项目中用到的地方还挺多，所以我们也专门开启一个章节做讲解。另外，学习本章节前，务必要优先学习第14章TCP客户端。学会创建一个TCP客户端了，创建多个客户端是一样的。
本章教程含STM32F407开发板和STM32F429开发板。
15.1 初学者重要提示
15.2 创建多个TCP客户端连接服务器
15.3 TCP配置说明（Net_Config.c）
15.4 TCP调试说明（Net_Debug.c）
15.5 TCP客户端的实现方法
15.6 网络调试助手创建TCP服务器的方法
15.7 实验例程说明（裸机）
15.8 实验例程说明（RTX）
15.9 总结

81^#

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

lee_st · 2017-11-15 08:25:59

三个TCP客户端的实现
三个TCP客户端实现都是一样的，我们这里仅以客户端1为例进行说明：
#include "includes.h"

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

/*
*********************************************************************************************************
* 变量
*********************************************************************************************************
*/
uint8_t socket_tcp1;

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

/* 确保是socket_tcp的回调 */
if (soc != socket_tcp1)
{
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_debug1("IP:%s port:%drn", buf, par);
return (1);

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

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

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

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

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

return (0);
}

/*
*********************************************************************************************************
* 函数名: TcpConnect_Client1
* 功能说明: 创建一个TCP Client
* 形参: _remip 要访问的远程IP地址
* _remport 远程端口号
* _localport 本地端口号
* 返回值: 无
*********************************************************************************************************
*/
void TcpConnect_Client1(uint8_t *_remip, uint16_t _remport, uint16_t _localport)
{
uint8_t res;

/*
创建TCP Socket并连接，客户端连接服务器后，10秒内无数据通信将断开连接。
但是由于这里使能了TCP_TYPE_KEEP_ALIVE，会一直保持连接，不受10秒的时间限制。
*/
socket_tcp1 = tcp_get_socket (TCP_TYPE_CLIENT | TCP_TYPE_KEEP_ALIVE, 0, 10, tcp_callback1);
if(socket_tcp1 != 0)
{
res = tcp_connect (socket_tcp1, _remip, _remport, _localport);
printf_debug1("TCP Socket创建成功res = %drn", res);
}
}

lee_st · 2017-11-15 08:44:48

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

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

/*
*********************************************************************************************************
* 外部变量和函数调用
*********************************************************************************************************
*/
extern uint8_t socket_tcp1;
extern void TcpConnect_Client1(uint8_t *_remip, uint16_t _remport, uint16_t _localport);

extern uint8_t socket_tcp2;
extern void TcpConnect_Client2(uint8_t *_remip, uint16_t _remport, uint16_t _localport);

extern uint8_t socket_tcp3;
extern void TcpConnect_Client3(uint8_t *_remip, uint16_t _remport, uint16_t _localport);

/*
*********************************************************************************************************
* 宏定义，远程服务器的IP和端口
*********************************************************************************************************
*/
/* 要访问的远程服务器IP和端口配置，也就是电脑端调试助手设置的IP和端口号 */
#define IP1 192
#define IP2 168
#define IP3 1
#define IP4 2

#define PORT_NUM 1001

/* 这个是本地端口 */
#define LocalPort_NUM1 1024
#define LocalPort_NUM2 1025
#define LocalPort_NUM3 1026

/*
*********************************************************************************************************
* 变量
*********************************************************************************************************
*/
uint8_t Rem_IP[4] = {IP1,IP2,IP3,IP4};

/* TCP状态的返回值 */
const char * ReVal_Table[]=
{
"0: TCP_STATE_FREE",
"1: TCP_STATE_CLOSED",
"2: TCP_STATE_LISTEN",
"3: TCP_STATE_SYN_REC",
"4: TCP_STATE_SYN_SENT",
"5: TCP_STATE_FINW1",
"6: TCP_STATE_FINW2",
"7: TCP_STATE_CLOSING",
"8: TCP_STATE_LAST_ACK",
"9: TCP_STATE_TWAIT",
"10: TCP_STATE_CONNECT",
"11: 连接还未创建",
};

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

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

/* 按键消息的处理 */
if(os_evt_wait_or(0xFFFF, usMaxBlockTime) == OS_R_EVT)
{
xResult = os_evt_get ();
switch (xResult)
{
/* 接收到K1键按下，TCP客户端1建立连接 */
case KEY1_BIT0:
TcpState = tcp_get_state(socket_tcp1);

/*
TCP_STATE_CONNECT是最后一个状态，未创建连接的话，会返回数值255，这里就是专门处理
这种状态，将其设置下一个TCP_STATE_CONNECT+1，即我们这里自定义了一个未创建连接的
状态。
*/
if(TcpState > TCP_STATE_CONNECT)
{
TcpState = TCP_STATE_CONNECT + 1;
}
printf_debug("TCP客户端1状态 = %srn", ReVal_Table[TcpState]);

if(TcpState != TCP_STATE_CONNECT)
{
TcpConnect_Client1(Rem_IP, PORT_NUM, LocalPort_NUM1);
}
break;

/* 接收到K2键按下，TCP客户端2建立连接 */
case KEY2_BIT1:
TcpState = tcp_get_state(socket_tcp2);

/*
TCP_STATE_CONNECT是最后一个状态，未创建连接的话，会返回数值255，这里就是专门处理
这种状态，将其设置下一个TCP_STATE_CONNECT+1，即我们这里自定义了一个未创建连接的
状态。
*/
if(TcpState > TCP_STATE_CONNECT)
{
TcpState = TCP_STATE_CONNECT + 1;
}
printf_debug("TCP客户端2状态 = %srn", ReVal_Table[TcpState]);

if(TcpState != TCP_STATE_CONNECT)
{
TcpConnect_Client2(Rem_IP, PORT_NUM, LocalPort_NUM2);
}
break;

/* 接收到K3键按下，TCP客户端3建立连接 */
case KEY3_BIT2:
TcpState = tcp_get_state(socket_tcp3);

/*
TCP_STATE_CONNECT是最后一个状态，未创建连接的话，会返回数值255，这里就是专门处理
这种状态，将其设置下一个TCP_STATE_CONNECT+1，即我们这里自定义了一个未创建连接的
状态。
*/
if(TcpState > TCP_STATE_CONNECT)
{
TcpState = TCP_STATE_CONNECT + 1;
}

printf_debug("TCP客户端3状态 = %srn", ReVal_Table[TcpState]);

if(TcpState != TCP_STATE_CONNECT)
{
TcpConnect_Client3(Rem_IP, PORT_NUM, LocalPort_NUM3);
}
break;

/* 接收到摇杆上键按下，TCP客户端1向TCP服务器发送4096字节数据 */
case JOY_U_BIT3:
TcpState = tcp_get_state(socket_tcp1);
printf_debug("TCP客户端1状态 = %srn", ReVal_Table[TcpState]);
iCount = 4096;
/* 保证已经建立连接了才可以发送数据 */
if(TcpState == TCP_STATE_CONNECT)
{
do
{
main_TcpNet();
if (tcp_check_send (socket_tcp1) == __TRUE)
{
maxlen = tcp_max_dsize (socket_tcp1);
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_tcp1, sendbuf, maxlen);
}

}while(iCount > 0);
}
break;

/* 接收到摇杆左键按下，TCP客户端2向TCP服务器发送4096字节数据 */
case JOY_L_BIT4:
TcpState = tcp_get_state(socket_tcp2);
printf_debug("TCP客户端2状态 = %srn", ReVal_Table[TcpState]);
iCount = 4096;
/* 保证已经建立连接了才可以发送数据 */
if(TcpState == TCP_STATE_CONNECT)
{
do
{
main_TcpNet();
if (tcp_check_send (socket_tcp2) == __TRUE)
{
maxlen = tcp_max_dsize (socket_tcp2);
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_tcp2, sendbuf, maxlen);
}

}while(iCount > 0);
}
break;

/* 接收到摇杆右键按下，TCP客户端3向TCP服务器发送4096字节数据 */
case JOY_R_BIT5:
TcpState = tcp_get_state(socket_tcp3);
printf_debug("TCP客户端3状态 = %srn", ReVal_Table[TcpState]);
iCount = 4096;
/* 保证已经建立连接了才可以发送数据 */
if(TcpState == TCP_STATE_CONNECT)
{
do
{
main_TcpNet();
if (tcp_check_send (socket_tcp3) == __TRUE)
{
maxlen = tcp_max_dsize (socket_tcp3);
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_tcp3, sendbuf, maxlen);
}

}while(iCount > 0);
}
break;

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

lee_st · 2017-11-15 08:46:13

分享完成，，，，，，，

搜索历史

第15章 RL-TCPnet之创建多个TCP连接

相关推荐

83 条评论

评论

精选推荐

热门帖

站长推荐 /7