程序啟動(dòng),自以為的,在loop中循環(huán),在loop中加入socket監(jiān)聽(tīng)端口,還需要loop一直循環(huán)么?
答案自然不知道,但事實(shí)問(wèn)題,在這種隊(duì)列中監(jiān)聽(tīng).
導(dǎo)致其他線程出問(wèn)題了.
1.創(chuàng)建隨機(jī)隊(duì)列方法不了解.
2.監(jiān)聽(tīng)端口的機(jī)制學(xué)習(xí).
下面是一個(gè)錯(cuò)誤的示范,時(shí)刻留意這個(gè)bug.
dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
CFSocketContext ctx = { 0, self, NULL, NULL, NULL };
recvSocket_ = CFSocketCreate(kCFAllocatorDefault,
PF_INET,
SOCK_DGRAM,
IPPROTO_UDP,
kCFSocketDataCallBack,
(CFSocketCallBack)DiscoverReceiveCallback,
&ctx);
if (recvSocket_ == NULL) {
LOG(@"[DSCV] Cannot create listening socket. %d", errno);
return ;
}
int flag = 1;
setsockopt(CFSocketGetNative(recvSocket_), SOL_SOCKET, SO_REUSEADDR, &flag, sizeof(flag));
struct sockaddr_in addr;
memset(&addr, 0, sizeof(addr));
addr.sin_len = sizeof(addr);
addr.sin_family = AF_INET;
addr.sin_port = htons(port);
addr.sin_addr.s_addr = INADDR_ANY;
NSData *addrData = [NSData dataWithBytes:&addr length:sizeof(addr)];
if (CFSocketSetAddress(recvSocket_, (CFDataRef)addrData)) {
CFSocketInvalidate(recvSocket_);
CFRelease(recvSocket_);
recvSocket_ = NULL;
LOG(@"[DSCV] Cannot set address to socket.");
return ;
}
LOG(@"recvSocket_------>%@",recvSocket_);
CFRunLoopSourceRef source = CFSocketCreateRunLoopSource(kCFAllocatorDefault, recvSocket_, 0);
CFRunLoopAddSource(CFRunLoopGetCurrent(), source, kCFRunLoopCommonModes);
CFRelease(source);
CFRunLoopRun(); });
