我有一个HttpServletRequest
在我的春节,servlet请求,我想AS-IS(即GET或POST内容)转发到不同的服务器。
什么是做到这一点的最好方式使用Spring框架?
我是否需要获取所有信息,并建立一个新的HTTPUrlConnection
? 或者有更简单的方法?
我有一个HttpServletRequest
在我的春节,servlet请求,我想AS-IS(即GET或POST内容)转发到不同的服务器。
什么是做到这一点的最好方式使用Spring框架?
我是否需要获取所有信息,并建立一个新的HTTPUrlConnection
? 或者有更简单的方法?
不幸的是没有简单的方法来做到这一点。 基本上你必须重建的要求,其中包括:
HTTPUrlConnection
不允许任意设置用户代理“ Java/1.*
”总是附加,你需要的HttpClient) 这是一个很大的工作,更何况它不能扩展,因为每个这样的代理呼叫会占用你的机器上的一个线程。
我的建议:使用原始套接字或网状上的最低水平和截距HTTP协议,只是替换一些值(例如Host
上飞标头)。 你能否提供更多的背景下,为什么那么你需要这个?
你是否应该做转发这样一边讨论,这里是我做到了:
package com.example.servlets;
import java.net.HttpURLConnection;
import java.net.URL;
import java.util.Enumeration;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import com.example.servlets.GlobalConstants;
@SuppressWarnings("serial")
public class ForwardServlet extends HttpServlet {
@Override
public void doGet(HttpServletRequest req, HttpServletResponse resp) {
forwardRequest("GET", req, resp);
}
@Override
public void doPost(HttpServletRequest req, HttpServletResponse resp) {
forwardRequest("POST", req, resp);
}
private void forwardRequest(String method, HttpServletRequest req, HttpServletResponse resp) {
final boolean hasoutbody = (method.equals("POST"));
try {
final URL url = new URL(GlobalConstants.CLIENT_BACKEND_HTTPS // no trailing slash
+ req.getRequestURI()
+ (req.getQueryString() != null ? "?" + req.getQueryString() : ""));
HttpURLConnection conn = (HttpURLConnection) url.openConnection();
conn.setRequestMethod(method);
final Enumeration<String> headers = req.getHeaderNames();
while (headers.hasMoreElements()) {
final String header = headers.nextElement();
final Enumeration<String> values = req.getHeaders(header);
while (values.hasMoreElements()) {
final String value = values.nextElement();
conn.addRequestProperty(header, value);
}
}
//conn.setFollowRedirects(false); // throws AccessDenied exception
conn.setUseCaches(false);
conn.setDoInput(true);
conn.setDoOutput(hasoutbody);
conn.connect();
final byte[] buffer = new byte[16384];
while (hasoutbody) {
final int read = req.getInputStream().read(buffer);
if (read <= 0) break;
conn.getOutputStream().write(buffer, 0, read);
}
resp.setStatus(conn.getResponseCode());
for (int i = 0; ; ++i) {
final String header = conn.getHeaderFieldKey(i);
if (header == null) break;
final String value = conn.getHeaderField(i);
resp.setHeader(header, value);
}
while (true) {
final int read = conn.getInputStream().read(buffer);
if (read <= 0) break;
resp.getOutputStream().write(buffer, 0, read);
}
} catch (Exception e) {
e.printStackTrace();
// pass
}
}
}
显然,这可以使用一些工作方面的错误处理等,但是它的功能。 我停止使用它,但是,因为它是在我的情况下直接调用更容易CLIENT_BACKEND
比对付饼干,权威性等跨两个不同的领域。
我也需要做同样的,并与Spring控制器和RestTemplate一些非最佳后,我发现了一个更好的解决方案: Smiley的HTTP代理Servlet 。 好处是,它确实AS-IS代理,就像Apache的mod_proxy
,它确实它在一个流媒体的方式,没有缓存在内存中的完整的请求/响应。
简单地说,你注册一个新的servlet要代理到另一个服务器的路径,并给这个servlet目标主机的初始化参数。 如果您使用的是有一个web.xml传统的Web应用程序,你可以像下面对其进行配置:
<servlet>
<servlet-name>proxy</servlet-name>
<servlet-class>org.mitre.dsmiley.httpproxy.ProxyServlet</servlet-class>
<init-param>
<param-name>targetUri</param-name>
<param-value>http://target.uri/target.path</param-value>
</init-param>
</servlet>
<servlet-mapping>
<servlet-name>proxy</servlet-name>
<url-pattern>/mapping-path/*</url-pattern>
</servlet-mapping>
或者,当然,你可以用去注解配置 。
如果您在使用Spring启动,它是更容易:你只需要创建类型的豆ServletRegistrationBean
,带有必需的配置:
@Bean
public ServletRegistrationBean proxyServletRegistrationBean() {
ServletRegistrationBean bean = new ServletRegistrationBean(
new ProxyServlet(), "/mapping-path/*");
bean.addInitParameter("targetUri", "http://target.uri/target.path");
return bean;
}
这样一来,你也可以使用在环境中可用的弹性性能。
你甚至可以扩展该类ProxyServlet
并覆盖其方法来定制请求/响应头等等,在你需要的情况下。
更新 :使用笑脸的代理servlet了一段时间后,我们有一些超时问题,它不能可靠地工作。 切换到Zuul来自Netflix,没有经过任何问题。 与春季启动配置方面的教程上可以找到这个链接 。
@RequestMapping(value = "/**")
public ResponseEntity route(HttpServletRequest request) throws IOException {
String body = IOUtils.toString(request.getInputStream(), Charset.forName(request.getCharacterEncoding()));
try {
ResponseEntity<Object> exchange = restTemplate.exchange(firstUrl + request.getRequestURI(),
HttpMethod.valueOf(request.getMethod()),
new HttpEntity<>(body),
Object.class,
request.getParameterMap());
return exchange;
} catch (final HttpClientErrorException e) {
return new ResponseEntity<>(e.getResponseBodyAsByteArray(), e.getResponseHeaders(), e.getStatusCode());
}
}
如果你被迫使用Spring,请检查其他模板方法交换代理请求到第三方服务。
在这里你可以找到工作的例子。