Springboot 3 + Micrometer Tracing: Tracer.currentSpan() случайным образом обнуляется при обработке параллельных вызовов GRPC

Значение io.micrometer.tracing.Tracer.currentSpan() становится нулевым для случайных вызовов на стороне сервера.

Это происходит при попадании на сервер нескольких параллельных вызовов, а не при последовательных вызовах.

Это трассировка стека на стороне сервера:

java.lang.NullPointerException: Cannot invoke "io.micrometer.tracing.Span.context()" because the return value of "io.micrometer.tracing.Tracer.currentSpan()" is null
    at com.example.micrometer.GrpcServerApplication$EchoService.unaryRpc(GrpcServerApplication.java:85) ~[main/:na]
    at io.grpc.testing.protobuf.SimpleServiceGrpc$MethodHandlers.invoke(SimpleServiceGrpc.java:410) ~[grpc-testing-proto-1.54.1.jar:1.54.1]
    at io.grpc.stub.ServerCalls$UnaryServerCallHandler$UnaryServerCallListener.onHalfClose(ServerCalls.java:182) ~[grpc-stub-1.54.1.jar:1.54.1]
    at io.grpc.PartialForwardingServerCallListener.onHalfClose(PartialForwardingServerCallListener.java:35) ~[grpc-api-1.54.1.jar:1.54.1]
    at io.grpc.ForwardingServerCallListener.onHalfClose(ForwardingServerCallListener.java:23) ~[grpc-api-1.54.1.jar:1.54.1]
    at io.grpc.ForwardingServerCallListener$SimpleForwardingServerCallListener.onHalfClose(ForwardingServerCallListener.java:40) ~[grpc-api-1.54.1.jar:1.54.1]
    at io.micrometer.core.instrument.binder.grpc.ObservationGrpcServerCallListener.onHalfClose(ObservationGrpcServerCallListener.java:47) ~[micrometer-core-1.10.6.jar:1.10.6]
    at io.grpc.internal.ServerCallImpl$ServerStreamListenerImpl.halfClosed(ServerCallImpl.java:355) ~[grpc-core-1.54.1.jar:1.54.1]
    at io.grpc.internal.ServerImpl$JumpToApplicationThreadServerStreamListener$1HalfClosed.runInContext(ServerImpl.java:867) ~[grpc-core-1.54.1.jar:1.54.1]
    at io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37) ~[grpc-core-1.54.1.jar:1.54.1]
    at io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:133) ~[grpc-core-1.54.1.jar:1.54.1]
    at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[na:na]
    at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[na:na]
    at java.base/java.lang.Thread.run(Thread.java:833) ~[na:na]

Вот минимальный образец сервера и образец клиента, воспроизводящий проблему. Что я мог упустить?

Пользовательский скаляр GraphQL
Пользовательский скаляр GraphQL
Листовые узлы системы типов GraphQL называются скалярами. Достигнув скалярного типа, невозможно спуститься дальше по иерархии типов. Скалярный тип...
Поднятие тревоги для долго выполняющихся методов в Spring Boot
Поднятие тревоги для долго выполняющихся методов в Spring Boot
Приходилось ли вам сталкиваться с требованиями, в которых вас могли попросить поднять тревогу или выдать ошибку, когда метод Java занимает больше...
Версия Java на основе версии загрузки
Версия Java на основе версии загрузки
Если вы зайдете на официальный сайт Spring Boot , там представлен start.spring.io , который упрощает создание проектов Spring Boot, как показано ниже.
Документирование API с помощью Swagger на Springboot
Документирование API с помощью Swagger на Springboot
В предыдущей статье мы уже узнали, как создать Rest API с помощью Springboot и MySql .
3
0
248
1
Перейти к ответу Данный вопрос помечен как решенный

Ответы 1

Ответ принят как подходящий

Это ошибка в микрометре версии 1.0.4 и отслеживается здесь.

Временный обходной путь до устранения проблемы — написать собственную версию ObservationGrpcServerCallListener, а затем добавить дополнительную строку this.scope.makeCurrent(); в ObservationGrpcServerCallListener#[onMessage|onHalfClose].

Другие вопросы по теме