kotlin - Micronaut gRPC 服务器端点吞噬异常(gRPC 的 StatusException 除外)；如何记录它们呢？

Question

我正在使用 Kotlin 开发 Micronaut gRPC 服务器。默认情况下，如果我的 gRPC 端点抛出异常，它会在没有任何日志记录的情况下被吞没(即使在调试级别)，并且 gRPC 仅返回一个 status: UNKNOWN 错误响应，没有详细信息。

我希望我所有的 gRPC 端点都在 ERROR 级别记录任何未捕获的异常及其堆栈跟踪。我怎样才能做到这一点？我可以看到使用 Micronaut 服务工具(拦截/记录异常)、一些 gRPC 更改或仅在 Kotlin 语言级别解决这个问题，以有效地将相同的 except-log-rethrow 逻辑应用于所有端点函数。

这是我尝试过的内容以及我发现的其他文档:

作为解决方法，我在我的端点中添加了一个带有日志记录的 try-catch，但我不想在每个端点中都有这个样板；我假设有一些更有效的方法可以将它添加到拦截器或其他东西中，但在 Micronaut 文档中没有找到。

import mu.KotlinLogging

import javax.inject.Singleton
import javax.sql.DataSource

private val logger = KotlinLogging.logger {}

@Singleton
@Suppress("unused")
class MyEndpoint(val dataSource: DataSource) : MyServiceGrpcKt.MyServiceCoroutineImplBase() {

    override suspend fun search(request: MyRequest): MyResponse {
        try {
            dataSource.getConnection().use { con ->
                con.prepareStatement("SELECT ... some sql ... ").use { stm ->
                    stm.setString(1, request.query)
                    stm.executeQuery().use { rs ->
                        // build RPC response from ResultSet
                      }
                  }
              }
          }
        } catch (e: Throwable) {
            // The question is, how to avoid having to add this try-catch and logger.error
            // call in every Endpoint?
            logger.error(e) { "Error handling $request" }
            throw e
        }

        return MyResponse.newBuilder().setStuff(... from sql ...).build()
    }
}

我检查了 Micronaut gRPC server docs和 gRPC error handling guide ，但看不到那里的提示。和 Micronaut error handling docs用于 HTTP 错误页面，而不是通用拦截器。我也在gitter Micronaut community上问过, 但没有反应。

gRPC Endpoint 类的抽象基础在我正在实现的 search RPC 方法上有这个文档:

    /**                                                                                              
     * Returns the response to an RPC for valohealth_monocle.model_search.ModelSearchService.Search. 
     *                                                                                               
     * If this method fails with a [StatusException], the RPC will fail with the corresponding       
     * [io.grpc.Status].  If this method fails with a [java.util.concurrent.CancellationException],  
     * the RPC will fail                                                                             
     * with status `Status.CANCELLED`.  If this method fails for any other reason, the RPC will      
     * fail with `Status.UNKNOWN` with the exception as a cause.                                     
     *                                                                                               
     * @param request The request from the client.                                                   
     */                                                                                              
    open suspend fun search...

该评论表明 gRPC 将异常转换为 UNKNOWN 状态是预期的行为。但它没有指出我如何启用捕获异常的日志记录。

Answer 1

对于 Kotlin，创建一个 ServerInterceptor like this .请注意，这不同于 how it's done in grpc-java .

在 Micronaut 中，只需将类注释为 @javax.inject.Singleton 即可安装拦截器。