如何解决我们可以唯一标识从 POST 方法发送响应的请求吗?
我正在开发一个异步的网络服务。在我的客户端代码中,我使用 boto3 session client
来调用我的 Jetty 服务器的 GET API,它是 S3 类似的服务。 GET API 从 S3 获取原始数据并修改请求,以便能够将请求转发到 Flask 服务器。然后 Python flask 处理请求(完成数据转换)并调用 Jetty Server 的 POST API。
现在我一直在想如何回复原来的来电者?因为我不确定一个 API 请求是否可以有一个 session-id 来识别原始调用者?
我的 POST API 如何响应客户端?以下是我试图实现的总体概念。我该怎么做?
解决方法
由于我使用的是嵌入式 Jetty,所以我使用了内置的 org.eclipse.jetty.server.HttpChannel.Listener
。
我现在可以访问具有该请求的 HTTP 字段的原始内部 Jetty org.eclipse.jetty.server.Request
对象。
要使用它,我将创建该 HttpChannel.Listener
的一个实例,并将其作为 bean 添加到我的连接器中。
public class RequestChannelListener implements HttpChannel.Listener {
@Override
public void onRequestBegin(Request request) {
HttpFields.Mutable replacement = HttpFields.build(request.getHttpFields())
.put("X-Request-ID",UUID.randomUUID().toString().toUpperCase());
request.setHttpFields(replacement);
}
}
在连接器中作为 bean 添加 -
RequestChannelListener channelListener = new RequestChannelListener();
connector.addBean(channelListener);
然后对该请求的所有其他访问,无论是 Jetty 的内部组件、Web 应用程序、特定 servlet、过滤器、转发、包含、servlet 规范中的错误处理、servlet 上下文之外的错误处理等都可以看到
要检查自定义标头是否已添加到请求中 -
Enumeration<String> headerNames = request.getHeaderNames();
while(headerNames.hasMoreElements()) {
String headerName = headerNames.nextElement();
System.out.println("Header Name - " + headerName + ",Value - " + request.getHeader(headerName));
}
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。