ThreadX NetXDUO回调函数方式接收数据的玩法非常不错，这样就跟TCPnet差不多了

eric2013

比如创建一个TCP回调：

1.          nx_tcp_socket_receive_notify(&TCPSocket[i],
   
2.                                       my_receive_notify);

复制代码

回调函数处理：

1. /*
   
2. *********************************************************************************************************
   
3. *        函 数 名: NetXTest
   
4. *        功能说明: TCPnet应用
   
5. *        形    参: 无
   
6. *        返 回 值: 无
   
7. *********************************************************************************************************
   
8. */                                            
   
9. void my_receive_notify(NX_TCP_SOCKET *socket_ptr)
   
10. {
    
11.     UINT status;
    
12.     UINT ret;
    
13.     ULONG socket_state;
    
14.     UINT old_priority;
    
15.     int i;
    
16. 
    
17.     NX_PACKET *RecPacket;
    
18.     NX_PACKET *TraPacket;
    
19. 
    
20.     ULONG bytes_read;
    
21.     static uint32_t count = 0;
    
22.        
    
23.         ULONG peer_ip_address;
    
24.         ULONG peer_port;
    
25.     uint8_t sendbuf[20];
    
26.    
    
27.      ret = nx_tcp_socket_receive(socket_ptr,     /* TCP Socket控制块 */
    
28.                                               &RecPacket,    /* 接收到的数据包 */
    
29.                                                   0);        /* 永久等待 */
    
30.    
    
31.         /* 获取客户端的IP地址和端口 */
    
32.     nx_tcp_socket_peer_info_get(socket_ptr,       /* TCP Socket控制块 */
    
33.                                 &peer_ip_address, /* 远程IP地址 */
    
34.                                 &peer_port);      /* 远程端口号 */
    
35.    
    
36. 
    
37.     /* 获取客户端发来的数据 */
    
38.     nx_packet_data_retrieve(RecPacket,    /* 接收到的数据包 */
    
39.                             data_buffer,    /* 解析出数据 */
    
40.                             &bytes_read);   /* 数据大小 */
    
41. 
    
42.     /* 打印接收到数据 */
    
43.     PRINT_DATA(peer_ip_address, (unsigned int)peer_port, data_buffer);
    
44.    
    
45.     nx_packet_release(RecPacket);
    
46.    
    
47.     /* 申请发送数据包 */
    
48.     ret = nx_packet_allocate(&pool_0, &TraPacket, NX_TCP_PACKET, 0);
    
49. 
    
50.     if (ret)
    
51.     {
    
52.         Error_Handler(__FILE__, __LINE__);  
    
53.     }
    
54. 
    
55.     sprintf((char *)sendbuf, "sendbuf = %d\r\n", count++);
    
56.    
    
57.     /*将要发送的数据附加到TraPacket */
    
58.     ret = nx_packet_data_append(TraPacket, (VOID *)sendbuf, strlen((char *)sendbuf), &pool_0, 0);
    
59. 
    
60.     if (ret)
    
61.     {
    
62.         Error_Handler(__FILE__, __LINE__);
    
63.     }
    
64. 
    
65.     /* 发送数据，注意发送后，此函数会释放数据包 */
    
66.     ret =  nx_tcp_socket_send(socket_ptr,   
    
67.                                TraPacket,      
    
68.                                0);
    
69.    
    
70.     if (ret)
    
71.     {
    
72.         Error_Handler(__FILE__, __LINE__);
    
73.     }
    
74. 
    
75. }

复制代码

morning_enr6U

eggplant886

我年纪小，入门的晚，现在只用threadx全家桶了，lwip，ucos什么听说但没用过

way2888

我测试了一下,如果用这种回调函数方式接收数据的话,上位机主动断开/连接几次后就无法收到数据了

ihavedone

nx_tcp_socket_send 如果发送失败就不会释放数据包，所以失败处理中要加一个手动释放数据包。