RxSwift错误后DisposeBag导致无法重新登录问题求助

这个问题我之前也碰到过，本质是RxSwift序列的生命周期和订阅管理没处理好，咱们一步步来定位和解决：

问题根源分析 #

你当前的代码每次调用performLogin都会创建一个新的订阅并绑定到disposeBag，但出现问题的原因大概率是下面两个情况之一：

1. performLogin返回的Observable是一次性且不可复用的：如果ViewModel里的这个方法返回的是同一个Observable实例（比如把请求序列存在了属性里），那它在第一次出错后就进入了error终止状态，后续再订阅也不会触发新的请求。
2. disposeBag的生命周期不正确：如果disposeBag是局部变量（比如在登录方法内部创建），那订阅会在方法执行完后立刻被销毁，导致后续的登录请求无法被监听。

具体解决方案 #

1. 确保每次调用performLogin都返回新的Observable实例 #

检查你的LoginViewModel里的performLogin实现，要保证每次调用都创建全新的请求序列，而不是复用旧的实例。比如：

class LoginViewModel {
    func performLogin(email: String, password: String) -> Observable<Void> {
        // 每次调用都创建新的网络请求Observable
        return ApiClient.login(email: email, password: password)
            .map { loginResponse in
                // 处理登录响应，转换成Void类型
                return ()
            }
            .catch { error in
                // 可选：统一处理错误，或者直接抛出
                return Observable.error(error)
            }
    }
}

重点：不要把请求序列存在ViewModel的属性里复用，每次登录都要新建。

2. 保证disposeBag是ViewController的实例属性 #

disposeBag必须和ViewController同生命周期，不能是局部变量。正确的写法如下：

class LoginViewController: UIViewController {
    // 作为实例属性，和VC一起创建、销毁
    private let disposeBag = DisposeBag()
    private let loginViewModel = LoginViewModel()
    
    // 点击登录按钮触发的方法
    @IBAction func loginButtonTapped(_ sender: UIButton) {
        guard let email = emailTextField.text?.trimmingCharacters(in: .whitespaces),
              let password = passwordTextField.text?.trimmingCharacters(in: .whitespaces),
              !email.isEmpty, !password.isEmpty else {
            // 提示输入合法信息
            return
        }
        
        self.loginViewModel.performLogin(email: email, password: password)
            .observeOn(MainScheduler.instance)
            .subscribe(onNext: { [weak self] _ in
                self?.loginSucceeded()
            }, onError: { [weak self] error in
                self?.loginFailed(withError: error as? ApiError)
            })
            .disposed(by: disposeBag)
    }
    
    // ... 其他登录成功/失败的方法
}

注意：这里用[weak self]避免循环引用，这也是RxSwift订阅里的最佳实践。

3. 进阶优化：用Relay实现更可控的登录触发（可选） #

如果希望避免重复创建订阅，让ViewModel的逻辑更清晰，可以用PublishRelay来触发登录请求，只在ViewController里订阅一次结果：

ViewModel代码：

class LoginViewModel {
    // 用Relay接收登录触发事件
    private let loginTrigger = PublishRelay<(email: String, password: String)>()
    // 对外暴露登录结果的Observable
    let loginResult: Observable<Void>
    
    init() {
        loginResult = loginTrigger
            // 用flatMapLatest确保如果快速多次点击，只保留最新的请求
            .flatMapLatest { [weak self] credentials in
                guard let self = self else { return Observable.empty() }
                return self.performLoginRequest(email: credentials.email, password: credentials.password)
            }
            // 共享订阅，避免重复发起请求
            .share(replay: 1, scope: .whileConnected)
    }
    
    // 对外提供的登录触发方法
    func performLogin(email: String, password: String) {
        loginTrigger.accept((email: email, password: password))
    }
    
    // 内部实际执行登录请求的方法
    private func performLoginRequest(email: String, password: String) -> Observable<Void> {
        return ApiClient.login(email: email, password: password)
            .map { _ in () }
            .catch { error in
                return Observable.error(error)
            }
    }
}

ViewController代码：

class LoginViewController: UIViewController {
    private let disposeBag = DisposeBag()
    private let loginViewModel = LoginViewModel()
    
    override func viewDidLoad() {
        super.viewDidLoad()
        // 只在viewDidLoad里订阅一次登录结果
        setupLoginBindings()
    }
    
    private func setupLoginBindings() {
        loginViewModel.loginResult
            .observeOn(MainScheduler.instance)
            .subscribe(onNext: { [weak self] _ in
                self?.loginSucceeded()
            }, onError: { [weak self] error in
                self?.loginFailed(withError: error as? ApiError)
            })
            .disposed(by: disposeBag)
    }
    
    @IBAction func loginButtonTapped(_ sender: UIButton) {
        guard let email = emailTextField.text?.trimmingCharacters(in: .whitespaces),
              let password = passwordTextField.text?.trimmingCharacters(in: .whitespaces),
              !email.isEmpty, !password.isEmpty else {
            return
        }
        // 只需要触发登录，不需要重复订阅
        loginViewModel.performLogin(email: email, password: password)
    }
}

这种方式的好处是：避免重复创建订阅，同时用flatMapLatest可以防止快速点击导致的多次请求，让登录逻辑更可控。

内容的提问来源于stack exchange，提问作者Neria Jerafi