在 Micronaut 过滤器中相应地向外部服务和 return 状态请求时如何处理异常

Question

所以我对 rx-java/rx-kotlin 完全陌生，直到我在 Micronaut 中编写 HTTP 过滤器 (https://docs.micronaut.io/latest/guide/index.html#filters) 之前才听说过它，这让我措手不及，因为我已经仅完成常规 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)
            }
        }

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

我想做的是改进异常处理，return 500 以防抛出异常（比如无法访问 remoteClient 调用的远程服务） . 我怎样才能做到这一点？除了上面 return 下一个观察者的空列表的解决方案外，我没有其他工作要做。

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 中嵌入一个 onErrorReturn，链接到 chain.proceed(request) 调用，以防止它向下游发出异常。

在 Micronaut 过滤器中相应地向外部服务和 return 状态请求时如何处理异常

How to handle exception when doing request to external service and return status accordingly in Micronaut filter

rx-java2

rx-kotlin2

micronaut