IOS UI 在套接字连接期间卡住

Question

我对流或套接字连接了解不多，但似乎没有其他方法可以满足我的需要。我正在尝试构建一个简单的连接，该连接将允许我监视打开的连接并在收到输入时读取该输入。

连接工作正常，但用户界面在连接设置期间卡住。我不知道如何将其推到后台，这样它就不会干扰用户界面。

套接字类别如下

import Foundation

protocol SocketDelegate {
  func hasBytes(stream: Stream)
  func opened(stream: Stream)
  func error(stream: Stream)
  func closed(stream: Stream)
  func other(stream: Stream)
}

class Socket: NSObject, StreamDelegate {

  fileprivate var hostname: String
  fileprivate var port: Int

  fileprivate var delegate: SocketDelegate?

  fileprivate var istreamopen: Bool
  fileprivate var ostreamopen: Bool

  fileprivate var istream : InputStream?
  fileprivate var ostream : OutputStream?

  init(hostname: String, port: Int) {

    self.hostname = hostname
    self.port = port
    self.istreamopen = false
    self.ostreamopen = false

    Stream.getStreamsToHost(withName: self.hostname, port: self.port, inputStream: &self.istream, outputStream: &self.ostream)


    self.istream!.schedule(in: RunLoop.current, forMode: RunLoopMode.defaultRunLoopMode)
    self.ostream!.schedule(in: RunLoop.current, forMode: RunLoopMode.defaultRunLoopMode)

  }


  func getInputStream() -> InputStream {
    return istream!
  }

  func getOutputStream() -> OutputStream {
    return ostream!
  }

  func Connect() -> Void {

    self.istream?.delegate = self
    self.ostream?.delegate = self

    istream!.open()
    ostream!.open()
  }

  func DisConnect() -> Void {
    istream!.close()
    ostream!.close()
    istreamopen = false
    ostreamopen = false
  }

  func write(bytes: [UInt8]) {
    ostream?.write(bytes, maxLength: (bytes).count)
  }

  func write(string: String) {
    ostream?.write([UInt8](string.utf8), maxLength: ([UInt8](string.utf8)).count)
  }

  func read(bufferSize: Int) -> String {
    var output = String()
    var buffer = [UInt8](repeating: 0, count: bufferSize)
    //while (self.istream?.hasBytesAvailable)! {
      //print("HELLO")
      let bytesRead: Int = self.istream!.read(&buffer, maxLength: buffer.count)
      if bytesRead >= 0 {
        output += NSString(bytes: UnsafePointer(buffer), length: bytesRead, encoding: String.Encoding.ascii.rawValue)! as String
      } else {
        output = "# Stream read() error"
      }
      //print(output)
    //}
    return output
  }


  func setDelegate(delegate: SocketDelegate) -> Void {
    self.delegate = delegate
  }

  func stream(_ aStream: Stream, handle eventCode: Stream.Event) {
    //print("\(aStream) Stream!")
    switch eventCode {
    case Stream.Event.hasBytesAvailable:
      delegate?.hasBytes(stream: aStream)
      break;
    case Stream.Event.errorOccurred:
      //print("Stream error occurred: %@",aStream.streamError?.localizedDescription ?? "ERROR")
      delegate?.error(stream: aStream)
    case Stream.Event.openCompleted:
      //print("\(aStream)  --  \(self.istream)  --  \(self.ostream)")
      if (aStream == self.istream) {
        self.istreamopen = true
        //print("\(self.istream) Open")
      } else if (aStream === self.ostream) {
        self.ostreamopen = true
        //print("\(self.ostream) Open")
      }
      delegate?.opened(stream: aStream)
      break
    case Stream.Event.endEncountered:
      //print("Stream ended")
      if (aStream === self.istream) {
        self.istreamopen = false
      } else if (aStream === self.ostream) {
        self.ostreamopen = false
      }
      delegate?.closed(stream: aStream)
      break
    default:
      delegate?.other(stream: aStream)
      break
    }
  }

  func isConnected() -> Bool {
    return (istreamopen && ostreamopen)
  }


}

Answer 1

看来不是连接失败了。这是 SSL 协商期间的初始写入。我将写入命令包装在 DispatchQueue 中，它似乎已经解决了这个问题。

  func write(bytes: [UInt8]) {
    DispatchQueue.global(qos: .background).async {
      self.ostream?.write(bytes, maxLength: (bytes).count)
    }
  }

  func write(string: String) {
    DispatchQueue.global(qos: .background).async {
      self.ostream?.write([UInt8](string.utf8), maxLength: ([UInt8](string.utf8)).count)
    }
  }