kotlin 用Quarkus和Reactor重写DNC滤波器中的数据流

yshpjwxd  于 2023-10-23  发布在  Kotlin
关注(0)|答案(1)|浏览(222)

我有一个webhook从侧面服务，我试图使一个过滤器在前面的控制器，检查签名。类似于Spring Security风格，但不幸的是，它是Quarkus with Reactor。在控制器中，我有null，调试器甚至没有实现控制器方法。
我的目标是：
1.检查签名我需要一个头部和身体，它和WebhookHandlerUtility不是mt类，我不能改变它。和WebhookHandlerUtility.verifySignature(signature, body)同步方法，我不能改变它。
1.我需要重写流，因为我希望在控制器中接收此数据作为主体。
我的实现有什么问题以及如何修复它？

  1. @Provider
  2. class SignatureFilter(
  3.         private val objectMapper: ObjectMapper,
  4.         private val webhookHandlerUtility: WebhookHandlerUtility
  5. ) : ContainerRequestFilter {
  7.     private val executor = Executors.newFixedThreadPool(5)
  9.     @Throws(IOException::class)
  10.     override fun filter(requestContext: ContainerRequestContext) {
  11.         executor.execute {
  12.             val signature = requestContext.getHeaderString("signature")
  13.             val body = requestContext.entityStream.reader().readText()
  15.             if (!webhookHandlerUtility.verifySignature(signature, body)) {
  16.                 throw TerraSignatureVerificationException()
  17.             }
  19.             val payload = webhookHandlerUtility.parseWebhookPayload(body)
  20.                     ?: throw TerraWebHookPayloadParseException()
  22.             val json = objectMapper.writeValueAsString(payload.raw)
  23.             val newInputStream = ByteArrayInputStream(json.toByteArray())
  25.             requestContext.entityStream = newInputStream
  26.         }
  27.     }
  28. }
  30. @ApplicationScoped
  31. @Path("/webHook")
  32. class WebHookController(
  33.         private val omronService: OmronService
  34. ) {
  36.     @POST
  37.     @Path("/device")//, 
  38.     @Consumes(MediaType.APPLICATION_JSON)
  39.     fun omronWebHook(req: HookDto): Uni<Response> {
  40.         log.info("Received data: $req")
  41.         return omronService.save(req)
  42.                 .map { Response.noContent().build() }
  43.     }
  44. }
  1. 2023-09-29 14:30:46,346 DEBUG [org.jbo.res.rea.ser.han.ParameterHandler] (vert.x-eventloop-thread-0) Error occurred during parameter extraction: 
  2. javax.enterprise.inject.UnsatisfiedResolutionException: No bean found for required type [interface javax.ws.rs.container.ContainerRequestContext] and qualifiers [[]]
  3.     at io.quarkus.arc.impl.InstanceImpl.bean(InstanceImpl.java:190)
  4.     at io.quarkus.arc.impl.InstanceImpl.getInternal(InstanceImpl.java:211)
  5.     at io.quarkus.arc.impl.InstanceImpl.get(InstanceImpl.java:97)
  6.     at org.jboss.resteasy.reactive.server.core.parameters.ContextParamExtractor.extractParameter(ContextParamExtractor.java:100)
  7.     at org.jboss.resteasy.reactive.server.handlers.ParameterHandler.handle(ParameterHandler.java:45)
  8.     at io.quarkus.resteasy.reactive.server.runtime.QuarkusResteasyReactiveRequestContext.invokeHandler(QuarkusResteasyReactiveRequestContext.java:111)
  9.     at org.jboss.resteasy.reactive.common.core.AbstractResteasyReactiveContext.run(AbstractResteasyReactiveContext.java:142)
  10.     at org.jboss.resteasy.reactive.server.handlers.RestInitialHandler.beginProcessing(RestInitialHandler.java:51)
  11.     at org.jboss.resteasy.reactive.server.vertx.ResteasyReactiveVertxHandler.handle(ResteasyReactiveVertxHandler.java:18)
  12.     at org.jboss.resteasy.reactive.server.vertx.ResteasyReactiveVertxHandler.handle(ResteasyReactiveVertxHandler.java:8)
  13.     at io.vertx.ext.web.impl.RouteState.handleContext(RouteState.java:1284)
  14.     at io.vertx.ext.web.impl.RoutingContextImplBase.iterateNext(RoutingContextImplBase.java:173)
  15.     at io.vertx.ext.web.impl.RoutingContextImpl.next(RoutingContextImpl.java:140)
  16.     at io.quarkus.vertx.http.runtime.StaticResourcesRecorder$2.handle(StaticResourcesRecorder.java:84)
  17.     at io.quarkus.vertx.http.runtime.StaticResourcesRecorder$2.handle(StaticResourcesRecorder.java:71)
  18.     at io.vertx.ext.web.impl.RouteState.handleContext(RouteState.java:1284)
  19.     at io.vertx.ext.web.impl.RoutingContextImplBase.iterateNext(RoutingContextImplBase.java:173)
  20.     at io.vertx.ext.web.impl.RoutingContextImpl.next(RoutingContextImpl.java:140)
  21.     at io.quarkus.vertx.http.runtime.VertxHttpRecorder$6.handle(VertxHttpRecorder.java:430)
  22.     at io.quarkus.vertx.http.runtime.VertxHttpRecorder$6.handle(VertxHttpRecorder.java:408)
  23.     at io.vertx.ext.web.impl.RouteState.handleContext(RouteState.java:1284)
  24.     at io.vertx.ext.web.impl.RoutingContextImplBase.iterateNext(RoutingContextImplBase.java:173)
  25.     at io.vertx.ext.web.impl.RoutingContextImpl.next(RoutingContextImpl.java:140)
  26.     at io.quarkus.vertx.http.runtime.devmode.VertxHttpHotReplacementSetup$5.handle(VertxHttpHotReplacementSetup.java:196)
  27.     at io.quarkus.vertx.http.runtime.devmode.VertxHttpHotReplacementSetup$5.handle(VertxHttpHotReplacementSetup.java:185)
  28.     at io.vertx.core.impl.future.FutureImpl$3.onSuccess(FutureImpl.java:141)
  29.     at io.vertx.core.impl.future.FutureBase.lambda$emitSuccess$0(FutureBase.java:54)
  30.     at io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:174)
  31.     at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:167)
  32.     at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:470)
  33.     at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:569)
  34.     at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997)
  35.     at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
  36.     at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
  37.     at java.base/java.lang.Thread.run(Thread.java:833)
  39. 2023-09-29 14:30:46,349 DEBUG [org.jbo.res.rea.com.cor.AbstractResteasyReactiveContext] (vert.x-eventloop-thread-0) Restarting handler chain for exception exception: 
  40. javax.ws.rs.WebApplicationException: HTTP 400 Bad Request
  41.     at org.jboss.resteasy.reactive.server.handlers.ParameterHandler.handle(ParameterHandler.java:66)
  42.     at io.quarkus.resteasy.reactive.server.runtime.QuarkusResteasyReactiveRequestContext.invokeHandler(QuarkusResteasyReactiveRequestContext.java:111)
  43.     at org.jboss.resteasy.reactive.common.core.AbstractResteasyReactiveContext.run(AbstractResteasyReactiveContext.java:142)
  44.     at org.jboss.resteasy.reactive.server.handlers.RestInitialHandler.beginProcessing(RestInitialHandler.java:51)
  45.     at org.jboss.resteasy.reactive.server.vertx.ResteasyReactiveVertxHandler.handle(ResteasyReactiveVertxHandler.java:18)
  46.     at org.jboss.resteasy.reactive.server.vertx.ResteasyReactiveVertxHandler.handle(ResteasyReactiveVertxHandler.java:8)
  47.     at io.vertx.ext.web.impl.RouteState.handleContext(RouteState.java:1284)
  48.     at io.vertx.ext.web.impl.RoutingContextImplBase.iterateNext(RoutingContextImplBase.java:173)
  49.     at io.vertx.ext.web.impl.RoutingContextImpl.next(RoutingContextImpl.java:140)
  50.     at io.quarkus.vertx.http.runtime.StaticResourcesRecorder$2.handle(StaticResourcesRecorder.java:84)
  51.     at io.quarkus.vertx.http.runtime.StaticResourcesRecorder$2.handle(StaticResourcesRecorder.java:71)
  52.     at io.vertx.ext.web.impl.RouteState.handleContext(RouteState.java:1284)
  53.     at io.vertx.ext.web.impl.RoutingContextImplBase.iterateNext(RoutingContextImplBase.java:173)
  54.     at io.vertx.ext.web.impl.RoutingContextImpl.next(RoutingContextImpl.java:140)
  55.     at io.quarkus.vertx.http.runtime.VertxHttpRecorder$6.handle(VertxHttpRecorder.java:430)
  56.     at io.quarkus.vertx.http.runtime.VertxHttpRecorder$6.handle(VertxHttpRecorder.java:408)
  57.     at io.vertx.ext.web.impl.RouteState.handleContext(RouteState.java:1284)
  58.     at io.vertx.ext.web.impl.RoutingContextImplBase.iterateNext(RoutingContextImplBase.java:173)
  59.     at io.vertx.ext.web.impl.RoutingContextImpl.next(RoutingContextImpl.java:140)
  60.     at io.quarkus.vertx.http.runtime.devmode.VertxHttpHotReplacementSetup$5.handle(VertxHttpHotReplacementSetup.java:196)
  61.     at io.quarkus.vertx.http.runtime.devmode.VertxHttpHotReplacementSetup$5.handle(VertxHttpHotReplacementSetup.java:185)
  62.     at io.vertx.core.impl.future.FutureImpl$3.onSuccess(FutureImpl.java:141)
  63.     at io.vertx.core.impl.future.FutureBase.lambda$emitSuccess$0(FutureBase.java:54)
  64.     at io.netty.util.concurrent.AbstractEventExecutor.runTask(AbstractEventExecutor.java:174)
  65.     at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java:167)
  66.     at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:470)
  67.     at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:569)
  68.     at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:997)
  69.     at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
  70.     at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30)
  71.     at java.base/java.lang.Thread.run(Thread.java:833)
  72. Caused by: javax.enterprise.inject.UnsatisfiedResolutionException: No bean found for required type [interface javax.ws.rs.container.ContainerRequestContext] and qualifiers [[]]
  73.     at io.quarkus.arc.impl.InstanceImpl.bean(InstanceImpl.java:190)
  74.     at io.quarkus.arc.impl.InstanceImpl.getInternal(InstanceImpl.java:211)
  75.     at io.quarkus.arc.impl.InstanceImpl.get(InstanceImpl.java:97)
  76.     at org.jboss.resteasy.reactive.server.core.parameters.ContextParamExtractor.extractParameter(ContextParamExtractor.java:100)
  77.     at org.jboss.resteasy.reactive.server.handlers.ParameterHandler.handle(ParameterHandler.java:45)
  78.     ... 30 more
  80. 2023-09-29 14:30:46,358 INFO  [http-problem] (vert.x-eventloop-thread-0) status=400, title="Bad Request", detail="HTTP 400 Bad Request" 
  81. Exception in thread "pool-6-thread-1" java.lang.IllegalStateException: Cannot be called from response filter
  82.     at org.jboss.resteasy.reactive.server.jaxrs.ContainerRequestContextImpl.assertNotResponse(ContainerRequestContextImpl.java:94)
  83.     at org.jboss.resteasy.reactive.server.jaxrs.ContainerRequestContextImpl.setEntityStream(ContainerRequestContextImpl.java:158)
  84.     at com.dfskjhzxk.terra.configuration.SignatureFilter.filter$lambda$0(SignatureFilter.kt:41)
  85.     at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
  86.     at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
  87.     at java.base/java.lang.Thread.run(Thread.java:833)
kotlin

1条答案

按热度按时间
r6l8ljro

r6l8ljro1#

问题是，你试图从一个不是由Quarkus管理的线程访问一个请求作用域的bean（因为你正在使用自己的执行器）。
一个简单的补救方法是在filter方法本身中访问ContainerRequestContext中所需的任何内容，而不是在用作线程Runnable的lambda中访问前者

赞(0）分享  回复(0）举报  2023-10-23
我来回答

相关问题

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新问答

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com