微服务网关Zuul进行路由、过滤、负载均衡、灰度发布

cloud-provider-sms-payment8999/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">
+    <parent>
+        <artifactId>SpringCloud</artifactId>
+        <groupId>org.afeiamic.com.afeiamic.springcloud</groupId>
+        <version>1.0-SNAPSHOT</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>cloud-provider-sms-payment8999</artifactId>
+
+    <dependencies>
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-web</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-actuator</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-devtools</artifactId>
+            <scope>runtime</scope>
+            <optional>true</optional><!-- 防止将devtools依赖传递到其他模块中 -->
+        </dependency>
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+            <optional>true</optional>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-test</artifactId>
+            <scope>test</scope>
+        </dependency>
+    </dependencies>
+</project>
\ No newline at end of file

cloud-provider-sms-payment8999/src/main/java/com/afeiamic/springcloud/PaymentSmsMain8999.java

+package com.afeiamic.springcloud;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
+
+@SpringBootApplication
+@EnableEurekaClient
+public class PaymentSmsMain8999 {
+
+    public static void main(String[] args) {
+        SpringApplication.run(PaymentSmsMain8999.class, args);
+    }
+}

cloud-provider-sms-payment8999/src/main/java/com/afeiamic/springcloud/controller/SmsController.java

+package com.afeiamic.springcloud.controller;
+
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@Slf4j
+public class SmsController {
+
+    @Value("${server.port}")
+    private String serverPort;
+
+    @GetMapping("/payment/sms")
+    public String sms() {
+        return "sms provider service: \tserverPort: " + serverPort;
+    }
+}

cloud-provider-sms-payment8999/src/main/resources/application.yml

+server:
+  port: 8999
+
+### 服务名称 ( 服务注册到 eureka 名称 )
+spring:
+  application:
+    name: cloud-provider-sms-payment
+
+eureka:
+  client: # 服务提供者 provider 注册进 eureka 服务列表
+    register-with-eureka: true
+    fetch-registry: true
+    service-url:
+      defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka
\ No newline at end of file

cloud-zuul-gateway9527/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">
+    <parent>
+        <artifactId>SpringCloud</artifactId>
+        <groupId>org.afeiamic.com.afeiamic.springcloud</groupId>
+        <version>1.0-SNAPSHOT</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>cloud-zuul-gateway9527</artifactId>
+
+    <dependencies>
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.cloud</groupId>
+            <artifactId>spring-cloud-starter-netflix-zuul</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-actuator</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-devtools</artifactId>
+            <scope>runtime</scope>
+            <optional>true</optional><!-- 防止将devtools依赖传递到其他模块中 -->
+        </dependency>
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+            <optional>true</optional>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-test</artifactId>
+            <scope>test</scope>
+        </dependency>
+    </dependencies>
+</project>
\ No newline at end of file

cloud-zuul-gateway9527/src/main/java/com/afeiamic/springcloud/ZuulMain9527.java

+package com.afeiamic.springcloud;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.cloud.netflix.zuul.EnableZuulProxy;
+
+@SpringBootApplication
+@EnableZuulProxy
+public class ZuulMain9527 {
+
+    public static void main(String[] args) {
+        SpringApplication.run(ZuulMain9527.class, args);
+    }
+}

cloud-zuul-gateway9527/src/main/java/com/afeiamic/springcloud/filter/MyZuulFilter.java

+package com.afeiamic.springcloud.filter;
+
+import com.netflix.zuul.ZuulFilter;
+import com.netflix.zuul.context.RequestContext;
+import com.netflix.zuul.exception.ZuulException;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+import javax.servlet.http.HttpServletRequest;
+
+@Component
+@Slf4j
+public class MyZuulFilter extends ZuulFilter {
+
+    @Override
+    public String filterType() {
+        return "pre";
+    }
+
+    @Override
+    public int filterOrder() {
+        return 1;
+    }
+
+    @Override
+    public boolean shouldFilter() {
+        return true;
+    }
+
+    @Override
+    public Object run() throws ZuulException {
+        RequestContext requestContext = RequestContext. getCurrentContext ();
+        HttpServletRequest request = requestContext.getRequest();
+        String host = request.getRemoteHost();
+        String method = request.getMethod();
+        String uri = request.getRequestURI();
+        log.info("=====> Remote host:{},method:{},uri:{}", host, method, uri);
+        // System.out.println( "********" + new Date().getTime());
+        return null;
+    }
+}

cloud-zuul-gateway9527/src/main/resources/application.yml

+server:
+  port: 9527
+
+spring:
+  application:
+    name: cloud-zuul-gateway
+eureka:
+  client:
+    service-url:
+      defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka
+  instance:
+    instance-id: cloud-zuul-gateway01
+    prefer-ip-address: true
+zuul:
+  # ignored-services: cloud-payment-service
+  # ignored-services: "*"
+  routes: # 路由映射配置
+    mypayment.path: /mypayment/** # IE 地址栏输入的路径
+    mypayment.serviceId: cloud-payment-service #  注册进 eureka 服务器的地址
+    smspayment.path: /smspayment/**
+    smspayment.serviceid: cloud-provider-sms-payment
+  prefix: /afeiamic # 设置统一资源前缀
+
+# 开启查看路由的端点
+management:
+  endpoints:
+    web:
+      exposure:
+        include: 'routes'
\ No newline at end of file

pom.xml

@@ -24,6 +24,8 @@
         <module>cloud-provider-hystrix-payment8001</module>
         <module>cloud-consumer-feign-hystrix-order80</module>
         <module>cloud-consumer-hystrix-dashboard9001</module>
+        <module>cloud-zuul-gateway9527</module>
+        <module>cloud-provider-sms-payment8999</module>
     </modules>
 
     <!-- 统一管理jar包版本 -->