如何在Spring Integration InboundChannelAdapter中获取请求路径

你可以通过以下几种方式在Spring Integration Flow中获取HTTP请求路径：

1. 通过消息头存储请求路径 #

在定义Http.inboundChannelAdapter时，使用headerExpressions将请求路径存入消息头，后续步骤直接从消息头读取：

return IntegrationFlow
        .from(Http.inboundChannelAdapter(IMPORT_BASE_PATH + "/**")
                .requestMapping(mapping -> mapping.methods(POST))
                .headerExpressions(headers -> headers.put("requestPath", "request.requestURI")))
        .handle((payload, headers) -> {
            String requestPath = headers.get("requestPath", String.class);
            // 根据路径分支处理逻辑
            if ("/import".equals(requestPath)) {
                return "Importing everything";
            } else if ("/import/case1".equals(requestPath)) {
                return "Importing part A";
            } else if (requestPath.startsWith("/import/case2")) {
                // 处理case2或case2/{filename}的逻辑
                return "Importing part B or specific file";
            }
            return "Unknown path";
        })
        .get();

2. 利用Spring MVC路径变量与内置消息头 #

如果你的路径包含变量（比如/import/case2/{filename}），可以通过pathVariable声明变量，同时Spring Integration会自动将完整请求URL存入HttpHeaders.REQUEST_URL消息头：

return IntegrationFlow
        .from(Http.inboundChannelAdapter(IMPORT_BASE_PATH + "/**")
                .requestMapping(mapping -> mapping.methods(POST))
                .pathVariable("filename")) // 声明路径变量，适配/import/case2/{filename}
        .handle((payload, headers) -> {
            // 获取完整请求路径
            String fullRequestPath = headers.get(HttpHeaders.REQUEST_URL, String.class);
            // 获取路径变量filename
            String filename = headers.get("filename", String.class);
            
            if (filename != null) {
                return String.format("Importing single file: %s from part B", filename);
            }
            return "Importing part B";
        })
        .get();

3. 直接获取ServerHttpRequest对象 #

如果需要更多请求相关细节，可以从消息头中取出ServerHttpRequest对象，直接获取路径：

return IntegrationFlow
        .from(Http.inboundChannelAdapter(IMPORT_BASE_PATH + "/**")
                .requestMapping(mapping -> mapping.methods(POST)))
        .handle((payload, headers) -> {
            ServerHttpRequest request = headers.get(HttpHeaders.SERVER_HTTP_REQUEST, ServerHttpRequest.class);
            String requestPath = request.getURI().getPath();
            // 处理路径逻辑
            return "Processed request path: " + requestPath;
        })
        .get();

内容的提问来源于stack exchange，提问作者Chris