open1081 TCP UDP ECHO例程测试

IAR的例程不知道为什么打不开，这里使用的是MDK版本。
首先修改AP_NAME和AP_PASSWORD

启动后，程序自动连接无线网络，一旦连接上即回调socket_connected，不知道这个函数是怎么被回调的，没有看到注册这个函数的地方。
然后开始读取www.baidu.com的数据。

例程太乱，为了单纯测试TCP和UDP的echo功能，我将其他代码都去掉。只保留基本功能。
下面是我修改后的代码。
TCP监听8080端口，UDP监听8090端口

1. #include "stdio.h"
   
2. #include "ctype.h"
   
3. 
   
4. #include "stm32f2xx.h"
   
5. #include "platform.h"
   
6. #include "mxchipWNET.h"
   
7. 
   
8. 
   
9. /*
   
10. Enable IEEE powersave mode,
    
11. */
    
12. //#define LowPowerMode
    
13. 
    
14. /*
    
15. Under this configuration, you can allocate every socket's send/recv buffer for application's requirement.
    
16. The more buffer is allocated, faster the speed would be, but the max connection number would be less.
    
17. If there is not enough memory for a connection:
    
18. TCP client: function: connect would return fail
    
19. TCP server: Any connection to the server would reset
    
20. If the buffer is not setted, stack would use the default size: 2048bytes.
    
21. */
    
22. //#define DynamicMemAlloc
    
23. #define AP_NAME "TP-604"
    
24. #define AP_PASSWORD "robot604"
    
25. #define WEB_SERVER "www.baidu.com"
    
26. #define APP_INFO "Open1081: TCP[8080] UDP[8090] ECHO"
    
27. 
    
28. //#define BlockMode
    
29. 
    
30. network_InitTypeDef_st wNetConfig;
    
31. lib_config_t libConfig;
    
32. int wifi_up = 0;
    
33. int webserverTest = 1;
    
34. int cloud_ip_addr = -1;
    
35. int cloud_connected = 0;
    
36. int dns_pending = 0;
    
37. extern u32 MS_TIMER;
    
38. 
    
39. void print_msg(void);
    
40. 
    
41. /* ========================================
    
42. User provide callback functions
    
43. ======================================== */
    
44. void system_version(char *str, int len)
    
45. {
    
46. snprintf(str, len, "%s", APP_INFO);
    
47. }
    
48. 
    
49. void WifiStatusHandler(int event)
    
50. {
    
51. switch (event) {
    
52. case MXCHIP_WIFI_UP:
    
53. wifi_up = 1;
    
54. printf("Station up \r\n");
    
55. break;
    
56. case MXCHIP_WIFI_DOWN:
    
57. printf("Station down \r\n");
    
58. break;
    
59. case MXCHIP_UAP_UP:
    
60. break;
    
61. case MXCHIP_UAP_DOWN:
    
62. break;
    
63. default:
    
64. break;
    
65. }
    
66. }
    
67. 
    
68. void NetCallback(net_para_st *pnet)
    
69. {
    
70. printf("IP address: %s \r\n", pnet->ip);
    
71. printf("NetMask address: %s \r\n", pnet->mask);
    
72. printf("Gateway address: %s \r\n", pnet->gate);
    
73. printf("DNS server address: %s \r\n", pnet->dns);
    
74. printf("MAC address: %s \r\n", pnet->mac);
    
75. }
    
76. 
    
77. //#ifndef BlockMode
    
78. #if 0
    
79. void dns_ip_set(u8 *hostname, u32 ip)
    
80. {
    
81. char ipstr[16];
    
82. cloud_ip_addr = ip;
    
83. dns_pending = 0;
    
84. if(cloud_ip_addr == -1)
    
85. printf("DNS test: %s failed \r\n", WEB_SERVER);
    
86. else {
    
87. inet_ntoa(ipstr, ip);
    
88. printf("DNS test: %s address is %s \r\n", WEB_SERVER, ipstr);
    
89. }
    
90. }
    
91. 
    
92. void socket_connected(int fd)
    
93. {
    
94. printf("Connect to web server success! Reading web pages...\r\n");
    
95. cloud_connected = 1;
    
96. }
    
97. #endif
    
98. 
    
99. 
    
100. int main(void)
     
101. {
     
102. int i, j, fd_listen = -1, fd_udp = -1, fd_client = -1;
     
103. char *buf, ip_address[16];
     
104. int len;
     
105. int con = -1;
     
106. 
     
107. int clientfd[8];
     
108. fd_set readfds, exceptfds;
     
109. struct timeval_t t;
     
110. struct sockaddr_t addr;
     
111. socklen_t addrLen;
     
112. 
     
113. int bufferSize;
     
114. libConfig.tcp_buf_dynamic = mxEnable;
     
115. libConfig.tcp_max_connection_num = 12;
     
116. libConfig.tcp_rx_size = 2048;
     
117. libConfig.tcp_tx_size = 2048;
     
118. libConfig.hw_watchdog = 0;
     
119. libConfig.wifi_channel = WIFI_CHANNEL_1_13;
     
120. lib_config(&libConfig);
     
121. 
     
122. for(i = 0; i < 8; i++)
     
123. clientfd[i] = -1;
     
124. 
     
125. buf = (char*)malloc(3*1024);
     
126. 
     
127. mxchipInit();
     
128. UART_Init();
     
129. 
     
130. printf("\r\n%s\r\nmxchipWNet library version: %s\r\n", APP_INFO, system_lib_version());
     
131. 
     
132. ps_enable();
     
133. 
     
134. memset(&wNetConfig, 0x0, sizeof(network_InitTypeDef_st));
     
135. wNetConfig.wifi_mode = Station;
     
136. strcpy((char*)wNetConfig.wifi_ssid, AP_NAME);
     
137. strcpy((char*)wNetConfig.wifi_key, AP_PASSWORD);
     
138. wNetConfig.dhcpMode = DHCP_Client;
     
139. StartNetwork(&wNetConfig);
     
140. printf("Connect to %s.....\r\n", wNetConfig.wifi_ssid);
     
141. 
     
142. t.tv_sec = 0;
     
143. t.tv_usec = 100;
     
144. 
     
145. set_tcp_keepalive(3, 60);
     
146. 
     
147. for (;;) {
     
148. 
     
149. mxchipTick();
     
150. 
     
151. /* Establish a TCP server that accept the tcp clients connections */
     
152. if (fd_listen == -1) {
     
153. 
     
154. fd_listen = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
     
155. bufferSize = 5*1024;
     
156. setsockopt(fd_listen, 0, SO_RDBUFLEN, &bufferSize, 4);
     
157. bufferSize = 5*1024;
     
158. setsockopt(fd_listen, 0, SO_WRBUFLEN, &bufferSize, 4);
     
159. addr.s_port = 8080;
     
160. bind(fd_listen, &addr, sizeof(addr));
     
161. listen(fd_listen, 0);
     
162. printf("TCP server established at port: %d \r\n", addr.s_port);
     
163. }
     
164. 
     
165. /* Establish a UDP port to receive any data sent to this port */
     
166. if (fd_udp == -1) {
     
167. fd_udp = socket(AF_INET, SOCK_DGRM, IPPROTO_UDP);
     
168. addr.s_port = 8090;
     
169. bind(fd_udp, &addr, sizeof(addr));
     
170. printf("Open UDP port %d\r\n", addr.s_port);
     
171. }
     
172. 
     
173. /* Check status on erery sockets */
     
174. FD_ZERO(&readfds);
     
175. FD_SET(fd_listen, &readfds);
     
176. FD_SET(fd_udp, &readfds);
     
177. 
     
178. if(fd_client!=-1)
     
179. FD_SET(fd_client, &readfds);
     
180. 
     
181. for(i = 0; i < 8; i++) {
     
182. if (clientfd[i] != -1)
     
183. FD_SET(clientfd[i], &readfds);
     
184. }
     
185. 
     
186. select(1, &readfds, NULL, &exceptfds, &t);
     
187. 
     
188. /* Check tcp connection requests */
     
189. if(FD_ISSET(fd_listen, &readfds)) {
     
190. j = accept(fd_listen, &addr, &len);
     
191. if (j > 0) {
     
192. inet_ntoa(ip_address, addr.s_ip);
     
193. printf("Client %s:%d connected\r\n", ip_address, addr.s_port);
     
194. 
     
195. for(i = 0; i < 8; i++) {
     
196. if (clientfd[i] == -1) {
     
197. clientfd[i] = j;
     
198. break;
     
199. }
     
200. }
     
201. }
     
202. }
     
203. 
     
204. /* Read data from tcp clients and send data back */
     
205. for(i = 0; i < 8; i++) {
     
206. if (clientfd[i] != -1) {
     
207. if (FD_ISSET(clientfd[i], &readfds)) {
     
208. con = recv(clientfd[i], buf, 1*1024, 0);
     
209. if (con > 0)
     
210. send(clientfd[i], buf, con, 0);
     
211. else {
     
212. close(clientfd[i]);
     
213. clientfd[i] = -1;
     
214. }
     
215. }
     
216. else if (FD_ISSET(clientfd[i], &exceptfds))
     
217. clientfd[i] = -1;
     
218. }
     
219. }
     
220. 
     
221. /* Read data from udp and send data back */
     
222. if (FD_ISSET(fd_udp, &readfds)) {
     
223. con = recvfrom(fd_udp, buf, 3*1024, 0, &addr, &addrLen);
     
224. sendto(fd_udp, buf, con, 0, &addr, sizeof(struct sockaddr_t));
     
225. }
     
226. }
     
227. }
     

复制代码

从log中可以看到open1081的IP地址是192.168.1.107

TCP echo测试，发送12，返回12

UDP echo测试，发送df，回复df

通过这个简单的echo测试例程，我们了解了socket编程的基本知识。

这个怎么看不到？

带有外链的帖子一般需要经过后台审核的，平时会很快，周末我们有人值班，可能略慢一些。