11

我有以下用 Objective-C 编写的代码，它将数据写入套接字。服务器在 Ubuntu 上运行 node.js：

NSString *url = @"anIPAddress";        
CFReadStreamRef readStream;
CFWriteStreamRef writeStream;            
CFStreamCreatePairWithSocketToHost(NULL, (CFStringRef)url, 9000, &readStream, &writeStream);
self.inputStream = (NSInputStream *)readStream;            
self.outputStream = (NSOutputStream *)writeStream;
[self.inputStream setDelegate:self];            
[self.outputStream setDelegate:self];            
[self.inputStream scheduleInRunLoop:[NSRunLoop currentRunLoop] forMode:NSDefaultRunLoopMode];            
[self.outputStream scheduleInRunLoop:[NSRunLoop currentRunLoop] forMode:NSDefaultRunLoopMode];            
[self.inputStream open];            
[self.outputStream open];

我能够连接到服务器并发送信息。但是我注意到几分钟后连接超时（我认为是 5 分钟左右？）。我怎样才能保持这个连接活着？我知道存在断开连接，因为如果我连接到终端下的服务器也会发生同样的事情，我必须保持该连接处于活动状态。我想我的代码中也发生了同样的事情。谢谢你的帮助！

4

4 回答 4

6

最简单的答案是尝试使用SO_KEEPALIVE套接字选项。

如果端点之间没有数据流动，则很难检测到断开的连接，这使得此选项在某些方面无用，因为它不使用数据来检测断开的连接。但是，很容易添加到您的代码中查看。添加它，看看它是否有帮助......

这就是它在 C 或 C++ 中的完成方式

int opt = 1;
// Get the native socket handle from your socket class here...
int socket_handle = getNativeSocketHandle( self.outputStream );

/*Enabling keep alive*/
if( setsockopt( socket_handle, SOL_SOCKET, SO_KEEPALIVE, &opt, sizeof( opt ) ) < 0 )
{
   // failed setting socket option
}

不那么简单的答案是将ping数据包添加到您的协议中并定期发送该 ping 数据包，以便您可以检测到断开的连接。

于 2012-07-08T23:58:05.050 回答
3

您需要定期通过连接发送一些垃圾。试试这个：

NSTimer* t = [NSTimer scheduledTimerWithTimeInterval:240 target:self selector:@selector(timerMethod:) userInfo:[NSNumber numberWithInt:sockfd] repeats:YES];

然后在中声明self：

-(void)timerMethod:(NSTimer*)t
{
  send([[t userInfo] intValue], "Keepalive!", 11, 0);
}

注意：替换`“Keepalive！” 为您的协议提供任何您想要的东西。唯一的要求是远程端（套接字服务器）忽略该消息。

于 2012-07-09T00:05:02.947 回答
3

我找到了如何做到这一点。由于服务器运行的是 node.js，所以我使用了

socket.setKeepAlive(true, 2000);

并且以这种方式节点保持每个套接字打开。默认值为 false，所以这就是超时的原因。我希望这对其他人有用。感谢您的回复，我认为保持心跳（保持活动状态）也是一个好主意，但是使用此本地方法节点会处理它。

于 2012-07-11T04:44:53.643 回答
3

假设一个 NSOutputStream *oStream;

在 iOS 上这样做：

#if 1 // Using CF
CFDataRef data = (CFDataRef)CFWriteStreamCopyProperty((__bridge CFWriteStreamRef)oStream, kCFStreamPropertySocketNativeHandle);
if(data) {
    CFSocketNativeHandle socket_handle = *(CFSocketNativeHandle *)CFDataGetBytePtr(data);
    CFRelease(data);
#else // Using Foundation
NSData *data = (NSData *)[oStream propertyForKey:(__bridge NSString *)kCFStreamPropertySocketNativeHandle];
if(data) {
    CFSocketNativeHandle socket_handle = *(CFSocketNativeHandle *)[data bytes];
#endif
    NSLog(@"SOCK HANDLE: %x", socket_handle);

    /*Enabling keep alive*/
    if( setsockopt( socket_handle, SOL_SOCKET, SO_KEEPALIVE, &opt, sizeof( opt ) ) < 0 )
    {
       NSLog(@"Yikes 2: failed to set keepalive! ERRNO: %s", strerror(errno));
    }

我之所以发布这个，是因为我花了几个小时才把它全部搞定，想节省别人的精力。

于 2013-02-10T23:32:25.787 回答