Máy chủ GCDAsyncSocket chỉ nhận dữ liệu lần đầu tiên

Question

Tin nhắn được gửi của khách hàng mỗi khi tôi nhấn nút gửi nhưng Máy chủ chỉ nhận được tin nhắn lần đầu tiên. vấn đề này là gì trong máy chủ

Server:

- (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); 

} 

Chủ đầu tư:

- (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]; 

} 

Answer 1

Bạn phải thực hiện một cuộc gọi đọc từ lớp máy chủ của bạn trong didReadData: đại biểu. Phần còn lại là tốt. Sử dụng mã dưới đây.

-(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); 
} 

Answer 2

vì vậy sau khi đấu tranh với điều này một chút, tôi đã đưa ra mẫu sau để phân tích dữ liệu. Mặc dù dưới đây là một quá đơn giản hóa, nó dễ dàng được chuyển đến các tác vụ khác nhau:

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() 

}