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
遇到的坑,后续在使用过程中还有其他的坑还是会与大家分享。
总结
以上为个人经验,希望能给大家一个参考,也希望大家多多支持代码网。
发表评论