我在我的应用程序中使用套接字连接。

这是我的 SocketConnection.swift

    init(host: String, port:UInt32){
        self.host = host
        self.port = port
        self.status = false
        output = ""
        super.init()
    }

    func stream(aStream: NSStream, handleEvent aStreamEvent: NSStreamEvent) {
        switch aStreamEvent {

        case NSStreamEvent.OpenCompleted:
            break

        case NSStreamEvent.HasBytesAvailable:

            break

        case NSStreamEvent.HasSpaceAvailable:
            break

        case NSStreamEvent.EndEncountered:

//            aStream.close()
            aStream.removeFromRunLoop(NSRunLoop.currentRunLoop(), forMode: NSDefaultRunLoopMode)
            break

        case NSStreamEvent.None:

            break

        case NSStreamEvent.ErrorOccurred:

            break

        default:
            println("# something weird happend")
            break
        }
    }

    func connect() {
        println("# connecting to \(host):\(port)")
        var cfReadStream : Unmanaged<CFReadStream>?
        var cfWriteStream : Unmanaged<CFWriteStream>?

        CFStreamCreatePairWithSocketToHost(kCFAllocatorDefault, host, port, &cfReadStream, &cfWriteStream)
        inputStream = cfReadStream!.takeRetainedValue()
        outputStream = cfWriteStream!.takeRetainedValue()

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

        inputStream!.scheduleInRunLoop(NSRunLoop.currentRunLoop(), forMode: NSDefaultRunLoopMode)
        outputStream!.scheduleInRunLoop(NSRunLoop.currentRunLoop(), forMode: NSDefaultRunLoopMode)

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


    func read(){  
        var buffer = [UInt8](count: bufferSize, repeatedValue: 0)
        output = ""
        while (self.inputStream!.hasBytesAvailable){
            var bytesRead: Int = inputStream!.read(&buffer, maxLength: buffer.count)
            if bytesRead >= 0 {
                output += NSString(bytes: UnsafePointer(buffer), length: bytesRead, encoding: encoding)! as String
            } else {
                println("# error")
            }
            println("> \(output)")
        }
    }

    func send(message:String){        
            let data:NSData = message.dataUsingEncoding(NSUTF8StringEncoding, allowLossyConversion: false)!
            let bytesWritten = self.outputStream!.write(UnsafePointer(data.bytes), maxLength: data.length)
            println("< send to \(host)")

    }

在我的 ViewController.swift 中， 我是这样连接到服务器的

var socketConnection = SocketConnection(host: _ip, port: _port) 
socketConnection.connect() 
socketConnection.send(urlString) 
socketConnection.read()

现在我可以通过套接字发送我的 url 字符串，但是当我显式读取时，如果我从 NSStreamEvent.HasBytesAvailable 调用相同的读取函数，我不会从服务器获取数据它打印服务器响应..但是我怎样才能触发事件队列？

我想显式调用此 socketConnection.read()。我该怎么做？

连接 2 秒后，它会关闭连接 channel ，我想在关闭之前保持连接。

帮我解决这个问题。

谢谢

最佳答案

如下更改您的 read()，然后在 NSStreamEvent.HasBytesAvailable 的情况下调用 read() func:

private func read(stream: InputStream) {
    let maxReadLength = 1024
    let buffer = UnsafeMutablePointer<UInt8>.allocate(capacity: maxReadLength)
    while stream.hasBytesAvailable {
        let numberOfBytesRead = inputStream?.read(buffer, maxLength: maxReadLength)

        if numberOfBytesRead! < 0 {
            if let _ = inputStream?.streamError {
                break
            }
        }

        if let message = processedMessageString(buffer: buffer, length: numberOfBytesRead!) {
            delegate?.receivedMessage(message: message)
        }
    }
}

关于sockets - 如何在 swift 中明确地从 NSInputStream 中读取数据？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/30031268/