swift - 套接字阻塞 UI 的挑战(我相信是这样)

Question

我希望你能帮助我。我对 Xcode 和 Swift 非常陌生，但我正在努力快速提高技能。我将基础语言的学习与一些真实的例子结合起来。我快到了，但我正在为一个小项目而苦苦挣扎。

基本上，我正在编写一个连接到基于套接字的服务器的小套接字客户端。在网上搜索之后，我终于找到了我认为正确的方法 - 使用 NSStream 功能。

在我附加的 View Controller 代码(附加到带有几个标签的基本 View )中，该代码有效，因为它连接并可以从服务器接收数据；流函数中的 println() 调用有效。

我遇到的问题是，一旦我的应用程序收到任何数据，它似乎就会阻塞 UI。我确实在“所有输出”窗口中看到了数据，但我的界面不再工作。例如，我有一个按钮(作为导航 Controller 的一部分)，在我收到数据之前一直有效...

我正在使用以下内容在我的 OS X 机器上创建服务器:

nc -k -l 2444

...这是我的 View Controller 代码

import UIKit

class VCMainView: UIViewController, NSStreamDelegate{

    let serverAddress: String = "127.0.0.1"
    let serverPort: Int = 2444

    var inputStream: NSInputStream?
    var outputStream: NSOutputStream?

    @IBOutlet weak var lblScreenLabel1: UILabel!
    @IBOutlet weak var lblScreenLabel2: UILabel!

    override func viewDidLoad() {

        super.viewDidLoad()

        self.lblScreenLabel1.text = "Connecting"
        self.lblScreenLabel2.text = "Please Wait..."

        self.connectSocket()

    } // func

    override func didReceiveMemoryWarning() {

        super.didReceiveMemoryWarning()

    } // func

    func connectSocket() {

        NSStream.getStreamsToHostWithName(self.serverAddress, port: self.serverPort, inputStream: &self.inputStream, outputStream: &self.outputStream)

        if inputStream != nil && outputStream != nil {

            inputStream!.delegate = self
            outputStream!.delegate = self

            inputStream!.scheduleInRunLoop(.mainRunLoop(), forMode: NSDefaultRunLoopMode)
            outputStream!.scheduleInRunLoop(.mainRunLoop(), forMode: NSDefaultRunLoopMode)

            inputStream!.open()
            outputStream!.open()

        } // if

    } // func

    func stream(aStream: NSStream, handleEvent eventCode: NSStreamEvent) {

        switch (eventCode) {

        case NSStreamEvent.ErrorOccurred:
            break

        case NSStreamEvent.EndEncountered:
            break

        case NSStreamEvent.None:
            break

        case NSStreamEvent.HasBytesAvailable:

            var buffer = [UInt8](count: 4096, repeatedValue: 0)

            if ( aStream == inputStream) {

                let hasBytes = self.inputStream!.hasBytesAvailable

                while ( hasBytes ) {

                    var len = self.inputStream!.read(&buffer, maxLength: buffer.count)
                    if(len > 0){
                        var output = NSString(bytes: &buffer, length: buffer.count, encoding: NSUTF8StringEncoding)
                        if ("" != output){

                            println(output)


                        } // if
                    } // if

                } // while

            } // if

            break
        case NSStreamEvent.allZeros:
            break

        case NSStreamEvent.OpenCompleted:
            break

        case NSStreamEvent.HasSpaceAvailable:
            break

        default:
            break

        } // switch

    } // func

} // class

如果有人能帮我指出正确的方向，我将不胜感激......

提前致谢!乔恩

Answer 1

所以看起来在发布我的问题几个小时后，尽管我在发布之前搜索了几个小时，但我发现我做错了什么。我在 Greg Parker 在另一篇文章中的回答中找到了我的解决方案 - Is calling read:maxLength: once for every NSStreamEventHasBytesAvailable correct?

我的问题是我在循环中调用检查 HasBytesAvailable，这导致了阻塞。事实证明，如果您没有读取所有可用数据(因此缓冲区比可用数据短)，那么委托(delegate)无论如何都会收到另一个事件。删除此循环解决了我的阻塞问题。这是我更新的 View Controller 类:

import UIKit

class VCMainView: UIViewController, NSStreamDelegate{

    let serverAddress: String = "127.0.0.1"
    let serverPort: Int = 2444

    var inputStream: NSInputStream?
    var outputStream: NSOutputStream?

    @IBOutlet weak var lblScreenLabel1: UILabel!
    @IBOutlet weak var lblScreenLabel2: UILabel!

    override func viewDidLoad() {

        super.viewDidLoad()

        self.lblScreenLabel1.text = "Connecting"
        self.lblScreenLabel2.text = "Please Wait..."

        self.connectSocket()

    } // func

    override func didReceiveMemoryWarning() {

        super.didReceiveMemoryWarning()

    } // func

    func connectSocket() {

        NSStream.getStreamsToHostWithName(self.serverAddress, port: self.serverPort, inputStream: &self.inputStream, outputStream: &self.outputStream)

        if inputStream != nil && outputStream != nil {

            inputStream!.delegate = self
            outputStream!.delegate = self

            inputStream!.scheduleInRunLoop(.mainRunLoop(), forMode: NSDefaultRunLoopMode)
            outputStream!.scheduleInRunLoop(.mainRunLoop(), forMode: NSDefaultRunLoopMode)

            inputStream!.open()
            outputStream!.open()

        } // if

    } // func

    func stream(aStream: NSStream, handleEvent eventCode: NSStreamEvent) {

        switch (eventCode) {

        case NSStreamEvent.ErrorOccurred:
            break

        case NSStreamEvent.EndEncountered:
            break

        case NSStreamEvent.None:
            break

        case NSStreamEvent.HasBytesAvailable:

            var buffer = [UInt8](count: 4096, repeatedValue: 0)

            if ( aStream == inputStream) {

                if ( self.inputStream!.hasBytesAvailable ) {

                    var bytesRead = self.inputStream!.read(&buffer, maxLength: 4096)
                    var output = NSString(bytes: &buffer, length: buffer.count, encoding: NSUTF8StringEncoding)

                    println(output)

                } // if

            } // if

            break
        case NSStreamEvent.allZeros:
            break

        case NSStreamEvent.OpenCompleted:
            break

        case NSStreamEvent.HasSpaceAvailable:
            break

        default:
            break

        } // switch

    } // func

} // class

现在，这并不是说我的其余代码很好，正如我在最初的问题中所说的那样，我正在学习 Swift 并且完全是初学者。如果有人确实发现任何错误，我当然欢迎任何反馈。

谢谢，乔恩