Chinaunix首页 | 论坛 | 博客
  • 博客访问: 1738784
  • 博文数量: 347
  • 博客积分: 9328
  • 博客等级: 中将
  • 技术积分: 2680
  • 用 户 组: 普通用户
  • 注册时间: 2010-07-29 23:45
文章分类

全部博文(347)

文章存档

2016年(1)

2013年(4)

2012年(207)

2011年(85)

2010年(50)

分类: 嵌入式

2012-11-13 21:58:45


Android NDK中使用socket的整个过程分为以下几部分:

第一部分: 创建socket并绑定IP和端口

  1. #include <sys/select.h>
  2. #include <sys/socket.h>
  3. #include <arpa/inet.h>

  4. #define MAX_DATA_BUF_LEN 10240

  5. int sd = INVALID_SOCKET;
  6. sockaddr_in addr_org; // 发送端地址

  7. sd = socket(AF_INET, SOCK_DGRAM, IPPROTO_UDP); // 创建socket

  8. addr_org.sin_family = AF_INET;
  9. addr_org.sin_addr.s_addr = inet_addr("192.128.0.1"); // 发送端IP
  10. addr_org.sin_port = htons(8080); // 发送端端口

  11. bind(sd, (struct sockaddr *)&(addr_org), sizeof(struct sockaddr_in)); // 绑定IP和端口

第二部分: 发送数据

  1. sockaddr_in addr_dst; // 接收端地址

  2. addr_dst.sin_family = AF_INET;
  3. addr_dst.sin_addr.s_addr = inet_addr("192.128.0.2"); // 接收端IP
  4. addr_dst.sin_port = htons(8080); // 接收端端口

  5. ... // 生成要发送的数据到SendDataBuff, 长度为ulLen
  6. sendto(sd, SendDataBuff, ulLen, 0, (struct sockaddr *)&(addr_dst), sizeof(sockaddr_in)); // 发送SendDataBuff中的数据

第三部分: 在线程中接收数据(非阻塞式)

  1. void *SocketReceiveThread(void *pParam)
  2. {
  3.     fd_set fdset;
  4.     struct timeval delayval;
  5.     unsigned long lRetVal;

  6.     delayval.tv_sec = 0;
  7.     delayval.tv_usec = 5000; /*5ms延时*/

  8.     while (!end_flag)
  9.     {
  10.         FD_ZERO(&fdset);
  11.         FD_SET(sd, &fdset);

  12.         lRetVal = select(sd+1, &fdset, NULL, NULL, &delayval); // 尤其要注意第一个参数
  13.         if (0 == lRetVal)
  14.         {
  15.             continue;
  16.         }
  17.         else if (SOCKET_ERROR == lRetVal)
  18.         {
  19.             break;
  20.         }
  21.         else if (FD_ISSET(sd, &fdset) != 0)
  22.         {
  23.             char RecvDataBuff[MAX_DATA_BUF_LEN]; // 接收数据buffer
  24.             unsigned long ulLen = recvfrom(sd, RecvDataBuff, MAX_DATA_BUF_LEN, 0, NULL, NULL);
  25.             ... // 处理接收到的数据
  26.         }
  27.     }
  28. }

第四部分: 关闭socket

  1. close(sd);

阅读(2230) | 评论(0) | 转发(1) |
给主人留下些什么吧!~~