HttpServletRequest代理请求

Love The Way You Lie 2022-02-03 14:11 258阅读 0赞

service

@Service
    public class HttpClient {
        public String proxyPri = "http://ip:端口";
    
        public String callProxy(HttpServletRequest request){
            String result = "";
            String requestURI = request.getRequestURL().toString();
            String servletPath = request.getServletPath();
            String url = proxyPri + requestURI.substring(requestURI.indexOf(servletPath));
            System.out.println("请求方式："+request.getMethod());
            Enumeration<String> paraNames=request.getParameterNames();
            OkHttpClient okHttpClient = new OkHttpClient();
            Request req = null;
            if ("GET".equalsIgnoreCase(request.getMethod())){
                StringBuilder paramsAll = new StringBuilder();
                for(Enumeration<String> e=paraNames;e.hasMoreElements();){
                    String thisName=e.nextElement().toString();
                    String thisValue=request.getParameter(thisName);
                    if (paramsAll.length()!=0){
                        paramsAll.append("&");
                    }
                    paramsAll.append(thisName).append("=").append(thisValue);
                }
                if (url.contains("?")){
                    url += "&" + paramsAll.toString();
                }else{
                    url += "?" + paramsAll.toString();
                }
                req = addHeaderParams(request, new Request.Builder()).url(url).build();
            }else{
                String JSONStr = getRequestPayload(request);
                if(JSONStr!=null && !"".equals(JSONStr)){
                    MediaType JSON = MediaType.parse("application/json; charset=utf-8");
                    RequestBody body = RequestBody.create(JSON, JSONStr);
                    req = addHeaderParams(request, new Request.Builder()).url(url).post(body).build();
                }else{
                    FormBody.Builder builder = new FormBody.Builder();
                    //RequestBody body = new FormBody.Builder().build();
                    for(Enumeration<String> e=paraNames;e.hasMoreElements();){
                        String thisName=e.nextElement().toString();
                        String thisValue=request.getParameter(thisName);
                        builder.add(thisName,thisValue);
                    }
                    RequestBody body = builder.build();
                    req = addHeaderParams(request, new Request.Builder()).url(url).post(body).build();
                }
            }
            System.out.println("请求地址："+url);
            Call call = okHttpClient.newCall(req);
            try {
                Response response = call.execute();
                result = response.body().string();
                System.out.println("返回结果："+result);
            } catch (IOException e) {
                e.printStackTrace();
            }
            return result;
        }
    
        private String getRequestPayload(HttpServletRequest req) {
            StringBuilder sb = new StringBuilder();
            try(BufferedReader reader = req.getReader();) {
                char[]buff = new char[1024];
                int len;
                while((len = reader.read(buff)) != -1) {
                    sb.append(buff,0, len);
                }
            }catch (IOException e) {
                e.printStackTrace();
            }
            return sb.toString();
        }
    
        private Request.Builder addHeaderParams(HttpServletRequest request, Request.Builder builder){
            Enumeration<String> headerNames=request.getHeaderNames();
            for(Enumeration<String> e=headerNames;e.hasMoreElements();){
                String thisName=e.nextElement().toString();
                String thisValue=request.getHeader(thisName);
                builder.addHeader(thisName,thisValue);
            }
            return builder;
        }
    }

controller

@RestController
    public class HttpProxy {
        @Autowired
        HttpClient httpClient;
    
        @RequestMapping(value = "/business")		
        public String business2(HttpServletRequest request, HttpSession session){
            String result = httpClient.callProxy(request);
            return result;
        }
    
        @RequestMapping(value = "/business/**/*")
        public String business3(HttpServletRequest request, HttpSession session){
            String result = httpClient.callProxy(request);
            return result;
        }
    
    }

pom.xml

<?xml version="1.0" encoding="UTF-8"?>
    <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
             xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0</modelVersion>
        <parent>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <version>2.1.3.RELEASE</version>
            <relativePath/> 
        </parent>
        <groupId>com.tyxx</groupId>
        <artifactId>demo</artifactId>
        <version>0.0.1-SNAPSHOT</version>
        <name>demo</name>
        <description>Demo project for Spring Boot</description>
    
        <properties>
            <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
            <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
            <maven.compiler.source>1.8</maven.compiler.source>
            <maven.compiler.target>1.8</maven.compiler.target>
            <java.version>1.8</java.version>
            
            <slf4j.version>1.7.7</slf4j.version>
            <log4j.version>1.2.17</log4j.version>
        </properties>
    
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-thymeleaf</artifactId>
            </dependency>
            <dependency>
                <groupId>nz.net.ultraq.thymeleaf</groupId>
                <artifactId>thymeleaf-layout-dialect</artifactId>
                <version>2.2.1</version>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework</groupId>
                <artifactId>spring-oxm</artifactId>
                <version>5.1.5.RELEASE</version>
            </dependency>
            
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
            <dependency>
                <groupId>org.hamcrest</groupId>
                <artifactId>hamcrest-core</artifactId>
                <version>1.3</version>
                <scope>test</scope>
            </dependency>
            <dependency>
                <groupId>junit</groupId>
                <artifactId>junit</artifactId>
                <version>4.12</version>
            </dependency>
            <dependency>
                <groupId>org.springframework</groupId>
                <artifactId>spring-test</artifactId>
                <version>4.3.13.RELEASE</version>
            </dependency>
            
            <dependency>
                <groupId>com.squareup.okhttp3</groupId>
                <artifactId>okhttp</artifactId>
                <version>3.10.0</version>
            </dependency>
            
            <dependency>
                <groupId>com.google.code.gson</groupId>
                <artifactId>gson</artifactId>
                <version>2.8.2</version>
            </dependency>
            
            <dependency>
                <groupId>org.jsoup</groupId>
                <artifactId>jsoup</artifactId>
                <version>1.11.3</version>
            </dependency>
    
    
            
            
            
            <dependency>
                <groupId>commons-logging</groupId>
                <artifactId>commons-logging</artifactId>
                <version>1.2</version>
            </dependency>
            <dependency>
                <groupId>log4j</groupId>
                <artifactId>log4j</artifactId>
                <version>${log4j.version}</version>
            </dependency>
            <dependency>
                <groupId>org.slf4j</groupId>
                <artifactId>slf4j-api</artifactId>
                <version>${slf4j.version}</version>
            </dependency>
            <dependency>
                <groupId>org.slf4j</groupId>
                <artifactId>slf4j-log4j12</artifactId>
                <version>${slf4j.version}</version>
            </dependency>
            
        </dependencies>
    
        <build>
            <plugins>
                <plugin>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-maven-plugin</artifactId>
                </plugin>
            </plugins>
        </build>
    
    </project>