头文件：
#import <sys/socket.h>
#import <netinet/in.h>
#import <arpa/inet.h>
#import <unistd.h>1. 创建连接

1. CFSocketContext sockContext = {0, // 结构体的版本，必须为0
   
2. self,  // 一个任意指针的数据，可以用在创建时CFSocket对象相关联。这个指针被传递给所有的上下文中定义的回调。
   
3. NULL, // 一个定义在上面指针中的retain的回调， 可以为NULL
   
4. NULL, NULL};
   
5. 
   
6. CFSocketRef _socket = (kCFAllocatorDefault, // 为新对象分配内存，可以为nil
   
7. PF_INET, // 协议族，如果为0或者负数，则默认为PF_INET
   
8. SOCK_STREAM, // 套接字类型，如果协议族为PF_INET,则它会默认为SOCK_STREAM
   
9. IPPROTO_TCP, // 套接字协议，如果协议族是PF_INET且协议是0或者负数，它会默认为IPPROTO_TCP
   
10. kCFSocketConnectCallBack, // 触发回调函数的socket消息类型，具体见Callback Types
    
11. TCPServerConnectCallBack, // 上面情况下触发的回调函数
    
12. &sockContext // 一个持有CFSocket结构信息的对象，可以为nil
    
13. );
    
14. 
    
15. if (_socket != nil) {
    
16.     struct sockaddr_in addr4;   // IPV4
    
17.     memset(&addr4, 0, sizeof(addr4));
    
18.     addr4.sin_len = sizeof(addr4);
    
19.     addr4.sin_family = AF_INET;
    
20.     addr4.sin_port = htons(8888);
    
21.     addr4.sin_addr.s_addr = inet_addr([strAddress UTF8String]);  // 把字符串的地址转换为机器可识别的网络地址
    
22.         
    
23.     // 把sockaddr_in结构体中的地址转换为Data
    
24.     CFDataRef address = CFDataCreate(kCFAllocatorDefault, (UInt8 *)&addr4, sizeof(addr4));
    
25.     CFSocketConnectToAddress(_socket, // 连接的socket
    
26. address, // CFDataRef类型的包含上面socket的远程地址的对象
    
27. -1  // 连接超时时间，如果为负，则不尝试连接，而是把连接放在后台进行，如果_socket消息类型为kCFSocketConnectCallBack，将会在连接成功或失败的时候在后台触发回调函数
    
28. );
    
29. 
    
30.     CFRunLoopRef cRunRef = CFRunLoopGetCurrent();    // 获取当前线程的循环
    
31.     // 创建一个循环，但并没有真正加如到循环中，需要调用CFRunLoopAddSource
    
32.     CFRunLoopSourceRef sourceRef = CFSocketCreateRunLoopSource(kCFAllocatorDefault, _socket, 0);
    
33.     CFRunLoopAddSource(cRunRef, // 运行循环
    
34.     sourceRef,  // 增加的运行循环源, 它会被retain一次
    
35.     kCFRunLoopCommonModes  // 增加的运行循环源的模式
    
36.     );
    
37.     CFRelease(courceRef);
    
38. }

复制代码

2. 设置回调函数

1. // socket回调函数的格式：
   
2. static void TCPServerConnectCallBack(CFSocketRef socket, CFSocketCallBackType type, CFDataRef address, const void *data, void *info) ｛
   
3.     if (data != NULL) {
   
4.         // 当socket为kCFSocketConnectCallBack时，失败时回调失败会返回一个错误代码指针，其他情况返回NULL
   
5.         NSLog(@"连接失败");
   
6.         return;
   
7.     }
   
8.     TCPClient *client = (TCPClient *)info;
   
9.     // 读取接收的数据
   
10.     [info performSlectorInBackground:@selector(readStream) withObject:nil];
    
11. ｝

复制代码

3. 接收发送数据

1. // 读取接收的数据
   
2. - (void)readStream {
   
3.     char buffer[1024];
   
4.     NSAutoreleasePool *pool = [[NSAutoreleasePool alloc] init];
   
5.     while (recv(CFSocketGetNative(_socket), //与本机关联的Socket 如果已经失效返回－1:INVALID_SOCKET
   
6.            buffer, sizeof(buffer), 0)) {
   
7.         NSLog(@"%@", [NSString stringWithUTF8String:buffer]);
   
8.     }
   
9. }
   
10. 
    
11. // 发送数据
    
12. - (void)sendMessage {
    
13.     NSString *stringTosend = @"你好";
    
14.     char *data = [stringTosend UTF8String];
    
15.     send(SFSocketGetNative(_socket), data, strlen(data) + 1, 0);
    
16. }

复制代码

服务器端：

1. CFSockteRef _socket;
   
2. CFWriteStreamRef outputStream = NULL;
   
3. 
   
4. int setupSocket() {
   
5.     _socket = CFSocketCreate(kCFAllocatorDefault, PF_INET, SOCK_STREAM, IPPROTO_TCP, kCFSocketAcceptCallBack, TCPServerAcceptCallBack, NULL);
   
6.     if (NULL == _socket) {
   
7.         NSLog(@"Cannot create socket!");
   
8.         return 0;
   
9.     }
   
10.    
    
11.     int optval = 1;
    
12.     setsockopt(CFSocketGetNative(_socket), SOL_SOCKET, SO_REUSEADDR, // 允许重用本地地址和端口
    
13. (void *)&optval, sizeof(optval));
    
14.    
    
15.     struct sockaddr_in addr4;
    
16.     memset(&addr4, 0, sizeof(addr4));
    
17.     addr4.sin_len = sizeof(addr4);
    
18.     addr4.sin_family = AF_INET;
    
19.     addr4.sin_port = htons(port);
    
20.     addr4.sin_addr.s_addr = htonl(INADDR_ANY);
    
21.     CFDataRef address = CFDataCreate(kCFAllocatorDefault, (UInt8 *)&addr4, sizeof(addr4));
    
22.    
    
23.     if (kCFSocketSuccess != CFSocketSetAddress(_socket, address)) {
    
24.         NSLog(@"Bind to address failed!");
    
25.         if (_socket)
    
26.              CFRelease(_socket);
    
27.         _socket = NULL;
    
28.         return 0;
    
29.     }
    
30.         
    
31.     CFRunLoopRef cfRunLoop = CFRunLoopGetCurrent();
    
32.     CFRunLoopSourceRef source = CFSocketCreateRunLoopSource(kCFAllocatorDefault, _socket, 0);
    
33.     CFRunLoopAddSource(cfRunLoop, source, kCFRunLoopCommonModes);
    
34.     CFRelease(source);
    
35.    
    
36.     return 1;
    
37. }
    
38. 
    
39. // socket回调函数，同客户端
    
40. void TCPServerAcceptCallBack(CFSocketRef socket, CFSocketCallBackType type, CFDataRef address, const void *data, void *info) {
    
41.     if (kCFSocketAcceptCallBack == type) {
    
42.         // 本地套接字句柄
    
43.         CFSocketNativeHandle nativeSocketHandle = *(CFSocketNativeHandle *)data;
    
44.         uint8_t name[SOCK_MAXADDRLEN];      
    
45.         socklen_t nameLen = sizeof(name);
    
46.         if (0 != getpeername(nativeSocketHandle, (struct sockaddr *)name, &nameLen)) {
    
47.             NSLog(@"error");
    
48.             exit(1);
    
49.         }
    
50.         NSLog(@"%@ connected.", inet_ntoa( ((struct sockaddr_in *)name)->sin_addr )):
    
51. 
    
52.         CFReadStreamRef iStream;
    
53.         CFWriteStreamRef oStream;
    
54.         // 创建一个可读写的socket连接
    
55.         CFStreamCreatePairWithSocket(kCFAllocatorDefault, nativeSocketHandle, &iStream, &oStream);  
    
56.         if (iStream && oStream) {
    
57.             CFStreamClientContext streamContext = {0, NULL, NULL, NULL};
    
58.             if (!CFReadStreamSetClient(iStream, kCFStreamEventHasBytesAvaiable,
    
59.                                        readStream, // 回调函数，当有可读的数据时调用
    
60.                                        &streamContext)){
    
61.                 exit(1);
    
62.             }
    
63. 
    
64.             if (!CFReadStreamSetClient(iStream, kCFStreamEventCanAcceptBytes, writeStream, &streamContext)){
    
65.                 exit(1);
    
66.             }
    
67. 
    
68.             CFReadStreamScheduleWithRunLoop(iStream, CFRunLoopGetCurrent(), kCFRunLoopCommomModes);
    
69.             CFWriteStreamScheduleWithRunLoop(wStream, CFRunLoopGetCurrent(), kCFRunLoopCommomModes);
    
70.             CFReadStreamOpen(iStream);
    
71.             CFWriteStreamOpen(wStream);
    
72.         } else {
    
73.              close(nativeSocketHandle);  
    
74.         }
    
75.     }
    
76. }
    
77. 
    
78. // 读取数据
    
79. void readStream(CFReadStreamRef stream, CFStreamEventType eventType, void *clientCallBackInfo) {
    
80.     UInt8 buff[255];
    
81.     CFReadStreamRead(stream, buff, 255);
    
82.     printf("received: %s", buff);
    
83. }
    
84. 
    
85. void writeStream (CFWriteStreamRef stream, CFStreamEventType eventType, void *clientCallBackInfo) {
    
86.     outputStream = stream;
    
87. }
    
88. 
    
89. main {
    
90.     char *str = "nihao";
    
91.    
    
92.     if (outputStream != NULL) {
    
93.         CFWriteStreamWrite(outputStream, str, strlen(line) + 1);
    
94.     } else {
    
95.         NSLog(@"Cannot send data!");
    
96.     }
    
97. }
    
98. 
    
99. // 开辟一个线程线程函数中
    
100. void runLoopInThread() {
     
101.     int res = setupSocket();
     
102.     if (!res) {
     
103.         exit(1);
     
104.     }
     
105.     CFRunLoopRun();    // 运行当前线程的CFRunLoop对象
     
106. }

复制代码

原帖地址：http://www.cocoachina.com/bbs/read.php?tid=149651

头文件：
#import <sys/socket.h>
#import <netinet/in.h>
#import <arpa/inet.h>
#import <unistd.h>1. 创建连接

1. CFSocketContext sockContext = {0, // 结构体的版本，必须为0
   
2. self,  // 一个任意指针的数据，可以用在创建时CFSocket对象相关联。这个指针被传递给所有的上下文中定义的回调。
   
3. NULL, // 一个定义在上面指针中的retain的回调， 可以为NULL
   
4. NULL, NULL};
   
5. 
   
6. CFSocketRef _socket = (kCFAllocatorDefault, // 为新对象分配内存，可以为nil
   
7. PF_INET, // 协议族，如果为0或者负数，则默认为PF_INET
   
8. SOCK_STREAM, // 套接字类型，如果协议族为PF_INET,则它会默认为SOCK_STREAM
   
9. IPPROTO_TCP, // 套接字协议，如果协议族是PF_INET且协议是0或者负数，它会默认为IPPROTO_TCP
   
10. kCFSocketConnectCallBack, // 触发回调函数的socket消息类型，具体见Callback Types
    
11. TCPServerConnectCallBack, // 上面情况下触发的回调函数
    
12. &sockContext // 一个持有CFSocket结构信息的对象，可以为nil
    
13. );
    
14. 
    
15. if (_socket != nil) {
    
16.     struct sockaddr_in addr4;   // IPV4
    
17.     memset(&addr4, 0, sizeof(addr4));
    
18.     addr4.sin_len = sizeof(addr4);
    
19.     addr4.sin_family = AF_INET;
    
20.     addr4.sin_port = htons(8888);
    
21.     addr4.sin_addr.s_addr = inet_addr([strAddress UTF8String]);  // 把字符串的地址转换为机器可识别的网络地址
    
22.         
    
23.     // 把sockaddr_in结构体中的地址转换为Data
    
24.     CFDataRef address = CFDataCreate(kCFAllocatorDefault, (UInt8 *)&addr4, sizeof(addr4));
    
25.     CFSocketConnectToAddress(_socket, // 连接的socket
    
26. address, // CFDataRef类型的包含上面socket的远程地址的对象
    
27. -1  // 连接超时时间，如果为负，则不尝试连接，而是把连接放在后台进行，如果_socket消息类型为kCFSocketConnectCallBack，将会在连接成功或失败的时候在后台触发回调函数
    
28. );
    
29. 
    
30.     CFRunLoopRef cRunRef = CFRunLoopGetCurrent();    // 获取当前线程的循环
    
31.     // 创建一个循环，但并没有真正加如到循环中，需要调用CFRunLoopAddSource
    
32.     CFRunLoopSourceRef sourceRef = CFSocketCreateRunLoopSource(kCFAllocatorDefault, _socket, 0);
    
33.     CFRunLoopAddSource(cRunRef, // 运行循环
    
34.     sourceRef,  // 增加的运行循环源, 它会被retain一次
    
35.     kCFRunLoopCommonModes  // 增加的运行循环源的模式
    
36.     );
    
37.     CFRelease(courceRef);
    
38. }

复制代码

2. 设置回调函数

1. // socket回调函数的格式：
   
2. static void TCPServerConnectCallBack(CFSocketRef socket, CFSocketCallBackType type, CFDataRef address, const void *data, void *info) ｛
   
3.     if (data != NULL) {
   
4.         // 当socket为kCFSocketConnectCallBack时，失败时回调失败会返回一个错误代码指针，其他情况返回NULL
   
5.         NSLog(@"连接失败");
   
6.         return;
   
7.     }
   
8.     TCPClient *client = (TCPClient *)info;
   
9.     // 读取接收的数据
   
10.     [info performSlectorInBackground:@selector(readStream) withObject:nil];
    
11. ｝

复制代码

3. 接收发送数据

1. // 读取接收的数据
   
2. - (void)readStream {
   
3.     char buffer[1024];
   
4.     NSAutoreleasePool *pool = [[NSAutoreleasePool alloc] init];
   
5.     while (recv(CFSocketGetNative(_socket), //与本机关联的Socket 如果已经失效返回－1:INVALID_SOCKET
   
6.            buffer, sizeof(buffer), 0)) {
   
7.         NSLog(@"%@", [NSString stringWithUTF8String:buffer]);
   
8.     }
   
9. }
   
10. 
    
11. // 发送数据
    
12. - (void)sendMessage {
    
13.     NSString *stringTosend = @"你好";
    
14.     char *data = [stringTosend UTF8String];
    
15.     send(SFSocketGetNative(_socket), data, strlen(data) + 1, 0);
    
16. }

复制代码

服务器端：

1. CFSockteRef _socket;
   
2. CFWriteStreamRef outputStream = NULL;
   
3. 
   
4. int setupSocket() {
   
5.     _socket = CFSocketCreate(kCFAllocatorDefault, PF_INET, SOCK_STREAM, IPPROTO_TCP, kCFSocketAcceptCallBack, TCPServerAcceptCallBack, NULL);
   
6.     if (NULL == _socket) {
   
7.         NSLog(@"Cannot create socket!");
   
8.         return 0;
   
9.     }
   
10.    
    
11.     int optval = 1;
    
12.     setsockopt(CFSocketGetNative(_socket), SOL_SOCKET, SO_REUSEADDR, // 允许重用本地地址和端口
    
13. (void *)&optval, sizeof(optval));
    
14.    
    
15.     struct sockaddr_in addr4;
    
16.     memset(&addr4, 0, sizeof(addr4));
    
17.     addr4.sin_len = sizeof(addr4);
    
18.     addr4.sin_family = AF_INET;
    
19.     addr4.sin_port = htons(port);
    
20.     addr4.sin_addr.s_addr = htonl(INADDR_ANY);
    
21.     CFDataRef address = CFDataCreate(kCFAllocatorDefault, (UInt8 *)&addr4, sizeof(addr4));
    
22.    
    
23.     if (kCFSocketSuccess != CFSocketSetAddress(_socket, address)) {
    
24.         NSLog(@"Bind to address failed!");
    
25.         if (_socket)
    
26.              CFRelease(_socket);
    
27.         _socket = NULL;
    
28.         return 0;
    
29.     }
    
30.         
    
31.     CFRunLoopRef cfRunLoop = CFRunLoopGetCurrent();
    
32.     CFRunLoopSourceRef source = CFSocketCreateRunLoopSource(kCFAllocatorDefault, _socket, 0);
    
33.     CFRunLoopAddSource(cfRunLoop, source, kCFRunLoopCommonModes);
    
34.     CFRelease(source);
    
35.    
    
36.     return 1;
    
37. }
    
38. 
    
39. // socket回调函数，同客户端
    
40. void TCPServerAcceptCallBack(CFSocketRef socket, CFSocketCallBackType type, CFDataRef address, const void *data, void *info) {
    
41.     if (kCFSocketAcceptCallBack == type) {
    
42.         // 本地套接字句柄
    
43.         CFSocketNativeHandle nativeSocketHandle = *(CFSocketNativeHandle *)data;
    
44.         uint8_t name[SOCK_MAXADDRLEN];      
    
45.         socklen_t nameLen = sizeof(name);
    
46.         if (0 != getpeername(nativeSocketHandle, (struct sockaddr *)name, &nameLen)) {
    
47.             NSLog(@"error");
    
48.             exit(1);
    
49.         }
    
50.         NSLog(@"%@ connected.", inet_ntoa( ((struct sockaddr_in *)name)->sin_addr )):
    
51. 
    
52.         CFReadStreamRef iStream;
    
53.         CFWriteStreamRef oStream;
    
54.         // 创建一个可读写的socket连接
    
55.         CFStreamCreatePairWithSocket(kCFAllocatorDefault, nativeSocketHandle, &iStream, &oStream);  
    
56.         if (iStream && oStream) {
    
57.             CFStreamClientContext streamContext = {0, NULL, NULL, NULL};
    
58.             if (!CFReadStreamSetClient(iStream, kCFStreamEventHasBytesAvaiable,
    
59.                                        readStream, // 回调函数，当有可读的数据时调用
    
60.                                        &streamContext)){
    
61.                 exit(1);
    
62.             }
    
63. 
    
64.             if (!CFReadStreamSetClient(iStream, kCFStreamEventCanAcceptBytes, writeStream, &streamContext)){
    
65.                 exit(1);
    
66.             }
    
67. 
    
68.             CFReadStreamScheduleWithRunLoop(iStream, CFRunLoopGetCurrent(), kCFRunLoopCommomModes);
    
69.             CFWriteStreamScheduleWithRunLoop(wStream, CFRunLoopGetCurrent(), kCFRunLoopCommomModes);
    
70.             CFReadStreamOpen(iStream);
    
71.             CFWriteStreamOpen(wStream);
    
72.         } else {
    
73.              close(nativeSocketHandle);  
    
74.         }
    
75.     }
    
76. }
    
77. 
    
78. // 读取数据
    
79. void readStream(CFReadStreamRef stream, CFStreamEventType eventType, void *clientCallBackInfo) {
    
80.     UInt8 buff[255];
    
81.     CFReadStreamRead(stream, buff, 255);
    
82.     printf("received: %s", buff);
    
83. }
    
84. 
    
85. void writeStream (CFWriteStreamRef stream, CFStreamEventType eventType, void *clientCallBackInfo) {
    
86.     outputStream = stream;
    
87. }
    
88. 
    
89. main {
    
90.     char *str = "nihao";
    
91.    
    
92.     if (outputStream != NULL) {
    
93.         CFWriteStreamWrite(outputStream, str, strlen(line) + 1);
    
94.     } else {
    
95.         NSLog(@"Cannot send data!");
    
96.     }
    
97. }
    
98. 
    
99. // 开辟一个线程线程函数中
    
100. void runLoopInThread() {
     
101.     int res = setupSocket();
     
102.     if (!res) {
     
103.         exit(1);
     
104.     }
     
105.     CFRunLoopRun();    // 运行当前线程的CFRunLoop对象
     
106. }

复制代码

原帖地址：http://www.cocoachina.com/bbs/read.php?tid=149651