Сервер / Клиент не взаимодействует правильно (CocoaAsyncSocket) - PullRequest
Новая
       2

Сервер / Клиент не взаимодействует правильно (CocoaAsyncSocket)

0 голосов
/ 23 августа 2011

У меня есть простое клиент-серверное приложение, частично работающее с CocoaAsyncSocket. Я могу использовать клиент для подключения к серверу и передавать между ними данные туда и обратно, и методы делегата, похоже, работают правильно. Моя проблема в том, что я могу отправлять данные только объекту (AsyncSocket *), который передается одному из методов делегата. Принимая соединение, я добавляю сокет в NSMutableArray, но позже, если я пытаюсь использовать сокет, запись не выполняется. Так 

[connectedSockets addObject:newSocket];
//then later
[[connectedSockets objectAtIndex:i] writeData:someData withTimeout:-1 tag:0];

не работает. Код ниже для сервера и клиента. Первоначальный обмен данными работает, но когда вызывается мое уведомление, никакие данные не отправляются, даже если оператор NSLog проверяет сокет в массиве и получает правильный IP-адрес и порт #:

Сервер: 

- (id)init
{
    self = [super init];
    if (self) {
        listenSocket = [[AsyncSocket alloc] initWithDelegate:self];
        [listenSocket setRunLoopModes:[NSArray arrayWithObject:NSRunLoopCommonModes]];
        [listenSocket acceptOnPort:42381 error:nil];


        connectedSockets = [[NSMutableArray alloc] init];
        newNotificationDictArray = [[NSMutableArray alloc] init];
        updateNotificationDictArray = [[NSMutableArray alloc] init];

        [[NSNotificationCenter defaultCenter] addObserver:self
                                                 selector:@selector(newJobNotification:)
                                                     name:@"NewJob"
                                                   object:nil];
    }

    return self;

}

-(void)onSocketDidDisconnect:(AsyncSocket *)sock
{
    [connectedSockets removeObject:sock];
}

- (void)onSocket:(AsyncSocket *)sock willDisconnectWithError:(NSError *)err
{
    [connectedSockets removeObject:sock];
}

- (void)onSocket:(AsyncSocket *)sock didAcceptNewSocket:(AsyncSocket *)newSocket
{
    [connectedSockets addObject:newSocket];
}


- (void)onSocket:(AsyncSocket *)sock didConnectToHost:(NSString *)host port:(UInt16)port
{
if ([newNotificationDictArray count] > 0) {
    NSMutableData *data = [[NSMutableData alloc] init];
    NSKeyedArchiver *archiver = [[NSKeyedArchiver alloc] initForWritingWithMutableData:data];
    [archiver encodeObject:newNotificationDictArray forKey:@"DictArray"];
    [archiver finishEncoding];
    [archiver release];
    [sock writeData:data withTimeout:-1 tag:0];
    [data release];
}

[sock readDataWithTimeout:-1 tag:0];
}

- (void)onSocket:(AsyncSocket *)sock didWriteDataWithTag:(long)tag
{
    [sock readDataWithTimeout:-1 tag:0];
}

- (void)onSocket:(AsyncSocket *)sock didReadData:(NSData *)data withTag:(long)tag
{
[sock readDataWithTimeout:-1 tag:0];
}

-(void) newJobNotification: (NSNotification *) notification
{
NSDictionary *dict = [notification userInfo];
[newNotificationDictArray addObject:dict];
[updateNotificationDictArray addObject:dict];
NSMutableData *updateData = [[NSMutableData alloc] init];
NSKeyedArchiver *archiver = [[NSKeyedArchiver alloc] initForWritingWithMutableData:updateData];
[archiver encodeObject:updateNotificationDictArray forKey:@"DictArray"];
[archiver finishEncoding]
[updateNotificationDictArray removeAllObjects];
[archiver release];
NSLog(@"Attempting to write to %@:%i", [[connectedSockets objectAtIndex:0] connectedHost], [[connectedSockets objectAtIndex:0] connectedPort]) 
[[connectedSockets objectAtIndex:0] writeData:updateData withTimeout:-1 tag:0];
}

а затем клиент: 

- (id)init
{
self = [super init];
if (self) {
    socket = [[AsyncSocket alloc] initWithDelegate:self];
}
return self;
}

-(void) connectToHost: (NSString *) address
{

}

-(BOOL)onSocketWillConnect:(AsyncSocket *)sock 
{
[sock retain];
[socket readDataWithTimeout:-1 tag:0];
return YES;
}

-(void)onSocket:(AsyncSocket *)sock didConnectToHost:(NSString *)host port:(UInt16)port 
{    
NSLog(@"Did Connect on port %i", [sock connectedPort]);
}

-(void) disconnectFromRemoteHost
{
[socket disconnect];
}

-(void)onSocketDidDisconnect:(AsyncSocket *)sock
{
NSLog(@"Did Disconnect");
}

- (void)onSocket:(AsyncSocket *)sock willDisconnectWithError:(NSError *)err
{
NSLog(@"Disconnect Error: %@", [err localizedDescription]);
}

- (void)onSocket:(AsyncSocket *)sock didWriteDataWithTag:(long)tag
{
[socket readDataWithTimeout:-1 tag:0];
}

- (void)onSocket:(AsyncSocket *)sock didReadData:(NSData *)data withTag:(long)tag
{
    NSKeyedUnarchiver *unarchiver = [[NSKeyedUnarchiver alloc] initForReadingWithData:data];
    NSArray *dictArray = [[unarchiver decodeObjectForKey:@"DictArray"] retain];
    [unarchiver finishDecoding];
    [unarchiver release];
    for (NSDictionary *dict in dictArray) {
        if ([[dict objectForKey:@"Kind"] isEqualTo:@"New"])
            [[NSNotificationCenter defaultCenter] postNotificationName:@"NewJob" object:self userInfo:dict];
        else if ([[dict objectForKey:@"Kind"] isEqualTo:@"Update"])
            [[NSNotificationCenter defaultCenter] postNotificationName:@"JobUpdate" object:self userInfo:dict];
    }
[socket readDataWithTimeout:-1 tag:0];
}

Помоги мне переполниться стеком, ты моя единственная надежда!

1 Ответ

1 голос
/ 23 августа 2011

Я вижу 2 потенциальных проблемы с вашим размещенным кодом. Первое, похоже, вряд ли будет причиной ваших проблем, но я все равно выложу. В вашем коде клиента у вас есть: 

-(BOOL)onSocketWillConnect:(AsyncSocket *)sock 
{
    [sock retain];
    [socket readDataWithTimeout:-1 tag:0];
    return YES;
}

Я не уверен, почему вы сохранили здесь "носок". У вас уже есть сохраненная копия сокета, который вы создали, и это может привести к утечке.

Что касается второй проблемы, которая, скорее всего, является причиной ваших неудач, я думаю, что это происходит. Глядя на документацию по AsyncSocket, я вижу это:

Однако AsyncSocket не является потокобезопасным. Вы должны вызывать только методы AsyncSocket из поток / runloop, на котором настроен сокет. Если вы окажетесь в теме, которая отличается от потока, в котором работает AsyncSocket, и вам нужно вызвать метод на AsyncSocket, то вы должны использовать метод, такой как executeSelector: onThread: для обеспечения метод вызывается в потоке AsyncSocket (и тем самым поддерживается безопасность потока).

Ваш код, который получает уведомления и запускает "более позднюю" запись, вероятно, находится в другом потоке, поэтому даже через этот поток запись не работает, как вы ожидаете. Далее в документации AsyncSocket предлагается использовать GCDAsyncSocket, если вам нужна безопасность потоков.

...