STM32F7 LWIP socket 创建TCP server
7 \, G1 C7 J' q

1. **阻塞方式：**

复制代码

1. typedef struct {
   
2.     struct sockaddr_in client_info;
   
3.     s32 id;
   * a7 i3 K' F- Y9 u
4.     u16 port;
   
5. } client_info_s;
   2 Y9 g! M" r7 m% g0 }
6. 
   4 [2 T) G' }* y, N: C' K
7. void client_proc(void* parm) {
   6 n6 S5 G% a6 ]# ~# q4 k
8.     client_info_s* info = (client_info_s*)parm;
     [1 F9 C- C' B) m
9.     u8* rec_data = sys_malloc(1500);
   
10. 
    
11.     WDBG("PORT:%d client[%d] %s:%d\n", info->port, info->id,
    # @* k2 R" P* k; O, F! {
12.         inet_ntoa(info->client_info.sin_addr), info->client_info.sin_port);
    
13. 
    
14.     while(1) {
    0 k2 W- G& j8 T
15.         s32 ret = read(info->id, rec_data, 1500);
    3 _- y) V% |" \( q( f4 D
16. 
    
17.         if(ret > 0) {
    
18.             WDBG("PORT:%d rec[%d]:%d",info->port, info->id, ret);
      H6 e" y, Z" T! }. M
19.             ret = write(info->id, rec_data, ret);
    
20. 
    9 U$ a  |" S8 J3 `: Y' u1 |# n5 w
21.             if(ret <  0) {
    6 W0 Z1 k' h/ E" F3 H. _
22.                 WDBG("PORT:%d client[%d] write err:%s:%d",info->port, info->id,
    
23.                     inet_ntoa(info->client_info.sin_addr), info->client_info.sin_port);
    
24.                 sys_free(rec_data);
    
25.                 osThreadExit();
    
26.             }
    
27.         } else if(ret < 0 ) {
    / \- Q6 }) o! }$ T
28.             WDBG("PORT:%d client[%d] read err:%s:%d", info->port,info->id,
    
29.                     inet_ntoa(info->client_info.sin_addr), info->client_info.sin_port);
    . s  L& ^" P3 s7 k0 \+ |* E
30.             close(info->id);
    # G1 [- X, o. e  a0 A, V
31.             sys_free(rec_data);
    3 O& A% @3 I- R% b
32.             osThreadExit();
    
33.         }            
    
34.     }
      V/ ?7 \" E- Q) N
35. }
    
36. 
    
37. typedef struct {
    
38.     u16 port;
    3 ^# w% U$ ?- M6 u6 y& x
39.     u8 cnt;
    
40.     u8 rvd;
    
41. } server_parm_s;
    
42. 
    
43. void create_tcp_task(void* pram) {
    
44.     server_parm_s parm;
    8 t6 X7 x, H) [% h( {
45.     memcpy(&parm, &pram, 4);
    % [5 K8 S5 \7 J# |! j
46.     WDBG("TCP SEVER port:%d cnt:%d", parm.port, parm.cnt);
    ; S7 g# R0 \7 j" f) a; H/ u$ I% v# y
47.     int listenfd, connfd;
    
48.     struct sockaddr_in servaddr;
    8 j- y/ }6 z0 e
49.     struct sockaddr client_addr;
    * k- D% s' y1 x. {; e/ w
50. 
    
51.     if( (listenfd = socket(AF_INET, SOCK_STREAM, 0)) == -1 )
    
52.     {
    % C1 r1 r$ f% A
53.         WDBG("create socket error: %s(errno: %d)",strerror(errno),errno);
    ( e3 y5 a' S* x- y1 s
54.         while(1);
    2 N. D; [6 o8 j3 ~: m5 @7 _
55.     }
    ; w! [: n+ f* [7 J
56.     memset(&servaddr, 0, sizeof(servaddr));
    9 M* z  w0 q# j% X' }5 N. k
57.     servaddr.sin_family = AF_INET;
    0 w3 l4 W! |; b; @
58.     servaddr.sin_addr.s_addr = htonl(INADDR_ANY);            
    8 ^) X' `5 m4 ^* m
59.     servaddr.sin_port = htons(parm.port);
    
60. 
    % u  T0 ~% t1 Q
61.     if( bind(listenfd, (struct sockaddr*)&servaddr, sizeof(servaddr)) == -1)
    
62.     {
    9 e* R& e2 h! g% Y5 Y
63.         WDBG("bind socket error: %s(errno: %d)",strerror(errno),errno);
    
64.         while(1);
    7 s) u4 H& h" D* d" X
65.     }
    ( F' n( C) [5 J, S6 @/ w% O& m
66. 
    
67.     if( listen(listenfd, parm.cnt) == -1)
    5 X! G4 S$ P) A; Q+ m7 {
68.     {
    0 M/ n3 ~7 e# J' b) g- L
69.         WDBG("listen socket error: %s(errno: %d)",strerror(errno),errno);
    
70.     }
    
71. 
    
72.     while(1)
    
73.     {
    6 w- ]: {( p3 T; i
74.         socklen_t socklen = sizeof(client_addr);
    : [) B/ y$ x' i# x% K9 h
75.         memset(&client_addr, 0, sizeof(client_addr));
    
76.         if( (connfd = accept(listenfd, (struct sockaddr*)&client_addr, &socklen)) == -1)
    9 |. r. M& d& Y) ]6 g- E
77.         {
    . D8 S. w+ C- @( t/ O
78.             WDBG("accept socket error: %s(errno: %d)",strerror(errno),errno);
    # a+ Z& s. v- q+ a0 B7 l. B
79.             continue;
    
80.         }
    
81. 
    
82.         client_info_s* client = sys_malloc(sizeof(client_info_s));
    0 O0 a# o+ [/ @+ M* ?# e' K  R
83. 
    
84.         if(client) {
    " H7 U0 w+ q3 F4 [
85.             client->client_info = *(struct sockaddr_in*)&client_addr;
    ; @1 z7 H8 I  D6 B* b+ E
86.             client->id = connfd;
    
87.             client->port = parm.port;
    0 `! s( u8 n7 u& |, ~2 q- r
88.             osThreadNew(client_proc,(void*)client, NULL);
    6 p. _) m; G6 Y8 X1 O9 u
89.         }
    . d, \- {6 E: d: N: R( l6 D
90. 
    * x7 A3 D: W$ [6 `
91.     }
    7 V' u# J% Z. y
92. }
    
93. 
    
94. void create_tcp_server(u16 port, u16 cnt){
    . C* m1 i# {7 V
95.     server_parm_s parm;
    * P0 I& f6 X8 W$ [) ^: A2 v8 |
96.     parm.port = port;
    * |  \3 b. I; z, l
97.     parm.cnt = cnt;
    / ]7 \! r) Q+ A/ G( H; O- h
98.     u32* ptr =(u32*)&parm;
    9 E% Q" A5 r7 ~3 O/ m$ O
99.    osThreadNew(create_tcp_task,(void*)(ptr[0]), NULL);
    
100. }

复制代码

4 a3 h, O1 e4 Q, o1 i. ^非阻塞方式：
* e; f/ ?) _3 V- r+ i. g. d
9 z) F3 O6 R+ t2 q! }" K: _

1. void trace_task(void *argument) {
   
2.     const TickType_t xBlockTime = pdMS_TO_TICKS(50);
   
3.     u8* read_buf = malloc(128);
   
4.     WDBG("TCP SEVER port:%d", 1234);
   
5.     int listenfd = -1;
   
6.     int connfd = -1;
   
7.     struct sockaddr_in servaddr;
   3 ~6 _- Q  H! d7 T
8.     struct sockaddr_in client_addr;
   : F- z. e5 p- C5 i! Q+ l
9. 
   
10.     if( (listenfd = socket(AF_INET, SOCK_STREAM, 0)) == -1 )
    4 l3 H8 e" @6 g: \( b7 w
11.     {
      q7 a' ?( f1 D( q# o
12.         WDBG("create socket error: %s(errno: %d)",strerror(errno),errno);
    
13.         while(1);
    
14.     }
    
15.     memset(&servaddr, 0, sizeof(servaddr));
    
16.     servaddr.sin_family = AF_INET;
    
17.     servaddr.sin_addr.s_addr = htonl(INADDR_ANY);            
    
18.     servaddr.sin_port = htons(1234);
    
19. 
    
20.     if( bind(listenfd, (struct sockaddr*)&servaddr, sizeof(servaddr)) == -1)
    
21.     {
    
22.         WDBG("bind socket error: %s(errno: %d)",strerror(errno),errno);
    - |0 r; ]' V8 z1 P
23.         while(1);
    
24.     }
    5 n- I( A" ?* ~: m
25. 
    5 I9 d& @' h& N$ k. ]
26.     if( listen(listenfd, 3) == -1)
    
27.     {
    ' |! C0 Y* B3 S+ U3 Q$ G
28.         WDBG("listen socket error: %s(errno: %d)",strerror(errno),errno);
    
29.     }
    # ^  y& X2 k$ W: N
30. 
    
31.     {
    8 r- M; R. n" x$ z: `% k; E
32.         DWORD nMode = 1;
    
33.         ioctlsocket( listenfd, FIONBIO, &nMode );        
    " Z  K& z* y' v* G8 U
34.     }
    / W$ T5 I& K8 @3 f% z  {! B
35. 
    
36.     fd_set fdRead;
    
37.     fd_set fd_err;
    1 L7 L$ P# ^: Y+ d, c) A- D$ M
38.     struct timeval tv;
      m* S& s# N  N
39.     socklen_t socklen = sizeof(client_addr);
    
40.     memset(&client_addr, 0, sizeof(client_addr));
    9 q0 s8 k8 P0 l4 ]0 R2 ?2 U( S
41. 
    
42.     while(1) {
    
43.         FD_ZERO(&fdRead);
    
44.         FD_ZERO(&fd_err);  
    
45.         FD_SET( listenfd, &fdRead);
    5 U" \* R; |* H( F
46.         u8 cnt = 2;
    9 Z' |' I# O9 B8 `9 L0 D. q* A) M
47.         if(connfd != -1) {
    
48.             cnt++;
    
49.             FD_SET(connfd, &fdRead);
    
50.             FD_SET(connfd, &fd_err);
    ! @8 ^3 k/ n* u  m: P. B: Y
51.         }
    1 ~% o5 `$ |) ^( y5 g
52. 
    ) F$ s9 l  I: `" g- H! O7 Y$ ?
53.         if(connfd != -1) {
    ( u: b& x- P4 w' h8 {$ n  T
54.             u32 rec_size = xStreamBufferReceive( g_trace_handle,
    
55.                     ( void * ) read_buf, 128, xBlockTime);
    
56.             if(rec_size) {
    . m- \& t/ E+ H. b! w& h& A
57.                 s32 ret = send(connfd, read_buf, rec_size, 0);
    ; S* S& v# b( C$ V4 O4 j
58. 
    
59.                 if(ret <  0)  {
    
60.                     closesocket(connfd);
    8 z  \: j) ?0 P( I
61.                     connfd = -1;
    
62.                     continue;
    
63.                 }
    ' X6 z2 z! x* k) M; x  G
64.             }
    ; K9 r3 x. E! T% o
65. 
    
66.         }
    " j+ t) ^! O8 C: q. @8 ^
67. 
    
68.         tv.tv_sec  = 0;
    
69.         tv.tv_usec = 20000;
    4 s3 A  p! N8 X4 u8 U& ~
70.         s32 ret = select(cnt, &fdRead, NULL, &fd_err, &tv);
    ( q$ R9 g. ~9 |
71. 
    
72.         if(ret == 0) {
    
73. 
    
74.             continue;
    
75.         }
    
76. 
    
77.         if(ret > 0) {
    ; O! ]) @" |" O3 k
78.             if(connfd != -1 && FD_ISSET(connfd, &fd_err)){//rec.
    . f  o, t' q0 L2 x+ i8 ?0 }
79.                 connfd = -1;
    
80.                 continue;
    
81.             }
    5 `+ b, B3 |0 \  H
82. 
    * A0 x/ x. s+ L4 P& b, }
83.             if(connfd != -1 && FD_ISSET(connfd, &fdRead)){//rec.
    ) ?) f( o% e' B) v* [  m
84.                 ret = recv(connfd, read_buf, 128, 0);
    ; A( v# O+ b! k$ w$ P5 f. O) z7 @0 q
85.                 if(ret < 0) {
    7 H+ l# b% s, Q( f
86.                     closesocket(connfd);
    
87.                     connfd = -1;
    ! V: @5 R, ~! K% Q9 `* U
88.                     continue;
    
89.                 } else if(ret >0) {
    0 \, ]: h5 C7 ^  s
90.                     WDBG("rec size:%d", ret);
    3 D4 ^! U: ~# n, A
91.                 }
    
92.             }   
    ; I5 X8 I- t) x1 ~
93. 
    
94.             if(FD_ISSET(listenfd, &fdRead)) {
    - q+ j3 a' g. U( N% @7 m( _. E' T
95.                 s32 temp = accept(listenfd, (struct sockaddr*)&client_addr, &socklen);
    
96.                 // WDBG("-client:[%d] %s:%dn", temp, inet_ntoa(client_addr.sin_addr), ntohs(client_addr.sin_port));
    5 R, X" H- i6 X+ h+ i" z" ~
97. 
    8 F: W1 R, B( R# u  |7 r/ j
98.                 if(connfd == -1) {
    
99.                     connfd = temp;
    : {2 [3 c) k! g  X6 g& r9 P
100.                 } else {
     ' t$ F% U9 O( y% t  a
101.                     closesocket(temp);
     0 n" z6 ?6 R% {: T8 F: D
102.                 }
     6 j4 h% N4 g& X( }
103.             }        
     
104.         }
     
105.     }
     
106.     #endif
     , y. H4 @" t7 k: ?% P, y" N
107. }
     
108. 
     

复制代码

4 N/ i& q0 _4 ~8 n5 ]7 R