使用 NSOutputstream 和 NSInputstream 每隔一个时间间隔写入和读取
Use NSOutputstream and NSInputstream to write and read every interval
我正在尝试使用 NSOutputstream 和 NSInputstream 每隔一段时间写入和读取,比如 5 秒。这是为了以 P2P 方式与 windows 上的 C# 程序通信。
我想使用 NSOutputstream 每 5 秒向 C# 程序发送一个请求,然后 NSInputstream 将读取 C# 程序的响应。
目前我有:
class Connection : NSObject, NSStreamDelegate {
var serverAddress: CFString
let serverPort: UInt32 = 11000
private var inputStream: NSInputStream!
private var outputStream: NSOutputStream!
init(serverAddress: CFString) {
self.serverAddress = serverAddress
}
func connect() {
print("connecting...")
var readStream: Unmanaged<CFReadStream>?
var writeStream: Unmanaged<CFWriteStream>?
CFStreamCreatePairWithSocketToHost(nil, self.serverAddress, self.serverPort, &readStream, &writeStream)
self.inputStream = readStream!.takeRetainedValue()
self.outputStream = writeStream!.takeRetainedValue()
self.inputStream.delegate = self
self.outputStream.delegate = self
self.inputStream.scheduleInRunLoop(NSRunLoop.currentRunLoop(), forMode: NSDefaultRunLoopMode)
self.outputStream.scheduleInRunLoop(NSRunLoop.currentRunLoop(), forMode: NSDefaultRunLoopMode)
self.inputStream.open()
self.outputStream.open()
print("connected...")
}
func disconnect() {
self.inputStream.close()
self.outputStream.close()
}
func receive() -> String {
let data: NSData = "GiveMeCurrentTime".dataUsingEncoding(NSUTF8StringEncoding)!
let bytesWritten = outputStream.write(UnsafePointer<UInt8>(data.bytes), maxLength: data.length)
print("wrote \(bytesWritten) bytes")
var buffer = [UInt8](count: 100, repeatedValue: 0)
inputStream.read(&buffer,maxLength: buffer.count)
let currentTime = String.fromCString(UnsafePointer(buffer))
print("Data received is \(currentTime)")
return currentTime
}
func stream(stream: NSStream, handleEvent eventCode: NSStreamEvent) {
//print("stream event")
if stream === inputStream {
switch eventCode {
case NSStreamEvent.ErrorOccurred:
print("input: ErrorOccurred: \(stream.streamError?.description)")
case NSStreamEvent.OpenCompleted:
print("input: OpenCompleted")
case NSStreamEvent.HasBytesAvailable:
print("input: HasBytesAvailable")
break;
case NSStreamEvent.HasSpaceAvailable:
break;
default:
print("\(eventCode)")
break
}
}
else if stream === outputStream {
switch eventCode {
case NSStreamEvent.ErrorOccurred:
print("output: ErrorOccurred: \(stream.streamError?.description)")
case NSStreamEvent.OpenCompleted:
print("output: OpenCompleted")
case NSStreamEvent.HasSpaceAvailable:
print("output: HasSpaceAvailable")
// Here you can write() to `outputStream`
break;
default:
print("\(eventCode)")
break
}
}
}
连接 class 将与 NSTimer 和 NSRunLoop 一起使用,如下所示:
func start(ipAddress ipAddress: String) {
self.conn = Connection(serverAddress: ipAddress)
self.conn!.connect()
self.sendTimer = NSTimer.scheduledTimerWithTimeInterval(5.0, target: self, selector: "getTimeAndUpdateUI", userInfo: nil, repeats: true)
NSRunLoop.currentRunLoop().addTimer(self.sendTimer!, forMode: NSDefaultRunLoopMode)
}
}
func getTimeAndUpdateUI() {
let time = self.conn!.receive()
self.timeLabel.text = "Current time is \(time)"
}
第一个 运行 总是没问题 - 我可以获得当前时间并正确显示。但随后的 运行 永远不会成功。输出流不能写出任何字节。而输入流读取时出现如下错误:
ErrorOccurred: Optional("Error Domain=NSPOSIXErrorDomain Code=32
\"Broken pipe\"")
我已经尝试搜索了很长时间,但找不到解决方案。任何帮助将不胜感激。
看起来 NSInputStream 和 NSOutputStream 不应该在流结束后重新使用。我通过将代码更改为以下来解决问题:
func start(ipAddress ipAddress: String) {
self.conn = Connection(serverAddress: ipAddress)
self.sendTimer = NSTimer.scheduledTimerWithTimeInterval(5.0, target: self, selector: "getTimeAndUpdateUI", userInfo: nil, repeats: true)
NSRunLoop.currentRunLoop().addTimer(self.sendTimer!, forMode: NSDefaultRunLoopMode)
}
func getTimeAndUpdateUI() {
self.conn!.connect()
let time = self.conn!.receive()
self.timeLabel.text = "Current time is \(time)"
self.conn!.disconnect()
}
每次 iOS 轮询服务器以获取信息时,它都会重新创建 NSInputStream 和 NSOutputStream 的实例。
欢迎提出任何改进建议。谢谢
我正在尝试使用 NSOutputstream 和 NSInputstream 每隔一段时间写入和读取,比如 5 秒。这是为了以 P2P 方式与 windows 上的 C# 程序通信。
我想使用 NSOutputstream 每 5 秒向 C# 程序发送一个请求,然后 NSInputstream 将读取 C# 程序的响应。
目前我有:
class Connection : NSObject, NSStreamDelegate {
var serverAddress: CFString
let serverPort: UInt32 = 11000
private var inputStream: NSInputStream!
private var outputStream: NSOutputStream!
init(serverAddress: CFString) {
self.serverAddress = serverAddress
}
func connect() {
print("connecting...")
var readStream: Unmanaged<CFReadStream>?
var writeStream: Unmanaged<CFWriteStream>?
CFStreamCreatePairWithSocketToHost(nil, self.serverAddress, self.serverPort, &readStream, &writeStream)
self.inputStream = readStream!.takeRetainedValue()
self.outputStream = writeStream!.takeRetainedValue()
self.inputStream.delegate = self
self.outputStream.delegate = self
self.inputStream.scheduleInRunLoop(NSRunLoop.currentRunLoop(), forMode: NSDefaultRunLoopMode)
self.outputStream.scheduleInRunLoop(NSRunLoop.currentRunLoop(), forMode: NSDefaultRunLoopMode)
self.inputStream.open()
self.outputStream.open()
print("connected...")
}
func disconnect() {
self.inputStream.close()
self.outputStream.close()
}
func receive() -> String {
let data: NSData = "GiveMeCurrentTime".dataUsingEncoding(NSUTF8StringEncoding)!
let bytesWritten = outputStream.write(UnsafePointer<UInt8>(data.bytes), maxLength: data.length)
print("wrote \(bytesWritten) bytes")
var buffer = [UInt8](count: 100, repeatedValue: 0)
inputStream.read(&buffer,maxLength: buffer.count)
let currentTime = String.fromCString(UnsafePointer(buffer))
print("Data received is \(currentTime)")
return currentTime
}
func stream(stream: NSStream, handleEvent eventCode: NSStreamEvent) {
//print("stream event")
if stream === inputStream {
switch eventCode {
case NSStreamEvent.ErrorOccurred:
print("input: ErrorOccurred: \(stream.streamError?.description)")
case NSStreamEvent.OpenCompleted:
print("input: OpenCompleted")
case NSStreamEvent.HasBytesAvailable:
print("input: HasBytesAvailable")
break;
case NSStreamEvent.HasSpaceAvailable:
break;
default:
print("\(eventCode)")
break
}
}
else if stream === outputStream {
switch eventCode {
case NSStreamEvent.ErrorOccurred:
print("output: ErrorOccurred: \(stream.streamError?.description)")
case NSStreamEvent.OpenCompleted:
print("output: OpenCompleted")
case NSStreamEvent.HasSpaceAvailable:
print("output: HasSpaceAvailable")
// Here you can write() to `outputStream`
break;
default:
print("\(eventCode)")
break
}
}
}
连接 class 将与 NSTimer 和 NSRunLoop 一起使用,如下所示:
func start(ipAddress ipAddress: String) {
self.conn = Connection(serverAddress: ipAddress)
self.conn!.connect()
self.sendTimer = NSTimer.scheduledTimerWithTimeInterval(5.0, target: self, selector: "getTimeAndUpdateUI", userInfo: nil, repeats: true)
NSRunLoop.currentRunLoop().addTimer(self.sendTimer!, forMode: NSDefaultRunLoopMode)
}
}
func getTimeAndUpdateUI() {
let time = self.conn!.receive()
self.timeLabel.text = "Current time is \(time)"
}
第一个 运行 总是没问题 - 我可以获得当前时间并正确显示。但随后的 运行 永远不会成功。输出流不能写出任何字节。而输入流读取时出现如下错误:
ErrorOccurred: Optional("Error Domain=NSPOSIXErrorDomain Code=32 \"Broken pipe\"")
我已经尝试搜索了很长时间,但找不到解决方案。任何帮助将不胜感激。
看起来 NSInputStream 和 NSOutputStream 不应该在流结束后重新使用。我通过将代码更改为以下来解决问题:
func start(ipAddress ipAddress: String) {
self.conn = Connection(serverAddress: ipAddress)
self.sendTimer = NSTimer.scheduledTimerWithTimeInterval(5.0, target: self, selector: "getTimeAndUpdateUI", userInfo: nil, repeats: true)
NSRunLoop.currentRunLoop().addTimer(self.sendTimer!, forMode: NSDefaultRunLoopMode)
}
func getTimeAndUpdateUI() {
self.conn!.connect()
let time = self.conn!.receive()
self.timeLabel.text = "Current time is \(time)"
self.conn!.disconnect()
}
每次 iOS 轮询服务器以获取信息时,它都会重新创建 NSInputStream 和 NSOutputStream 的实例。
欢迎提出任何改进建议。谢谢