spring-cloud-starter-netflix-zuul(原spring-cloud-starter-zuul)的使用-程序员宅基地
技术标签： spring boot java gateway
1.基于eureka为服务注册中心的zuul。
首先我们需要搭建一个eureka服务，关于这一步可以参考我的另一篇文章spring-cloud-eureka服务发现注册中心及spring-cloud微服务，在本篇文章也会用到spring-cloud-eureka服务发现注册中心及spring-cloud微服务里面的工程
下面我们新建zuul工程
<groupId>com.wl.springcloud</groupId>
<artifactId>zuul</artifactId>
<version>1.0-SNAPSHOT</version>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>
<groupId>com.wl.springcloud</groupId>
<artifactId>zuul</artifactId>
<version>1.0-SNAPSHOT</version>
<name>zuul</name>
<!-- FIXME change it to the project's website -->
<url>http://www.example.com</url>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<maven.compiler.source>1.8</maven.compiler.source>
<maven.compiler.target>1.8</maven.compiler.target>
<spring-cloud-config-version>2.0.3.RELEASE</spring-cloud-config-version>
<spring-cloud-eureka-server>2.0.3.RELEASE</spring-cloud-eureka-server>
<spring-boot-version>2.0.8.RELEASE</spring-boot-version>
<spring-cloud-zuul-version>2.0.3.RELEASE</spring-cloud-zuul-version>
<spring-cloud-eureka-client-version>2.0.3.RELEASE</spring-cloud-eureka-client-version>
<MainClass>com.wl.springcloud.zuul.ZuulApplication</MainClass>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
<version>${spring-boot-version}</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-autoconfigure</artifactId>
<version>${spring-boot-version}</version>
</dependency>
<!-- https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-starter-netflix-eureka-client -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
<version>${spring-cloud-eureka-client-version}</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-actuator</artifactId>
<version>${spring-boot-version}</version>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-config</artifactId>
<version>${spring-cloud-config-version}</version>
</dependency>
<!-- https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-starter-netflix-zuul -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-zuul</artifactId>
<version>${spring-cloud-zuul-version}</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<version>${spring-boot-version}</version>
<scope>test</scope>
</dependency>
</dependencies>
<!-- Package as an executable jar -->
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
<version>${spring-boot-version}</version>
<configuration>
<mainClass>${MainClass}</mainClass>
<layout>JAR</layout>
</configuration>
<!-- repackage 生成两个 jar.original -->
<executions>
<execution>
<goals>
<goal>repackage</goal>
</goals>
</execution>
</executions>
</plugin>
<!-- 指定maven 打包java 版本 -->
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-compiler-plugin</artifactId>
<version>3.1</version>
<configuration>
<source>1.8</source>
<target>1.8</target>
</configuration>
</plugin>
</plugins>
<!-- maven 编译打包resource 和 java 目录下所有文件 maven默认资源路径是resources -->
<resources>
<resource>
<directory>src/main/resources</directory>
<includes>
<include>**/*.*</include>
<include>*.*</include>
</includes>
</resource>
<resource>
<directory>src/main/java</directory>
<includes>
<include>**/*.*</include>
<include>*.*</include>
</includes>
</resource>
</resources>
</build>
</project>
application.properties
server.port=8080
spring.application.name=zuul
zuul.routes.consume.path=/consume/**
zuul.routes.consume.url=consume-client
#zuul.routes.consume.url=http://localhost:8763
#zuul.routes.consume.serviceId=consume-client
zuul.routes.consume.stripPrefix=false
zuul.routes.provider.path=/provider/**
zuul.routes.provider.url=provider-client
#zuul.routes.provider.url=http://localhost:8764
#zuul.routes.provider.serviceId=provider-client
zuul.routes.provider.stripPrefix=false
1.zuul.routes.consume.path、zuul.routes.provider.path中consume和provider可以为任意的字符,只是作为一个标识。/consume/** 表示代理路径为 /consume/**的路径并转发到serviceId为consume-client的服务
2.zuul.routes.consume.url 可以是全路径也可以是serviceId，这里配置的为服务id(即spring.application.name对应的值)，与zuul.routes.consume.serviceId=consume-client效果一样
3.zuul.routes.provider.stripPrefix 表示是否匹配去掉前缀(默认为true)，即所有/consume/**的请求转发到consume-client服务中的路径是否去掉consume。也就是所有/consume/xxxx的请求转发给http://consume.com.cn/xxxx ,去除掉consume前缀
启动类
package com.wl.springcloud.zuul;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.WebApplicationType;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.autoconfigure.gson.GsonAutoConfiguration;
import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
import org.springframework.boot.autoconfigure.jdbc.DataSourceTransactionManagerAutoConfiguration;
import org.springframework.boot.autoconfigure.orm.jpa.HibernateJpaAutoConfiguration;
import org.springframework.cloud.netflix.zuul.EnableZuulProxy;
/**
* Created by Administrator on 2019/3/28.
*/
@SpringBootApplication(exclude = {
DataSourceAutoConfiguration.class,
DataSourceTransactionManagerAutoConfiguration.class,
HibernateJpaAutoConfiguration.class, //不使用数据库
GsonAutoConfiguration.class //spring-boot2.0.0以上版本需要引入高版本的gson依赖，如果不引用gson依赖需要加此属性
},scanBasePackages = "com.wl")
@EnableZuulProxy
public class ZuulApplication {
private static final Logger logger = LoggerFactory.getLogger(ZuulApplication.class);
public static void main(String[] args) {
SpringApplication app = new SpringApplication(ZuulApplication.class);
app.setWebApplicationType(WebApplicationType.SERVLET);
app.run(args);
logger.info("application init success");
}
}
依次启动eureka、provider-client、consume-client、zuul
下面我们分别访问http://localhost:8080/consume/ 、http://localhost:8080/provider/
2.基于zookeeper作为服务注册与发现中心的zuul的使用
使用zookeeper作为服务注册中心参考我的这篇文章spring-cloud使用zookeeper作为服务注册发现中心（下面会使用到该文章所建工程）
修改zuul工程的pom.xml如下(加入spring-cloud-starter-zookeeper-discovery依赖，移除spring-cloud-starter-netflix-eureka-client依赖)
<?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>
<groupId>com.wl.springcloud</groupId>
<artifactId>zuul</artifactId>
<version>1.0-SNAPSHOT</version>
<name>zuul</name>
<!-- FIXME change it to the project's website -->
<url>http://www.example.com</url>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<maven.compiler.source>1.8</maven.compiler.source>
<maven.compiler.target>1.8</maven.compiler.target>
<spring-cloud-config-version>2.0.3.RELEASE</spring-cloud-config-version>
<spring-cloud-eureka-server>2.0.3.RELEASE</spring-cloud-eureka-server>
<spring-boot-version>2.0.8.RELEASE</spring-boot-version>
<spring-cloud-zuul-version>2.0.3.RELEASE</spring-cloud-zuul-version>
<spring-cloud-eureka-client-version>2.0.3.RELEASE</spring-cloud-eureka-client-version>
<MainClass>com.wl.springcloud.zuul.ZuulApplication</MainClass>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
<version>${spring-boot-version}</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-autoconfigure</artifactId>
<version>${spring-boot-version}</version>
</dependency>
<!-- https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-starter-netflix-eureka-client -->
<!--<dependency>-->
<!--<groupId>org.springframework.cloud</groupId>-->
<!--<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>-->
<!--<version>${spring-cloud-eureka-client-version}</version>-->
<!--</dependency>-->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-actuator</artifactId>
<version>${spring-boot-version}</version>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-config</artifactId>
<version>${spring-cloud-config-version}</version>
</dependency>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-zookeeper-discovery</artifactId>
<version>2.0.0.RELEASE</version>
<exclusions>
<exclusion>
<groupId>org.apache.httpcomponents</groupId>
<artifactId>httpclient</artifactId>
</exclusion>
<exclusion>
<groupId>org.apache.zookeeper</groupId>
<artifactId>zookeeper</artifactId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>org.apache.zookeeper</groupId>
<artifactId>zookeeper</artifactId>
<version>3.4.10</version>
</dependency>
<!-- https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-starter-netflix-zuul -->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-zuul</artifactId>
<version>${spring-cloud-zuul-version}</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<version>${spring-boot-version}</version>
<scope>test</scope>
</dependency>
</dependencies>
<!-- Package as an executable jar -->
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
<version>${spring-boot-version}</version>
<configuration>
<mainClass>${MainClass}</mainClass>
<layout>JAR</layout>
</configuration>
<!-- repackage 生成两个 jar.original -->
<executions>
<execution>
<goals>
<goal>repackage</goal>
</goals>
</execution>
</executions>
</plugin>
<!-- 指定maven 打包java 版本 -->
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-compiler-plugin</artifactId>
<version>3.1</version>
<configuration>
<source>1.8</source>
<target>1.8</target>
</configuration>
</plugin>
</plugins>
<!-- maven 编译打包resource 和 java 目录下所有文件 maven默认资源路径是resources -->
<resources>
<resource>
<directory>src/main/resources</directory>
<includes>
<include>**/*.*</include>
<include>*.*</include>
</includes>
</resource>
<resource>
<directory>src/main/java</directory>
<includes>
<include>**/*.*</include>
<include>*.*</include>
</includes>
</resource>
</resources>
</build>
</project>
修改配置文件如下
server.port=8080
spring.application.name=zuul
spring.cloud.zookeeper.connect-string=192.168.245.129:2181
zuul.routes.zookeeper.path=/zookeeper/**
zuul.routes.zookeeper.url=zookeeper
zuul.routes.zookeeper.stripPrefix=false重启应用
浏览器输入http://localhost:8080/zookeeper/zookeeper
3.spring-cloud客户端配置
3.1 ribbon(负载均衡) com.netflix.client.config.DefaultClientConfigImpl 参考Netflix学习笔记：Ribbon-程序员宅基地 请求重试配置参考 为Spring Cloud Ribbon/Zuul配置请求重试 - 简书
3.2 hystrix（熔断器）com.netflix.hystrix.HystrixCommandProperties 参考hystrix参数详解-程序员宅基地 使用参考 https://www.cnblogs.com/yepei/p/7169127.html 与spring-boot整合参考 https://www.cnblogs.com/leeSmall/p/8847652.html 一行代码从Hystrix迁移到Sentinel参考Spring Cloud Alibaba迁移指南2：一行代码从Hystrix迁移到Sentinel - ITMuch的博客 - OSCHINA - 中文开源技术交流社区
3.3 zuul配置 org.springframework.cloud.netflix.zuul.filters.ZuulProperties 参考使用Zuul构建API Gateway
4.zuul 过滤器
4.1 异常拦截器
org.springframework.cloud.netflix.zuul.filters.post.SendErrorFilter(forwards to /error (by default))
org.springframework.boot.autoconfigure.web.servlet.error.BasicErrorController(位于spring-boot-autoconfigure 包中)
配置
ribbon.ReadTimeout=1000ZookeeperController修改如下
package com.wl.springcloud.zookeeper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.core.env.Environment;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
/**
* Created by Administrator on 2019/3/29.
*/
@RequestMapping("/zookeeper")
@RestController
public class ZookeeperController {
@Autowired
private Environment environment;
@RequestMapping("/zookeeper")
public String zookeeper() throws InterruptedException {
Thread.sleep(1000L);
return "zookeeper port:" + environment.getProperty("server.port");
}
}
浏览器输入http://localhost:8080/zookeeper/zookeeper
BasicErrorController断点如下
自定义异常捕获
方式一自定义ErrorController覆盖BasicErrorController
package com.wl.springcloud.zuul.controller;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.web.servlet.error.ErrorAttributes;
import org.springframework.http.HttpStatus;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.context.request.ServletWebRequest;
import org.springframework.web.context.request.WebRequest;
import javax.servlet.http.HttpServletRequest;
import java.util.Map;
/**
* Created by Administrator on 2019/4/2.
*/
@Controller
public class ErrorController implements org.springframework.boot.web.servlet.error.ErrorController {
@Value(value = "${server.error.path:${error.path:/error}}")
private String errorPath;
@Override
public String getErrorPath() {
return errorPath;
}
private final ErrorAttributes errorAttributes;
public ErrorController(ErrorAttributes errorAttributes){
this.errorAttributes = errorAttributes;
}
@RequestMapping("${server.error.path:${error.path:/error}}")
@ResponseBody
public ResponseEntity error(HttpServletRequest request) {
Map<String,Object> body = getErrorAttributes(request);
body.put("code",1);
body.remove("trace");
return new ResponseEntity<>(body, HttpStatus.OK);
}
private Map<String, Object> getErrorAttributes(HttpServletRequest request) {
WebRequest webRequest = new ServletWebRequest(request);
return this.errorAttributes.getErrorAttributes(webRequest, true);
}
}
方式二 自定义SendErrorFilter
配置
zuul.SendErrorFilter.error.disable=truefilter
package com.wl.springcloud.zuul.filter;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.netflix.client.ClientException;
import com.netflix.zuul.ZuulFilter;
import com.netflix.zuul.context.RequestContext;
import com.netflix.zuul.exception.ZuulException;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.cloud.netflix.zuul.util.ZuulRuntimeException;
import org.springframework.http.HttpStatus;
import org.springframework.util.ReflectionUtils;
import javax.servlet.http.HttpServletResponse;
import java.net.SocketTimeoutException;
import java.util.HashMap;
import java.util.Map;
import static org.springframework.cloud.netflix.zuul.filters.support.FilterConstants.ERROR_TYPE;
import static org.springframework.cloud.netflix.zuul.filters.support.FilterConstants.SEND_ERROR_FILTER_ORDER;
/**
* Created by Administrator on 2019/4/2.
*/
public class CusSendErrorFilter extends ZuulFilter {
protected static final String SEND_ERROR_FILTER_RAN = "sendErrorFilter.ran";
@Value("${error.path:/error}")
private String errorPath;
@Override
public String filterType() {
return ERROR_TYPE;
}
@Override
public int filterOrder() {
return SEND_ERROR_FILTER_ORDER;
}
@Override
public boolean shouldFilter() {
RequestContext ctx = RequestContext.getCurrentContext();
// only forward to errorPath if it hasn't been forwarded to already
return ctx.getThrowable() != null
&& !ctx.getBoolean(SEND_ERROR_FILTER_RAN, false);
}
@Override
public Object run() {
try {
RequestContext ctx = RequestContext.getCurrentContext();
ExceptionHolder exception = findZuulException(ctx.getThrowable());
HttpServletResponse response = ctx.getResponse();
Map<String,Object> body = new HashMap<>();
body.put("code",1);
body.put("status",exception.getStatusCode());
body.put("msg",exception.getErrorCause());
response.setContentType("application/json; charset=utf8");
response.setStatus(HttpStatus.OK.value());
response.getWriter().write(new ObjectMapper().writeValueAsString(body));
}
catch (Exception ex) {
ReflectionUtils.rethrowRuntimeException(ex);
}
return null;
}
protected ExceptionHolder findZuulException(Throwable throwable) {
if (throwable.getCause() instanceof ZuulRuntimeException) {
Throwable cause = null;
if (throwable.getCause().getCause() != null) {
cause = throwable.getCause().getCause().getCause();
}
if (cause instanceof ClientException && cause.getCause() != null
&& cause.getCause().getCause() instanceof SocketTimeoutException) {
ZuulException zuulException = new ZuulException("", 504,
ZuulException.class.getName() + ": Hystrix Readed time out");
return new ZuulExceptionHolder(zuulException);
}
// this was a failure initiated by one of the local filters
if(throwable.getCause().getCause() instanceof ZuulException) {
return new ZuulExceptionHolder((ZuulException) throwable.getCause().getCause());
}
}
if (throwable.getCause() instanceof ZuulException) {
// wrapped zuul exception
return new ZuulExceptionHolder((ZuulException) throwable.getCause());
}
if (throwable instanceof ZuulException) {
// exception thrown by zuul lifecycle
return new ZuulExceptionHolder((ZuulException) throwable);
}
// fallback
return new DefaultExceptionHolder(throwable);
}
protected interface ExceptionHolder {
Throwable getThrowable();
default int getStatusCode() {
return HttpStatus.INTERNAL_SERVER_ERROR.value();
}
default String getErrorCause() {
return null;
}
}
protected static class DefaultExceptionHolder implements ExceptionHolder {
private final Throwable throwable;
public DefaultExceptionHolder(Throwable throwable) {
this.throwable = throwable;
}
@Override
public Throwable getThrowable() {
return this.throwable;
}
}
protected static class ZuulExceptionHolder implements ExceptionHolder {
private final ZuulException exception;
public ZuulExceptionHolder(ZuulException exception) {
this.exception = exception;
}
@Override
public Throwable getThrowable() {
return this.exception;
}
@Override
public int getStatusCode() {
return this.exception.nStatusCode;
}
@Override
public String getErrorCause() {
return this.exception.errorCause;
}
}
}
config
package com.wl.springcloud.zuul.config;
import com.wl.springcloud.zuul.filter.CusSendErrorFilter;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
/**
* Created by Administrator on 2019/4/2.
*/
@Configuration
public class FilterConfig {
@Bean
public CusSendErrorFilter cusSendErrorFilter(){
return new CusSendErrorFilter();
}
}
4.2 自定义过滤器
package com.wl.springcloud.zuul.filter;
import com.fasterxml.jackson.core.JsonProcessingException;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.netflix.zuul.ZuulFilter;
import com.netflix.zuul.context.RequestContext;
import com.netflix.zuul.exception.ZuulException;
import org.springframework.cloud.netflix.zuul.filters.support.FilterConstants;
import org.springframework.http.HttpStatus;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.util.HashMap;
import java.util.Map;
/**
* Created by Administrator on 2019/4/2.
*/
public class CusZuulFilter extends ZuulFilter {
@Override
public String filterType() {
return FilterConstants.PRE_TYPE;
}
@Override
public int filterOrder() {
return 0;
}
/**
* a "true" return from this method means that the run() method should be invoked
*/
@Override
public boolean shouldFilter() {
RequestContext requestContext = RequestContext.getCurrentContext();
HttpServletRequest request = requestContext.getRequest();
String uri = request.getRequestURI();
return uri.contains("/service/"); //请求路径包含/service/的会被拦截
}
@Override
public Object run() throws ZuulException {
RequestContext requestContext = RequestContext.getCurrentContext();
HttpServletRequest request = requestContext.getRequest();
Object object = request.getSession().getAttribute("USER");
if(object != null){
requestContext.setSendZuulResponse(true);//会进行路由，也就是会调用api服务提供者
requestContext.setResponseStatusCode(HttpStatus.OK.value());
requestContext.set("isOK",true);// 相当于设置上下文的key-value键值对 requestContext(请求上下文)可以通过requestContext.get获取
boolean b = (boolean) requestContext.get("isOK");
System.out.println(b);
}else{
requestContext.setSendZuulResponse(false); //不会调用下级服务 直接在网关返回
requestContext.setResponseStatusCode(HttpStatus.OK.value());
Map<String,Object> body = new HashMap<>();
body.put("code",1);
body.put("msg","session is closed please login again");
//设置响应头信息 Content-Type
requestContext.addZuulResponseHeader("Content-Type","application/json");
try {
requestContext.setResponseBody(new ObjectMapper().writeValueAsString(body));
} catch (JsonProcessingException e) {
e.printStackTrace();
}
}
return null;
}
}
package com.wl.springcloud.zuul.config;
import com.wl.springcloud.zuul.filter.CusSendErrorFilter;
import com.wl.springcloud.zuul.filter.CusZuulFilter;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
/**
* Created by Administrator on 2019/4/2.
*/
@Configuration
public class FilterConfig {
@Bean
public CusSendErrorFilter cusSendErrorFilter(){
return new CusSendErrorFilter();
}
@Bean
public CusZuulFilter cusZuulFilter(){
return new CusZuulFilter();
}
}
浏览器地址输入 http://localhost:8080/zookeeper/zookeeper/service/
在zuul返回响应结果之前都会执行SendResponseFilter过滤器（除非直接调用response.write或关闭该拦截器）
更多过滤器在spring-cloud-starter-netflix-zuul jar包中org.springframework.cloud.netflix.zuul.filters包下面
自定义过滤器参考 springCloud学习05之api网关服务zuul过滤器filter_"ctx.set(\"isok\", false);"-程序员宅基地
5.zuul跨域
package com.wl.springcloud.zuul.config;
import org.springframework.boot.web.servlet.FilterRegistrationBean;
import org.springframework.cloud.netflix.zuul.filters.ZuulProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.cors.CorsConfiguration;
import org.springframework.web.cors.UrlBasedCorsConfigurationSource;
import org.springframework.web.filter.CorsFilter;
import java.util.Collections;
import java.util.Set;
/**
* Created by Administrator on 2019/4/2.
*/
@Configuration
public class CorsConfig {
@Bean
public FilterRegistrationBean<CorsFilter> filterRegistrationBean(ZuulProperties zuulProperties){
//需要过滤的下游头信息 可以配置zuul.sensitiveHeaders zuul.ignoredHeaders 参考 https://blog.csdn.net/ahutdbx/article/details/84192573
Set<String> ignoredHeaders = zuulProperties.getIgnoredHeaders();
ignoredHeaders.add("ga");
zuulProperties.setIgnoredHeaders(ignoredHeaders);
//跨域配置
CorsConfiguration corsConfiguration = new CorsConfiguration();
corsConfiguration.setAllowCredentials(true);
//设置网站域名 *表示全部
corsConfiguration.setAllowedOrigins(Collections.singletonList("*"));
//设置允许的头 *表示全部
corsConfiguration.setAllowedHeaders(Collections.singletonList("*"));
//设置允许的方法 *表示全部
corsConfiguration.setAllowedMethods(Collections.singletonList("*"));
UrlBasedCorsConfigurationSource source = new UrlBasedCorsConfigurationSource();
source.registerCorsConfiguration("/**",corsConfiguration);
FilterRegistrationBean<CorsFilter> bean = new FilterRegistrationBean<>(new CorsFilter(source));
// Set the order of the registration bean. 越小越排前面
bean.setOrder(0);
return bean;
}
}
6.zuul服务降级
package com.wl.springcloud.zuul.fallback;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.netflix.zuul.context.RequestContext;
import org.springframework.cloud.netflix.zuul.filters.route.FallbackProvider;
import org.springframework.http.HttpHeaders;
import org.springframework.http.HttpStatus;
import org.springframework.http.client.ClientHttpResponse;
import org.springframework.stereotype.Component;
import java.io.ByteArrayInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.util.HashMap;
import java.util.Map;
/**
* Created by Administrator on 2019/5/24.
*/
@Component
public class ZuulFallback implements FallbackProvider {
@Override
public String getRoute() {
return "*";//*表示匹配所有路由
}
@Override
public ClientHttpResponse fallbackResponse(String route, Throwable cause) {
RequestContext.getCurrentContext().set("fallback",true);
return new ClientHttpResponse() {
@Override
public HttpStatus getStatusCode() throws IOException {
return HttpStatus.OK;
}
@Override
public int getRawStatusCode() throws IOException {
return HttpStatus.OK.value();
}
@Override
public String getStatusText() throws IOException {
return HttpStatus.OK.getReasonPhrase();
}
@Override
public void close() {
}
@Override
public InputStream getBody() throws IOException {
Map<String,Object> body = new HashMap<>();
body.put("code",1);
body.put("msg",cause!= null ? cause.getMessage() : "");
return new ByteArrayInputStream(new ObjectMapper().writeValueAsString(body).getBytes());
}
@Override
public HttpHeaders getHeaders() {
HttpHeaders headers = new HttpHeaders();
headers.add("Content-Type","application/json");
return headers;
}
};
}
}
因为下游服务异常也可能会走之前设置的自定义异常过滤器，这里我设置了一个标识RequestContext.getCurrentContext().set("fallback",true);
修改之前自定义的异常过滤器，如果服务降级则不经过自定义异常过滤器（直接通过默认的SendResposeFiltrer返回响应数据）
@Override
public boolean shouldFilter() {
RequestContext ctx = RequestContext.getCurrentContext();
// only forward to errorPath if it hasn't been forwarded to already
return ctx.getThrowable() != null
&& !ctx.getBoolean(SEND_ERROR_FILTER_RAN, false)
&& !ctx.getBoolean("fallback",false);
}启动zuul并关闭下游服务
浏览器输入http://localhost:8080/zookeeper/zookeeper
版权声明：本文为博主原创文章，遵循 CC 4.0 BY-SA 版权协议，转载请附上原文出处链接和本声明。
智能推荐
文本分类特征提取之Word2Vec-程序员宅基地
文章浏览阅读4.4w次，点赞11次，收藏56次。分类问题是人类所面临的一个非常重要且具有普遍意义的问题，我们生活中的很多问题归根到底都是分类问题。文本分类就是根据文本内容将其分到合适的类别，它是自然语言处理的一个十分重要的问题。文本分类主要应用于信息检索，机器翻译，自动文摘，信息过滤，邮件分类等任务。文本分类技术发展历史 1960-1970：那时主要通过人工+规则（关键词或者正则表达式）的方式，制定规则的人需要对某类目领域有足够的认知和了解。举_文本特征提取word2vec
libevent高并发网络编程 - 06_基于libevent的C++线程池实现_windows c++ 开发 客户端 libevent-程序员宅基地
文章浏览阅读1k次。本文利用libevent，实现一个C++线程池，，可自定义用户任务类，继承于任务task基类，重写任务基类的纯虚函数实现多态。比如将定义定义处理客户端的请求任务类，实现对客户端请求的并发处理。工作队列：可以理解为线程的队列，一个线程同时可以处理一个任务，空闲的线程回从任务队列取出任务执行。当工作队列空时，线程会睡眠。任务队列：用户将任务加入任务队列，然后通知工作队列，取出一个任务到线程中执行。_windows c++ 开发 客户端 libevent
工作缺点和不足及措施_【工作中存在的问题和不足及改进措施】_工作中的不足与改进_工作中不足及改进措施...-程序员宅基地
文章浏览阅读3.4w次，点赞3次，收藏11次。篇一:《工作中存在的不足及改进措施》通过近一段时间的工作,反省自身,还存在许多不足和缺点,现将近期的工作、学习中存在的不足和缺点简要总结如下:1、自身的专业业务水平不高,事故应急处理能力不强.虽然通过学习和工作经验的积累,在业务水平上有了一定的提高,但业务水平和工作经验与其它老同志比还是比较低.在日常工作中偏重于日常生产工作,也忽视了自身思想素质的提高,工作中争强当先的意识不强.2、工作上满足于正..._工作不足之处及改进措施
java读取大数据量Excel按需读取(按需加载，速度快)_java 读取大文件excel-程序员宅基地
文章浏览阅读2k次。常用的poi工具，如easy-excel，hutool读取excel是都是先将整个excel加载到内存中分析，然后再一行行遍历，当excel文件太大时读取的时间就会更长，如果我们只需要读取excel的前几行来进行预览就不能使用这种方式，应该按需读取。_java 读取大文件excel
HTML_常用标签测试_html标签检测-程序员宅基地
文章浏览阅读237次。HTML_常用标签测试_html标签检测
【优化模型】牛顿法求解非线性方程组-程序员宅基地
文章浏览阅读482次。牛顿法是一种用于求解非线性方程组的迭代优化方法。其基本原理是基于泰勒级数展开和一阶导数的近似，通过不断迭代修正初始猜测解来逼近方程组的解。Fx0其中，Fxf1xf2x...fnxT是一个多元函数，xx1x2...xnT是待求解的变量向量。牛顿法的基本思想是，在当前的迭代点xk处，用一个一阶泰勒展开来近似fixfix≈fixkj1∑n∂xj∂fixk。
随便推点
克里金插值法（kringing）与PHPnow集成开发环境_后端克里金插值分析-程序员宅基地
文章浏览阅读815次。文章目录摘要摘要_后端克里金插值分析
使用有道云笔记的三个技巧_有道云笔记如何建立 文档索引-程序员宅基地
文章浏览阅读3.3w次，点赞10次，收藏36次。我们在 Windows 操作系统中写文档，做笔记，通常使用 Windows 自带的记事本，可是记事本不支持插入图片，创建表格等功能，从而不得不使用 Office Word。不知道大家有没有这样的感觉，使用 Office Word 写文档，效率极低，需要一边敲字，一边使用鼠标排版，比如：在文章中给团队的名字“LSGO软件技术团队”加粗，就需要先用鼠标选中这个词语，然后点击工具栏中“B”形状的工具..._有道云笔记如何建立 文档索引
IP-guard 远程命令执行漏洞_ipg 漏洞-程序员宅基地
文章浏览阅读137次。IP-guard 远程命令执行漏洞_ipg 漏洞
IOT时代，数据安全更无侥幸-程序员宅基地
文章浏览阅读255次。2017年，全球数据泄露事件已不仅是呈翻倍的速度增长。16年的14亿条，到17年仅上半年的17亿条，这样的数据泄露规模你是否还在存在侥幸心理，就是那所谓的“怎么可能刚好落在我身上”。随着我们在工作、生活中的云化，就在今天，万物互联已经融入到我们每个人的生活中，相信在不就的将来，整个IOT时代也将会很快的到来。仔细回忆一下，今天我们所做的任何情都离不..._8,iot时代,数据安全有哪些新特征?
MySQL 详细学习教程【万字长文, 建议收藏】_mysql教程-程序员宅基地
文章浏览阅读6.7k次，点赞47次，收藏143次。存放文本时，也可以使用Text数据类型，可以将TEXT列视为VARCHAR列，注意Text不能有默认值，大小0-2^16字节；同一查询在同一事务中多次进行，由于其它提交事务所做的修改和删除，每次返回不同的结果集，则发生不可重复读；多个连接开启各自事务操作数据库中数据时，数据库系统要负责隔离操作，以保证各个连接在获取数据是的准确性；同一查询在同一个事务中多次执行，由于其它提交事务所做的插入操作，每次返回不同的结果集，此时发生幻读；同真是的表一样，视图包含列，其数据来自对应的真实表(基表)_mysql教程
GD32官方开发环境及固件库使用笔记（一）_gd32e23 开发环境-程序员宅基地
文章浏览阅读550次，点赞10次，收藏6次。GD32官方的开发环境（基于Eclipse）的使用。_gd32e23 开发环境