spring cloud gateway

最后发布时间:2023-12-27 13:43:20 浏览量:
        return chain.filter(exchange).then(Mono.fromRunnable(()->{
            ServerHttpResponse response = exchange.getResponse();
            HttpStatus responseStatus = response.getStatusCode();

            if(responseStatus.equals(HttpStatus.FOUND)){
//                String newResponseBody =
//                        "<body>\n" +
//                                "      <h1 style=\"color:red;text-align:center\">Bad Request </h1>\n" +
//                                "      <p>If you are seeing this page it means response body is modified.</p>\n" +
//                                "  </body>";
//                response.setStatusCode(HttpStatus.OK);
//                response.getHeaders().setContentLength(newResponseBody.length());
//                DataBuffer dataBuffer = response.bufferFactory().wrap(newResponseBody.getBytes(StandardCharsets.UTF_8));
//                response.writeWith(Mono.just(dataBuffer)).subscribe();
//                exchange.mutate().response(response).build();
                if(response.getHeaders().containsKey("Location")){
                    URI uri = exchange.getRequest().getURI();
                    String path = uri.getPath();
                    String[] pathSegments = path.split("/");
                    if(pathSegments.length>2){
                        String extractedPath = "/" + pathSegments[1] + "/" + pathSegments[2];
                        List<String> location = response.getHeaders().get("Location");
                        response.getHeaders().setLocation(URI.create(extractedPath+location.get(0)));
                    }

                }


//                return response.writeWith(Mono.empty());
            }
        }));
    }

https://docs.spring.io/spring-cloud-gateway/reference/spring-cloud-gateway/gatewayfilter-factories/redirectto-factory.html

Spring Cloud Gateway || Modify Response Body Using Post Global Filter

@Configuration
public class DynamicRewriteRoute {
//    @Value("${rewrite.backend.uri}")
    private String backendUri="http://192.168.10.30:3000";
    private static Random rnd = new Random();
    @Bean
    public RouteLocator dynamicZipCodeRoute(RouteLocatorBuilder builder) {
        System.out.println("11111111111111");
        return builder.routes()
                .route("dynamicRewrite", r ->
                        r.path("/proxy2/8080/**")
                                .filters(f -> f.filter((exchange, chain) -> {
                                    ServerHttpRequest req = exchange.getRequest();
                                    addOriginalRequestUrl(exchange, req.getURI());
                                    String path = req.getURI().getRawPath();
//                                    String newPath = path.replaceAll(
//                                            "/proxy2/8080/(?<zipcode>.*)",
//                                            "/${zipcode}-" + String.format("%03d", rnd.nextInt(1000)));
                                    String newPath = path.replaceAll(
                                            "/proxy2/8080/(?<segment>.*)", "/${segment}" );

                                    backendUri = backendUri.replace("3000","8080");
                                    ServerHttpRequest request = req.mutate().path(newPath).build();
                                    exchange.getAttributes().put(GATEWAY_REQUEST_URL_ATTR, request.getURI());
                                    return chain.filter(exchange.mutate().request(request).build());
                                }))
                                .uri(backendUri))
                .build();

    }

}
apiVersion: v1
kind: Pod
metadata:
  name: test-pod
  labels:
    app: test-pod
spec:
  # 定义容器,可以多个
  containers:
    - name: test-k8s # 容器名字
      image: registry.cn-hangzhou.aliyuncs.com/wybioinfo/code-server:latest # 镜像
      volumeMounts:
        - {name: vol-1, mountPath: /data}
  volumes:
  - name: vol-1
    persistentVolumeClaim: {claimName: nextflowdata}

---

apiVersion: v1
kind: Service
metadata:
  name: test-pod
spec:
  selector:
    app: test-pod
  # 默认 ClusterIP 集群内可访问,NodePort 节点可访问,LoadBalancer 负载均衡模式(需要负载均衡器才可用)
  type: NodePort
  ports:
    - port: 8443        # 本 Service 的端口
      targetPort: 8443  # 容器端口
      nodePort: 31000   # 节点端口,范围固定 30000 ~ 32767

  #  kubectl port-forward  --address 0.0.0.0 svc/test-pod 31000:8443 

# docker run -it --name code-server -p 8080:8080    codercom/code-server:latest
# docker run -it --init -p 3000:3000 -v "$(pwd):/home/workspace:cached" gitpod/openvscode-server
server:
  port: 30000
spring:
  cloud:
    gateway:
      globalcors:
        corsConfigurations:
          '[/**]':
              allowedOrigins: "*"
              allowedMethods: "*"
              allowedHeaders: "*"
      discovery:
        locator:
          enabled: true
          lower-case-service-id: true
      filter:
        remove-non-proxy-headers:
          headers:
          - Proxy-Authenticate
          - Proxy-Authorization
          - TE
          - Trailer
          - Transfer-Encoding
      httpclient:
        websocket:
          max-frame-payload-length: 3000000 
      routes:
        - id:  docker-app
          uri: http://192.168.3.60:82
          predicates:
            - Path=/app/**
        - id: vscode-cloud
          uri: http://192.168.3.60:40001
          predicates:
            - Path=/vscode/**
          filters:
            - RewritePath=/vscode/(?<segment>.*), /$\{segment}

  redis:
    host: 127.0.0.1
    port: 6379
    password:
    timeout: 5000
    jedis:
      pool:
        max-active: 3
        max-idle: 3
        min-idle: 1
        max-wait: -1
server {
    listen 82;
    charset utf-8;
     client_max_body_size 200m;

    large_client_header_buffers 4 16k;
    #root /ssd1/shanjun/applications/web/;
    location /app/ {
        if ($request_uri ~ /app/(.+)){
            set $rightUrl $1;
        }
        add_header X-debug-message "A static file was served" always;
        proxy_pass http://192.168.3.60:$rightUrl;
        proxy_http_version 1.1;
        proxy_set_header Upgrade $http_upgrade;
        proxy_set_header Connection "Upgrade";
        proxy_set_header Host $host;
        proxy_set_header X-Real-IP $remote_addr;
        proxy_set_header X-Forwarded-For $proxy_add_x_forwarded_for;
        add_header bbb "$rightUrl";
        proxy_set_header Origin "";
        rewrite ^/app/$rightUrl(.*)$ /$1 break;
            # First attempt to serve request as file, then
            # as directory, then fall back to displaying a 404.
            #try_files $uri $uri/ =404;
            #proxy_pass http://10.110.1.12:8080;
    }

    location /node/ {
        proxy_pass http://192.168.3.60:40001;
        rewrite ^/node/(.*)$ /$1 break;
                    proxy_http_version 1.1;
            proxy_set_header Upgrade $http_upgrade;
            proxy_set_header Connection "Upgrade";
        proxy_set_header Origin "";
    }
}
server:
  port: 30000
spring:
  cloud:
    gateway:
      filter:
        remove-hop-by-hop:
          headers:
      httpclient:
        websocket:
          max-frame-payload-length: 3000000 
      discovery:
        locator:
          enabled: true
          lower-case-service-id: true
      routes:

        - id:  vscode-cloud
          uri: http://192.168.10.30:8080
          predicates:
            - Path=/proxy/**
          filters:
            - RewritePath=/proxy/(?<segment>.*), /$\{segment}

  redis:
    host: 192.168.10.177
    port: 6381
    password: 123456
    timeout: 5000
    jedis:
      pool:
        max-active: 3
        max-idle: 3
        min-idle: 1
        max-wait: -1

http://xxx:30000/app/40001/?folder=/home/coder

https://www.baeldung.com/spring-cloud-gateway-url-rewriting
https://docs.spring.io/spring-cloud-gateway/docs/2.2.7.RELEASE/reference/html/#removehopbyhop-headers-filter

快捷入口
java 思维导图 浏览PDF 下载PDF
分享到:
标签