3

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

这是我的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 秒后，它关闭连接通道，我想保持连接直到我关闭。

帮我解决这个问题。

谢谢

4

2 回答 2

1

如下更改您的 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)
        }
    }
}
于 2018-09-06T09:46:46.710 回答
0

您不需要显式调用读取功能。如下更改您的读取函数并在情况下调用 Stream.Event.hasBytesAvailable:。

func read(stream: InputStream) {
let maxReadLength = 1024
var buffer = [uint8](repeating: 0, count: maxReadLength)
while stream.hasBytesAvailable {
    let numberOfBytesRead : Int = stream.read(&buffer, maxLength: maxReadLength)
    if numberOfBytesRead < 0 {
        if let _ = stream.streamError {
            break
        }
    }

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

如果要显式调用 read()，则需要将流作为参数传递并调用 ViewController 类中的 read 函数——</p> 

socketConnection.read(stream)
于 2019-01-30T06:00:22.237 回答