- Gateway 底层通过 Netty 实现
- Gateway 基于异步非阻塞模型性能较高
- 动态路由,能够匹配任何请求属性
- 可以对路由指定 Predicate 断言,和 Filter 过滤器
- 集成Hystrix断路器功能
- 集成 Spring Cloud 服务发现功能
- 支持请求限流功能,支持路径重写功能
- Zuul1 底层通过 Ribbo 实现,基于 Servlet2.5使用阻塞式的,不支持唱两句,
- Zuul2 向基于 Netty实现非阻塞,并支持长连接
- 在 SpringCloud Finchley 版推荐使用 Zuul
“pre”: 请求路由之前执行
“route”: 请求路由之后执行
“post”: 在"routing" 和 error 过滤器之后执行
<!--eureka client-->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
server:
port: 8001 #当前服务端口号
spring:
application:
name: cloud-payment-service #当前服务名称
datasource:
type: com.alibaba.druid.pool.DruidDataSource #当前数据源操作类型
driver-class-name: com.mysql.cj.jdbc.Driver #mysql驱动包
url: jdbc:mysql://localhost:3306/test01?serverTimezone=GMT%2B8 #连接的库
username: root
password:
#=================eureka相关配置======================
eureka:
client:
register-with-eureka: true #true 表示将当前服务注册到eureka注册中心
#true 表示是否在注册中心抓取已有的注册信息,集群环境时必须为true,配合ribbon进行负载
fetchRegistry: true
service-url:
#eureka 注册中心访问连接,集群环境多个注册地址
defaultZone: http://127.0.0.1:7001/eureka,http://127.0.0.1:7002/eureka
instance:
instance-id: payment8001 #配置当前服务向eureka注册中心注册时显示的服务器主机名称
prefer-ip-address: true #配置在开发人员直接访问eureka服务器时显示当前eureka上注册的服务的ip
lease-renewal-interval-in-seconds: 1 #指定定时向eureka注册中心发送代表当前服务心跳包的时间默认30秒
lease-expiration-duration-in-seconds: 2 # Eureka 接收到当前服务最后一次发送代表正常心跳包的等待时间,默认90秒超过表示不存活
#=================eureka相关配置end======================
mybatis:
mapperLocations: classpath:mapper/*.xml #扫描mappper.xml */
type-aliases-package: com.test.dao #扫描对应mapper.xml 接口
@RestController
public class PaymentController {
@Autowired
private PaymentServerApi paymentServerApi;
@GetMapping(value = "/getRun")
public JsonResult getRun() {
System.out.println("执行查询所有数据8001");
return JsonResult.success();
}
}
@SpringBootApplication
@EnableEurekaClient //表示当前 PaymentMain8001 服务注册到Eureka中
public class PaymentMain8001 {
public static void main(String[] args) {
SpringApplication.run(PaymentMain8001.class,args);
}
}
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
<!--Zuul 依赖-->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-zuul</artifactId>
</dependency>
<!--eureka client-->
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
</dependency>
server:
port: 9527
spring:
application:
name: cloud-zuul
zuul:
host:
# 连接时间semaphores
connect-timeout-millis: 3000
# 每个router最大连接数
max-per-route-connections: 100
# 最大连接数
max-total-connections: 1000
# socket超时时间
socket-timeout-millis: 3000
#忽略路径或指定服务,*表示忽略所有,只通过下面配置的路由进行访问,多个用逗号隔开
ignored-services: *
routes:
api-a:
#假设请求当前网关服务"http://网关服务ip:网关服务端口号/此处配置拦截的路径/目标服务接口路径"
path: /myZuul-payment/** #当前网关服务拦截路径 */
#会自动转发到目标服务,通过该名称在注册中心获取调用地址列表,本地服务选择指定的地址进行调用
#实际会转发"http://cloud-payment-service/目标服务接口路径"
serviceId: cloud-payment-service #目标服务在注册中心注册的名称
#第二个
#api-b:
#path: /api-order/** #*/
#serviceId: cloud-order-service
#将当前 Gateway 服务注册到 Eureka注册中心
eureka:
client:
register-with-eureka: true #true 表示将当前服务注册到eureka注册中心
#true 表示是否在注册中心抓取已有的注册信息,集群环境时必须为true,配合ribbon进行负载
fetchRegistry: true
service-url:
#eureka 注册中心访问连接,集群环境多个注册地址
defaultZone: http://127.0.0.1:7001/eureka,http://127.0.0.1:7002/eureka
instance:
instance-id: zuul9527 #配置当前服务向eureka注册时显示id为指定的服务器主机名称
prefer-ip-address: true #配置在开发人员直接访问eureka服务器时显示当前eureka上注册的服务的ip
lease-renewal-interval-in-seconds: 1 #指定定时向eureka注册中心发送代表当前服务心跳包的时间默认30秒
lease-expiration-duration-in-seconds: 2 # Eureka 接收到当前服务最后一次发送代表正常心跳包的等待时间,默认90秒超过表示不存活
hostname: cloud-zuul-service ##配置当前服务向eureka注册时显示端口号
#=================eureka相关配置end======================
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
import org.springframework.cloud.netflix.zuul.EnableZuulProxy;
@SpringBootApplication
@EnableEurekaClient
@EnableZuulProxy
public class ZuulMain9527 {
public static void main(String[] args) {
SpringApplication.run(ZuulMain9527.class,args);;
}
}
filterType() : 设置当前过滤器类型
shouldFilter() : 设置当前过滤器是否生效
filterOrder() : 设置当前过滤器执行优先级
run() : 当前过滤器实际拦截或放行的逻辑方法
import com.netflix.zuul.ZuulFilter;
import com.netflix.zuul.context.RequestContext;
import com.netflix.zuul.exception.ZuulException;
import org.springframework.stereotype.Component;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
@Component
public class MyZuulFilter extends ZuulFilter {
//1.设置当前过滤器的过滤类型
@Override
public String filterType() {
//"pre": 请求路由之前执行
//"route": 请求路由之后执行
//"post": 在"routing" 和 error 过滤器之后执行
return "pre";
}
//2.根据返回值设置当前过滤器执行的优先级,参数越小优先级越高
@Override
public int filterOrder() {
return 0;
}
//3.判断过滤是否生效
@Override
public boolean shouldFilter() {
//可以在该方法中通过 RequestContext 获取请求的上下文
//通过获取到的数据判断设置当前过滤器是否生效
HttpServletRequest request = RequestContext.getCurrentContext().getRequest();
HttpServletResponse response = RequestContext.getCurrentContext().getResponse();
return true;
}
//4.过滤方法,当向 RequestContext 中存储一个 "sendZuulResponse" 变量,值为false
//时代表当前请求被拦截,解决访问,当没有存储该变量为false时return null 拦截放行
@Override
public Object run() throws ZuulException {
//1.通过 RequestContext 获取上下文
RequestContext currentContext = RequestContext.getCurrentContext();
//2.通过上下文获取 Request
HttpServletRequest request = currentContext.getRequest();
//3.在 Request 中获取请求数据
String userToken = request.getParameter("userToken");
if (null == userToken) {
//4.注意点,当上下文 RequestContext 调用 setSendZuulResponse() 方法,
//设置为 false 时, 后续 return null,当前请求则不会继续向下执行,代表拒绝访问
//查看该方法内部是向 RequestContext 中存储了一个"sendZuulResponse"变量值为false
currentContext.setSendZuulResponse(false);
currentContext.setResponseStatusCode(401);
currentContext.setResponseBody("userToken is null");
return null;
}
//5.RequestContext 中的 SendZuulResponse 不为 false
//return null,代表当前过滤器放行,继续执行下一个过滤器
return null;
}
}