如何在Micronaut筛选器中处理请求外部服务时的异常并相应地返回状态

Question

因此，我对rx-java/rx-kotlin完全陌生，直到我在Micronaut (https://docs.micronaut.io/latest/guide/index.html#filters)中编写HTTP filter时才听说过它，这让我猝不及防，因为我只做过常规的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)
            }
        }

代码被重写了，但point仍然存在。这里有一些改进的空间。

我想要做的是改进异常处理，在抛出异常的情况下返回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，以防止它向下游发出异常。