为您提供背景知识,在收到请求后,我们希望提取有效负载以及请求 URI、查询参数等其他信息,并将其作为消息放入消息队列中。然后另一个服务将选择消息并调用 Katharsis,以便适当的控制器处理请求。这是为了创建一个异步处理机制。
现在要手动调用 Katharsis,我们需要实现KatharsisInvokerContext
需要创建HttpServletRequest
和HSResponse
. 但是,由于这发生在服务器中,我们希望响应返回原始请求者。
有谁知道如何做到这一点,或者我们是否做错了?我愿意接受建议。
我们正在使用Spring Boot、Katharsis-core 2.0.1和Katharsis-spring 2.0.3。