SpringCloud从入门到进阶（三）——路由接入Zuul

<?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>com.leo</groupId>
        <version>1.0-SNAPSHOT</version>
    </parent>
    <modelVersion>4.0.0</modelVersion>
    <artifactId>gateway-service-7081-7082</artifactId>
?
    <dependencies>
        <!--zuul组件实现网关的路由转发和负载均衡-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-zuul</artifactId>
        </dependency>
        <!--eureka client-->
        <dependency>
            <groupId>org.springframework.cloud</groupId>
            <artifactId>spring-cloud-starter-eureka</artifactId>
        </dependency>
        <!--actuator监控-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
        </dependency>
    </dependencies>
    
    <!-- Spring Boot的Maven插件，使用Maven插件的方式来启动Spring Boot工程
    如果不添加该插件在使用mvn命令打包的jar有问题，执行时会报错：xxx.jar中没有主清单属性-->
    <build>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
                <executions>
                    <execution>
                        <goals>
                            <goal>repackage</goal>
                        </goals>
                    </execution>
                </executions>
            </plugin>
        </plugins>
    </build>
</project>

spring:
  application:
   name: application-gatewayservice
  profiles:
   active: peer1
?
#Zuul的配置
zuul:
  prefix: /jms  #通过zuul.prefix的配置，所有请求统一增加前缀，可以实现API接口的版本号控制，注意前缀要加/
  #如果某服务存在多个实例，Zuul结合Ribbon会做负载均衡，将请求均分的部分路由到不同的服务实例。
  routes:
   culturalService:  #此处的名称是用户自定义的，需要指定它的path和serviceld，两者配合使用，就可以将指定类型的请求Uri路由到指定的Serviceld
     path: /cultural/**    #以/cultural/** 开头的请求都转发给springcloud-culturalService
     serviceId: application-culturalService  #此处是spring的applicationname，即Eureka的服务名，而非instance-id 实例名。
   idleTimeService:
     path: /idleTime/**
     serviceId: application-idleTimeService
   idleGoodService:
     path: /idleGood/**
     serviceId: application-idleGoodService
   topicService:
     path: /topic/**
     serviceId: application-topicService
   publicWelfareService:
     path: /publicWelfare/**
     serviceId: application-publicWelfareService
   commonService:
     path: /common/**
     serviceId: application-commonService
#指明日志存放位置
logging:
  file: logs/application-gatewayservice-${server.port}.logs
?
eureka:
  client:
   service-url:
     defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka,http://eureka7003.com:7003/eureka
---
spring:
  profiles: peer1
server:
  port: 7081
?
?
eureka:
  instance:
   instance-id: springcloud-gatewayservice-7081
?
management:
  port: 7181
  security:
   enabled: false
#---
#spring:
#  profiles: peer2
#server:
#  port: 7082
#
#management:
#  port: 7182
#  security:
#   enabled: false
#
#eureka:
#  instance:
#   instance-id: springcloud-gatewayservice-7082

@EnableZuulProxy //开启Zuul的功能
@SpringBootApplication
@EnableEurekaClient
public class GatewayServiceApplicaton {
    public static void main(String[] args) {
        SpringApplication.run(GatewayServiceApplicaton.class,args);
   }
}

<!-- 加载日志文件 -->
<?xml version="1.0" encoding="UTF-8"?>
<configuration>
    <include  resource="org/springframework/boot/logging/logback/base.xml"/>
    <jmxConfigurator/>
</configuration>

@Component
public class MyFallbackProvider implements ZuulFallbackProvider {
?
    /**
     * getRoute()方法，用于指定熔断功能应用于哪些路由的服务。
     * 如果需要所有的路由服务都加熔断功能，只需要在getRoute()方法上返回"*"的匹配符，
     */
    @Override
    public String getRoute() {
        return "*"; //所有路由服务都增加熔断。
   }
?
    /**
     * fallbackResponse()为进入熔断功能时执行的逻辑
     */
    @Override
    public ClientHttpResponse fallbackResponse() {
        return new ClientHttpResponse() {
            @Override
            public HttpStatus getStatusCode() throws IOException {
                return HttpStatus.SERVICE_UNAVAILABLE;
           }
?
            @Override
            public int getRawStatusCode() throws IOException {
                return 503;
           }
?
            @Override
            public String getStatusText() throws IOException {
                return "Service_Fallbcak";
           }
?
            @Override
            public void close() {
?
           }
?
            @Override
            public InputStream getBody() throws IOException {
                return new ByteArrayInputStream("您好，服务出现故障，请重试。".getBytes("utf-8"));
           }
?
            @Override
            public HttpHeaders getHeaders() {
                HttpHeaders headers = new HttpHeaders();
                headers.setContentType(MediaType.APPLICATION_JSON_UTF8);
                return headers;
           }
       };
   }
}

#IP     域名      别名
[jms@iz8vb62snc6e5cage5yvzcz jars]$ sudo vi /etc/hosts
127.0.0.1   localhost localhost.localdomain localhost4 localhost4.localdomain4
::1         localhost localhost.localdomain localhost6 localhost6.localdomain6
172.26.125.118   eureka7001.com 
172.26.125.118   eureka7002.com 
172.26.125.118   eureka7003.com
127.0.0.1   gateway7081.com
#不加会出现无法路由的问题，详见系列文章第（四）节
172.26.125.113  iz8vb6a56ld0vy6vuaijriz  
172.26.125.111  iz8vb6a56ld0vy6vuaijrjz

[jms@iz8vb62snc6e5cage5yvzcz jars]$ sudo /etc/rc.d/init.d/network restart
Restarting network (via systemctl):                       [  OK  ]

[jms@iz8vb62snc6e5cage5yvzcz jars]$  ping eureka7001.com
PING eureka7001.com (172.26.125.118) 56(84) bytes of data.
64 bytes from eureka7001.com (172.26.125.118): icmp_seq=1 ttl=64 time=0.143 ms
64 bytes from eureka7001.com (172.26.125.118): icmp_seq=2 ttl=64 time=0.149 ms
[jms@iz8vb62snc6e5cage5yvzcz jars]$ ping gateway7081.com
PING gateway7081.com (127.0.0.1) 56(84) bytes of data.
64 bytes from localhost (127.0.0.1): icmp_seq=1 ttl=64 time=0.015 ms
64 bytes from localhost (127.0.0.1): icmp_seq=2 ttl=64 time=0.023 ms
#可见访问本机和访问局域网的网络延迟差1个数量级。

[jms@iz8vb62snc6e5cage5yvzcz jars]$ java -jar gateway-service-7081-7082-1.0-SNAPSHOT.jar  --spring.profiles.active=peer1 &