NetworkOnMainThreadException 当使用 rxandroid 和 mvvm 设计模式时

Question

我的代码有一个问题，它抛出了NetworkOnMainThreadException。我正在尝试使用Android XML-RPC库连接到Odoo的Android应用程序。

这就是我正在做的事情。

class OdooServiceImpl : OdooService {
/* This is the only function doing network operation*/
override fun userAuthenticate(
host: String,
login: String,
password: String,
database: String
): Single<Int> {
val client = XMLRPCClient("$host/xmlrpc/2/common")
val result =
client.call("login", database, login, password)
return Single.just(result as Int)
}}

此类是从存储库类调用的。

存储库(如果由视图模型类使用 rxandroid 调用(

class OdooViewModel(private val mainRepository: OdooRepository, private val context: Context) :
ViewModel() {
val host = "https://myodoo-domain.com"
private val user = MutableLiveData<OdooResource<Int>>()
private val compositeDisposable = CompositeDisposable()
init {
authUser()
}

private fun authUser(){
user.postValue(OdooResource.authConnecting(null))
compositeDisposable.add(
mainRepository.userAuthenticate(host,"mylogin","mypassword","mdb")
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe({
if (it != null) {
user.postValue(OdooResource.authSuccess(it))
} else {
user.postValue(
OdooResource.authError(
null,
msg = "Something went wring while authenticating to $host"
)
)
}
}, {
server.postValue(
OdooResource.conError(
null,
msg = "Something went wring while authenticating to $host"
)
)
})
)
}

override fun onCleared() {
super.onCleared()
compositeDisposable.dispose()
}

fun getUser(): LiveData<OdooResource<Int>> {
return user
}
}

我从我的活动中调用了这个类，如下所示

class OdooActivity : AppCompatActivity() {
private lateinit var odooViewModel: OdooViewModel
override fun onCreate(savedInstanceState: Bundle?) {
super.onCreate(savedInstanceState)
setContentView(R.layout.activity_odoo)

setupViewModel()
setupObserver()
}
private fun setupObserver() {
odooViewModel.getUser().observe(this, Observer {
Log.i("TAGGG", "Tests")
when (it.status) {
OdooStatus.AUTHENTICATION_SUCCESS -> {
progressBar.visibility = View.GONE
it.data?.let { server -> textView.setText(server.toString()) }
textView.visibility = View.VISIBLE
}
OdooStatus.AUTHENTICATION -> {
progressBar.visibility = View.VISIBLE
textView.visibility = View.GONE
}
OdooStatus.AUTHENTICATION_ERROR -> {
//Handle Error
progressBar.visibility = View.GONE
Toast.makeText(this, it.message, Toast.LENGTH_LONG).show()
}
else -> {
}
}
})

}
private fun setupViewModel() {
val viewModelFactory = OdooViewModelFactory(OdooApiHelper(OdooServiceImpl()), this)
odooViewModel = ViewModelProviders.of(this, viewModelFactory).get(OdooViewModel::class.java)
}
}

当我运行应用程序时，这是抛出错误的行

odooViewModel = ViewModelProviders.of(this, viewModelFactory).get(OdooViewModel::class.java) 

我在这里错过了什么？？

Answer 1

罪魁祸首在这里：

val result = client.call("login", database, login, password)
return Single.just(result as Int)

在设置 Rx 链时执行生成结果的调用，这发生在主线程上。您必须确保网络调用是在实际订阅时完成的(在io()上(。一种解决方案可能是返回一个Single.fromCallable：

return Single.fromCallable { client.call("login", database, login, password) as Int }