nginx反向代理java项目
server
{
listen 80;
server_name ***.***.com;
location / {
proxy_pass http://127.0.0.1:8686;
}
#一键申请ssl证书验证目录相关设置
location ~ \.well-known{
allow all;
}
access_log /www/wwwlogs/***.***.com.log;
error_log /www/wwwlogs/***.***.com.error.log;
}很简单,核心就是 proxy_pass
java实现反向代理的坑
公司是做车辆物联网相关业务的,需要一个网关系统对设备上传的报文进行解析。最近换了个一个新的开源网关系统,里面集成了一些对设备操作的api接口。由于网关系统不能对外,所以需要另一个系统鉴权后将接口反向代理到网关的api接口,类似于nginx的反向代理。
在网上找了半天,发现 smiley-http-proxy-servlet可以实现类似功能且实现非常简单,实现步骤如下:
导入smiley-http-proxy-servletmaven依赖
<dependency>
<groupid>org.mitre.dsmiley.httpproxy</groupid>
<artifactid>smiley-http-proxy-servlet</artifactid>
<version>1.12.1</version>
</dependency>在配置文件中编写代理的前缀和目标地址
proxy:
solr:
servlet_url: /proxy/*
target_url: http://solrserver:8983/proxy编写配置类
@configuration
public class solrproxyservletconfiguration implements environmentaware {
@bean
public servletregistrationbean servletregistrationbean() {
properties properties= (properties) bindresult.get();
// 设置代理前缀
servletregistrationbean servletregistrationbean = new servletregistrationbean(new proxyservlet(), properties.getproperty("servlet_url"));
// 设置代理目标地址
servletregistrationbean.addinitparameter(proxyservlet.p_target_uri, properties.getproperty("target_url"));
// 设置是否打印日志
servletregistrationbean.addinitparameter(proxyservlet.p_log, properties.getproperty("logging_enabled", "false"));
return servletregistrationbean;
}
private bindresult bindresult;
@override
public void setenvironment(environment environment) {
iterable sources = configurationpropertysources.get(environment);
binder binder = new binder(sources);
bindresult bindresult = binder.bind("proxy.solr", properties.class);
this.bindresult = bindresult;
}
}假设当前代理服务器地址为 127.0.0.1:8001,当访问 http://127.0.0.1:8001/proxy/test 这个请求回被代理服务器转发到 http://solrserver:8983/proxy/test 这样我们就实现了一个请求的代理了。
当时我喜滋滋的认为大功告成开始测试时,发现当时使用 post 请求且携带的参数类型 x-www-form-urlencoded 会导致请求超时。后面在百度搜了半天也没找到解决方法,于是我就想着去这个项目的github主页哪里看下有没有大神遇到这个问题。
当我用 x-www-form-urlencoded作为关键词在issues里搜索时,真好发现有大佬也遇到了这个问题。
出现这个问题的原因很简单就是springboot中过滤器太多,导致 responsebody 被提前消费了,无法返回到客户端。
在这条 issues下有个大佬提出来解决方案,就是继承 proxyservlet 并重写 newproxyrequestwithentity方法,代码如下:
protected httprequest newproxyrequestwithentity(
string method, string proxyrequesturi, httpservletrequest servletrequest) throws ioexception {
httpentityenclosingrequest eproxyrequest =
new basichttpentityenclosingrequest(method, proxyrequesturi);
string contenttype = servletrequest.getcontenttype();
boolean isformpost =
(contenttype != null
&& contenttype.contains("application/x-www-form-urlencoded")
&& "post".equalsignorecase(servletrequest.getmethod()));
if (isformpost) {
list<namevaluepair> queryparams = collections.emptylist();
string querystring = servletrequest.getquerystring();
if (querystring != null) {
queryparams = urlencodedutils.parse(querystring, consts.utf_8);
}
map<string, string[]> form = servletrequest.getparametermap();
list<namevaluepair> params = new arraylist<>();
outer_loop:
for (iterator<string> nameiterator = form.keyset().iterator(); nameiterator.hasnext(); ) {
string name = nameiterator.next();
// skip parameters from query string
for (namevaluepair queryparam : queryparams) {
if (name.equals(queryparam.getname())) {
continue outer_loop;
}
}
string[] value = form.get(name);
if (value.length != 1) {
throw new runtimeexception("expecting one value in post form");
}
params.add(new basicnamevaluepair(name, value[0]));
}
eproxyrequest.setentity(new urlencodedformentity(params, "utf-8"));
} else {
eproxyrequest.setentity(
new inputstreamentity(servletrequest.getinputstream(), getcontentlength(servletrequest)));
}
return eproxyrequest;
}solrproxyservletconfiguration也需要重新设置使用的 proxyservlet
servletregistrationbean servletregistrationbean = new servletregistrationbean(new myproxyservlet(), properties.getproperty("servlet_url"));这就是我在使用 smiley-http-proxy-servlet遇到的坑,后续在使用过程中还有其他的坑还是会与大家分享。
总结
以上为个人经验,希望能给大家一个参考,也希望大家多多支持代码网。
发表评论