ios – NSStreamDelegate没有收到NSStreamEvent.HasSpaceAvailable:

我让我的代码在另一个项目中工作,在具有以下签名的类中:
class ViewController: UIViewController,NsstreamDelegate,UITextFieldDelegate  {

然后我将连接移动到它自己的类,所以我可以在每个连接中重用它:

class XMPPConnection: NSObject,NsstreamDelegate

当我这样做时,我将所有viewDidLoad()代码移动到init()中.我还尝试将该init代码放在一个单独的函数中,并在实例化该类之后调用函数.这并没有改变任何事情.

我可以在2个项目之间切换,旧的和新的,只是为了确保它不是服务器问题,这样做确认它不是.

每次运行应用程序后,结果都不同.它要么不调用HasspaceAvailable并且只是坐在那里,要么在我的类AppDelegate中的线程1上抛出(lldb)错误:UIResponder,UIApplicationDelegate,FBLoginViewDelegate.这个错误可能与Facebook集成有关,但是对于lldb来说,没什么可看的.但是,对于每次运行,与其他项目不同,从不调用HasspaceAvailable.

这是NsstreamDelegate的完整代码,因此没有混淆.该类是一种使用XMPP协议的相当标准的连接方法.

import UIKit
import Foundation


class XMPPConnection: NSObject,NsstreamDelegate { //NSObject

    var input : NSInputStream?
    var output: NSOutputStream?

    //let XMLStream: String = "<stream:stream xmlns:stream='http://etherx.jabber.org/streams' version='1.0' xmlns='jabber:client' to='mydomain.com' xml:lang='en' xmlns:xml='http://www.w3.org/XML/1998/namespace'>"
    let XMLStream: String = "<stream:stream to='mydomain.com' xmlns='jabber:client' xmlns:stream='http://etherx.jabber.org/streams' version='1.0'>"
    var XMLAuth: String?
    let XMLStreamEnd: String = "</stream:stream>"
    let XMLResource: String = "<iq type='set' id='bind_1'><bind xmlns='urn:ietf:params:xml:ns:xmpp-bind'><resource>Oneside</resource></bind></iq>"
    let XMLSession: String = "<iq type='set' id='sess_1'><session xmlns='urn:ietf:params:xml:ns:xmpp-session'/></iq>"
    let XMLStartTLS: String = "<starttls xmlns='urn:ietf:params:xml:ns:xmpp-tls'/>";
    var messagesToBeSent:[String] = []
    var lastSentMessageID = 0
    var lastReceivedMessageID = 0


    init(facebookID: String) {
        super.init()
        let username = "admin@mydomain.com" //should hash device ID
        let password = "123456" //hash it
        var UTF8AuthStr = "\0\(username)\0\(password)".dataUsingEncoding(NSUTF8StringEncoding)
        let Base64Str = UTF8AuthStr!.base64EncodedStringWithOptions(NSDataBase64EncodingOptions.fromraw(0)!)
        XMLAuth = "<auth xmlns='urn:ietf:params:xml:ns:xmpp-sasl' mechanism='PLAIN'>\(Base64Str)</auth>"
        //println(XMLAuth)

        self.connectToSocket("mydomain.com",port: 5222)
        send(self.XMLStream)
        //send(self.XMLStartTLS)
        /*send(self.XMLAuth!)
        send(self.XMLStream)
        send(self.XMLResource)
        send(self.XMLSession)*/
        //sendMessage("hi")


    }

    func connectToSocket(host: String,port: Int) {

        Nsstream.getStreamsToHostWithName(host,port: port,inputStream: &(self.input),outputStream: &(self.output))

        self.input!.delegate  = self
        self.output!.delegate = self

        self.input!.scheduleInRunLoop(NSRunLoop.currentRunLoop(),forMode: NSDefaultRunLoopMode)
        self.output!.scheduleInRunLoop(NSRunLoop.currentRunLoop(),forMode: NSDefaultRunLoopMode)

        self.input!.open()
        self.output!.open()

        println("Connected")


        //let bytesWritten = self.output!.write(UnsafePointer(data.bytes),maxLength: data.length)

        //println(bytesWritten)


    }

    //The delegate receives this message when a given event has occurred on a given stream.
    func stream(theStream: Nsstream!,handleEvent streamEvent: NsstreamEvent) {

        println("Message received")

        switch streamEvent {
        case NsstreamEvent.None:
            println("NsstreamEvent.None")
        case NsstreamEvent.OpenCompleted:
            println("NsstreamEvent.OpenCompleted")
        case NsstreamEvent.HasBytesAvailable:
            println("NsstreamEvent.HasBytesAvailable")
            if let inputStream = theStream as? NSInputStream {
                //println("is NSInputStream")
                if inputStream.hasBytesAvailable {
                    //println("hasBytesAvailable")
                    let bufferSize = 1024
                    var buffer = Array<UInt8>(count: bufferSize,repeatedValue: 0)

                    var bytesRead: Int = inputStream.read(&buffer,maxLength: bufferSize)
                    //println(bytesRead)
                    if bytesRead >= 0 {
                        lastReceivedMessageID++
                        var output: String = Nsstring(bytes: &buffer,length: bytesRead,encoding: NSUTF8StringEncoding)
                        //println("output is")
                        println(output)
                    } else {
                        println("error")
                        // Handle error
                    }
                }
            }
        case NsstreamEvent.HasspaceAvailable:
            println("NsstreamEvent.HasspaceAvailable")
            send(nil) //send next item
            //send next message or
            //what if there is no next message to send,and instead waiting user input?
        case NsstreamEvent.ErrorOccurred:
            println("NsstreamEvent.ErrorOccurred")
        case NsstreamEvent.EndEncountered:
            println("NsstreamEvent.EndEncountered")
        default:
            println("default")
        }
    }

    func send(message:String?){
        if (self.output!.hasspaceAvailable){ //stream ready for input
            //println("true hasspaceAvailable")
            var data:NSData
            var thisMessage:String
            if message == nil{ // no message specified
                if messagesToBeSent.count != 0{ //messages waiting to be sent
                    thisMessage = messagesToBeSent[0]
                    data = messagesToBeSent[0].dataUsingEncoding(NSUTF8StringEncoding,allowLossyConversion: false)!
                    messagesToBeSent.removeAtIndex(0)
                }
                else{ //no data to be sent
                    //no message specified and nothing to be sent
                    return
                }
            }
            else{
                thisMessage = message!
                data = message!.dataUsingEncoding(NSUTF8StringEncoding,allowLossyConversion: false)!
            }

            //println("Sent the following")
            wait()
            let bytesWritten = self.output!.write(UnsafePointer(data.bytes),maxLength: data.length)
            lastSentMessageID++
            //println(thisMessage)
            //println("Message sent to server and response is")
            //println(bytesWritten) //int count
        }
        else{ //steam busy
            println("no space available in stream")
            if message != nil{
                messagesToBeSent.append(message!)
            }
        }
    }

    func sendMessage(message:String,from:String,to:String){
        let xmlMessage = "<message to='\(to)@mydomain.com' from='\(from)@mydomain.com' type='chat' xml:lang='en'> <body>\(message)</body></message>"
        send(xmlMessage)
    }


    func wait() {
        while true {
            //println("waiting")
            if lastSentMessageID == lastReceivedMessageID {
                break
            }

            NSRunLoop.currentRunLoop().runUntilDate(NSDate(timeIntervalSinceNow: 0.1));
            NSThread.sleepForTimeInterval(0.1)
        }
    }

}

所以我可以看到可能导致这种情况的两件事.要么将它移动到它自己的类中,要么创建它的实例,要么改变继承.考虑到第一种可能性,我正在研究代码的线程:self.input!.scheduleInRunLoop(NSRunLoop.currentRunLoop(),forMode:NSDefaultRunLoopMode)

检查streamStatus.toRaw()后,它显示1是NsstreamStatusopening.我不确定这是否会发生变化.

解决方法

如果XMPPConnection存储在局部变量中,我可以重现问题,
例如
func application(application: UIApplication,didFinishLaunchingWithOptions launchOptions: [NSObject: AnyObject]?) -> Bool {

    let conn = XMPPConnection(facebookID: "...")
    return true
}

方法返回时,实例将被释放.另一方面是流
代表仍指向实例,这会导致崩溃.代表
Nsstream的属性声明为

uNowned(unsafe) var delegate: NsstreamDelegate?

这是Swift相当于“assign”又名“unsafe_unretained”.因此
设置委托不保留对象,并取消分配对象
不将属性设置为nil(对于弱引用).

如果实例存储在属性中,例如

class AppDelegate: UIResponder,UIApplicationDelegate {

    var window: UIWindow?
    var conn : XMPPConnection!

    func application(application: UIApplication,didFinishLaunchingWithOptions launchOptions: [NSObject: AnyObject]?) -> Bool {

        conn = XMPPConnection(facebookID: "...")
        return true
    }

    // ...
}

然后你的代码在我的测试中正常工作.

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。

相关推荐


当我们远离最新的 iOS 16 更新版本时,我们听到了困扰 Apple 最新软件的错误和性能问题。
欧版/美版 特别说一下,美版选错了 可能会永久丧失4G,不过只有5%的概率会遇到选择运营商界面且部分必须连接到iTunes才可以激活
一般在接外包的时候, 通常第三方需要安装你的app进行测试(这时候你的app肯定是还没传到app store之前)。
前言为了让更多的人永远记住12月13日,各大厂都在这一天将应用变灰了。那么接下来我们看一下Flutter是如何实现的。Flutter中实现整个App变为灰色在Flutter中实现整个App变为灰色是非常简单的,只需要在最外层的控件上包裹ColorFiltered,用法如下:ColorFiltered(颜色过滤器)看名字就知道是增加颜色滤镜效果的,ColorFiltered( colorFilter:ColorFilter.mode(Colors.grey, BlendMode.
flutter升级/版本切换
(1)在C++11标准时,open函数的文件路径可以传char指针也可以传string指针,而在C++98标准,open函数的文件路径只能传char指针;(2)open函数的第二个参数是打开文件的模式,从函数定义可以看出,如果调用open函数时省略mode模式参数,则默认按照可读可写(ios_base:in | ios_base::out)的方式打开;(3)打开文件时的mode的模式是从内存的角度来定义的,比如:in表示可读,就是从文件读数据往内存读写;out表示可写,就是把内存数据写到文件中;
文章目录方法一:分别将图片和文字置灰UIImage转成灰度图UIColor转成灰度颜色方法二:给App整体添加灰色滤镜参考App页面置灰,本质是将彩色图像转换为灰度图像,本文提供两种方法实现,一种是App整体置灰,一种是单个页面置灰,可结合具体的业务场景使用。方法一:分别将图片和文字置灰一般情况下,App页面的颜色深度是24bit,也就是RGB各8bit;如果算上Alpha通道的话就是32bit,RGBA(或者ARGB)各8bit。灰度图像的颜色深度是8bit,这8bit表示的颜色不是彩色,而是256
领导让调研下黑(灰)白化实现方案,自己调研了两天,根据网上资料,做下记录只是学习过程中的记录,还是写作者牛逼
让学前端不再害怕英语单词(二),通过本文,可以对css,js和es6的单词进行了在逻辑上和联想上的记忆,让初学者更快的上手前端代码
用Python送你一颗跳动的爱心
在uni-app项目中实现人脸识别,既使用uni-app中的live-pusher开启摄像头,创建直播推流。通过快照截取和压缩图片,以base64格式发往后端。
商户APP调用微信提供的SDK调用微信支付模块,商户APP会跳转到微信中完成支付,支付完后跳回到商户APP内,最后展示支付结果。CSDN前端领域优质创作者,资深前端开发工程师,专注前端开发,在CSDN总结工作中遇到的问题或者问题解决方法以及对新技术的分享,欢迎咨询交流,共同学习。),验证通过打开选择支付方式弹窗页面,选择微信支付或者支付宝支付;4.可取消支付,放弃支付会返回会员页面,页面提示支付取消;2.判断支付方式,如果是1,则是微信支付方式。1.判断是否在微信内支付,需要在微信外支付。
Mac命令行修改ipa并重新签名打包
首先在 iOS 设备中打开开发者模式。位于:设置 - 隐私&安全 - 开发者模式(需重启)
一 现象导入MBProgressHUD显示信息时,出现如下异常现象Undefined symbols for architecture x86_64: "_OBJC_CLASS_$_MBProgressHUD", referenced from: objc-class-ref in ViewController.old: symbol(s) not found for architecture x86_64clang: error: linker command failed wit
Profiles >> 加号添加 >> Distribution >> "App Store" >> 选择 2.1 创建的App ID >> 选择绑定 2.3 的发布证书(.cer)>> 输入描述文件名称 >> Generate 生成描述文件 >> Download。Certificates >> 加号添加 >> "App Store and Ad Hoc" >> “Choose File...” >> 选择上一步生成的证书请求文件 >> Continue >> Download。
今天有需求,要实现的功能大致如下:在安卓和ios端实现分享功能可以分享链接,图片,文字,视频,文件,等欢迎大佬多多来给萌新指正,欢迎大家来共同探讨。如果各位看官觉得文章有点点帮助,跪求各位给点个“一键三连”,谢啦~声明:本博文章若非特殊注明皆为原创原文链接。