SpringCloud Zuul实现动态路由

<!-- zuul -->

    <dependency>

      <groupid>org.springframework.cloud</groupid>

      <artifactid>spring-cloud-starter-netflix-zuul</artifactid>

    </dependency>

server.port= 10010

spring.application.name=zuul-server

eureka.client.serviceurl.defaultzone=http: //localhost:1111/eureka/

#健康检查（需要spring-boot-starter-actuator依赖）

eureka.client.healthcheck.enabled= true

# 续约更新时间间隔（默认 30 秒）

eureka.instance.lease-renewal-interval-in-seconds= 10

# 续约到期时间（默认 90 秒）

eureka.instance.lease-expiration-duration-in-seconds= 10

#zuul代理配置 zuul.routes.服务名.path,服务名要与注册的一致

#应用名映射

zuul.routes.myspringboot.path=/myspringboot/**

zuul.routes.myspringboot.service-id=myspringboot

#url映射

#zuul.routes.myspringboot.path=/myspringboot/**

#zuul.routes.myspringboot-url.url=http: //localhost:10087/

/**

  * zuul过滤器，实现了路由检查

  */

public class accessfilter extends zuulfilter {

   /**

    * 通过int值来定义过滤器的执行顺序

    */

   @override

   public int filterorder() {

     // predecoration之前运行

     return pre_decoration_filter_order - 1 ;

   }

   /**

    * 过滤器的类型，在zuul中定义了四种不同生命周期的过滤器类型：

    *   public static final string error_type = "error";

    *   public static final string post_type = "post";

    *   public static final string pre_type = "pre";

    *   public static final string route_type = "route";

    */

   @override

   public string filtertype() {

     return pre_type;

   }

   /**

    * 过滤器的具体逻辑

    */

   @override

   public object run() {

     requestcontext ctx = requestcontext.getcurrentcontext();

     httpservletrequest request = ctx.getrequest();

     system.out.println(string.format( "%s accessfilter request to %s" , request.getmethod(),request.getrequesturl().tostring()));

     string accesstoken = request.getparameter( "accesstoken" );

     //有权限令牌

     if (!stringutils.isempty(accesstoken)) {

       ctx.setsendzuulresponse( true );

       ctx.setresponsestatuscode( 200 );

       //可以设置一些值

       ctx.set( "issuccess" , true );

       return null ;

     } else {

       ctx.setsendzuulresponse( false );

       ctx.setresponsestatuscode( 401 );

       ctx.setresponsebody( "{\"result\":\"accesstoken is not correct!\"}" );

       //可以设置一些值

       ctx.set( "issuccess" , false );

       return null ;

     }

   }

   /**

    * 返回一个boolean类型来判断该过滤器是否要执行

    */

   @override

   public boolean shouldfilter() {

     return true ;

   }

}

@enablezuulproxy

@springbootapplication

public class zuulserverapplication {

   public static void main(string[] args) {

     springapplication.run(zuulserverapplication. class , args);

   }

   @bean

   public accessfilter accessfilter() {

     return new accessfilter();

   }

}