在Spring Boot中区分嵌入式Tomcat中多个连接器/端口之间的请求

Question

我在多个端口上配置了一个基于Spring Boot rest服务的应用程序，该应用程序需要区分每个请求所经过的端口。为应用程序提供多个端口的想法是由于不同的公共和私有子网（具有不同的安全访问级别）可以访问应用程序公开的服务的不同部分。

从概念上讲，这个想法是向嵌入式tomcat添加额外的连接器，然后通过向每个指定它通过的“通道”添加自定义标头来捕获所有改变它们的传入请求。

我面临的问题是，我不知道如何在连接器级别捕获这些传入请求（在它到达任何过滤器或servlet之前）。

因此，对于多端口解决方案，我有：

@Configuration
public class EmbeddedTomcatConfiguration {

    @Value("${server.additional-ports}")
    private String additionalPorts;

    @Bean
    public TomcatServletWebServerFactory servletContainer() {
        TomcatServletWebServerFactory tomcat = new TomcatServletWebServerFactory();
        Connector[] additionalConnectors = additionalConnector();
        if(additionalConnectors != null && additionalConnectors.length > 0) {
            tomcat.addAdditionalTomcatConnectors(additionalConnectors);
        }
        return tomcat;
    }

    private Connector[] additionalConnector() {
        if(StringUtils.isNotBlank(additionalPorts)) {
            return Arrays.stream(additionalPorts.split(","))
                .map(String::trim)
                .map(p -> {
                    Connector connector = new Connector(Http11NioProtocol.class.getCanonicalName());
                    connector.setScheme("http");
                    connector.setPort(Integer.valueOf(p));
                    return connector;
                })
                .toArray(Connector[]::new);
        }
        return null;
    }
}

理论上，我可以向每个连接器注册一个自定义的生命周期侦听器，但据我所知，这没有用。我也听说过一些关于阀门的事情，尽管我不知道如何在每个连接器上实现它们。

也许我走错了路。

我真的很感谢你在这件事上的任何帮助。

Answer 1

还可以使用RequestCondition根据端口路由请求，我认为端口更接近stock-spring。参见Spring Boot |如何动态添加新的tomcat连接器？

Answer 2

似乎你已经下定决心要尝试一个瓣膜，但是，经过更多的研究，我建议使用ServletFilter来完成这项工作，而不是瓣膜。

我相信您可以在Valve中完成这项工作，但Valve必须部署到tomcat/lib目录中，而不是打包在应用程序中。我强烈建议您考虑将应用程序保存在可部署工件中，而不是在创建新部署时必须记住将一个额外的jar文件部署到tomcat实例中。

从这个答案可以看出servlet中getLocalPort（）和getServerPort（）之间的区别，您应该能够通过在HttpServletRequest上调用getLocalPort（）来访问tomcat端口。

然后根据您在问题中的想法，在请求头中添加一个特定的上下文名称。

public class PortContextFilter implements Filter {

    public void doFilter(ServletRequest request, ServletResponse response, FilterChain filterChain) throws IOException, ServletException {

        int localPort = request.getLocalPort();

        // if else or case statements

        ServletRequest newRequest = PortContextHttpServletRequestWrapper(request, YourPortContext)

        filterChain.doFilter(newRequest, response);
    }

    public void destroy() {
        // Nothing to do
    }

    public void init(FilterConfig filterConfig) throws ServletException {
        // Nothing to do.
    }

}

在这之后，理论上，您应该能够使用@RequestMapping注释根据标头内的名称进行路由。

@PreAuthorize("hasPermission(#your_object, 'YOUR_OBJECT_WRITE')")
@RequestMapping("/yourobject/{identifier}", headers="context=<context_name>", method = RequestMethod.POST)
public String postYourObject(@PathVariable(value = "identifier") YourObject yourObject) {
    // Do something here...
    ...
}