Swift 3 Socket問題

我在Swift 3中編寫了一個非常簡單的基於套接字的命令行工具，但是我的流並沒有調用委託方法。例如，當我檢查字節是否可用時，有可用的字節，但委託方法尚未被調用。這裏是我的連接代碼：Swift 3 Socket問題

func connect() { 

    print("Socket Connection") 

    let ipAddress = "127.0.0.1" as CFString 

    let portNumber: UInt32 = 8080 

    var readStream: Unmanaged<CFReadStream>? 
    var writeStream: Unmanaged<CFWriteStream>? 
    CFStreamCreatePairWithSocketToHost(nil, ipAddress, portNumber, &readStream, &writeStream) 

    self.inputStream = readStream!.takeRetainedValue() 
    self.outputStream = writeStream!.takeRetainedValue() 

    self.inputStream?.delegate = self 
    self.outputStream?.delegate = self 

    self.inputStream?.schedule(in: RunLoop.current, forMode: RunLoopMode.defaultRunLoopMode) 
    self.outputStream?.schedule(in: RunLoop.current, forMode: RunLoopMode.defaultRunLoopMode) 

    self.inputStream?.open() 
    self.outputStream?.open() 
}

來源

2016-09-16 wt65074

你可以嘗試用mainRunLoop而不是當前的。 – Hasya

我嘗試過，但它有相同的結果。 – wt65074

我建議你去https://github.com/tidwall/SwiftWebSocket，使用這個包裝類，我用它在我的項目。它非常耐用和堅固耐用。 – Hasya

這可能有助於

var inputStream:InputStream! 
var outputStream:OutputStream! 
var buffer = [UInt8](repeating: 0, count: 1024) 

func useCFStream() { 

    let host:CFString = "news.yahoo.com" as CFString 
    let port:uint = 80 


    var readStream :Unmanaged<CFReadStream>?; 
    var writeStream:Unmanaged<CFWriteStream>?; 


    CFStreamCreatePairWithSocketToHost(nil, host as CFString, port, &readStream, &writeStream) 

    inputStream    = readStream!.takeRetainedValue() 
    outputStream   = writeStream!.takeRetainedValue() 

    inputStream.delegate = self 
    outputStream.delegate = self 


    inputStream.schedule(in: RunLoop.current, forMode:.defaultRunLoopMode) 
    outputStream.schedule(in:RunLoop.current, forMode:.defaultRunLoopMode) 

    inputStream.open() 
    outputStream.open() 


    let iData      = "GET /rss/entertainment HTTP/1.1 \n\n" 
    var sendData     = iData.data(using: String.Encoding.utf8) 


    let uData = sendData?.withUnsafeBytes({ (buffer:UnsafePointer<UInt8>?) -> UnsafePointer<UInt8> in 

     return buffer!.advanced(by: 0) 
    }) 
    outputStream.write(uData!, maxLength: sendData!.count) 

} 

func stream(_ stream: Stream, handle eventCode: Stream.Event) { 

    if stream === inputStream { 

     print("input") 

     switch eventCode { 

     case Stream.Event.openCompleted: 
      //print("input: openCompleted") 
      break 
     case Stream.Event.hasBytesAvailable: 
      print("input: HasBytesAvailable") 


      inputStream.read(&buffer, maxLength: buffer.count) 
      while inputStream.hasBytesAvailable { 
       _ = inputStream.read(&buffer, maxLength: buffer.count) 
       let str = String(bytes: buffer, encoding: String.Encoding.utf8) 
       print(" \(str)") 

      } 

     default: 
      print("default") 
     } 
    } 
    else if stream === outputStream { 

     //print("output") 
    } 

}

不能保證代碼優化。我還沒有明白withUnsafeBytes和UnsafePointer的用法，但設法使它的工作，如果有人有更好的解決方案，請發佈。

來源

2016-09-19 10:08:30

這確實有幫助。謝謝！ – elmarko

Swift 3 Socket問題

回答

相關問題