2014-09-11 1 views
6

Клиент отправил сообщение каждый раз, когда я нажимаю кнопку отправки, но сервер получает сообщение только в первый раз. В чем проблема в сервереСервер GCDAsyncSocket принимает данные только в первый раз

Сервер:

- (void)viewDidLoad 
{ 
    [super viewDidLoad]; 

    asyncSocket = [[GCDAsyncSocket alloc] initWithDelegate:self delegateQueue:dispatch_get_main_queue()]; 

    NSError *err = nil; 
    if (![asyncSocket acceptOnPort:10000 error:&err]){ 

     NSLog(@"Error in acceptOnPort:error: -> %@", err); 

    } 
} 

- (void)socket:(GCDAsyncSocket *)sock didAcceptNewSocket:(GCDAsyncSocket *)newSocket 
{ 
    NSLog(@"Accepted new socket from %@:%hu", [newSocket connectedHost], [newSocket connectedPort]); 

    self.asyncSocket = newSocket; 
    NSString *welcomMessage = @"Hello from the server\r\n"; 
    [self.asyncSocket writeData:[welcomMessage dataUsingEncoding:NSUTF8StringEncoding] withTimeout:-1 tag:1]; 

    [self.asyncSocket readDataWithTimeout:-1 tag:0]; 

} 

-(void)socket:(GCDAsyncSocket *)sock didReadData:(NSData *)data withTag:(long)tag{ 
    NSString *msg = [[NSString alloc] initWithData:data encoding:NSUTF8StringEncoding]; 

    NSLog(@"MSG: %@",msg); 

} 

Клиент:

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

    socket = [[GCDAsyncSocket alloc] initWithDelegate:self delegateQueue:dispatch_get_main_queue()]; 
    [socket setDelegate:self]; 

} 

-(IBAction)connectToServer { 
    NSError *err = nil; 
    if (![socket connectToHost:self.txtIp.text onPort:10000 error:&err]) // Asynchronous! 
    { 
     // If there was an error, it's likely something like "already connected" or "no delegate set" 
     NSLog(@"I goofed: %@", err); 
     return; 
    } 
} 

- (void)socket:(GCDAsyncSocket *)sender didConnectToHost:(NSString *)host port:(UInt16)port 
{ 
    NSLog(@"Cool, I'm connected! That was easy."); 

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

- (void)socket:(GCDAsyncSocket *)sock didWriteDataWithTag:(long)tag 
{ 
    if (tag == 1) 
     NSLog(@"First request sent"); 
    else if (tag == 2) 
     NSLog(@"Second request sent"); 
} 

- (void)socket:(GCDAsyncSocket *)sender didReadData:(NSData *)data withTag:(long)tag 
{ 
    NSLog(@"Received Data: %@",data); 
} 


-(void)sendMessage { 

    NSData *msg = [self.txtMsg.text dataUsingEncoding:NSUTF8StringEncoding]; 

    NSLog(@"Data Send: %@",msg); 

    [socket writeData:msg withTimeout:-1 tag:1]; 

} 
+0

Получаете ли вы _message_ на сервере в первый раз или это просто вызов в результате новой попытки соединения сокета? Я считаю, что вы получаете соединение, а затем клиент должен получать приветственное сообщение. После этого на стороне сервера не будет приема. Подтвердите это, и я могу попытаться что-то предложить. – Gandalf

+0

@ Gandalf: спасибо, клиент получает приветственное сообщение, и когда клиент отправляет сообщение, только первое сообщение может принимать сервер. Другое сообщение клиента отправлено успешно, но сервер не может получить. – Salim

+1

Использование вашего кода, но неспособное к подключению к серверу. Даже в первый раз. Используете ли вы @ "localhost" в качестве параметра? –

ответ

5

Вы должны сделать вызов для чтения из своего серверного класса в didReadData: делегата. Отдых в порядке. Используйте ниже код.

-(void)socket:(GCDAsyncSocket *)sock didReadData:(NSData *)data withTag:(long)tag { 

    [sock readDataWithTimeout:-1 tag:0]; 

    NSString *msg = [[NSString alloc] initWithData:data encoding:NSUTF8StringEncoding]; 
    NSLog(@"MSG: %@",msg); 
} 
+0

Это не работает для меня. –

+0

@Coder_A_D - Вы уверены, что у вас есть точная настройка кода с вами? В вашем коде могут быть и другие отличия. Если он не работает для вас, расскажите нам, с какими проблемами вы столкнулись. Это не логика ответа на голосование сразу? – Gandalf

+1

отлично работает –

0

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

Somewhat Swift Solution 

var dataCache = Data() 

func socket(_ sock: GCDAsyncSocket, didConnectToHost host: String, port: UInt16) { 
    sock.readData(withTimeout: -1, tag: 0) 
} 

func socket(_ sock: GCDAsyncSocket, didRead data: Data, withTag tag: Int) { 
    dataCache.append(data) 
    sock.readData(withTimeout: -1, tag: 0) 
} 

func socketDidDisconnect(_ sock: GCDAsyncSocket, withError err: Error?) { 
    print("Closed with error: \(err)") 
    processData() 
} 

func socketDidCloseReadStream(_ sock: GCDAsyncSocket) { 
    print("Closed successfully") 
    processData() 
} 

func processData() { 
    // Do something with dataCache eg print it out: 
    print("The following read payload:\(String(data:dataCache, encoding: .utf8) ?? "Read data invalid")") 
    dataCache = Data() 

} 

 Смежные вопросы

  • Нет связанных вопросов^_^