用例

我正在使用套接字使用CFStreamCreatePairWithSocketToHost()发送和接收数据,并试图在发送多组数据(即不仅仅是1个请求)时如何完成此操作.

问题

目前我可以发送数据并接收响应(即1次往返).但是,在我发送outputStream中的所有数据后,流被关闭(即接收NsstreamEventEndEncountered).

所以问题是,当我想发送多个数据请求时会发生什么?

>每次要发送新数据对象时,是否设置了新套接字?
>我是否必须重置outputStream并发送更多数据.

大部分代码来自Cocoa Streams Documentation:

- (void)viewDidLoad {
    [super viewDidLoad];
    // Do any additional setup after loading the view,typically from a nib.

    _data = [[NSMutableData alloc] init];
    [self initNetworkCommunication];

    [self sendString:@"Hello World!"];
}

- (void)initNetworkCommunication {
    CFReadStreamRef readStream;
    CFWriteStreamRef writeStream;

    CFStreamCreatePairWithSocketToHost(NULL,(CFStringRef)@"123.456.0.0",1234,&readStream,&writeStream);

    inputStream = (NSInputStream *)readStream; // ivar
    [inputStream setDelegate:self];
    [inputStream scheduleInRunLoop:[NSRunLoop currentRunLoop] forMode:NSDefaultRunLoopMode];
    [inputStream open];

    outputStream = (NSOutputStream *)writeStream; // ivar
    [outputStream setDelegate:self];
    [outputStream scheduleInRunLoop:[NSRunLoop currentRunLoop] forMode:NSDefaultRunLoopMode];
    [outputStream open];
}

- (void)sendString:(Nsstring *)string {
    NSData *data = [[NSData alloc] initWithData:[string dataUsingEncoding:NSASCIIStringEncoding]];
    [_data appendData:data];
    [data release];
}

- (void)stream:(Nsstream *)theStream handleEvent:(NsstreamEvent)streamEvent {
    NSLog(@"stream event %u",streamEvent);

    switch (streamEvent) {
        case NsstreamEventOpenCompleted:
            NSLog(@"Stream opened");
            break;
        case NsstreamEventHasspaceAvailable: {
            uint8_t *readBytes = (uint8_t *)[_data mutableBytes];
            readBytes += byteIndex; // ivar
            int data_len = [_data length];
            unsigned int len = ((data_len - byteIndex >= 1024) ? 1024 : (data_len - byteIndex));
            uint8_t buf[len];
            (void)memcpy(buf,readBytes,len);
            len = [(NSOutputStream *)theStream write:(const uint8_t *)buf maxLength:len];
            NSLog(@"Sending buffer of len: %d",len);
            byteIndex += len;
            break;
        }
        case NsstreamEventHasBytesAvailable:
            if (theStream == inputStream) {
                uint8_t buffer[1024];
                int len;

                while ([inputStream hasBytesAvailable]) {
                    len = [inputStream read:buffer maxLength:sizeof(buffer)];
                    if (len > 0) {
                        Nsstring *output = [[Nsstring alloc] initWithBytes:buffer length:len encoding:NSASCIIStringEncoding];

                        if (nil != output) {
                            NSLog(@"server said: %@",output);
                        }
                    }
                }

                [self sendString:@"Another Test"];
            }
            break;
        case NsstreamEventErrorOccurred:
            NSLog(@"Can not connect to the host!");
            break;
        case NsstreamEventEndEncountered:
            NSLog(@"Closing stream...");
            [theStream close];
            [theStream removeFromrunLoop:[NSRunLoop currentRunLoop] forMode:NSDefaultRunLoopMode];
            [theStream release];
            theStream = nil;
            break;
        default:
            NSLog(@"UnkNown event");
    }
}

响应:

2012-08-15 08:16:30.896 Sockets[34836:f803] Opened input stream.
2012-08-15 08:16:30.898 Sockets[34836:f803] Opened output stream.
2012-08-15 08:16:30.899 Sockets[34836:f803] Sending buffer of len: 12
2012-08-15 08:16:30.900 Sockets[34836:f803] Sending buffer of len: 0
2012-08-15 08:16:30.901 Sockets[34836:f803] Closing output stream.
2012-08-15 08:16:30.939 Sockets[34836:f803] server said: Hello World!

请注意,在发送数据后,outputStream流将关闭.我尝试在[self sendString:@“Another Test”]之前重新启动outputStream.我也试过了idz的回答.

根据文档,我相信len:0的发送缓冲区是我的问题.

If the delegate receives an NsstreamEventHasspaceAvailable event and
does not write anything to the stream,it does not receive further
space-available events from the run loop until the NSOutputStream
object receives more bytes. When this happens,the run loop is
restarted for space-available events.

但是,文档没有说明在到达流末尾时关闭流.所以我很困惑……

解决方法

套接字是连接两个程序的双向流,可能在两台不同的计算机上.它只是将您在一端写入的数据传输到另一端进行读取.它在数据中不强制执行任何结构,并且不了解有关请求或响应的任何信息.

CFStreamCreatePairWithSocketToHost API将单个连接拆分为两个独立的流 – 一个可以读取,另一个可以写入.这是一个很好的接触,底层套接字API只使用一个文件描述符进行读取和写入,这可能会让人非常困惑.

连接保持打开,直到一侧关闭插座.还有可能仅在一个方向上关闭插座.也可以仅在一个方向上关闭连接.如果遥控器关闭它的读取流,您的写入流将被关闭,反之亦然.

Do I setup a new socket every time I have a new data object to send?

你应该避免这样做.建立新连接需要一些时间,并且在连接达到全速之前需要更多时间.因此,您应该尽可能多地重用相同的连接.

Do I have to reset outputStream and send more data.

不,这不是必需的,只需发送更多数据.

Per the documentation,I believe the Sending buffer of len: 0 is my
problem.

什么都不写(这是一个长度为0的缓冲区)应该不是问题.文档没有说明会发生什么.所以我今天写了一个测试程序,看看会发生什么,什么也不期待.事实证明,写入长度为0的缓冲区会关闭输出流.所以这真的是你的问题.我将在Apple Bug Reporter上提出有关该文档问题的错误,您也应如此.

您引用的文档部分是关于不同的东西.如果您在获得可用空间通知后没有写信,那么在您写完文章之前,您将无法获得另一个通知.这很有用,因为系统不会浪费cpu周期来反复告诉您的代码,如果您没有任何要编写的内容,您可以写一些东西.

iOS:使用CFStreamCreatePairWithSocketToHost的套接字网络基础的更多相关文章

  1. 配置iOS VoIP应用程序以在睡眠/后台模式下运行

    我正在开发基于VoIP的iOS(7.1)应用程序.它的底层套接字编程是用C而不是客观C编写的.应用程序在前台运行良好,但在进入睡眠/后台模式时,它无法从服务器接收任何通信.根据apple文档,我们必须为VoIP使用配置一个appsocket.我无法弄清楚如何配置C套接字.目的是在睡眠模式下运行应用程序,直到它被杀死.从SO中尝试了几个链接甚至几个链接,但由于我是新手,我希望这个配置有一步一步的过程.[注意:在某个地方我发现了CoreFoudation框架,我是否需要使用它?

  2. ios – UIScrollView内容不允许用户交互

    我有一个启用了分页的UIScrollView,如下所示:在UIScrollView中,我添加了几个UIWebViews,并将其启用的交互设置为是这样的.它打破了UIScrollView上的分页和所有触摸.如果我将用户交互设置为NO,则页面有效,但我无法在UIWebView中突出显示文本.我试着像下面那样对UIScrollView进行子类化,但是会出现同样的情况.任何的想法?

  3. iOS上的GCDAsyncUdpSocket缺少多播数据报

    我还看到GCDAsyncUdpSocket中有一个readStream方法.也许我需要使用它而不是beginReceiving?

  4. 我应该使用哪个高级API来管理iOS上的UDP套接字?

    在“NetworkProgrammingTopicsConceptualGuide”的“UsingSocketsandStreams”一章中,Apple说:Note:POSIXnetworkingdoesnotactivatethecellularradiooniOS.Forthisreason,thePOSIXnetworkingAPIisgenerallydiscouragediniOS.同样

  5. ios – UINavigationBar -pushNavigationItem在将新控制器推送到UINavigationController堆栈时从不调用

    解决方法我找到了原因:它调用–pushNavigationItem:项不调用–pushNavigationItem:animated!

  6. ios – Touch拖动输入如何工作?

    任何人都可以给我一个关于触摸拖动输入以从一个按钮拖动到另一个触发两个按钮事件的示例.它是如何工作的?例如,我想从Do到Fa拖动Do,Re,Mi,Fa的事件被触发.这是我的代码:哦,我已经看到,当我按住Simulator时,会触发方法btnDragOut.当我从Simulator拖出按钮时,会触发此按钮的方法.现在我希望当我拖出一个按钮时触发方法btnDragOut.有谁知道吗?

  7. ios – avplayer没有播放网址

    我正在使用avplayer播放音频网址,但它无法正常工作,我不知道我错在哪里任何帮助,将不胜感激.解决方法我强烈推荐下面的代码来播放无线电流:请看一下AVPlayer_Class参考链接是–Streamingmp3audiowithAVPlayer

  8. 从AVFullScreenViewController iOS 8获取媒体链接

    我想在某些内容开始播放时尝试获取视频链接.首先我抓住视频开始播放然后延迟尝试获取链接CUViewController,CUPlayerView,CUPlayerController–假的类,它看起来像这样一切都还行,直到这一行球员总是零.也许有更简单的方式来获得媒体链接?

  9. ios – 未提示在应用程序中启用位置服务

    更新:这不是重复.我已经在info.plist中添加了所需的密钥,如我原始问题中所述,问题仍然存在.我已经尝试了各种组合的所有三个键.在任何人感到不安之前,我已阅读了许多AppleDev论坛帖子和堆栈溢出帖子,无法弄清楚为什么我的应用程序拒绝提示用户允许使用时授权.我已将以下密钥添加到我的Info.plist文件中,并附带一个String值:然后我写了(在Swift和Obj-C中)应该提示用户的代

  10. ios – NSLocalizedString有时会加载字符串,而不是总是

    解决方法如果您的localisable文件中有任何额外的分号,它会构建但无法进行本地化.

随机推荐

  1. iOS实现拖拽View跟随手指浮动效果

    这篇文章主要为大家详细介绍了iOS实现拖拽View跟随手指浮动,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下

  2. iOS – genstrings:无法连接到输出目录en.lproj

    使用我桌面上的项目文件夹,我启动终端输入:cd然后将我的项目文件夹拖到终端,它给了我路径.然后我将这行代码粘贴到终端中找.-name*.m|xargsgenstrings-oen.lproj我在终端中收到此错误消息:genstrings:无法连接到输出目录en.lproj它多次打印这行,然后说我的项目是一个目录的路径?没有.strings文件.对我做错了什么的想法?

  3. iOS 7 UIButtonBarItem图像没有色调

    如何确保按钮图标采用全局色调?解决方法只是想将其转换为根注释,以便为“回答”复选标记提供更好的上下文,并提供更好的格式.我能想出这个!

  4. ios – 在自定义相机层的AVFoundation中自动对焦和自动曝光

    为AVFoundation定制图层相机创建精确的自动对焦和曝光的最佳方法是什么?

  5. ios – Xcode找不到Alamofire,错误:没有这样的模块’Alamofire’

    我正在尝试按照github(https://github.com/Alamofire/Alamofire#cocoapods)指令将Alamofire包含在我的Swift项目中.我创建了一个新项目,导航到项目目录并运行此命令sudogeminstallcocoapods.然后我面临以下错误:搜索后我设法通过运行此命令安装cocoapodssudogeminstall-n/usr/local/bin

  6. ios – 在没有iPhone6s或更新的情况下测试ARKit

    我在决定下载Xcode9之前.我想玩新的框架–ARKit.我知道要用ARKit运行app我需要一个带有A9芯片或更新版本的设备.不幸的是我有一个较旧的.我的问题是已经下载了新Xcode的人.在我的情况下有可能运行ARKit应用程序吗?那个或其他任何模拟器?任何想法或我将不得不购买新设备?解决方法任何iOS11设备都可以使用ARKit,但是具有高质量AR体验的全球跟踪功能需要使用A9或更高版本处理器的设备.使用iOS11测试版更新您的设备是必要的.

  7. 将iOS应用移植到Android

    我们制作了一个具有2000个目标c类的退出大型iOS应用程序.我想知道有一个最佳实践指南将其移植到Android?此外,由于我们的应用程序大量使用UINavigation和UIView控制器,我想知道在Android上有类似的模型和实现.谢谢到目前为止,guenter解决方法老实说,我认为你正在计划的只是制作难以维护的糟糕代码.我意识到这听起来像很多工作,但从长远来看它会更容易,我只是将应用程序的概念“移植”到android并从头开始编写.

  8. ios – 在Swift中覆盖Objective C类方法

    我是Swift的初学者,我正在尝试在Swift项目中使用JSONModel.我想从JSONModel覆盖方法keyMapper,但我没有找到如何覆盖模型类中的Objective-C类方法.该方法的签名是:我怎样才能做到这一点?解决方法您可以像覆盖实例方法一样执行此操作,但使用class关键字除外:

  9. ios – 在WKWebView中获取链接URL

    我想在WKWebView中获取tapped链接的url.链接采用自定义格式,可触发应用中的某些操作.例如HTTP://我的网站/帮助#深层链接对讲.我这样使用KVO:这在第一次点击链接时效果很好.但是,如果我连续两次点击相同的链接,它将不报告链接点击.是否有解决方法来解决这个问题,以便我可以检测每个点击并获取链接?任何关于这个的指针都会很棒!解决方法像这样更改addobserver在observeValue函数中,您可以获得两个值

  10. ios – 在Swift的UIView中找到UILabel

    我正在尝试在我的UIViewControllers的超级视图中找到我的UILabels.这是我的代码:这是在Objective-C中推荐的方式,但是在Swift中我只得到UIViews和CALayer.我肯定在提供给这个方法的视图中有UILabel.我错过了什么?我的UIViewController中的调用:解决方法使用函数式编程概念可以更轻松地实现这一目标.

返回
顶部