swift - 为 Swift 安排套接字通信

Question

我是 Swift 编程的新手，请原谅我必须在下面提出的虚拟问题。

在我的应用程序中，我试图安排调用一个函数，该函数将从我的服务器接收一些数据并每秒调用一次。通信需要通过 TCP 套接字实现。在做了一些研究之后，在我看来，我需要有一种方法来正确使用线程来调用该函数。所以我的问题来了:

1. 我应该在哪里连接到服务器？ (我应该在我的第一个 View Controller 的 viewDidLoad() 函数中建立连接吗？)
2. 我应该在哪里创建一个线程来安排函数调用？如果我在我的第一个 View Controller 中创建线程，该线程会在我切换到另一个 View Controller 后死掉吗？
3. 我应该为该线程使用什么 QoS 级别？该应用每秒都会渲染从服务器接收到的数据，因此我认为此任务的优先级很高。

我尝试查找有关线程和套接字通信的教程和示例，但找不到适用于我的应用程序的信息。因此，我们将不胜感激有关设计的任何帮助或见解!

提前致谢!

Answer 1

根据我的说法，可以针对问题中出现的场景进行以下操作

1. 如果您打算在启动应用程序后立即连接到您的服务器。我相信最好在下面给出的 didFinishLaunchingWithOptions 中的 AppDelegate 中执行此操作

   func application(_ application: UIApplication, didFinishLaunchingWithOptions launchOptions: [UIApplicationLaunchOptionsKey: Any]?) -> Bool {
   
   }
   

2. 这取决于您将如何切换到其他 ViewController。在切换的过程中，如果你要释放你当前的 ViewController，那么你的线程就会死掉。

3. 考虑到您正在制作一个基于套接字的应用程序，并且您将每秒从服务器接收数据。然后，NSURLSession 可能对您没有太大帮助。对于套接字通信，通常会使用 NSInputStream 和 NSOutputStream。以下来自 Objective-C 的示例可能会帮助您入门:

    - (void)connectWithHostFromUrl: (NSURL *)hostUrl {
   
           CFReadStreamRef readStream;
           CFWriteStreamRef writeStream;
           CFStreamCreatePairWithSocketToHost(NULL, (__bridge CFStringRef)[hostUrl host], 80, &readStream, &writeStream);
   
          _inputStream = (__bridge_transfer NSInputStream *)readStream;
          [_inputStream setDelegate:self];
          [_inputStream scheduleInRunLoop:[NSRunLoop currentRunLoop] forMode:NSDefaultRunLoopMode];
          [_inputStream open];
   
          _outputStream = (__bridge_transfer NSOutputStream *)writeStream;
          [_outputStream setDelegate:self];
          [_outputStream scheduleInRunLoop:[NSRunLoop currentRunLoop] forMode:NSDefaultRunLoopMode];
          [_outputStream open];
     }
   
    // Delegate methods
   
   - (void)stream:(NSStream *)aStream handleEvent:(NSStreamEvent)eventCode {
   
           switch (eventCode) {
                case NSStreamEventNone:
                {
                 // handle it according to your need
                }
                     break;
                case NSStreamEventOpenCompleted:
                {
                 // handle it according to your need
                }
                     break;
                case NSStreamEventHasBytesAvailable:
                {
                    if (_receivedData == nil) {
                         _receivedData = [NSMutableData new];
                    }
                    uint8_t buffer[1024];
                    NSInputStream *inputStream = (NSInputStream *)aStream;
                    NSInteger bytesReceived = [inputStream read:buffer maxLength:1024];
                   if (bytesReceived > 0) {
                       [_receivedData appendBytes:(const void *)buffer length:bytesReceived];
                   }
                }
                     break;
                case NSStreamEventHasSpaceAvailable:
                {
                     if (_dataToSend != nil) {
                       // _dataToSend is NSMutableData/NSData object
                         NSOutputStream *outputStream = (NSOutputStream *)aStream;
                         const uint8_t *mutableBytes = (const uint8_t *)[_dataToSend mutableBytes];
                         NSInteger length = [_dataToSend length]/sizeof(uint8_t);
                         [outputStream write:(const uint8_t *)mutableBytes maxLength:length];
                     }
                 }
                     break;
                 case NSStreamEventErrorOccurred:
                 {
                   // handle it according to your need
                 }
                     break;
                 case NSStreamEventEndEncountered:
                 {
                   // handle it according to your need
                 }
                     break;
                 default:
                     break;
          }
   }
   

因为这里要处理的情况很多。大多数时候，我建议使用经过测试的第三方库，如 SocketRocket .

请提出修改建议以使这个答案更好:)