#import <arpa/inet.h>
#import <netdb.h>
#include <sys/ioctl.h>
@interfaceXCClient() {
intsock_fd;
structhostent*host;
structsockaddr_inserver_addr;
intloopcount;
}
staticintPortNum_Car;//端口號
constchar*IP_Car;//IP地址
設(shè)置端口號和服務(wù)器地址
PortNum_Car=16868;
NSString*ipString =@"192.168.43.1";//這個ip地址要從服務(wù)端要
IP_Car= ipString.UTF8String;
//下面創(chuàng)建并連接端口
if((host=gethostbyname(IP_Car)) ==NULL) {
NSLog(@"host Error");
}
if((sock_fd=socket(AF_INET,SOCK_STREAM,0)) == -1) {
NSLog(@"create Socket Error");
}
//設(shè)置調(diào)用closesocket()后,仍可繼續(xù)重用該socket。調(diào)用closesocket()一般不會立即關(guān)閉socket德绿,而經(jīng)歷TIME_WAIT的過程
BOOLnREUSEADDR =true;
setsockopt(sock_fd,SOL_SOCKET,SO_REUSEADDR, (constchar*)&nREUSEADDR,sizeof(int));
server_addr.sin_family=AF_INET;
server_addr.sin_port=htons(PortNum_Car);
server_addr.sin_addr= *((structin_addr*)host->h_addr);
bzero(&(server_addr.sin_zero),8);
//異常
sigset_tset;
sigemptyset(&set);
sigaddset(&set,SIGPIPE);
sigprocmask(SIG_BLOCK, &set,NULL);
if(connect(sock_fd, (structsockaddr*)&server_addr,sizeof(structsockaddr)) == -1) {
//失敗處理
}else {
//連接成功,開始通訊
}
//warning 當(dāng)然了在connect的時候如果遇到服務(wù)器沒開端口葡粒,由于socket是阻塞模式暮芭,它就會connect到超時,才知道失敗黔牵,所以在connect的時候留攒,我們把它設(shè)為非阻塞的煤惩。系統(tǒng)就會很快就告訴我們了。上代碼炼邀;
在connect之前魄揉,先把socket設(shè)為非阻塞的
//設(shè)置為非阻塞,能改connect超時時間
structtimevaltimeout;
unsignedlongul =1;//1是非阻塞
fd_setwriteset;
intret;
ioctl(sock_fd,FIONBIO, &ul);
//嘗試連接
if(connect(sock_fd, (structsockaddr*)&server_addr,sizeof(structsockaddr)) == -1) {
timeout.tv_sec=5;
timeout.tv_usec=0;
FD_ZERO(&writeset);
FD_SET(sock_fd, &writeset);
ret =select(sock_fd+1,NULL, &writeset,NULL, &timeout);
if(ret ==0)//返回0拭宁,代表在描述詞狀態(tài)改變已超過timeout時間
{
超時處理
return;
}elseif(ret==-1){
錯誤處理
}else{
perror("connect error");close(sock_fd);
return;
}
}else{
interror;
socklen_tlen =sizeof(unsignedint);
getsockopt(sock_fd,SOL_SOCKET,SO_ERROR, &error, &len);//檢查一下是否真的連成功
if(error ==0)
{
//true
}
else
{
perror("connect error");close(sock_fd);
return;
}
成功就再把socket設(shè)成阻塞的洛退,開始后面的邏輯
ul =0;
ioctl(sock_fd,FIONBIO, &ul);//重新將socket設(shè)置成阻塞模式
[self connectSuccess_AndOpenthread];
}
}