如何处理在向外部服务发出请求时出现异常，并在Micronaut过滤器中相应地返回状态

Question

所以我对rx-java/rx-kotlin完全陌生，直到我在Micronaut(https://docs.micronaut.io/latest/guide/index.html#filters(中编写HTTP过滤器之前一直没有听说过它，这让我措手不及，因为我只做过常规的JAX-RS过滤器。

所以在做了一些反复试验之后，我想出了这个。

return Flowable.fromPublisher(remoteClient.getPermissions(userId))
.subscribeOn(Schedulers.io())
.onErrorReturn { e ->
logger.error("Error when fetching users from remote service", e)
emptyList()
}
.switchMap { permissions ->
if (permissions.contains(somePermission)) {
chain.proceed(request)
} else {
val response = HttpResponseFactory.INSTANCE.status(
HttpStatus.FORBIDDEN,
"No user found"
)
Flowable.just(response)
}
}

代码被重写，但点仍然存在。这里还有一些改进的余地。

我想做的是改进异常处理，并在引发异常的情况下返回 500(例如，如果无法访问remoteClient调用的远程服务(。我怎样才能做到这一点？除了上面的解决方案之外，我没有其他工作可以为下一个观察者返回一个空列表。

Answer 1

您可以将onErrorReturn运算符移到switchMap运算符之后。如果getPermissions发出错误，执行将跳过您的switchMap，并在onErrorReturn内部拾取：

return Flowable.fromPublisher(remoteClient.getPermissions(userId))
.subscribeOn(Schedulers.io())
.switchMap { permissions ->
if (permissions.contains(somePermission)) {
chain.proceed(request)
} else {
val response = HttpResponseFactory.INSTANCE.status(
HttpStatus.FORBIDDEN,
"No user found"
)
Flowable.just(response)
}
}
.onErrorReturn { e ->
logger.error("Error when fetching users from remote service", e)
val response = // whatever
return response
}

请注意，switchMap内部发生的异常也会导致执行onErrorReturn。因此，您要么想要检查传递到onErrorReturn中的异常以决定使用哪个响应，要么在switchMap中嵌入一个链接到chain.proceed(request)调用的onErrorReturn，以防止它在下游发出异常。