ios - GCD を使用して CFStreams を使用する方法

Question

私はiosの初心者です..

ソケット接続を使用してサーバーに接続したいのですが、こちらのチュートリアルに従いました

これは正常に動作しますが、メインの UI スレッドですべてを行っていましたが、サーバーからの応答が得られるまでビューがフリーズしていました。私のボタンをクリックして、次のコードを呼び出します...

    [SVProgressHUD showWithStatus:@"Processing.."];
    [self.view setUserInteractionEnabled:NO];


  qt = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);
    dispatch_async(qt, ^{
CFReadStreamRef readStream;
CFWriteStreamRef writeStream;
CFStreamCreatePairWithSocketToHost(NULL, (CFStringRef)ip, 54000, &readStream, &writeStream);

inputStream = (NSInputStream *)readStream;
outputStream = (NSOutputStream *)writeStream;
[inputStream setDelegate:self];
[outputStream setDelegate:self];

[inputStream scheduleInRunLoop:[NSRunLoop currentRunLoop] forMode:NSDefaultRunLoopMode];
[outputStream scheduleInRunLoop:[NSRunLoop currentRunLoop] forMode:NSDefaultRunLoopMode];

[inputStream open];
[outputStream open];

NSData *data = [[NSData alloc] initWithData:[pinno dataUsingEncoding:NSASCIIStringEncoding]];
[outputStream write:[data bytes] maxLength:[data length]];
[outputStream close];
    });

そして、関数を使用してイベントを処理しています

- (void)stream:(NSStream *)theStream handleEvent:(NSStreamEvent)streamEvent {

    NSLog(@"StreamEvent %i",streamEvent);
    switch (streamEvent) {

                            dispatch_async(dispatch_get_main_queue(), ^{[SVProgressHUD dismiss];
            });

        case NSStreamEventOpenCompleted:
            NSLog(@"Stream opened");
            break;

        case NSStreamEventHasBytesAvailable:
                 NSLog(@"Stream has byte Avaliable");

            if (theStream==inputStream) {

                while ([inputStream hasBytesAvailable]) {
                    uint8_t buffer[1024];
                    int len;
                    len = [inputStream read:buffer maxLength:sizeof(buffer)];
                    if(len>0){
                        NSString *output = [[NSString alloc] initWithBytes:buffer length:len encoding:NSASCIIStringEncoding];
                        [self.view setUserInteractionEnabled:YES];

                        NSLog(@"output %@",output);


                    }
                }
            }
            break;

        case NSStreamEventErrorOccurred:
            [self.view setUserInteractionEnabled:YES];

            NSLog(@"Can not connect to the host!");
            break;

        case NSStreamEventEndEncountered:
            [self.view setUserInteractionEnabled:YES];

            break;

        default:
            [self.view setUserInteractionEnabled:YES];

            NSLog(@"Unknown event");

    }
}

上記のコードを使用して、サーバーへのリクエストを取得し、サーバーも成功した応答を送信しますが、ハンドルイベントメソッドでデータを受信しませんが、hasbytesavaliable イベントを取得していません..私のコンソールログは

2013-07-02 14:06:15.312 Multi[899:1c03] StreamEvent 1
2013-07-02 14:06:15.313 Multi[899:1c03] Stream opened
2013-07-02 14:06:15.313 Multi[899:1c03] StreamEvent 4
2013-07-02 14:06:15.313 Multi[899:1c03] Unknown event

私が間違っていることは何ですか...

Edit:Updated Code

ボタンをクリックすると、タイマーが開始され、connect メソッドが呼び出されます。

counter=[NSTimer scheduledTimerWithTimeInterval:30.0 target:self selector:@selector(stream:handleEvent:) userInfo:nil repeats:NO];


        qt = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);
        dispatch_async(qt, ^{[self connect];});

接続方法:

  CFReadStreamRef readStream;
    CFWriteStreamRef writeStream;
    CFStreamCreatePairWithSocketToHost(NULL, (CFStringRef)ip, 54000, &readStream, &writeStream);


    inputStream = (NSInputStream *)readStream;
    outputStream = (NSOutputStream *)writeStream;

    NSRunLoop *loop = [NSRunLoop currentRunLoop];

    [inputStream setDelegate:self];
    [outputStream setDelegate:self];

    [inputStream scheduleInRunLoop:loop forMode:NSDefaultRunLoopMode];
    [outputStream scheduleInRunLoop:loop forMode:NSDefaultRunLoopMode];

    [inputStream open];
    [outputStream open];

    NSData *data = [[NSData alloc] initWithData:[pinno dataUsingEncoding:NSASCIIStringEncoding]];
    [outputStream write:[data bytes] maxLength:[data length]];
    [outputStream close];

    [loop run];

ストリームハンドルイベント

- (void)stream:(NSStream *)theStream handleEvent:(NSStreamEvent)streamEvent {
    Username.text = @"";
    Password.text = @"";
    [self disconnect];
    if (counter!=nil){
        [counter invalidate];
        counter=nil;
    }

    NSLog(@"StreamEvent %i",streamEvent);
    switch (streamEvent) {

        case NSStreamEventOpenCompleted:
            NSLog(@"Stream opened");
            break;

        case NSStreamEventHasBytesAvailable:
            if (theStream==inputStream) {

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

                        NSLog(@"output %@",output);
                        [SVProgressHUD dismiss];
                        main = [[Mainmenu alloc]
                                initWithNibName:@"Mainmenu"
                                bundle:nil];
                        //                        [self.view addSubview:main.view];
                        [self presentViewController:main animated:NO completion:NO];
                    }
                }
            }
            dispatch_async(dispatch_get_main_queue(), ^{[SVProgressHUD dismiss];
            });

            break;

        case NSStreamEventErrorOccurred:

            NSLog(@"Can not connect to the host!");
            dispatch_async(dispatch_get_main_queue(), ^{[self dismiss:@"Cannot connect to host!"];
            });

            break;

        case NSStreamEventEndEncountered:
            dispatch_async(dispatch_get_main_queue(), ^{[self dismiss:@"Connection Error"];
            });

            break;

        default:
            NSLog(@"Unknown event");
            dispatch_async(dispatch_get_main_queue(), ^{[self dismiss:@"Timeout Expired"];
            });

    }
}

そして、切断方法..

-(void) disconnect
{
    [inputStream close];
    [inputStream removeFromRunLoop:[NSRunLoop currentRunLoop] forMode:NSDefaultRunLoopMode];
    [outputStream close];
    [outputStream removeFromRunLoop:[NSRunLoop currentRunLoop] forMode:NSDefaultRunLoopMode];
    [inputStream setDelegate:nil];
    inputStream = nil;
    [outputStream setDelegate:nil];
    outputStream = nil;

}

ios - GCD を使用して CFStreams を使用する方法

1 に答える 1

Related

Reference