問(wèn)題描述

1. 列表中的任務(wù),是要用戶分享到微信群或者朋友圈,當(dāng)分享成功收到回調(diào)之后,把改任務(wù)設(shè)置成"已完成"
2. 連續(xù)若干次分享,前面n次都沒(méi)有分享成功,第n+1次分享成功后,前面的所有任務(wù)都變成了"已完成"

問(wèn)題排查

在相關(guān)頁(yè)面中,有個(gè)shareToWechat的方法

當(dāng)用戶點(diǎn)擊了"分享"按鈕,就調(diào)用這個(gè)方法,方法中添加了一個(gè)微信分享回調(diào)通知監(jiān)聽(tīng)

監(jiān)聽(tīng)回調(diào)方法中,把該任務(wù)id加入到已完成列表,代碼如下:

// 分享到微信
    private func shareToWechat(model: GWXShareModel, task: GOwnMissionMetaTask){
        // 調(diào)用分享
        if wxShareSendMultiMessage(model: model) == false {
            SVProgressHUD.showError(withStatus: "分享失敗")
            return
        }
        SVProgressHUD.dismiss()
        NotificationCenter.default.rx
            .notification(Notification.Name.init(R.string.global.kNoti_Share_Wechat_Success()))
            .subscribe({ (noti) in
            print("~~~~分享成功!!")
            SVProgressHUD.dismiss()
            // 把當(dāng)前任務(wù)加到完成列表里,用戶可以領(lǐng)取獎(jiǎng)勵(lì)
            self.viewModel.addTaskToDoneList(id: task.id)
            // 刷新列表
            self.viewModel.missionList.value = self.viewModel.missionList.value
            
        }).disposed(by: self.disposeBag)
    }

問(wèn)題分析

• 通過(guò)斷點(diǎn)調(diào)試,發(fā)現(xiàn)當(dāng)?shù)趎+1次分享成功后,發(fā)射了一次成功回調(diào)的廣播

• 而成功的回調(diào)被注冊(cè)了n+1次,于是回調(diào)方法調(diào)用了n+1次,問(wèn)題就出在了這里.

• 所以 問(wèn)題的關(guān)鍵是: 如何保證沒(méi)有分享成功的任務(wù),不執(zhí)行成功的回調(diào)方法

問(wèn)題解決

為了達(dá)到目的,我目前有兩個(gè)想法:

1. 在分享成功的廣播發(fā)送后,分別進(jìn)入到n+1個(gè)回調(diào)操作,然后通過(guò)某種條件判斷當(dāng)前的任務(wù)是否成功
2. 在分享失敗的廣播發(fā)送后,把對(duì)任務(wù)成功的訂閱事件銷毀掉

經(jīng)過(guò)一番思索,發(fā)現(xiàn)想法1不可行,想法2很容易做到,最終的代碼如下:

    // 分享到微信
    private func shareWX(model: GWXShareModel, task: GOwnMissionMetaTask){
        // 調(diào)用分享
        if wxShareSendMultiMessage(model: model) == false {
            SVProgressHUD.showError(withStatus: "分享失敗")
            return
        }
        // 分享成功的監(jiān)聽(tīng)
        let notificationSubscription = NotificationCenter.default.rx
            .notification(Notification.Name.init(R.string.global.kNoti_Share_Wechat_Success()))
            .subscribe({ (noti) in
            print("~~~~分享成功!!")
            SVProgressHUD.dismiss()
            // 把當(dāng)前任務(wù)加到完成列表里,用戶可以領(lǐng)取獎(jiǎng)勵(lì)
            self.viewModel.addTaskToDoneList(id: task.id)
            // 刷新列表
            self.viewModel.missionList.value = self.viewModel.missionList.value
        })
        // 分享失敗的監(jiān)聽(tīng)
        NotificationCenter.default.rx
        .notification(Notification.Name.init(R.string.global.kNoti_Share_Wechat_Fail()))
            .subscribe { (noti) in
                // 微信分享失敗后,把對(duì)分享成功的rx監(jiān)聽(tīng)對(duì)象銷毀
                notificationSubscription.dispose()
        }.disposed(by: disposeBag)
    }

總結(jié)

對(duì)于監(jiān)聽(tīng)通知,要留意是否注冊(cè)了多余的訂閱者,如果不及時(shí)清除很可能會(huì)有bug