无法在使用 CFStreamCreatePairWithSocket 成功创建的 CFWriteStream 上写入答案

【问题标题】：Can't write on a CFWriteStream successfully created with CFStreamCreatePairWithSocket无法在使用 CFStreamCreatePairWithSocket 成功创建的 CFWriteStream 上写入
【发布时间】：2024-04-13 13:50:01
【问题描述】：

由于 iOS 开发框架中的 CFWrite/ReadStream，我在尝试建立双向异步通信时遇到问题。

我开始创建一个套接字连接，一切似乎都是正确的：

CFSocketContext socketCtx = {0, self, NULL, NULL, NULL};
socket = CFSocketCreate(NULL, PF_INET, SOCK_STREAM, IPPROTO_TCP,kCFSocketConnectCallBack, (CFSocketCallBack)onConnectOrDisconnect, &socketCtx);

CFSocketEnableCallBacks(socket, kCFSocketConnectCallBack);
struct sockaddr_in addr;
memset(&addr, 0, sizeof(addr));
addr.sin_len = sizeof(addr);
addr.sin_family = AF_INET;
addr.sin_port = htons(appDelegate.portSocket);
addr.sin_addr.s_addr = inet_addr([adress cStringUsingEncoding:NSASCIIStringEncoding]);
CFDataRef connectAddr = CFDataCreate(NULL, (unsigned char *)&addr, sizeof(addr));   
CFRunLoopSourceRef sourceRef = CFSocketCreateRunLoopSource(kCFAllocatorDefault, socket, 0);
CFRunLoopAddSource(CFRunLoopGetCurrent(), sourceRef, kCFRunLoopCommonModes);
CFRelease(sourceRef);
CFSocketConnectToAddress(socket, connectAddr, -1);

然后，在我的连接回调中，我创建了两个流，一个用于读取，另一个用于写入：

void onConnectOrDisconnect(CFSocketRef socket, CFSocketCallBackType type, CFDataRef address,
                           const void *data, void *info)
{
    TCPClient * clientTCP = (TCPClient *)info;
    if(data==NULL)
    {
        [clientTCP ConnectionSuccess];
    }else {
        SInt32 *error = (SInt32*)data;
        NSLog(@"Connection error : %d", *error);
        StreamErrorOccured(clientTCP);
    }
}
- (void) ConnectionSuccess
{
    CFStreamCreatePairWithSocket(kCFAllocatorDefault, CFSocketGetNative(socket), &readStream, &writeStream);
    CFReadStreamSetProperty(readStream, kCFStreamPropertyShouldCloseNativeSocket, kCFBooleanTrue);
    CFWriteStreamSetProperty(writeStream, kCFStreamPropertyShouldCloseNativeSocket, kCFBooleanTrue);
    CFStreamClientContext dataStreamContext = {0, self, NULL, NULL, NULL};  
    CFOptionFlags events = kCFStreamEventHasBytesAvailable | kCFStreamEventOpenCompleted;
    if (CFReadStreamSetClient(readStream, events, readStreamEventCallBack , &dataStreamContext)) 
    {
        CFReadStreamScheduleWithRunLoop(readStream, CFRunLoopGetCurrent(), kCFRunLoopCommonModes);
    }
    if (CFWriteStreamSetClient(writeStream, kCFStreamEventOpenCompleted | kCFStreamEventCanAcceptBytes | kCFStreamEventErrorOccurred | kCFStreamEventEndEncountered,
                               writeStreamEventCallBack, &dataStreamContext))
    {
        CFWriteStreamScheduleWithRunLoop(writeStream, CFRunLoopGetCurrent(), kCFRunLoopCommonModes);
    }else {
        NSLog(@"can't create write stream client");
    }

    CFReadStreamOpen(readStream);
    CFWriteStreamOpen(writeStream);

    NSLog(@"Connection Success");
}

请注意，我在 kCFStreamEventCanAcceptBytes 事件和 kCFStreamEventOpenCompleted 事件上注册了回调。在这个回调中，我可以看到 kCFStreamEventOpenCompleted 发生了，但是 kCFStreamEventCanAcceptBytes 从来没有发生过！

当我尝试在我的流上写入时，我检查了流的可用性，这要归功于：CFWriteStreamCanAcceptBytes(writeStream)。这个函数总是返回 false。

如果我尝试在流上写入而不调用 CFWriteStreamCanAcceptBytes，则写入操作将永远循环。我的问题是： 1. 为什么我没有收到任何 kCFStreamEventCanAcceptBytes 事件？ 2. 为什么我的直播不能写？

我看到我的问题和SIMILAR QUESTION一模一样，但是没有人回复他。

也许我会更幸运！

干杯，

【问题讨论】：

标签： ios sockets stream ios-simulator

【解决方案1】：

我不知道答案，但我也遇到了这个问题。一种解决方案是在您的 writeStreamEventCallBack 中接收事件“kCFStreamEventCanAcceptBytes”，并在此回调函数中写入数据。其实问题是，如果你在 'kCFStreamEventCanAcceptBytes' 事件上没有发送任何数据，你下次就不能发送数据了。

Apple 开发文档的A page 说：

当您使用 CFStream API 进行网络连接时，套接字上的读写操作可能会阻塞。为了防止阻塞：

调用CFReadStreamSetClient和CFWriteStreamSetClient注册接收流相关事件通知。
调用 CFReadStreamScheduleWithRunLoop 和 CFWriteStreamScheduleWithRunLoop 以在运行循环中调度流，以接收流相关事件通知。
调用 CFReadStreamOpen 和 CFWriteStreamOpen 打开每个流。
在收到 kCFStreamEventHasBytesAvailable 通知后只读。仅在收到 kCFStreamEventCanAcceptBytes 通知后写入。

【讨论】：