udpclient.c 1.5 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950
  1. #include <rtthread.h>
  2. #include <lwip/netdb.h> /* 为了解析主机名,需要包含netdb.h头文件 */
  3. #include <lwip/sockets.h> /* 使用BSD socket,需要包含sockets.h头文件 */
  4. const char send_data[] = "This is UDP Client from RT-Thread.\n"; /* 发送用到的数据 */
  5. void udpclient(const char* url, int port, int count)
  6. {
  7. int sock;
  8. struct hostent *host;
  9. struct sockaddr_in server_addr;
  10. /* 通过函数入口参数url获得host地址(如果是域名,会做域名解析) */
  11. host= (struct hostent *) gethostbyname(url);
  12. /* 创建一个socket,类型是SOCK_DGRAM,UDP类型 */
  13. if ((sock = socket(AF_INET, SOCK_DGRAM, 0)) == -1)
  14. {
  15. rt_kprintf("Socket error\n");
  16. return;
  17. }
  18. /* 初始化预连接的服务端地址 */
  19. server_addr.sin_family = AF_INET;
  20. server_addr.sin_port = htons(port);
  21. server_addr.sin_addr = *((struct in_addr *)host->h_addr);
  22. rt_memset(&(server_addr.sin_zero), 0, sizeof(server_addr.sin_zero));
  23. /* 总计发送count次数据 */
  24. while (count)
  25. {
  26. /* 发送数据到服务远端 */
  27. sendto(sock, send_data, strlen(send_data), 0,
  28. (struct sockaddr *)&server_addr, sizeof(struct sockaddr));
  29. /* 线程休眠一段时间 */
  30. rt_thread_delay(50);
  31. /* 计数值减一 */
  32. count --;
  33. }
  34. /* 关闭这个socket */
  35. lwip_close(sock);
  36. }
  37. #ifdef RT_USING_FINSH
  38. #include <finsh.h>
  39. /* 输出udpclient函数到finsh shell中 */
  40. FINSH_FUNCTION_EXPORT(udpclient, startup udp client);
  41. #endif