) {, o" e% Z2 v
现在都 lwip 210 版本了，无奈，因为客户 SDK 的原因还在捣鼓 lwip151 版本。
% q( L" f1 K( r9 k/ V( s
将客户 SDK 升级到 RT-Thread 系统的时候，发现低功耗部分与 LWIP 有耦合，不能直接使用 RT-Thread 移植的 LWIP 组件，也就意味着，我不同享受 RT-Thread netdev 组件和 SAL 组件开发的便利。

于是，给自己挖了个坑，把 LWIP151 版本对接到 netdev 和 sal 组件上
, l' y& j  O( C2 X
: u! I" F8 l2 S3 n5 z为了测试，捣鼓了一个简单的 TCP 客户端程序，后面有时间也把对接 RT-Thread netdev 组件和 SAL 组件的过程也给分享出来。
- t* n( b* w+ I& n7 h; ?4 Q
这里提供的代码基于 BSD-type 风格的 socket 函数接口，你可以在任何支持 BSD socket 的平台上使用这段程序，当然这段程序也可以在包含了 RT-Thread SAL 的使用方法，引入 SAL 相关头文件。

1. #include <stdio.h>
   - T" d1 F" [6 ~* G' D
2. #include <string.h>
   # f0 o$ k& u6 n9 ~( Y
3. #include <rtthread.h>
   ; w: f* q2 ], N2 ?) `
4. 
   
5. /* 引入 lwip socket 头文件 */
   3 j% z/ Y8 Q+ m  e) ~
6. #include "lwip/sockets.h"
   
7. #include "lwip/netdb.h"
   
8. #include "lwip/sys.h"
   ) z# D2 I6 ^0 z! T& D/ Y" ?
9. 
   
10. #define TCP_TEST_HOST    "your host or ip addr" /* 输入你的 TCP server 域名或者 ip 地址 */
    + J- o; ^  \7 x( G9 N( ?" l
11. #define TCP_TEST_PORT    (80u)                  /* 输入你的 TCP Server 断口号 */
    , A$ f% A# s! G( o7 u
12. #define TEST_BUFSZ       (1024u)
    6 _! l' a3 c* Z6 V. j( w3 M
13. 
    
14. static const char *send_tcp_req_data = "Hi, I am from tcp client.";
    
15. 
    - h$ ^4 ^4 U# Q9 |
16. static void _tcp_test(void)
    + }2 R! Z' v& J. k
17. {
    
18.     int ret, i;
      p2 |4 N0 A' K" z  w
19.     char *recv_data;
    
20.     struct hostent *host;
    
21.     int sock = -1, bytes_received;
    
22.     struct sockaddr_in server_addr;
    
23. 
    
24.     /* 通过函数入口参数url获得host地址（如果是域名，会做域名解析） */
    % a* y; `" T1 q7 P+ c
25.     host = gethostbyname(TCP_TEST_HOST);
    
26.     if (!host)
    4 Z9 j7 L) T1 P
27.     {
    ) S* V3 n: p- N; d* I9 ]
28.         rt_kprintf("gethostbyname failed!\r\n");
    
29.         return;
    
30.     }
    
31.     else
    3 A, F) n' l. T( x) z
32.     {
    
33.         rt_kprintf("gethostbyname success!\r\n");
    
34.     }
    
35. 
    
36.     recv_data = calloc(1, TEST_BUFSZ);
    
37.     if (recv_data == RT_NULL)
    ( M4 ~$ z' @% @; y6 ~5 Q
38.     {
    
39.         rt_kprintf("No memory\n");
    
40.         return;
    
41.     }
    
42. 
    
43.     /* 创建一个socket，类型是SOCKET_STREAM，TCP 协议, TLS 类型 */
    
44.     if ((sock = socket(AF_INET, SOCK_STREAM, 0)) < 0)
    
45.     {
    
46.         rt_kprintf("Socket error\n");
    & n- z) t# A1 P, X& R, O8 V
47.         goto __exit;
    7 j  a: u7 N, V' v' S, b
48.     }
    + O$ u2 q- k% l) o. o" i" U. ?
49.     else
    
50.     {
      s# k6 R- j: k! L# C; }7 z  B
51.         rt_kprintf("Socket pass\n");
    2 k! [( d: ^+ `" f5 E* O9 r
52.     }
    ; ?4 m2 j* k5 c7 K% Z! H5 J
53. 
    3 F: q/ M% z( Z5 e$ {/ a
54.     /* 初始化预连接的服务端地址 */
    8 d! l6 L3 U7 n
55.     server_addr.sin_family = AF_INET;
    ' j$ Z( H+ V6 H, ~* m
56.     server_addr.sin_port = htons(TCP_TEST_PORT);
    
57.     server_addr.sin_addr = *((struct in_addr *)host->h_addr);
    - N& h, V# e6 ?7 V  U- z0 E
58.     memset(&(server_addr.sin_zero), 0, sizeof(server_addr.sin_zero));
      M! R. X$ T. C- R6 x& `# M$ i9 o
59. 
    
60.     rt_kprintf("will connect...\n");
    
61.     if (connect(sock, (struct sockaddr *)&server_addr, sizeof(struct sockaddr)) < 0)
    + p9 b; B" ]3 @9 C: c2 Q# ]
62.     {
    ( \* G0 R- {" B& ^2 j& B% _
63.         rt_kprintf("Connect fail!\n");
    
64.         goto __exit;
    9 ^7 U, [* }/ n7 z
65.     }
    : q! ]3 m* r" v
66.     else
    
67.     {
    
68.         rt_kprintf("Connect pass!\n");
    
69.     }
    
70. 
      y* Z6 v/ y5 N; A" [3 v4 [
71.     /* 发送数据到 socket 连接 */
    $ |( i" e2 }. v6 w/ Y! L8 Y1 o
72.     ret = send(sock, send_tcp_req_data, strlen(send_tcp_req_data), 0);
    / q: v& [" T* J, E" K. K' v* N0 x) V5 X
73.     if (ret <= 0)
    + w( B8 n1 P  U& l
74.     {
    ( }  f- L- M  [, r/ E/ R
75.         rt_kprintf("send error,close the socket.\n");
      @& s/ o0 Y" k# L  H! g+ O( l
76.         goto __exit;
    
77.     }
    
78.     else
    ( h1 D( V8 K1 j, w
79.     {
    3 B( ^8 Q5 n0 l. q
80.         rt_kprintf("send pass!\n");
    9 Y, q/ H# w9 ]1 [0 n9 Q9 v- u
81.     }
    
82. 
    
83.     /* 接收并打印响应的数据，使用加密数据传输 */
    
84.     bytes_received = recv(sock, recv_data, TEST_BUFSZ - 1, 0);
    
85.     if (bytes_received <= 0)
    9 O2 V  I8 M2 b- U
86.     {
    3 u0 {# \& k# N& `5 x1 j
87.         rt_kprintf("received error,close the socket.\n");
    
88.         goto __exit;
    
89.     }
    * `. L9 E/ J% Y/ Z
90. 
    
91.     rt_kprintf("recv data:\n");
    
92.     for (i = 0; i < bytes_received; i++)
    
93.     {
    6 Z) k  n/ F$ F' Z
94.         rt_kprintf("%c", recv_data);
    " x: f9 P1 d7 s# a% j0 V8 T$ z" k7 D/ Y
95.     }
    
96. 
    
97. __exit:
    # \0 H; o4 X6 R
98.     if (recv_data)
    ; o( T: _" _  ^* \4 {" W0 i
99.         rt_free(recv_data);
    ) p2 U5 T: t# e& L; d1 Q- A0 N
100. 
     
101.     if (sock >= 0)
     
102.         close(sock);
     
103. }
     . |* e( {4 v! B  l* ^
104. 
     
105. void tcp_test(void)
     
106. {
     - T, Z5 d) V$ a$ G/ C  S- w0 N
107.     rt_thread_t tid;
     & p0 ?: G5 E! f: c/ K0 ^% E
108.     tid = rt_thread_create("tcp", _tcp_test, NULL, 4096, 23, 5);
     
109.     if (tid)
     
110.         rt_thread_startup(tid);
     + h3 t5 W2 \5 b# Z
111.     else
     
112.     {
     
113.         rt_kprintf("tcp thread create failed!\r\n");
     ! l' J# N! P  ^3 a# P+ v3 o3 R: ^
114.     }
     & D: ?9 \6 g' g9 ^% u
115. }
     
116. 
     
117. #ifdef FINSH_USING_MSH
     ' m0 e1 P* _; O4 I
118. #include <finsh.h>
     7 h. E( r5 @7 O9 [4 v
119. MSH_CMD_EXPORT(tcp_test, TCP function test);
     
120. #endif /* FINSH_USING_MSH */
     

复制代码

7 \/ T( C" z' h; ?- b7 O
如果你也是使用 RT-Thread，那么直接复制代码加入编译，然后在 MSH 中运行既可以：

1. msh /> tcp_test

复制代码

tcp_client.rar (1.32 KB, 下载次数: 3)

2019-6-27 09:26 上传

点击文件名下载附件

# v" Q3 V5 p+ J  a" ~7 y3 c6 T

, D) O+ l4 D$ {2 E: }* Q1 F4 c) |

2 V) }6 p" R& f

之前粘贴的代码有问题，这下学会怎么插入代码了。
6 ~5 d( x1 E1 v. T% s, R
从文本编辑器复制代码，粘贴到论坛里的代码插入标签，提交之后会插入到当前光标位置。
这个时候你看到的代码格式是乱掉的，没有空格缩进等，不要紧，保存提交帖子即可，这个时候会发现，代码格式显示正常了。