STM32F7 LWIP socket 创建TCP server
8 m8 H0 W  \5 }3 |

1. **阻塞方式：**

复制代码

1. typedef struct {
   
2.     struct sockaddr_in client_info;
   # ?( p0 M; B; n
3.     s32 id;
   
4.     u16 port;
   5 y* g2 }& _, [( `' _
5. } client_info_s;
   % N' ]& o: C3 U2 ^/ ~
6. 
   
7. void client_proc(void* parm) {
   
8.     client_info_s* info = (client_info_s*)parm;
   
9.     u8* rec_data = sys_malloc(1500);
   7 X/ L; B" `1 |9 s2 P" t2 Q
10. 
    
11.     WDBG("PORT:%d client[%d] %s:%d\n", info->port, info->id,
    / s& o! t+ j1 m
12.         inet_ntoa(info->client_info.sin_addr), info->client_info.sin_port);
    3 C3 }1 n: t- k! e1 i, Q( I' z0 @
13. 
    " T& Z/ N8 [! F
14.     while(1) {
    ; |! ~/ b$ O# f1 s
15.         s32 ret = read(info->id, rec_data, 1500);
    ) F. z6 U  t( _" c( V
16. 
    
17.         if(ret > 0) {
    
18.             WDBG("PORT:%d rec[%d]:%d",info->port, info->id, ret);
    + s+ L( @! U8 o( ^0 C& x( K+ ]
19.             ret = write(info->id, rec_data, ret);
    # Z' e( `" L8 ]4 h* {. F$ G" a# N
20. 
    ' P; [$ e* r8 u# X3 \
21.             if(ret <  0) {
    
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 ) {
      t$ }( r0 B7 e0 j4 ~7 F
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. e& O( T' r) r& [& ]5 F% b
30.             close(info->id);
    $ B- X+ ^6 d! h
31.             sys_free(rec_data);
    ! `; X8 V) k- P9 q; J
32.             osThreadExit();
    . Y. W$ k# O2 l% [# ?  y  c% b
33.         }            
    
34.     }
    # ^0 d. Q0 v; l* s
35. }
    * u9 l( T4 V! _3 q: f/ r
36. 
    
37. typedef struct {
    # K. Q7 b' k$ e; g' J: B
38.     u16 port;
    
39.     u8 cnt;
    + p1 n# ?! I" e( X/ W
40.     u8 rvd;
    
41. } server_parm_s;
    
42. 
    
43. void create_tcp_task(void* pram) {
    
44.     server_parm_s parm;
    % q5 c) c" {- s# {# ^) z2 |
45.     memcpy(&parm, &pram, 4);
    
46.     WDBG("TCP SEVER port:%d cnt:%d", parm.port, parm.cnt);
    0 q3 y5 o5 {! \8 a. W" l! z
47.     int listenfd, connfd;
    & R) p0 v# J/ e1 N" T" J
48.     struct sockaddr_in servaddr;
    
49.     struct sockaddr client_addr;
    
50. 
    
51.     if( (listenfd = socket(AF_INET, SOCK_STREAM, 0)) == -1 )
    " L/ S4 ~7 W: b8 I% C' J
52.     {
    : O: N2 `( J4 B+ `
53.         WDBG("create socket error: %s(errno: %d)",strerror(errno),errno);
    
54.         while(1);
    
55.     }
    
56.     memset(&servaddr, 0, sizeof(servaddr));
    8 `, f! ]9 H: z/ _7 ?1 p, V
57.     servaddr.sin_family = AF_INET;
    2 Y( ?) K) e9 m9 e. R1 I& n
58.     servaddr.sin_addr.s_addr = htonl(INADDR_ANY);            
    ( ]2 F! C( ?6 d! Y. r
59.     servaddr.sin_port = htons(parm.port);
    
60. 
    % _& `. ?( `3 R3 d
61.     if( bind(listenfd, (struct sockaddr*)&servaddr, sizeof(servaddr)) == -1)
    ! M) z6 q. x+ j
62.     {
    0 c3 V4 N8 ~* G. d. v, k7 N
63.         WDBG("bind socket error: %s(errno: %d)",strerror(errno),errno);
    
64.         while(1);
    " c" [6 Z* Y' Y7 [6 c
65.     }
      x9 W# O" N* @9 Y6 v
66. 
    " k% n9 ?, _9 y" L0 i0 x6 L9 f
67.     if( listen(listenfd, parm.cnt) == -1)
    8 X2 f3 e1 b" y% Y
68.     {
    - @9 u+ j9 ~/ y( L! K: J" q
69.         WDBG("listen socket error: %s(errno: %d)",strerror(errno),errno);
    6 n. e0 t" T# g% W2 G& \# k
70.     }
    
71. 
    
72.     while(1)
    3 M9 u8 M" T0 B6 ]! m) R
73.     {
    
74.         socklen_t socklen = sizeof(client_addr);
    
75.         memset(&client_addr, 0, sizeof(client_addr));
    
76.         if( (connfd = accept(listenfd, (struct sockaddr*)&client_addr, &socklen)) == -1)
    . h$ |9 \' ~% j( ^- O: U
77.         {
    , ]* x5 k8 h6 J: G
78.             WDBG("accept socket error: %s(errno: %d)",strerror(errno),errno);
    + c& Y/ X0 T1 v# j2 D/ P2 _8 \
79.             continue;
    
80.         }
    7 D' x6 Z0 @9 `
81. 
    
82.         client_info_s* client = sys_malloc(sizeof(client_info_s));
    7 h) W$ D& ]' v% ?) ?
83. 
    
84.         if(client) {
    
85.             client->client_info = *(struct sockaddr_in*)&client_addr;
    
86.             client->id = connfd;
    ) H- O/ h2 U7 ]- z' Y2 r+ f
87.             client->port = parm.port;
    / h5 t6 {$ N$ I  W& W; Z
88.             osThreadNew(client_proc,(void*)client, NULL);
    4 s$ t$ j; c# C: m* _
89.         }
    
90. 
    
91.     }
    
92. }
    
93. 
    2 S+ x+ B7 p7 b4 w: d6 ?
94. void create_tcp_server(u16 port, u16 cnt){
    ; h; N& X' R- `' u- m
95.     server_parm_s parm;
    4 e0 W6 n: j9 t" \) n
96.     parm.port = port;
    
97.     parm.cnt = cnt;
    2 i' q& @) ?; Q8 s
98.     u32* ptr =(u32*)&parm;
    + ^3 r1 A% a4 c1 G# g" h
99.    osThreadNew(create_tcp_task,(void*)(ptr[0]), NULL);
    
100. }

复制代码

* w4 A5 r* \8 D# f非阻塞方式：

1. void trace_task(void *argument) {
   8 @1 D" [) {7 O7 l* N
2.     const TickType_t xBlockTime = pdMS_TO_TICKS(50);
   
3.     u8* read_buf = malloc(128);
   
4.     WDBG("TCP SEVER port:%d", 1234);
   ! b4 C3 P. \* _  f, ^9 w
5.     int listenfd = -1;
   
6.     int connfd = -1;
   
7.     struct sockaddr_in servaddr;
   , O6 M1 Z+ X' [" Z! x- t3 T. z
8.     struct sockaddr_in client_addr;
   
9. 
   7 ]: H0 j  u4 }4 Z
10.     if( (listenfd = socket(AF_INET, SOCK_STREAM, 0)) == -1 )
    
11.     {
    " P+ M' S% L6 k* C/ S
12.         WDBG("create socket error: %s(errno: %d)",strerror(errno),errno);
    
13.         while(1);
    
14.     }
    1 H( o6 Z* R+ f3 h+ G4 u
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)
    5 d* ?& W5 ]; F+ q) ^
21.     {
    
22.         WDBG("bind socket error: %s(errno: %d)",strerror(errno),errno);
    
23.         while(1);
    
24.     }
    : \% T3 l- B8 [8 \) ]; o
25. 
    ) [3 P8 A+ _4 B' f* D
26.     if( listen(listenfd, 3) == -1)
    
27.     {
    
28.         WDBG("listen socket error: %s(errno: %d)",strerror(errno),errno);
    $ r' ^  R( ~4 c2 `
29.     }
    3 Q1 }/ X( Q4 |' A8 e
30. 
    * V' y! w# g! K, M
31.     {
    4 z0 X; r5 I) s% t. B8 b. l9 m
32.         DWORD nMode = 1;
    
33.         ioctlsocket( listenfd, FIONBIO, &nMode );        
    
34.     }
    ( J- v* N/ E3 U+ p' D
35. 
    
36.     fd_set fdRead;
    
37.     fd_set fd_err;
    $ T3 _. ?6 I, @/ k2 `
38.     struct timeval tv;
    5 ?0 B4 ?: V  H/ [& _; N
39.     socklen_t socklen = sizeof(client_addr);
    
40.     memset(&client_addr, 0, sizeof(client_addr));
    % q! R9 _0 Y: R
41. 
    : X/ B6 u4 o7 D; q& G' ?# p
42.     while(1) {
    2 J/ v/ j5 {$ H6 {& N! C5 s
43.         FD_ZERO(&fdRead);
    % ?* U. s* H7 L- K
44.         FD_ZERO(&fd_err);  
    
45.         FD_SET( listenfd, &fdRead);
    ! K, s5 \6 l+ u& \4 `
46.         u8 cnt = 2;
    
47.         if(connfd != -1) {
    3 x# V+ \/ Y, Z' {; y# V% z' j+ k
48.             cnt++;
    2 z+ h. h5 ]. Y
49.             FD_SET(connfd, &fdRead);
    
50.             FD_SET(connfd, &fd_err);
    : M- K  ?. d3 k( k6 U6 f1 }
51.         }
    : @; m- T. R7 X0 p" }
52. 
    - P) K" d# F# A4 D. ^3 M
53.         if(connfd != -1) {
    
54.             u32 rec_size = xStreamBufferReceive( g_trace_handle,
    # d, D! f6 n' B+ c2 }8 p2 g
55.                     ( void * ) read_buf, 128, xBlockTime);
    
56.             if(rec_size) {
    
57.                 s32 ret = send(connfd, read_buf, rec_size, 0);
    4 f0 r5 F& C5 ~& |2 S9 i2 y( U
58. 
    - j. s! \2 Z' _
59.                 if(ret <  0)  {
    
60.                     closesocket(connfd);
    
61.                     connfd = -1;
    9 F/ e- T/ c1 j, S
62.                     continue;
    
63.                 }
    
64.             }
    
65. 
    1 @# h& t+ V) p* R* @) D5 U
66.         }
    ( X' T/ H9 L& {( j3 n/ F5 }2 o
67. 
    - u( a1 ?. B, J2 n% P# u, C* @. [
68.         tv.tv_sec  = 0;
    
69.         tv.tv_usec = 20000;
    , }5 p9 q, @. ]& ?# B" L7 f
70.         s32 ret = select(cnt, &fdRead, NULL, &fd_err, &tv);
    5 ^7 \  w( Z, N
71. 
    
72.         if(ret == 0) {
    * t1 A' N! e! [$ [7 m; e
73. 
    2 @6 @1 c( ~' w# P# c
74.             continue;
    ; Q6 O& j0 T/ @' M' d' J3 t2 d: Y4 i( a
75.         }
    : G) G5 @  T) a6 o
76. 
    6 I3 k- C5 ~. e5 i
77.         if(ret > 0) {
    
78.             if(connfd != -1 && FD_ISSET(connfd, &fd_err)){//rec.
    / E8 E! Q0 b3 Q  X4 b1 x
79.                 connfd = -1;
    
80.                 continue;
    
81.             }
    9 n3 P& O" k* T5 O  e
82. 
    
83.             if(connfd != -1 && FD_ISSET(connfd, &fdRead)){//rec.
    " w0 D3 ^1 a4 O" S7 y. a( K: O; s
84.                 ret = recv(connfd, read_buf, 128, 0);
    1 p* [  C4 L% c* P
85.                 if(ret < 0) {
    
86.                     closesocket(connfd);
    
87.                     connfd = -1;
    ; z5 A  Q1 c) w" [7 b! y& \
88.                     continue;
    
89.                 } else if(ret >0) {
    
90.                     WDBG("rec size:%d", ret);
    
91.                 }
    
92.             }   
    
93. 
    
94.             if(FD_ISSET(listenfd, &fdRead)) {
    
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));
    
97. 
    2 [8 ]( ^: p& l. a% c
98.                 if(connfd == -1) {
    . w8 \5 r, c7 j. V5 Z$ K/ e3 J
99.                     connfd = temp;
    
100.                 } else {
     
101.                     closesocket(temp);
     
102.                 }
     8 a. d$ K; @; R+ }! v/ s; m
103.             }        
     
104.         }
     # l+ H* D3 w& Q- s  A3 F
105.     }
     + |( n# `2 y0 G# v4 r+ }
106.     #endif
     ; \! p: ^6 y" p+ X/ U
107. }
     : ?- b3 D% T- y
108. 
     

复制代码

6 B4 G$ v% a/ x2 l) u