博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
iphone开发之轻松搞定原生socket 编程,阻塞与非阻塞,收发自如
阅读量:7104 次
发布时间:2019-06-28

本文共 3743 字,大约阅读时间需要 12 分钟。

iphone socket 开发

 

iphone的平台下,要进行socket开发其实有很多种的方法,开源的库Asyncsocket,官方的CFSocket,还有BSDsocket

这里要做一个简单的socket普及,这里包含在socket的设置非阻塞和超时的控制逻辑,心跳包和线程的启动时间同步的控制。

 

这里都是标准的linux的流程

先创建一个socket

 

- (int)CSocket

{

    if((sockfd = socket(AF_INET, SOCK_STREAM, 0)) == -1)

    {

      perror("socket");

      exit(errno);    

    }

    return sockfd;

}

然后是链接

//

- (BOOL)ConnectToServer:(NSString*)addr port:(int)port

{

    their_addr.sin_family = AF_INET;

    their_addr.sin_addr.s_addr = inet_addr([addr UTF8String]);

    their_addr.sin_port = htons(port);

    bzero(&(their_addr.sin_zero), 8);

    int conn = connect(sockfd, (struct sockaddr*)&their_addr, sizeof(struct sockaddr));

    NSLog(@"Connect error no is %d:",conn);

    return misConnect;

}

 

这样子的链接是阻塞的,这样子就比较不好,可以设置成非阻塞的方式来控制超时

    /***************************************************/

    //connect之前,设成非阻塞模式

    int flags = fcntl(sockfd, F_GETFL,0);

    fcntl(sockfd,F_SETFL, flags | O_NONBLOCK);

    /***************************************************

    //这是另外一种设置成非阻塞的方式

     int flags;

     if((flags = fcntl(sockfd, F_GETFL)) < 0 )

     {

     perror("fcntl F_SETFL");

     }

     flags |= O_NONBLOCK;

     if(fcntl(sockfd, F_SETFL,flags) < 0)

     {

     perror("fcntl");

     }

    ****************************************************/

设置connect后可以设置用select设置超时

/***************************************************/

    //设置超时

    fd_set          fdwrite;

    struct timeval  tvSelect;

   

    FD_ZERO(&fdwrite);

    FD_SET(sockfd, &fdwrite);

    tvSelect.tv_sec = 2;

    tvSelect.tv_usec = 0;

    int retval = select(sockfd + 1,NULL, &fdwrite, NULL, &tvSelect);

    if(retval < 0)

    {

      if ( errno == EINTR )

      {

        NSLog(@"select error");

      }

      else

      {

        NSLog(@"error");

        close(sockfd);

      }

    }

    else if(retval == 0)

    {

      NSLog(@"select timeout........");

    }

    else if(retval > 0)

    {

      misConnect = YES;

    }

 

 

 

    /***************************************************/

    //connect成功之后,设成阻塞模式

    flags = fcntl(sockfd, F_GETFL,0);

    flags &= ~ O_NONBLOCK;

    fcntl(sockfd,F_SETFL, flags);

 

    /***************************************************/

    //设置不被SIGPIPE信号中断,物理链路损坏时才不会导致程序直接被Terminate

    //在网络异常的时候如果程序收到SIGPIRE是会直接被退出的。

    struct sigaction sa;

    sa.sa_handler = SIG_IGN;

    sigaction( SIGPIPE, &sa, 0 );

    /***************************************************/

 

 

然后就可以收发数据了

sendwrite两种方法都可以,你需要自己维护一个队列,控制时间等等

    NSString *str = [SendCmdArray objectAtIndex:0];

    NSData *data = [str dataUsingEncoding:NSISOLatin1StringEncoding];

//  ssize_t datalen = send(sockfd,[data bytes],[data length],0);

    ssize_t datalen = write(sockfd, [data bytes], [data length]);

    if(datalen == [data length])

    {

      NSLog(@"Send str:%@",str);

    }

 

 

如何接收数据,readrecv都可以,这是方法,你需要自己维护一个队列,控制时间等等。

    char readBuffer[512] = {

0};

    NSString* readString = nil;

    int br = 0; 

    while (br = read(sockfd, readBuffer, sizeof(readBuffer)) < sizeof(readBuffer))

//  while((br = recv(sockfd, readBuffer, sizeof(readBuffer), 0)) < sizeof(readBuffer))

    {

      NSLog(@"Received CMD:%s",readBuffer);

      readString = [NSString stringWithUTF8String:readBuffer];

      memset(readBuffer,0,sizeof(readBuffer));

    }

    NSLog(@"br is %d,receive exit.",br);

 

 

获取时间后就可以进行时间同步了,具体的时间同步协议要根据自己平台来设计

      time_t timep;

      struct tm *p;

      time(&timep);

      p = localtime(&timep);

      int wday = -1;//return num is (0,6),the weekday range is (1,7)

      if(p->tm_wday == 0)

        wday = 7;

      else

        wday = p->tm_wday;

      char data[256] = {

0};

      sprintf(data,"0E4007%02x%02x%02x%02x%02x%02x%02x",(1900+p->tm_year)%100,(1+p->tm_mon),p->tm_mday,p->tm_hour,p->tm_min,p->tm_sec,wday);

      NSString *msgtime = [NSString stringWithUTF8String:data];

 

可以开一个线程来进行收发,处理相关的操作,想要多线程控制需要注意这个socket必须是全局可用的,因为新线程已经不在主循环了

还有如果有界面更新也需要在主线程更新

 

[NSThread detachNewThreadSelector:@selector(OnNewThread) toTarget:self withObject:nil];

 

可以用timer做一个心跳包维持通讯

 

timer = [NSTimer scheduledTimerWithTimeInterval:2 target:selfselector:@selector(OnHeartBeatTimer:) userInfo:nil repeats:YES];

 

结束的时候记得关掉定时器和socket

[timer invalidate];

close(sockfd);

 

原文URL:http://blog.csdn.net/arthurchenjs/article/details/6043289

你可能感兴趣的文章
0c-42-ARC模式下如何兼容非ARC的类
查看>>
程序员进阶之路—如何独当一面
查看>>
闲话WPF之十一(Dependency属性 [3] )
查看>>
JS组件系列——基于Bootstrap Ace模板的菜单Tab页效果优化
查看>>
eclipse中tomcat快速启动关闭参数设置
查看>>
C++ extern "c "的作用
查看>>
实践:几十亿条数据分布在几十个节点上的毫秒级实时排序方法
查看>>
PMWiki安装教程
查看>>
JAVA多线程之volatile 与 synchronized 的比较
查看>>
一个经典编程面试题的“隐退”
查看>>
POJ2109
查看>>
显示创建一个表的SQL语句
查看>>
光流和KLT
查看>>
Linux c括号作用域【原创笔记】
查看>>
高性能后台服务器架构设计
查看>>
MIUI刷机曝重大危险 可致短信照片等个人隐私被盗
查看>>
物联网时代 企业需做出的十大战略选择
查看>>
光速运行的量子加密
查看>>
ESG:浅析思科进军服务器市场行业影响
查看>>
美国“黑色星期五”单日销量不及双十一
查看>>