分享个RL-TCPnet V7.X回调函数里面发送RTOS消息的案例
例子用的固定IP，大家更新修改。
/*
*********************************************************************************************************
*
* 模块名称 : TCPnet网络协议栈测试
* 文件名称 : app_tcpnet_lib.c
* 版 本 : V1.0
* 说 明 : 测试的功能说明
* 1. 强烈推荐将网线接到路由器或者交换机上面测试，因为已经使能了DHCP，可以自动获取IP地址。
* 2. 创建了一个TCP Server，而且使能了局域网域名NetBIOS，用户只需在电脑端ping armfly
* 就可以获得板子的IP地址，端口号1001。
* 3. 用户可以在电脑端用网络调试软件创建TCP Client连接此服务器端。
* 4. 按键K1按下，发送8字节的数据给TCP Client。
* 5. 按键K2按下，发送1024字节的数据给TCP Client。
* 6. 按键K3按下，发送5MB字节的数据给TCP Client。
*
* 修改记录 :
* 版本号 日期 作者 说明
* V1.0 2019-10-22 Eric2013 首发
*
* Copyright (C), 2018-2030, 安富莱电子 www.armfly.com
*
*********************************************************************************************************
*/
#include "includes.h"
/*
*********************************************************************************************************
* 用于本文件的调试
*********************************************************************************************************
*/
#if 1
#define printf_debug printf
#else
#define printf_debug(...)
#endif
/*
*********************************************************************************************************
* 宏定义
*********************************************************************************************************
*/
#define PORT_NUM 1001 /* TCP服务器监听端口号 */
/*
*********************************************************************************************************
* 变量
*********************************************************************************************************
*/
int32_t tcp_sock;
typedef struct { // object data type
uint8_t Buf;
uint32_t Idx;
} MSGQUEUE_OBJ_t;
osMessageQueueId_t mid_MsgQueue; // message queue id
/* TCPnet API的返回值 */
static const char * ReVal_Table[]=
{
"netOK: Operation succeeded",
"netBusy: Process is busy",
"netError: Unspecified error",
"netInvalidParameter: Invalid parameter specified",
"netWrongState: Wrong state error",
"netDriverError: Driver error",
"netServerError: Server error",
"netAuthenticationFailed: User authentication failed",
"netDnsResolverError: DNS host resolver failed",
"netFileError: File not found or file r/w error",
"netTimeout: Operation timeout",
};
/*
*********************************************************************************************************
* 函 数 名: tcp_cb_server
* 功能说明: TCP Socket的回调函数
* 形 参: socket句柄
* event 事件类型
* addr NET_ADDR类型变量，记录IP地址，端口号。
* buf ptr指向的缓冲区记录着接收到的TCP数据。
* len 记录接收到的数据个数。
* 返 回 值:
*********************************************************************************************************
*/
uint32_t tcp_cb_server (int32_t socket, netTCP_Event event,
const NET_ADDR *addr, const uint8_t *buf, uint32_t len)
{
MSGQUEUE_OBJ_t msg;
switch (event)
{
/*
远程客户端连接消息
1、数组ptr存储远程设备的IP地址，par中存储端口号。
2、返回数值1允许连接，返回数值0禁止连接。
*/
case netTCP_EventConnect:
if (addr->addr_type == NET_ADDR_IP4)
{
printf_debug("远程客户端请求连接IP: %d.%d.%d.%d端口号:%d\r\n",
addr->addr,
addr->addr,
addr->addr,
addr->addr,
addr->port);
return (1);
}
else if (addr->addr_type == NET_ADDR_IP6)
{
return (1);
}
return(0);
/* Socket远程连接已经建立 */
case netTCP_EventEstablished:
printf_debug("Socket is connected to remote peer\r\n");
break;
/* 连接断开 */
case netTCP_EventClosed:
printf_debug("Connection has been closed\r\n");
break;
/* 连接终止 */
case netTCP_EventAborted:
break;
/* 发送的数据收到远程设备应答 */
case netTCP_EventACK:
break;
/* 接收到TCP数据帧，ptr指向数据地址，par记录数据长度，单位字节 */
case netTCP_EventData:
printf_debug("Data length = %d\r\n", len);
printf ("%.*s\r\n",len, buf);
msg.Buf = buf;
msg.Idx = len;
osMessageQueuePut(mid_MsgQueue, &msg, 0U, 0U);
break;
}
return (0);
}
/*
*********************************************************************************************************
* 函 数 名: TCPnetTest
* 功能说明: TCPnet应用
* 形 参: 无
* 返 回 值: 无
*********************************************************************************************************
*/
void TCPnetTest(void)
{
MSGQUEUE_OBJ_t msg;
osStatus_t status;
int32_t iCount;
uint8_t *sendbuf;
uint32_t maxlen;
netStatus res;
const uint16_t usMaxBlockTime = 2; /* 延迟周期 */
uint32_t EvtFlag;
mid_MsgQueue = osMessageQueueNew(16, sizeof(MSGQUEUE_OBJ_t), NULL);
if (mid_MsgQueue == NULL) {
printf("Message Queue object not created, handle failure\r\n");
}
tcp_sock = netTCP_GetSocket (tcp_cb_server);
if (tcp_sock > 0)
{
res = netTCP_Listen (tcp_sock, PORT_NUM);
printf_debug("tcp listen res = %s\r\n", ReVal_Table);
/* 使能TCP_TYPE_KEEP_ALIVE，会一直保持连接 */
netTCP_SetOption (tcp_sock, netTCP_OptionKeepAlive, 1);
}
while (1)
{
status = osMessageQueueGet(mid_MsgQueue, &msg, NULL, 100U); // wait for message
if (status == osOK)
{
printf("===%d\r\n", msg.Idx);
}
}
}
/***************************** 安富莱电子 www.armfly.com (END OF FILE) *********************************/
感谢硬汉不停更新,学习了.
页:
[1]