[EVAL-WSN]6LowPan——UDP Client客户端

dvd1478

上期说了[EVAL-WSN]6LowPan——UDP Serverhttps://www.cirmall.com/bbs/foru ... 1&fromuid=23447

这期说 UDP  Client

UDP 客户端程序
struct uip_udp_conn *
udp_new(const uip_ipaddr_t *ripaddr, uint16_t port, void *appstate)
传入的参数分别是远程UDP服务器地址，服务器端口和应用程序定义的指针（一般为NULL），
返回的是建立的连接，如：
client_conn = udp_new(&ipaddr, UIP_HTONS(3000), NULL);
/* new connection with remote host */
  client_conn = udp_new(&ipaddr, UIP_HTONS(3000), NULL);/*远程端口*/
  udp_bind(client_conn, UIP_HTONS(3001)); /*本节点端口*/

UDP Client 区别与 UDP Server
UDP Server 的实现http://blog.sina.com.cn/s/blog_7e7fa4c80102w9da.html

Wireshark 抓取的数据




源代码

1. 
   
2. #include "contiki.h"
   
3. #include "contiki-lib.h"
   
4. #include "contiki-net.h"
   
5. #include "net/ip/resolv.h"
   
6. 
   
7. #include <string.h>
   
8. #include <stdbool.h>
   
9. 
   
10. #define DEBUG DEBUG_PRINT
    
11. #include "net/ip/uip-debug.h"
    
12. 
    
13. #define SEND_INTERVAL                15 * CLOCK_SECOND
    
14. #define MAX_PAYLOAD_LEN                40
    
15. 
    
16. static struct uip_udp_conn *client_conn;
    
17. /*---------------------------------------------------------------------------*/
    
18. PROCESS(udp_client_process, "UDP client process");
    
19. AUTOSTART_PROCESSES(&resolv_process,&udp_client_process);
    
20. /*---------------------------------------------------------------------------*/
    
21. static void
    
22. tcpip_handler(void)
    
23. {
    
24.   char *str;
    
25. 
    
26.   if(uip_newdata()) {
    
27.     str = uip_appdata;
    
28.     str[uip_datalen()] = '\0';
    
29.     printf("Response from the server: '%s'\n", str);
    
30.   }
    
31. }
    
32. /*---------------------------------------------------------------------------*/
    
33. static char buf[MAX_PAYLOAD_LEN];
    
34. static void
    
35. timeout_handler(void)
    
36. {
    
37.   static int seq_id;
    
38. 
    
39.   printf("Client sending to: ");
    
40.   PRINT6ADDR(&client_conn->ripaddr);
    
41.   sprintf(buf, "Hello %d from the client", ++seq_id);
    
42.   printf(" (msg: %s)\n", buf);
    
43. #if SEND_TOO_LARGE_PACKET_TO_TEST_FRAGMENTATION
    
44.   uip_udp_packet_send(client_conn, buf, UIP_APPDATA_SIZE);
    
45. #else /* SEND_TOO_LARGE_PACKET_TO_TEST_FRAGMENTATION */
    
46.   uip_udp_packet_send(client_conn, buf, strlen(buf));
    
47. #endif /* SEND_TOO_LARGE_PACKET_TO_TEST_FRAGMENTATION */
    
48. }
    
49. /*---------------------------------------------------------------------------*/
    
50. static void
    
51. print_local_addresses(void)
    
52. {
    
53.   int i;
    
54.   uint8_t state;
    
55. 
    
56.   PRINTF("Client IPv6 addresses: ");
    
57.   for(i = 0; i < UIP_DS6_ADDR_NB; i++) {
    
58.     state = uip_ds6_if.addr_list[i].state;
    
59.     if(uip_ds6_if.addr_list[i].isused &&
    
60.        (state == ADDR_TENTATIVE || state == ADDR_PREFERRED)) {
    
61.       PRINT6ADDR(&uip_ds6_if.addr_list[i].ipaddr);
    
62.       PRINTF("\n");
    
63.     }
    
64.   }
    
65. }
    
66. /*---------------------------------------------------------------------------*/
    
67. #if UIP_CONF_ROUTER
    
68. static void
    
69. set_global_address(void)
    
70. {
    
71.   uip_ipaddr_t ipaddr;
    
72. 
    
73.   uip_ip6addr(&ipaddr, 0xaaaa, 0, 0, 0, 0, 0, 0, 0);
    
74.   uip_ds6_set_addr_iid(&ipaddr, &uip_lladdr);
    
75.   uip_ds6_addr_add(&ipaddr, 0, ADDR_AUTOCONF);
    
76. }
    
77. #endif /* UIP_CONF_ROUTER */
    
78. /*---------------------------------------------------------------------------*/
    
79. static resolv_status_t
    
80. set_connection_address(uip_ipaddr_t *ipaddr)
    
81. {
    
82. #define UDP_CONNECTION_ADDR aaaa::1
    
83.   
    
84. #ifndef UDP_CONNECTION_ADDR
    
85. #if RESOLV_CONF_SUPPORTS_MDNS
    
86. #define UDP_CONNECTION_ADDR       contiki-udp-server.local
    
87. #elif UIP_CONF_ROUTER
    
88. #define UDP_CONNECTION_ADDR       aaaa:0:0:0:0212:7404:0004:0404
    
89. #else
    
90. #define UDP_CONNECTION_ADDR       fe80:0:0:0:6466:6666:6666:6666
    
91. #endif
    
92. #endif /* !UDP_CONNECTION_ADDR */
    
93. 
    
94. #define _QUOTEME(x) #x
    
95. #define QUOTEME(x) _QUOTEME(x)
    
96. 
    
97.   resolv_status_t status = RESOLV_STATUS_ERROR;
    
98. 
    
99.   if(uiplib_ipaddrconv(QUOTEME(UDP_CONNECTION_ADDR), ipaddr) == 0) {
    
100.     uip_ipaddr_t *resolved_addr = NULL;
     
101.     status = resolv_lookup(QUOTEME(UDP_CONNECTION_ADDR),&resolved_addr);
     
102.     if(status == RESOLV_STATUS_UNCACHED || status == RESOLV_STATUS_EXPIRED) {
     
103.       PRINTF("Attempting to look up %s\n",QUOTEME(UDP_CONNECTION_ADDR));
     
104.       resolv_query(QUOTEME(UDP_CONNECTION_ADDR));
     
105.       status = RESOLV_STATUS_RESOLVING;
     
106.     } else if(status == RESOLV_STATUS_CACHED && resolved_addr != NULL) {
     
107.       PRINTF("Lookup of "%s" succeded!\n",QUOTEME(UDP_CONNECTION_ADDR));
     
108.     } else if(status == RESOLV_STATUS_RESOLVING) {
     
109.       PRINTF("Still looking up "%s"...\n",QUOTEME(UDP_CONNECTION_ADDR));
     
110.     } else {
     
111.       PRINTF("Lookup of "%s" failed. status = %d\n",QUOTEME(UDP_CONNECTION_ADDR),status);
     
112.     }
     
113.     if(resolved_addr)
     
114.       uip_ipaddr_copy(ipaddr, resolved_addr);
     
115.   } else {
     
116.     status = RESOLV_STATUS_CACHED;
     
117.   }
     
118. 
     
119.   return status;
     
120. }
     
121. /*---------------------------------------------------------------------------*/
     
122. PROCESS_THREAD(udp_client_process, ev, data)
     
123. {
     
124.   static struct etimer et;
     
125.   uip_ipaddr_t ipaddr;
     
126. 
     
127.   PROCESS_BEGIN();
     
128.   PRINTF("UDP client process started\n");
     
129. 
     
130. #if UIP_CONF_ROUTER
     
131.   set_global_address();
     
132. #endif
     
133. 
     
134.   print_local_addresses();
     
135. 
     
136.   static resolv_status_t status = RESOLV_STATUS_UNCACHED;
     
137.   while(status != RESOLV_STATUS_CACHED) {
     
138.     status = set_connection_address(&ipaddr);
     
139. 
     
140.     if(status == RESOLV_STATUS_RESOLVING) {
     
141.       PROCESS_WAIT_EVENT_UNTIL(ev == resolv_event_found);
     
142.     } else if(status != RESOLV_STATUS_CACHED) {
     
143.       PRINTF("Can't get connection address.\n");
     
144.       PROCESS_YIELD();
     
145.     }
     
146.   }
     
147. 
     
148.   /* new connection with remote host */
     
149.   client_conn = udp_new(&ipaddr, UIP_HTONS(3000), NULL);
     
150.   udp_bind(client_conn, UIP_HTONS(3001));
     
151. 
     
152.   PRINTF("Created a connection with the server ");
     
153.   PRINT6ADDR(&client_conn->ripaddr);
     
154.   PRINTF(" local/remote port %u/%u\n",
     
155.         UIP_HTONS(client_conn->lport), UIP_HTONS(client_conn->rport));
     
156. 
     
157.   etimer_set(&et, SEND_INTERVAL);
     
158.   while(1) {
     
159.     PROCESS_YIELD();
     
160.     if(etimer_expired(&et)) {
     
161.       timeout_handler();
     
162.       etimer_restart(&et);
     
163.     } else if(ev == tcpip_event) {
     
164.       tcpip_handler();
     
165.     }
     
166.   }
     
167. 
     
168.   PROCESS_END();
     
169. }
     
170. /*---------------------------------------------------------------------------*/
     

复制代码

wywywy

不明觉厉

糖悦之果飞

亲，可以将内容一并发到经验频道，很有机会获得每月之星的呢http://jingyan.eeboard.com/