nginx

关注公众号 jb51net

关闭
首页 > 网站技巧 > 服务器 > nginx > nginx反向代理java项目

nginx反向代理java项目方式

作者:liuyuinsdu

文章简要介绍了如何使用Nginx作为反向代理来部署Java项目,核心在于配置proxy_pass指令

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遇到的坑,后续在使用过程中还有其他的坑还是会与大家分享。

总结

以上为个人经验,希望能给大家一个参考,也希望大家多多支持脚本之家。

您可能感兴趣的文章:
阅读全文