Micronaut gRPC服务器endpoint吞咽异常（gRPC的StatusException除外）；如何记录它们？

Question

我正在Kotlin的Micronaut gRPC服务器上工作。默认情况下，如果我的gRPCendpoint抛出异常，它将在没有任何日志记录的情况下被吞噬（即使在调试级别），gRPC只返回一个状态：未知的错误响应，没有任何详细信息。

我希望我所有的gRPCendpoint在ERROR级别记录任何未捕获的异常及其堆栈跟踪。我该怎么做？我可以看到使用Micronaut服务工具（拦截/记录异常）、一些gRPC更改或仅在静态编程语言级别解决此问题，以有效地将相同的除日志重抛逻辑应用于所有endpoint函数。

以下是我尝试过的内容和我找到的其他文档：

作为一种解决方法，我在我的endpoint中添加了一个try-catch日志记录，但我不想在每个endpoint中都使用这个样板文件；我假设有更有效的方法将其添加到拦截器中，但在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服务器文档和gRPC错误处理指南，但没有看到任何提示。Micronaut错误处理文档用于HTTP错误页面，而不是通用拦截器。我还询问了gitter Micronaut社区，但没有回应。

gRPCendpoint类的抽象基在我正在实现的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

对于静态编程语言，创建一个像这样的ServerInterceptor。请注意，这与在grpc-java中完成的方式不同。

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